org.axiondb.engine
Class SnapshotIsolationTransaction

java.lang.Object
  org.axiondb.engine.SnapshotIsolationTransaction

All Implemented Interfaces:

Database, TableModificationListener, Transactable, Transaction, VariableContext

public class SnapshotIsolationTransaction
extends java.lang.Object
implements Transaction, TableModificationListener, VariableContext

A Transactionimplementation that provides "snapshot isolation", which supports TRANSACTION_SERIALIZABLE isolation without locking.

Version:

$Revision: 1.45 $ $Date: 2005/12/20 18:32:45 $

Field Summary

Fields inherited from interface org.axiondb.Transaction

STATE_ABORTED, STATE_APPLIED, STATE_COMMITTED, STATE_OPEN

Fields inherited from interface org.axiondb.Database

COMMIT_SIZE

Constructor Summary

SnapshotIsolationTransaction(Database db)

Method Summary

void	addDatabaseModificationListener(DatabaseModificationListener l) Adds a listener to receive events on this database
void	addIndex(Index index, Table table) Add the given Indexto this database, associated with the given table.
void	addIndex(Index index, Table table, boolean doPopulate) Add the given Indexto this database, associating it with the given table and (optionally) populating it.
void	addTable(Table table) Add the given Tableto this database.
void	apply() Apply this committedtransaction..
void	checkpoint() Make sure any modified state or data has been written to disk.
void	columnAdded(ColumnEvent event)
void	commit() This transaction has been committed.
TransactableTable	commit(TableIdentifier tid)
void	constraintAdded(ConstraintEvent event)
void	constraintRemoved(ConstraintEvent event)
boolean	containsKey(java.lang.Object key)
void	createDatabaseLink(DatabaseLink server)
void	createSequence(Sequence seq) Create a numeric sequence
void	dropDatabaseLink(java.lang.String server)
void	dropDependentExternalDBTable(java.util.List tables)
void	dropDependentViews(java.util.List views)
void	dropIndex(java.lang.String name) Drop the given Indexfrom this database.
void	dropSequence(java.lang.String name) Drop the specified Sequencefrom this database.
void	dropTable(java.lang.String name) Drop the specified Tablefrom this database.
java.lang.Object	get(java.lang.Object key)
DatabaseLink	getDatabaseLink(java.lang.String name)
java.util.List	getDatabaseModificationListeners() Returns all listeners set to receive events on this database
DataType	getDataType(java.lang.String name) Get the DataTypecurrently registered for the given name, or null.
java.io.File	getDBDirectory() Get the directory into which table information is stored, or null.
java.util.List	getDependentExternalDBTable(java.lang.String name)
java.util.List	getDependentViews(java.lang.String tableName)
ConcreteFunction	getFunction(java.lang.String name)
java.lang.Object	getGlobalVariable(java.lang.String key)
IndexFactory	getIndexFactory(java.lang.String name) Get the IndexFactorycurrently registered for the given name, or null.
java.util.Set	getModifiedTables() Return a Setof Tables that have been modified thus far in this transaction.
java.lang.String	getName() Returns the name of this Database.
Database	getOpenOnTransaction() Get the Databaseupon which I am open (i.e., the state to which we will return to if I am rolled back.
java.util.Set	getReadTables() Return a Setof Tables that have been read thus far in this transaction.
Sequence	getSequence(java.lang.String name) Get the specified Sequence, or null if no such sequence can be found.
int	getState() Return my current transaction state.
Table	getTable(java.lang.String name) Get the specified Table, or null if no such table can be found.
Table	getTable(TableIdentifier table) Get the specified Table, or null if no such table can be found.
TableFactory	getTableFactory(java.lang.String name) Get the TableFactorycurrently registered for the given name, or null.
TransactionManager	getTransactionManager() Get the TransactionManagerfor this database.
boolean	hasDatabaseLink(java.lang.String name)
boolean	hasIndex(java.lang.String name) Returns true iff the given Indexexists.
boolean	hasSequence(java.lang.String name)
boolean	hasTable(java.lang.String name)
boolean	hasTable(TableIdentifier table)
boolean	isReadOnly() Is this database read-only?
void	migrate(int version) Migrate from older version to newer version for this database
void	put(java.lang.Object key, java.lang.Object value)
void	remount(java.io.File newdir) Notify this database that its root directory has been moved to the given location.
void	remove(java.lang.Object key)
void	renameTable(java.lang.String oldName, java.lang.String newName)
void	rollback() This transaction has been aborted.
void	rowDeleted(RowEvent event)
void	rowInserted(RowEvent event)
void	rowUpdated(RowEvent event)
void	shutdown() Close this database and free any resources associated with it.
void	tableAltered(Table table) Update metadata tables since this table has changed.

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotIsolationTransaction

public SnapshotIsolationTransaction(Database db)

Method Detail

addDatabaseModificationListener

public void addDatabaseModificationListener(DatabaseModificationListener l)

Description copied from interface: Database

Adds a listener to receive events on this database

Specified by:

addDatabaseModificationListener in interface Database

addIndex

public void addIndex(Index index,
                     Table table)
              throws AxionException

Description copied from interface: Database

Add the given Indexto this database, associated with the given table.

Specified by:

addIndex in interface Database

Throws:

AxionException

addIndex

public void addIndex(Index index,
                     Table table,
                     boolean doPopulate)
              throws AxionException

Description copied from interface: Database

Add the given Indexto this database, associating it with the given table and (optionally) populating it.

Specified by:

addIndex in interface Database

Parameters:

index - Index to be added and (optionally) populated

table - Table to be indexed

doPopulate - true if index should be populated by the appropriate column in table; false if index should be left as-is.

Throws:

AxionException - if error occurs during addition and/or population of index

addTable

public void addTable(Table table)
              throws AxionException

Description copied from interface: Database

Add the given Tableto this database.

Specified by:

addTable in interface Database

Throws:

AxionException

apply

public void apply()
           throws AxionException

Description copied from interface: Transactable

Apply this committedtransaction..

Specified by:

apply in interface Transactable

Throws:

AxionException

checkpoint

public void checkpoint()
                throws AxionException

Description copied from interface: Database

Make sure any modified state or data has been written to disk.

Specified by:

checkpoint in interface Database

Throws:

AxionException

columnAdded

public void columnAdded(ColumnEvent event)
                 throws AxionException

Specified by:

columnAdded in interface TableModificationListener

Throws:

AxionException

commit

public void commit()
            throws AxionException

Description copied from interface: Transactable

This transaction has been committed.

Specified by:

commit in interface Transactable

Throws:

AxionException

commit

public TransactableTable commit(TableIdentifier tid)
                         throws AxionException

Throws:

AxionException

constraintAdded

public void constraintAdded(ConstraintEvent event)
                     throws AxionException

Specified by:

constraintAdded in interface TableModificationListener

Throws:

AxionException

constraintRemoved

public void constraintRemoved(ConstraintEvent event)
                       throws AxionException

Specified by:

constraintRemoved in interface TableModificationListener

Throws:

AxionException

containsKey

public boolean containsKey(java.lang.Object key)

Specified by:

containsKey in interface VariableContext

createDatabaseLink

public void createDatabaseLink(DatabaseLink server)
                        throws AxionException

Specified by:

createDatabaseLink in interface Database

Throws:

AxionException

createSequence

public void createSequence(Sequence seq)
                    throws AxionException

Description copied from interface: Database

Create a numeric sequence

Specified by:

createSequence in interface Database

Throws:

AxionException

dropDatabaseLink

public void dropDatabaseLink(java.lang.String server)
                      throws AxionException

Specified by:

dropDatabaseLink in interface Database

Throws:

AxionException

dropDependentExternalDBTable

public void dropDependentExternalDBTable(java.util.List tables)
                                  throws AxionException

Specified by:

dropDependentExternalDBTable in interface Database

Throws:

AxionException

dropDependentViews

public void dropDependentViews(java.util.List views)
                        throws AxionException

Specified by:

dropDependentViews in interface Database

Throws:

AxionException

dropIndex

public void dropIndex(java.lang.String name)
               throws AxionException

Description copied from interface: Database

Drop the given Indexfrom this database.

Specified by:

dropIndex in interface Database

Throws:

AxionException

dropSequence

public void dropSequence(java.lang.String name)
                  throws AxionException

Description copied from interface: Database

Drop the specified Sequencefrom this database.

Sequence name matching is case-insensitive.

Specified by:

dropSequence in interface Database

Throws:

AxionException

dropTable

public void dropTable(java.lang.String name)
               throws AxionException

Description copied from interface: Database

Drop the specified Tablefrom this database.

Table name matching is case-insensitive.

Specified by:

dropTable in interface Database

Throws:

AxionException

get

public java.lang.Object get(java.lang.Object key)

Specified by:

get in interface VariableContext

getDatabaseLink

public DatabaseLink getDatabaseLink(java.lang.String name)

Specified by:

getDatabaseLink in interface Database

getDatabaseModificationListeners

public java.util.List getDatabaseModificationListeners()

Description copied from interface: Database

Returns all listeners set to receive events on this database

Specified by:

getDatabaseModificationListeners in interface Database

getDataType

public DataType getDataType(java.lang.String name)

Description copied from interface: Database

Get the DataTypecurrently registered for the given name, or null.

Specified by:

getDataType in interface Database

getDBDirectory

public java.io.File getDBDirectory()

Description copied from interface: Database

Get the directory into which table information is stored, or null.

Specified by:

getDBDirectory in interface Database

getDependentExternalDBTable

public java.util.List getDependentExternalDBTable(java.lang.String name)

Specified by:

getDependentExternalDBTable in interface Database

getDependentViews

public java.util.List getDependentViews(java.lang.String tableName)

Specified by:

getDependentViews in interface Database

getFunction

public ConcreteFunction getFunction(java.lang.String name)

Specified by:

getFunction in interface Database

getGlobalVariable

public java.lang.Object getGlobalVariable(java.lang.String key)

Specified by:

getGlobalVariable in interface Database

getIndexFactory

public IndexFactory getIndexFactory(java.lang.String name)

Description copied from interface: Database

Get the IndexFactorycurrently registered for the given name, or null.

Specified by:

getIndexFactory in interface Database

getModifiedTables

public java.util.Set getModifiedTables()

Description copied from interface: Transaction

Return a Setof Tables that have been modified thus far in this transaction.

Specified by:

getModifiedTables in interface Transaction

getName

public java.lang.String getName()

Description copied from interface: Database

Returns the name of this Database.

Specified by:

getName in interface Database

getOpenOnTransaction

public Database getOpenOnTransaction()

Description copied from interface: Transaction

Get the Databaseupon which I am open (i.e., the state to which we will return to if I am rolled back. Note that this may be another Transaction.

Specified by:

getOpenOnTransaction in interface Transaction

getReadTables

public java.util.Set getReadTables()

Description copied from interface: Transaction

Return a Setof Tables that have been read thus far in this transaction.

Specified by:

getReadTables in interface Transaction

getSequence

public Sequence getSequence(java.lang.String name)

Description copied from interface: Database

Get the specified Sequence, or null if no such sequence can be found.

Sequence name matching is case-insensitive.

Specified by:

getSequence in interface Database

getState

public int getState()

Description copied from interface: Transaction

Return my current transaction state. Returns one of Transaction.STATE_OPEN, Transaction.STATE_COMMITTED,Transaction.STATE_ABORTED,Transaction.STATE_APPLIED.

Specified by:

getState in interface Transaction

getTable

public Table getTable(java.lang.String name)
               throws AxionException

Description copied from interface: Database

Get the specified Table, or null if no such table can be found.

Table name matching is case-insensitive.

Specified by:

getTable in interface Database

Throws:

AxionException

getTable

public Table getTable(TableIdentifier table)
               throws AxionException

Description copied from interface: Database

Get the specified Table, or null if no such table can be found.

Table name matching is case-insensitive.

Specified by:

getTable in interface Database

Throws:

AxionException

getTableFactory

public TableFactory getTableFactory(java.lang.String name)

Description copied from interface: Database

Get the TableFactorycurrently registered for the given name, or null.

Specified by:

getTableFactory in interface Database

getTransactionManager

public TransactionManager getTransactionManager()

Description copied from interface: Database

Get the TransactionManagerfor this database.

Specified by:

getTransactionManager in interface Database

hasDatabaseLink

public boolean hasDatabaseLink(java.lang.String name)
                        throws AxionException

Specified by:

hasDatabaseLink in interface Database

Throws:

AxionException

hasIndex

public boolean hasIndex(java.lang.String name)
                 throws AxionException

Description copied from interface: Database

Returns true iff the given Indexexists.

Specified by:

hasIndex in interface Database

Throws:

AxionException

hasSequence

public boolean hasSequence(java.lang.String name)
                    throws AxionException

Specified by:

hasSequence in interface Database

Throws:

AxionException

hasTable

public boolean hasTable(java.lang.String name)
                 throws AxionException

Specified by:

hasTable in interface Database

Throws:

AxionException

hasTable

public boolean hasTable(TableIdentifier table)
                 throws AxionException

Specified by:

hasTable in interface Database

Throws:

AxionException

isReadOnly

public boolean isReadOnly()

Description copied from interface: Database

Is this database read-only?

Specified by:

isReadOnly in interface Database

migrate

public void migrate(int version)
             throws AxionException

Description copied from interface: Database

Migrate from older version to newer version for this database

Specified by:

migrate in interface Database

Throws:

AxionException

put

public void put(java.lang.Object key,
                java.lang.Object value)

Specified by:

put in interface VariableContext

remount

public void remount(java.io.File newdir)
             throws AxionException

Description copied from interface: Database

Notify this database that its root directory has been moved to the given location. (E.g., the CD containing the data for a CD-resident database has changed drives.)

Specified by:

remount in interface Database

Throws:

AxionException

remove

public void remove(java.lang.Object key)

Specified by:

remove in interface VariableContext

renameTable

public void renameTable(java.lang.String oldName,
                        java.lang.String newName)
                 throws AxionException

Specified by:

renameTable in interface Database

Throws:

AxionException

rollback

public void rollback()
              throws AxionException

Description copied from interface: Transactable

This transaction has been aborted.

Specified by:

rollback in interface Transactable

Throws:

AxionException

rowDeleted

public void rowDeleted(RowEvent event)
                throws AxionException

Specified by:

rowDeleted in interface TableModificationListener

Throws:

AxionException

rowInserted

public void rowInserted(RowEvent event)
                 throws AxionException

Specified by:

rowInserted in interface TableModificationListener

Throws:

AxionException

rowUpdated

public void rowUpdated(RowEvent event)
                throws AxionException

Specified by:

rowUpdated in interface TableModificationListener

Throws:

AxionException

shutdown

public void shutdown()
              throws AxionException

Description copied from interface: Database

Close this database and free any resources associated with it.

Specified by:

shutdown in interface Database

Throws:

AxionException

tableAltered

public void tableAltered(Table table)
                  throws AxionException

Description copied from interface: Database

Update metadata tables since this table has changed.

Specified by:

tableAltered in interface Database

Throws:

AxionException