com.ibm.di.store
Class StoreFactory

java.lang.Object
  com.ibm.di.store.StoreFactory

public class StoreFactory
extends Object

Field Summary

static String	DEFAULT_PROPERTYSTORE
static String	JDBC_DRIVER_DB2
static String	JDBC_DRIVER_DERBY_EMB
static String	JDBC_DRIVER_DERBY_NET
static String	JDBC_DRIVER_MSSQL
static String	JDBC_DRIVER_ORACLE
static String	JDBC_DRIVER_SOLID
static String	REGEX
static String	VARCHAR_LENGTH

Constructor Summary

StoreFactory()

Method Summary

static void	debugmsg(String msg)
static Object	deserializeObject(Object o) Deserializes a byte array into a Java object.
static boolean	dropTable(Connection connection, String table) Drops a table in the database associated with connection.
static Exception	dropTable(String tableName) Drops a table in the default database.
static Connection	getConnection() Returns a connection object to the default database.
static Connection	getConnection(boolean autoCommit) Returns a connection object to the default database using the default username/password.
static Connection	getConnection(String database) Returns a connection object to the named database with AutoCommit set to TRUE using the default username/password.
static Connection	getConnection(String database, boolean autoCommit) Returns a connection object to the named database with the default username/password.
static Connection	getConnection(String database, boolean autoCommit, String user, String password, Properties info) Returns a connection to the named database.
static String	getDbHost()
static String	getDbPort()
static String	getDefaultDatabase()
static PropertyStore	getDefaultPropertyStore() Returns the default property store.
static DeltaStore	getDeltaStore(String identifier, boolean isRestarting) Returns the DeltaStore with identifier
static String	getJdbcDriver()
static String	getJdbcPassword()
static String	getJdbcURL()
static String	getJdbcUser()
static String	getProperty(String key) This method will look at the configuration in the caller's thread (RS.getServer) to see if it overrides the default settings from global/solution properties.
static PropertyStore	getPropertyStore(String name) Returns the PropertyStore identified by name.
static String	getSysStoreCreateStmtByDriver(String driver) This method returns the proper 'CREATE TABLE' statement for the System Store Connector based on the specified JDBC driver name.
static String	getSystemDatabase() Returns the default system database name
static String	getSystemDatabaseURL() Returns the SystemStore JDBC URL.
static Vector<String>	getTables(Connection connection, String table)
static String	getVarcharLength()
static boolean	isDerbyDriver(String driver)
static boolean	isDerbyNetworkDriver(String driver) Determines if the passed driver is a Derby Network Driver.
static boolean	isMSSQLDriver(String driver)
static void	logmsg(String msg)
static void	releaseDB(String id)
static void	retainDB(String id, String db)
static byte[]	serializeObject(Object obj) Serializes an object to a byte array.
static void	setDerbyUserPassword(String user, String password)
static void	shutdown() Shuts down all open databases.
static void	startDerbyServer(String hostname, String portNo, boolean sysIBM) Start the networked Derby Server.
static void	stopDerbyServer(String hostname, int port)
static boolean	tableExists(Connection connection, String table) Checks if a table is accessible in the database.
static boolean	verifyTable(Connection connection, String table, Vector<String> sql) Verifies that a table is accessible in the database.

Methods inherited from class java.lang.Object

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

Field Detail

JDBC_DRIVER_DERBY_NET

public static final String JDBC_DRIVER_DERBY_NET

See Also:

Constant Field Values

JDBC_DRIVER_DERBY_EMB

public static final String JDBC_DRIVER_DERBY_EMB

See Also:

Constant Field Values

JDBC_DRIVER_DB2

public static final String JDBC_DRIVER_DB2

See Also:

Constant Field Values

JDBC_DRIVER_ORACLE

public static final String JDBC_DRIVER_ORACLE

See Also:

Constant Field Values

JDBC_DRIVER_MSSQL

public static final String JDBC_DRIVER_MSSQL

See Also:

Constant Field Values

JDBC_DRIVER_SOLID

public static final String JDBC_DRIVER_SOLID

See Also:

Constant Field Values

DEFAULT_PROPERTYSTORE

public static final String DEFAULT_PROPERTYSTORE

See Also:

Constant Field Values

REGEX

public static final String REGEX

See Also:

Constant Field Values

VARCHAR_LENGTH

public static final String VARCHAR_LENGTH

Constructor Detail

StoreFactory

public StoreFactory()

Method Detail

getDefaultPropertyStore

public static PropertyStore getDefaultPropertyStore()
                                             throws Exception

Returns the default property store.

Throws:

Exception

getPropertyStore

public static PropertyStore getPropertyStore(String name)
                                      throws Exception

Returns the PropertyStore identified by name. Only one instance of a given name is present at one time.

Parameters:

name - The property store name

Returns:

The property store object associated with name

Throws:

Exception

getDeltaStore

public static DeltaStore getDeltaStore(String identifier,
                                       boolean isRestarting)
                                throws Exception

Returns the DeltaStore with identifier

Parameters:

identifier - The delta table identity/tablename

isRestarting - True if the delta is opened in restart mode

Returns:

The DeltaStore object associated with identifier

Throws:

Exception

getSystemDatabaseURL

public static String getSystemDatabaseURL()

Returns the SystemStore JDBC URL.

getSystemDatabase

public static String getSystemDatabase()

Returns the default system database name

getConnection

public static Connection getConnection()
                                throws Exception

Returns a connection object to the default database. The connection object is in auto-commit mode and uses the default username/password.

Returns:

A connection object to the named database.

Throws:

Exception

getConnection

public static Connection getConnection(boolean autoCommit)
                                throws Exception

Returns a connection object to the default database using the default username/password.

Parameters:

autoCommit - The auto-commit flag

Returns:

A connection object to the named database.

Throws:

Exception

getConnection

public static Connection getConnection(String database)
                                throws Exception

Returns a connection object to the named database with AutoCommit set to TRUE using the default username/password.

Parameters:

database - The database name

Returns:

A connection object to the named database.

Throws:

Exception

getConnection

public static Connection getConnection(String database,
                                       boolean autoCommit)
                                throws Exception

Returns a connection object to the named database with the default username/password.

Parameters:

database - The database name

autoCommit - The auto-commit flag

Returns:

A connection object to the named database.

Throws:

Exception

getConnection

public static Connection getConnection(String database,
                                       boolean autoCommit,
                                       String user,
                                       String password,
                                       Properties info)
                                throws Exception

Returns a connection to the named database.

Parameters:

database - If the value starts with "jdbc:" then it is used asis to obtain a connection object. Otherwise, this method prepends the JDBC_URL setting from the global.properties file and appends ";create=true". When prepending JDBC_URL it is assumed that Derby is used.

autoCommit - The auto commit flag set on the connection object

user - The username

password - The password

info - If specified, this method will use the database asis (e.g. no prepend/append) combined with this parameter to obtain a connection object. The info object should contain fields for user and pass and other related parameters to the driver.

Throws:

Exception

setDerbyUserPassword

public static void setDerbyUserPassword(String user,
                                        String password)

dropTable

public static boolean dropTable(Connection connection,
                                String table)

Drops a table in the database associated with connection.

Parameters:

connection - The connection object obtained by getConnection()

table - The table to drop

verifyTable

public static boolean verifyTable(Connection connection,
                                  String table,
                                  Vector<String> sql)
                           throws Exception

Verifies that a table is accessible in the database.

Parameters:

connection - The connection object obtained by getConnection(). If NULL, a connection to the default table is obtained.

table - The table name to verify

sql - A vector of SQL statements to create the table if it does not exist

Throws:

Exception

tableExists

public static boolean tableExists(Connection connection,
                                  String table)
                           throws Exception

Checks if a table is accessible in the database.

Parameters:

connection - The connection object obtained by getConnection(). If NULL, a connection to the default table is obtained.

table - The table name to verify

Throws:

Exception

getTables

public static Vector<String> getTables(Connection connection,
                                       String table)
                                throws Exception

Throws:

Exception

shutdown

public static void shutdown()

Shuts down all open databases.

dropTable

public static Exception dropTable(String tableName)

Drops a table in the default database.

Parameters:

tableName - The name of the table to drop.

serializeObject

public static byte[] serializeObject(Object obj)
                              throws Exception

Serializes an object to a byte array.

Parameters:

obj - The object to serialize

Returns:

The byte array containing the serialized object

Throws:

Exception

deserializeObject

public static Object deserializeObject(Object o)
                                throws Exception

Deserializes a byte array into a Java object.

Parameters:

o - The byte array with the serialized Java object

Returns:

The resurrected java object

Throws:

Exception

retainDB

public static void retainDB(String id,
                            String db)

releaseDB

public static void releaseDB(String id)

logmsg

public static void logmsg(String msg)

debugmsg

public static void debugmsg(String msg)

startDerbyServer

public static void startDerbyServer(String hostname,
                                    String portNo,
                                    boolean sysIBM)
                             throws Exception

Start the networked Derby Server. This method does not use the API, but spawns a new process, to let the database stay around after exiting the server/CE.

Parameters:

hostname -

portNo -

sysIBM -

Throws:

Exception

stopDerbyServer

public static void stopDerbyServer(String hostname,
                                   int port)
                            throws Exception

Throws:

Exception

isDerbyNetworkDriver

public static boolean isDerbyNetworkDriver(String driver)

Determines if the passed driver is a Derby Network Driver.

Returns:

true if the passed driver is a Derby network driver otherwise false.

isDerbyDriver

public static boolean isDerbyDriver(String driver)

isMSSQLDriver

public static boolean isMSSQLDriver(String driver)

getDefaultDatabase

public static String getDefaultDatabase()

getJdbcDriver

public static String getJdbcDriver()

getJdbcURL

public static String getJdbcURL()

getJdbcUser

public static String getJdbcUser()

getJdbcPassword

public static String getJdbcPassword()

getVarcharLength

public static String getVarcharLength()

getDbHost

public static String getDbHost()

getDbPort

public static String getDbPort()

getSysStoreCreateStmtByDriver

public static String getSysStoreCreateStmtByDriver(String driver)

This method returns the proper 'CREATE TABLE' statement for the System Store Connector based on the specified JDBC driver name.

Parameters:

driver - java class name of the JDBC driver

Returns:

the proper 'CREATE TABLE' statement for the used database; null if the driver is not recognized.

getProperty

public static String getProperty(String key)

This method will look at the configuration in the caller's thread (RS.getServer) to see if it overrides the default settings from global/solution properties. If the custom system store settings are enabled the value is retrieved from the configuration, otherwise it is retrieved by System.getProperty().

Parameters:

key - the property's indentifier

Returns:

the value corresponding to the specified identifier.