org.opensubsystems.core.persist.db.sapdb
Class SapDBDatabaseImpl

java.lang.Object
  org.opensubsystems.core.persist.db.DatabaseImpl
      org.opensubsystems.core.persist.db.sapdb.SapDBDatabaseImpl

All Implemented Interfaces:

Database

Direct Known Subclasses:

MaxDBDatabaseImpl

public class SapDBDatabaseImpl
extends DatabaseImpl

Management layer for SAP DB database (www.sapdb.org)

Version:

$Id: SapDBDatabaseImpl.java,v 1.5 2007/01/07 06:15:04 bastafidli Exp $

Author:

Miro Halas

Code reviewer:

Miro Halas

Code reviewed:

1.1 2005/08/20 21:17:02 bastafidli

Field Summary

Fields inherited from class org.opensubsystems.core.persist.db.DatabaseImpl

m_bDatabaseSchemaInitialized, m_bDatabaseStarted, m_bDatabaseStartInProgress, m_vdsSchema, MAX_SAFE_LENGTH

Fields inherited from interface org.opensubsystems.core.persist.db.Database

BATCH_ITERATOR, DB2_DATABASE_TYPE, DB2_DATABASE_TYPE_IDENTIFIER, HSQLDB_DATABASE_TYPE, HSQLDB_DATABASE_TYPE_IDENTIFIER, MAXDB_DATABASE_TYPE, MAXDB_DATABASE_TYPE_IDENTIFIER, MSSQL_DATABASE_TYPE, MSSQL_DATABASE_TYPE_IDENTIFIER, MYSQL_DATABASE_TYPE, MYSQL_DATABASE_TYPE_IDENTIFIER, ORACLE_DATABASE_TYPE, ORACLE_DATABASE_TYPE_IDENTIFIER, POSTGRESQL_DATABASE_TYPE, POSTGRESQL_DATABASE_TYPE_IDENTIFIER, SAPDB_DATABASE_TYPE, SAPDB_DATABASE_TYPE_IDENTIFIER, SYBASE_DATABASE_TYPE, SYBASE_DATABASE_TYPE_IDENTIFIER

Constructor Summary

SapDBDatabaseImpl()
Default constructor for empty database.

Method Summary

void	createDatabaseInstance() Method for creating database instance.
protected void	createUser(java.sql.Connection cntAdminDBConnection) Create database user which will be used by connection pool to access the database.
java.lang.String	getCurrentTimestampFunctionCall() Get string which can be used in SQL queries to retrieve timestamp representing current time.
protected java.lang.String	getDatabaseHost(java.lang.String strDatabaseURL) Returns the database host name.
protected java.lang.String	getDatabaseName(java.lang.String strDatabaseURL) Returns the database name.
int	getDatabaseType() Returns the type of database currently in use.
java.lang.String	getDatabaseTypeIdentifier() Returns the identifier for the type of database currently in use which can be used to construct package and class names.
java.lang.Object[]	getSQLAnalyzeFunctionCall(java.util.Map mapTableNames) Get DB specific SQL queries for analyzing tables or updating statistics on the tables (it is good for performance).
java.lang.String	getSQLCountFunctionCall() Get string which can be used in SQL queries to retrieve record count.
void	insertAndFetchGeneratedValues(java.sql.Connection dbConnection, java.sql.PreparedStatement insertStatement, boolean bIsInDomain, java.lang.String strTableName, int iIndex, BasicDataObject data) Insert the data, fetch from the database id and generated creation and optionally modification timestamps for the newly created data object.
boolean	isCallableStatement(java.lang.String strQuery) Test if the specified query invokes stored procedure or if it is just a regular prepared statement.
boolean	preferCountToLast() Find out if when trying to find out size of the result set we should use rather count(*)/count(1)/count(id) instead of using hasAbsolutePositioningSupport.
void	startDatabaseServer() Method for starting database instance.
void	stop() Stop the database. After the database is stopped, no more requests can be issued until the database is started again.
void	updatedAndFetchGeneratedValues(java.lang.String strDataName, java.sql.Connection dbConnection, java.sql.PreparedStatement updateStatement, boolean bIsInDomain, java.lang.String strTableName, int iIndex, ModifiableDataObject data) Update the data, check for errors and fetch from the database generated modification timestamps for the updated data object.

Methods inherited from class org.opensubsystems.core.persist.db.DatabaseImpl

add, add, getAdminConnection, getConnectionTestStatement, getInstance, getInstanceIfStarted, getSelectListResultSetConcurrency, getSelectListResultSetType, getTransactionIsolation, hasAbsolutePositioningSupport, hasSelectListRangeSupport, isStarted, setInstance, start

Methods inherited from class java.lang.Object

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

Constructor Detail

SapDBDatabaseImpl

public SapDBDatabaseImpl()
                  throws OSSException

Default constructor for empty database.

Throws:

OSSException - - problem connecting to database

Method Detail

createUser

protected void createUser(java.sql.Connection cntAdminDBConnection)
                   throws OSSException

Create database user which will be used by connection pool to access the database.

Specified by:

createUser in class DatabaseImpl

Parameters:

cntAdminDBConnection - - connection with rights to create users

Throws:

OSSException - - cannot create user

startDatabaseServer

public void startDatabaseServer()
                         throws OSSException

Method for starting database instance. For HSQL it is not needed because the database is started (created) when the administrator is connected to. For HSQL will be empty implementation of this method. For SAPDB is neccessary to start DB instance before connecting to.

Specified by:

startDatabaseServer in class DatabaseImpl

Throws:

OSSException - - problem starting the server

createDatabaseInstance

public void createDatabaseInstance()
                            throws OSSException

Method for creating database instance. For HSQL it is not needed because the database is created when the administrator is connected to. For HSQL will be empty implementation of this method. For SAPDB is neccessary to create DB instance before connecting to.

Specified by:

createDatabaseInstance in class DatabaseImpl

Throws:

OSSException - - problem creating the database instance

getDatabaseType

public int getDatabaseType()

Returns the type of database currently in use. It will be one of the constants defined in this class (SAPDB, HSQLDB, etc.).

Returns:

int - database type

getDatabaseTypeIdentifier

public java.lang.String getDatabaseTypeIdentifier()

Returns the identifier for the type of database currently in use which can be used to construct package and class names. It will be one of the constants defined in this class (SAPDB, HSQLDB, etc.).

Returns:

String - database type

getDatabaseHost

protected java.lang.String getDatabaseHost(java.lang.String strDatabaseURL)

Returns the database host name.

Parameters:

strDatabaseURL - - The database URL the host name to be parsed from

Returns:

String - database host name

getDatabaseName

protected java.lang.String getDatabaseName(java.lang.String strDatabaseURL)

Returns the database name.

Parameters:

strDatabaseURL - - The database URL the name to be parsed from

Returns:

String - database name

stop

public void stop()
          throws OSSException

Stop the database. After the database is stopped, no more requests can be issued until the database is started again.

Specified by:

stop in interface Database

Overrides:

stop in class DatabaseImpl

Throws:

OSSException - - problems stopping the database

preferCountToLast

public boolean preferCountToLast()

Find out if when trying to find out size of the result set we should use rather count(*)/count(1)/count(id) instead of using hasAbsolutePositioningSupport.

Specified by:

preferCountToLast in interface Database

Overrides:

preferCountToLast in class DatabaseImpl

Returns:

boolean - true if should use count(x) instead of last()

getCurrentTimestampFunctionCall

public java.lang.String getCurrentTimestampFunctionCall()

Get string which can be used in SQL queries to retrieve timestamp representing current time.

Returns:

String - SQL representation of function call to get current timestamp

getSQLCountFunctionCall

public java.lang.String getSQLCountFunctionCall()

Get string which can be used in SQL queries to retrieve record count.

Returns:

String - SQL representation of function call to get record count

getSQLAnalyzeFunctionCall

public java.lang.Object[] getSQLAnalyzeFunctionCall(java.util.Map mapTableNames)

Get DB specific SQL queries for analyzing tables or updating statistics on the tables (it is good for performance).

Parameters:

mapTableNames - - map of table names the update statistics will be processed on. Key is the data object data of which are stored in the table and value is te name of the table

Returns:

Object[] - index 0 - String[] - SQL representation of function calls to analyze tables and indexes (array of SQL commands for each table the update statistics will be processed) - index 1 - Boolean flag signaling if the autocommit when executing these statements should be true or false

isCallableStatement

public boolean isCallableStatement(java.lang.String strQuery)

Test if the specified query invokes stored procedure or if it is just a regular prepared statement.

Parameters:

strQuery - - query to test

Returns:

boolean - true if query invokes stored procedure false otherwise

insertAndFetchGeneratedValues

public void insertAndFetchGeneratedValues(java.sql.Connection dbConnection,
                                          java.sql.PreparedStatement insertStatement,
                                          boolean bIsInDomain,
                                          java.lang.String strTableName,
                                          int iIndex,
                                          BasicDataObject data)
                                   throws java.sql.SQLException,
                                          OSSException

Insert the data, fetch from the database id and generated creation and optionally modification timestamps for the newly created data object. Note: Since the caller created the prepared (or callable) statement, the caller is responsible for its closing.

Parameters:

dbConnection - - connection to use to access the database

insertStatement - - statement used to insert the data. This can be CallableStatement if stored procedure is used.

bIsInDomain - - are the data objects maintained in domains

strTableName - - name of the table where the data are being inserted

iIndex - - 1 based index of the next parameter value of which can be set on the statement (last parameter set by caller + 1)

data - - data object to update with the fetched values

Throws:

java.sql.SQLException - - an error has occured

OSSException - - an error has occured

updatedAndFetchGeneratedValues

public void updatedAndFetchGeneratedValues(java.lang.String strDataName,
                                           java.sql.Connection dbConnection,
                                           java.sql.PreparedStatement updateStatement,
                                           boolean bIsInDomain,
                                           java.lang.String strTableName,
                                           int iIndex,
                                           ModifiableDataObject data)
                                    throws java.sql.SQLException,
                                           OSSException

Update the data, check for errors and fetch from the database generated modification timestamps for the updated data object. Note: Since the caller created the prepared statement, the caller is responsible for its closing.

Parameters:

strDataName - - name of the data object

dbConnection - - connection to use to access the datavase

updateStatement - - statement to update data in the database. This can be CallableStatement if stored procedure is used.

bIsInDomain - - are the data objects maintained in domains

strTableName - - name of the table

iIndex - - 1 based index of the next parameter value of which can be set on the statement (last parameter set by caller + 1)

data - - data object to update

Throws:

java.sql.SQLException - - an error has occured

OSSException - - an error has occured