Package com.arjuna.ats.internal.arjuna.objectstore.jdbc

Class JDBCImple_driver

java.lang.Object

com.arjuna.ats.internal.arjuna.objectstore.jdbc.JDBCImple_driver

Direct Known Subclasses:

h2_driver, ibm_driver, jconnect_driver, mariadb_driver, microsoft_driver, mysql_ab_driver, mysql_driver, oracle_driver, postgresql_driver

public abstract class JDBCImple_driver
extends Object

An object store implementation which uses a JDBC database for maintaining object states. All states are maintained within a single table.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	tableName

Constructor Summary

Constructors

Constructor	Description
JDBCImple_driver()

Method Summary

Modifier and Type	Method	Description
boolean	allObjUids(String typeName, InputObjectState state, int match)	allObjUids - Given a type name, return an ObjectState that contains all of the uids of objects of that type.
boolean	allTypes(InputObjectState foundTypes)
protected abstract void	checkCreateTableError(SQLException ex)
protected abstract void	checkDropTableException(Connection connection, SQLException ex)
boolean	commit_state(Uid objUid, String typeName)
protected void	createTable(Statement stmt, String tableName)	Can be overridden by implementation-specific code to create the store table.
int	currentState(Uid objUid, String typeName)	currentState - determine the current state of an object.
int	getMaxStateSize()
protected String	getObjectStateSQLType()
boolean	hide_state(Uid objUid, String typeName)
void	initialise(JDBCAccess jdbcAccess, String tableName, ObjectStoreEnvironmentBean jdbcStoreEnvironmentBean)	Set up the store for use.
InputObjectState	read_state(Uid objUid, String typeName, int stateType)
boolean	remove_state(Uid objUid, String typeName, int stateType)
boolean	reveal_state(Uid objUid, String typeName)
boolean	write_state(Uid objUid, String typeName, OutputObjectState state, int stateType)

Methods inherited from class java.lang.Object

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

Field Details

tableName

protected String tableName

Constructor Details

JDBCImple_driver

public JDBCImple_driver()

Method Details

commit_state

public boolean commit_state(Uid objUid,
 String typeName)
                     throws ObjectStoreException

Throws:

ObjectStoreException

hide_state

public boolean hide_state(Uid objUid,
 String typeName)
                   throws ObjectStoreException

Throws:

ObjectStoreException

reveal_state

public boolean reveal_state(Uid objUid,
 String typeName)
                     throws ObjectStoreException

Throws:

ObjectStoreException

currentState

public int currentState(Uid objUid,
 String typeName)
                 throws ObjectStoreException

currentState - determine the current state of an object. State search is ordered OS_UNCOMMITTED, OS_UNCOMMITTED_HIDDEN, OS_COMMITTED, OS_COMMITTED_HIDDEN

Throws:

ObjectStoreException - - in case the JDBC store cannot be contacted

allObjUids

public boolean allObjUids(String typeName,
 InputObjectState state,
 int match)
                   throws ObjectStoreException

allObjUids - Given a type name, return an ObjectState that contains all of the uids of objects of that type.

Throws:

ObjectStoreException

allTypes

public boolean allTypes(InputObjectState foundTypes)
                 throws ObjectStoreException

Throws:

ObjectStoreException

remove_state

public boolean remove_state(Uid objUid,
 String typeName,
 int stateType)
                     throws ObjectStoreException

Throws:

ObjectStoreException

read_state

public InputObjectState read_state(Uid objUid,
 String typeName,
 int stateType)
                            throws ObjectStoreException

Throws:

ObjectStoreException

write_state

public boolean write_state(Uid objUid,
 String typeName,
 OutputObjectState state,
 int stateType)
                    throws ObjectStoreException

Throws:

ObjectStoreException

initialise

public void initialise(JDBCAccess jdbcAccess,
 String tableName,
 ObjectStoreEnvironmentBean jdbcStoreEnvironmentBean)
                throws SQLException,
NamingException

Set up the store for use.

Throws:

NamingException

SQLException - In case the configured store cannot be connected to

createTable

protected void createTable(Statement stmt,
 String tableName)
                    throws SQLException

Can be overridden by implementation-specific code to create the store table. Called from initialise() and addTable(), above.

Throws:

SQLException

getObjectStateSQLType

protected String getObjectStateSQLType()

checkCreateTableError

protected abstract void checkCreateTableError(SQLException ex)
                                       throws SQLException

Throws:

SQLException

checkDropTableException

protected abstract void checkDropTableException(Connection connection,
 SQLException ex)
                                         throws SQLException

Throws:

SQLException

getMaxStateSize

public int getMaxStateSize()