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

Class JDBCStore

java.lang.Object

com.arjuna.ats.internal.arjuna.objectstore.jdbc.JDBCStore

All Implemented Interfaces:

BaseStore, ObjectStoreAPI, ParticipantStore, RecoveryStore, TxLog

public class JDBCStore
extends Object
implements ObjectStoreAPI

An object store implementation which uses a JDBC database for maintaining object states. All states are maintained within a single table. It is assumed that only one object will use a given instance of the JDBCStore. Hence, there is no need for synchronizations.

Field Summary

Fields

Modifier and Type	Field and Description
protected JDBCImple_driver	_theImple
protected ObjectStoreEnvironmentBean	jdbcStoreEnvironmentBean
protected String	tableName

Constructor Summary

Constructors

Constructor and Description
JDBCStore(ObjectStoreEnvironmentBean jdbcStoreEnvironmentBean) Create a new JDBCStore

Method Summary

Modifier and Type	Method and Description
boolean	allObjUids(String s, InputObjectState buff)
boolean	allObjUids(String tName, InputObjectState state, int match) Obtain all of the Uids for a specified type.
boolean	allTypes(InputObjectState foundTypes) Obtain all types of objects stored in the object store.
boolean	commit_state(Uid objUid, String tName) Commit the object's state in the object store.
int	currentState(Uid objUid, String tName)
boolean	fullCommitNeeded() Does this store need to do the full write_uncommitted/commit protocol?
protected String	getDefaultTableName()
String	getStoreName()
boolean	hide_state(Uid objUid, String tName) Hide the object's state in the object store.
boolean	isType(Uid u, String tn, int st) Is the current state of the object the same as that provided as the last parameter?
void	packInto(OutputBuffer buff)
InputObjectState	read_committed(Uid storeUid, String tName) Read the object's committed state.
InputObjectState	read_uncommitted(Uid storeUid, String tName) Read the object's shadowed state.
boolean	remove_committed(Uid storeUid, String tName) Remove the object's committed state.
boolean	remove_uncommitted(Uid storeUid, String tName) Remove the object's uncommitted state.
boolean	reveal_state(Uid objUid, String tName) Reveal a hidden object's state.
void	start()
void	stop()
void	sync() Some object store implementations may be running with automatic sync disabled.
void	unpackFrom(InputBuffer buff)
boolean	write_committed(Uid storeUid, String tName, OutputObjectState state) Write a new copy of the object's committed state.
boolean	write_uncommitted(Uid storeUid, String tName, OutputObjectState state) Write a copy of the object's uncommitted state.

Methods inherited from class java.lang.Object

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

Field Detail

_theImple

protected JDBCImple_driver _theImple

tableName

protected String tableName

jdbcStoreEnvironmentBean

protected final ObjectStoreEnvironmentBean jdbcStoreEnvironmentBean

Constructor Detail

JDBCStore

public JDBCStore(ObjectStoreEnvironmentBean jdbcStoreEnvironmentBean)
          throws ObjectStoreException

Create a new JDBCStore

Parameters:

jdbcStoreEnvironmentBean - The environment bean containing the configuration

Throws:

ObjectStoreException - In case the store environment bean was not correctly configured

{@link - FatalError} In case the configured store cannot be connected to

Method Detail

start

public void start()

Specified by:

start in interface BaseStore

stop

public void stop()

Specified by:

stop in interface BaseStore

fullCommitNeeded

public boolean fullCommitNeeded()

Does this store need to do the full write_uncommitted/commit protocol?

Specified by:

fullCommitNeeded in interface ParticipantStore

Returns:

true if full commit is needed, false otherwise.

sync

public void sync()
          throws SyncFailedException,
                 ObjectStoreException

Some object store implementations may be running with automatic sync disabled. Calling this method will ensure that any states are flushed to disk.

Specified by:

sync in interface TxLog

Throws:

SyncFailedException

ObjectStoreException

isType

public boolean isType(Uid u,
                      String tn,
                      int st)
               throws ObjectStoreException

Is the current state of the object the same as that provided as the last parameter?

Specified by:

isType in interface RecoveryStore

Parameters:

u - The object to work on.

tn - The type of the object.

st - The expected type of the object.

Returns:

true if the current state is as expected, false otherwise.

Throws:

ObjectStoreException

getStoreName

public String getStoreName()

Specified by:

getStoreName in interface BaseStore

Returns:

the "name" of the object store. Where in the hierarchy it appears, e.g., /ObjectStore/MyName/...

allObjUids

public boolean allObjUids(String s,
                          InputObjectState buff)
                   throws ObjectStoreException

Specified by:

allObjUids in interface RecoveryStore

Throws:

ObjectStoreException

commit_state

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

Description copied from interface: ParticipantStore

Commit the object's state in the object store.

Specified by:

commit_state in interface ParticipantStore

Parameters:

objUid - The object to work on.

tName - The type of the object to work on.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

hide_state

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

Description copied from interface: RecoveryStore

Hide the object's state in the object store. Used by crash recovery.

Specified by:

hide_state in interface RecoveryStore

Parameters:

objUid - The object to work on.

tName - The type of the object to work on.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

reveal_state

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

Description copied from interface: RecoveryStore

Reveal a hidden object's state.

Specified by:

reveal_state in interface RecoveryStore

Parameters:

objUid - The object to work on.

tName - The type of the object to work on.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

currentState

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

Specified by:

currentState in interface RecoveryStore

Parameters:

objUid - The object to query.

tName - The type of the object to query.

Returns:

the current state of the object's state (e.g., shadowed, committed ...) [StateStatus]

Throws:

ObjectStoreException

read_committed

public InputObjectState read_committed(Uid storeUid,
                                       String tName)
                                throws ObjectStoreException

Description copied from interface: ParticipantStore

Read the object's committed state.

Specified by:

read_committed in interface ParticipantStore

Specified by:

read_committed in interface RecoveryStore

Parameters:

storeUid - The object to work on.

tName - The type of the object to work on.

Returns:

the state of the object.

Throws:

ObjectStoreException

read_uncommitted

public InputObjectState read_uncommitted(Uid storeUid,
                                         String tName)
                                  throws ObjectStoreException

Description copied from interface: ParticipantStore

Read the object's shadowed state.

Specified by:

read_uncommitted in interface ParticipantStore

Parameters:

storeUid - The object to work on.

tName - The type of the object to work on.

Returns:

the state of the object.

Throws:

ObjectStoreException

remove_committed

public boolean remove_committed(Uid storeUid,
                                String tName)
                         throws ObjectStoreException

Description copied from interface: TxLog

Remove the object's committed state.

Specified by:

remove_committed in interface TxLog

Parameters:

storeUid - The object to work on.

tName - The type of the object to work on.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

remove_uncommitted

public boolean remove_uncommitted(Uid storeUid,
                                  String tName)
                           throws ObjectStoreException

Description copied from interface: ParticipantStore

Remove the object's uncommitted state.

Specified by:

remove_uncommitted in interface ParticipantStore

Parameters:

storeUid - The object to work on.

tName - The type of the object to work on.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

write_committed

public boolean write_committed(Uid storeUid,
                               String tName,
                               OutputObjectState state)
                        throws ObjectStoreException

Description copied from interface: TxLog

Write a new copy of the object's committed state.

Specified by:

write_committed in interface TxLog

Parameters:

storeUid - The object to work on.

tName - The type of the object to work on.

state - The state to write.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

write_uncommitted

public boolean write_uncommitted(Uid storeUid,
                                 String tName,
                                 OutputObjectState state)
                          throws ObjectStoreException

Description copied from interface: ParticipantStore

Write a copy of the object's uncommitted state.

Specified by:

write_uncommitted in interface ParticipantStore

Parameters:

storeUid - The object to work on.

tName - The type of the object to work on.

state - The state to write.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

allObjUids

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

Description copied from interface: RecoveryStore

Obtain all of the Uids for a specified type.

Specified by:

allObjUids in interface RecoveryStore

Parameters:

tName - The type to scan for.

state - The object state in which to store the Uids

match - The file type to look for (e.g., committed, shadowed). [StateStatus]

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

allTypes

public boolean allTypes(InputObjectState foundTypes)
                 throws ObjectStoreException

Description copied from interface: RecoveryStore

Obtain all types of objects stored in the object store.

Specified by:

allTypes in interface RecoveryStore

Parameters:

foundTypes - The state in which to store the types.

Returns:

true if no errors occurred, false otherwise.

Throws:

ObjectStoreException

packInto

public void packInto(OutputBuffer buff)
              throws IOException

Throws:

IOException

unpackFrom

public void unpackFrom(InputBuffer buff)
                throws IOException

Throws:

IOException

getDefaultTableName

protected String getDefaultTableName()