com.lf.commons.db.postgresql

Class PostgreSQLConnector

java.lang.Object

com.lf.commons.db.DatabaseConnector

com.lf.commons.db.postgresql.PostgreSQLConnector

public class PostgreSQLConnector
extends DatabaseConnector

Configures and manages the PostgreSQL database management system.

Do not CTID as attribute name since this and UID is reserved in PostgreSQL.

Since:

1.6

Version:

$Revision: 1.28 $, $Date: 2012/12/28 11:44:25 $

Author:

Axel Schwolow

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DATABASE_DESCRIPTION The name of the represented database management system.
static java.lang.String	DATABASE_NAME The name of the represented database management system.
static java.lang.String	DRIVER_DISPLAY_NAME SQL driver display name (client/server mode).
static java.lang.String	DRIVER_NAME SQL driver class name (client/server mode).
static java.net.URL	ICON_POSTGRESQL Default icon for the connector.

Fields inherited from class com.lf.commons.db.DatabaseConnector

cacheSchemaByTable, CONNECT_AUTH_REQUIRED, CONNECT_FAILED, CONNECT_SUCCESS, databaseDescription, databaseName, dbManager, defaultConn, defaultConnURL, driverDisplayName, driverName, driverProductName, driverProductVersion, params, pool, schemaMappings, typeConfig

Constructor Summary

Constructors

Constructor and Description
PostgreSQLConnector() Constructor method for i18n purposes only.
PostgreSQLConnector(java.util.Properties params, DatabaseManager manager) Constructor to create a connector instance.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	checkSequenceExists(java.lang.String schema, java.lang.String table) Checks whether a sequence for the given target table does exist.
int	connect(java.lang.String jdbcurl) Connects to the configured database.
static java.util.Properties	createParams(java.lang.String host, int port, java.lang.String dbname, java.lang.String username, java.lang.String password) Convenience method to preconfigure a connection.
boolean	createSequence(java.lang.String schema, java.lang.String table, int initval) Creates a new sequence for the given target table.
javax.swing.tree.TreeNode[]	createSubTree(java.lang.String[] jdbcurls) Creates a connector specific sub-tree from a set of JDBC URLs handled by the connector.
java.io.InputStream	getBytes(int columnIndex, java.sql.ResultSet rs) Provides the binary value from the certain column.
byte[]	getBytes(java.sql.ResultSet rs, int columnIndex) Provides the binary value from the certain column.
byte[]	getBytes(java.sql.ResultSet rs, java.lang.String columnLabel) Provides the binary value from the certain column.
java.io.InputStream	getBytes(java.lang.String columnLabel, java.sql.ResultSet rs) Provides the binary value from the certain column.
static DatabaseConnectorDef	getConnectorDef(boolean supported, boolean createconnections) Provides the connector definition to be listed without installing any connectors.
java.lang.String	getDefaultConnectionURL() Provides the JDBC URL for the default conenction (normally a user connection).
java.lang.String	getDisplayURL(java.lang.String jdbcurl) Makes sure that the given JDBC URL does not contain any passwords.
javax.swing.ImageIcon	getIcon() Provides the connector specific icon to represent it by GUI components.
java.sql.Connection	getNewConnectionNoCheck(java.lang.String jdbcurl) Creates a fresh connection for the given JDBC URL (never taken from the pool).
int	getSequenceCurrentValue(java.lang.String schema, java.lang.String table) Reads the current (last generated) value from a sequence.
int	getSequenceNextValue(java.lang.String schema, java.lang.String table) Reads the next value from a sequence.
java.lang.String	getUserConnectionURL() Creates a JDBC connection URL to access the database with user permissions.
java.lang.String	getUserName() Provides the name of the default user.
java.lang.String	getUserPassword() Provides the password for the default user.
static boolean	isAvailableStatic() Is the JDBC driver available on the classpath?
boolean	isBinary(int metadatatype) Checks if the given JDBC type is binary to serialize native database types properly.
boolean	isConnected() Provides the info if this connector is currently connected to the database.
java.lang.Class	mapToJavaType(int metadatatype) Provides the appropriate Java type to serialize native database types.
boolean	resetSequence(java.lang.String schema, java.lang.String table, int nextval) Resets an existing sequence for the given target table.
void	updateBytes(java.sql.ResultSet rs, int columnIndex, byte[] x) Updates the designated column with a binary value.
void	updateBytes(java.sql.ResultSet rs, int columnIndex, java.io.InputStream inputStream) Updates the designated column with a binary value.
void	updateBytes(java.sql.ResultSet rs, java.lang.String columnLabel, byte[] x) Updates the designated column with a binary value.
void	updateBytes(java.sql.ResultSet rs, java.lang.String columnLabel, java.io.InputStream inputStream) Updates the designated column with a binary value.

Methods inherited from class com.lf.commons.db.DatabaseConnector

addSchemaMapping, checkAndCreateSchemas, disconnect, finalize, getConnectionPool, getDatabaseDescription, getDatabaseManager, getDatabaseName, getDatabaseProductName, getDatabaseProductVersion, getDefaultConnection, getDefaultSchema, getDriver, getDriverDisplayName, getDriverName, getNewConnection, getParamDatabaseHost, getParamDatabaseName, getParamDatabasePort, getParams, getPooledConnection, getSchema, getSchemaMappings, getSchemaSeparator, getSerializedField, getTableFQN, getTypeTable, getUsedSchema, isAvailable, isEmbedded, releasePooledConnection, replaceParams, replaceTableFQN, setParams, updateSchemaTables, updateSerializedField

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DATABASE_NAME

public static final java.lang.String DATABASE_NAME

The name of the represented database management system.

See Also:

Constant Field Values

DATABASE_DESCRIPTION

public static final java.lang.String DATABASE_DESCRIPTION

The name of the represented database management system.

See Also:

Constant Field Values

DRIVER_NAME

public static final java.lang.String DRIVER_NAME

SQL driver class name (client/server mode).

See Also:

Constant Field Values

DRIVER_DISPLAY_NAME

public static final java.lang.String DRIVER_DISPLAY_NAME

SQL driver display name (client/server mode).

See Also:

Constant Field Values

ICON_POSTGRESQL

public static final java.net.URL ICON_POSTGRESQL

Default icon for the connector.

Constructor Detail

PostgreSQLConnector

public PostgreSQLConnector()
                    throws java.lang.InstantiationException

Constructor method for i18n purposes only.

Can only be used if beans design time is set (e.g. by external tools like the I18NExtractor).

Throws:

java.lang.InstantiationException - Error indication

Since:

1.6

PostgreSQLConnector

public PostgreSQLConnector(java.util.Properties params,
                   DatabaseManager manager)

Constructor to create a connector instance.

• PARAM_DB_HOST: required
• PARAM_DB_PORT: required
• PARAM_DB_NAME: required
• PARAM_DB_USER: required
• PARAM_DB_USER_PASSWORD: required

Parameters:

params - The database configuration

manager - The database manager

Since:

1.6

Method Detail

getDisplayURL

public java.lang.String getDisplayURL(java.lang.String jdbcurl)

Makes sure that the given JDBC URL does not contain any passwords.

Use this method if a JDBC URL shall be be displayed for the users of your application and if you do not like passwords being exposed.

Specified by:

getDisplayURL in class DatabaseConnector

Parameters:

jdbcurl - The original URL including passwords

Returns:

The JDBC URL without passwords

Throws:

java.lang.NullPointerException - If parameters are invalid

Since:

1.6

createSubTree

public javax.swing.tree.TreeNode[] createSubTree(java.lang.String[] jdbcurls)

Creates a connector specific sub-tree from a set of JDBC URLs handled by the connector.

Specified by:

createSubTree in class DatabaseConnector

Parameters:

jdbcurls - The JDBC URLs to be processed

Returns:

The array of tree nodes to be displayed

Throws:

java.lang.NullPointerException - If parameters are invalid

Since:

1.6

getUserConnectionURL

public java.lang.String getUserConnectionURL()

Creates a JDBC connection URL to access the database with user permissions.

Returns:

The JDBC URL

Since:

1.6

getNewConnectionNoCheck

public java.sql.Connection getNewConnectionNoCheck(java.lang.String jdbcurl)
                                            throws java.sql.SQLException

Creates a fresh connection for the given JDBC URL (never taken from the pool).

Here, no checking of the default connection is performed.

Parameters:

jdbcurl - The desired connector class in FQN

Returns:

The open connection, null if an error occurs

Throws:

java.sql.SQLException - If something goes wrong

Since:

1.6

connect

public int connect(java.lang.String jdbcurl)

Connects to the configured database.

Specified by:

connect in class DatabaseConnector

Parameters:

jdbcurl - The URL for the default connection

Returns:

CONNECT_SUCCESS | ...

Since:

1.6

isConnected

public boolean isConnected()

Provides the info if this connector is currently connected to the database.

The connection is present if the default connection is alive. If this method returns false then none of the connection types should be used any more.

Overrides:

isConnected in class DatabaseConnector

Returns:

Currently connected?

Since:

1.6

getDefaultConnectionURL

public java.lang.String getDefaultConnectionURL()

Provides the JDBC URL for the default conenction (normally a user connection).

Typical JDBC URLs look like "jdbc:derby://localhost:1527/lima".

Specified by:

getDefaultConnectionURL in class DatabaseConnector

Returns:

The JDBC URL for the default connection, null if an error occurs

Since:

1.6

getUserName

public java.lang.String getUserName()

Provides the name of the default user.

Specified by:

getUserName in class DatabaseConnector

Returns:

The user name, may be empty, but never null

Since:

1.6

getUserPassword

public java.lang.String getUserPassword()

Provides the password for the default user.

Specified by:

getUserPassword in class DatabaseConnector

Returns:

The user password, may be empty, but never null

Since:

1.6

checkSequenceExists

public boolean checkSequenceExists(java.lang.String schema,
                          java.lang.String table)

Checks whether a sequence for the given target table does exist.

Specified by:

checkSequenceExists in class DatabaseConnector

Parameters:

schema - The target schema (optional)

table - The name of the target table

Returns:

Exists?

Since:

1.6

createSequence

public boolean createSequence(java.lang.String schema,
                     java.lang.String table,
                     int initval)

Creates a new sequence for the given target table.

Specified by:

createSequence in class DatabaseConnector

Parameters:

schema - The target schema (optional)

table - The name of the target table

initval - The initial value from sequence

Returns:

Successful?

Since:

1.6

getSequenceCurrentValue

public int getSequenceCurrentValue(java.lang.String schema,
                          java.lang.String table)

Reads the current (last generated) value from a sequence.

Specified by:

getSequenceCurrentValue in class DatabaseConnector

Parameters:

schema - The target schema (optional)

table - The name of the target table

Returns:

The current value, -1 otherwise

Since:

1.6

getSequenceNextValue

public int getSequenceNextValue(java.lang.String schema,
                       java.lang.String table)

Reads the next value from a sequence.

PostgreSQL sequences follow the name schema "SEQ_[table]", so that the sequence for the table CRYPTO needs to be created as SEQ_CRYPTO.

Specified by:

getSequenceNextValue in class DatabaseConnector

Parameters:

schema - The target schema (optional)

table - The name of the target table

Returns:

The next value, -1 otherwise

Since:

1.6

resetSequence

public boolean resetSequence(java.lang.String schema,
                    java.lang.String table,
                    int nextval)

Resets an existing sequence for the given target table.

Specified by:

resetSequence in class DatabaseConnector

Parameters:

schema - The target schema (optional)

table - The name of the target table

nextval - The next value from sequence

Returns:

Successful?

Since:

1.6

getIcon

public javax.swing.ImageIcon getIcon()

Provides the connector specific icon to represent it by GUI components.

Variants of the provided image (24|32|48|128) should be made accessible to the GUIUtils.getIconVariant() method.

Specified by:

getIcon in class DatabaseConnector

Returns:

The connector icon 16 x 16 pixels

Since:

1.6

updateBytes

public void updateBytes(java.sql.ResultSet rs,
               java.lang.String columnLabel,
               byte[] x)
                 throws java.sql.SQLException

Updates the designated column with a binary value.

Overrides:

updateBytes in class DatabaseConnector

Parameters:

rs - The result set to be updated

columnLabel - The label for the column specified with the SQL AS clause

x - The new column value

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

updateBytes

public void updateBytes(java.sql.ResultSet rs,
               int columnIndex,
               byte[] x)
                 throws java.sql.SQLException

Updates the designated column with a binary value.

Overrides:

updateBytes in class DatabaseConnector

Parameters:

rs - The result set to be updated

columnIndex - The index of the column specified with the SQL AS clause (1-based)

x - The new column value

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

updateBytes

public void updateBytes(java.sql.ResultSet rs,
               java.lang.String columnLabel,
               java.io.InputStream inputStream)
                 throws java.sql.SQLException

Updates the designated column with a binary value.

Overrides:

updateBytes in class DatabaseConnector

Parameters:

rs - The result set to be updated

columnLabel - The label for the column specified with the SQL AS clause

inputStream - The new column value

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

updateBytes

public void updateBytes(java.sql.ResultSet rs,
               int columnIndex,
               java.io.InputStream inputStream)
                 throws java.sql.SQLException

Updates the designated column with a binary value.

Overrides:

updateBytes in class DatabaseConnector

Parameters:

rs - The result set to be updated

columnIndex - The index of the column specified with the SQL AS clause (1-based)

inputStream - The new column value

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

getBytes

public byte[] getBytes(java.sql.ResultSet rs,
              java.lang.String columnLabel)
                throws java.sql.SQLException

Provides the binary value from the certain column.

Overrides:

getBytes in class DatabaseConnector

Parameters:

rs - The result set to be updated

columnLabel - The label for the column specified with the SQL AS clause

Returns:

The binary data, null indicates error

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

getBytes

public byte[] getBytes(java.sql.ResultSet rs,
              int columnIndex)
                throws java.sql.SQLException

Provides the binary value from the certain column.

Overrides:

getBytes in class DatabaseConnector

Parameters:

rs - The result set to be updated

columnIndex - The index of the column specified with the SQL AS clause (1-based)

Returns:

The binary data, null indicates error

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

getBytes

public java.io.InputStream getBytes(java.lang.String columnLabel,
                           java.sql.ResultSet rs)
                             throws java.sql.SQLException

Provides the binary value from the certain column.

Overrides:

getBytes in class DatabaseConnector

Parameters:

columnLabel - The label for the column specified with the SQL AS clause

rs - The result set to be updated

Returns:

The binary data stream, null indicates error

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

getBytes

public java.io.InputStream getBytes(int columnIndex,
                           java.sql.ResultSet rs)
                             throws java.sql.SQLException

Provides the binary value from the certain column.

Overrides:

getBytes in class DatabaseConnector

Parameters:

columnIndex - The index of the column specified with the SQL AS clause (1-based)

rs - The result set to be updated

Returns:

The binary data, null indicates error

Throws:

java.lang.NullPointerException - If a parameter is null

java.sql.SQLException - If an SQL error occurs

Since:

1.6

mapToJavaType

public java.lang.Class mapToJavaType(int metadatatype)

Provides the appropriate Java type to serialize native database types.

Here, the allowed data type conversions of a database system is implemented so that table data may be transferred from one system to another. Remember that only the JDBC types supported by the JDBCConfiguration class may be used here.

Overrides:

mapToJavaType in class DatabaseConnector

Parameters:

metadatatype - The original JDBC type to be mapped

Returns:

The Java class type that fits, null if not supported

Since:

1.6

isBinary

public boolean isBinary(int metadatatype)

Checks if the given JDBC type is binary to serialize native database types properly.

Overrides:

isBinary in class DatabaseConnector

Parameters:

metadatatype - The original JDBC type to be mapped

Returns:

Binary type?

Since:

1.6

getConnectorDef

public static DatabaseConnectorDef getConnectorDef(boolean supported,
                                   boolean createconnections)

Provides the connector definition to be listed without installing any connectors.

Parameters:

supported - May the connector be used?

createconnections - May new connections be created?

Returns:

The connector definition

Since:

1.6

isAvailableStatic

public static boolean isAvailableStatic()

Is the JDBC driver available on the classpath?

Returns:

Driver available?

Since:

1.6

createParams

public static java.util.Properties createParams(java.lang.String host,
                                int port,
                                java.lang.String dbname,
                                java.lang.String username,
                                java.lang.String password)

Convenience method to preconfigure a connection.

Parameters:

host - The host

port - The port

dbname - The database name

username - The user

password - The password

Returns:

The database specific parameters