org.hsqldb

Class TransactionManager2PL

java.lang.Object

org.hsqldb.TransactionManager2PL

All Implemented Interfaces:

TransactionManager

public class TransactionManager2PL
extends java.lang.Object
implements TransactionManager

Manages rows involved in transactions

Since:

2.0.0

Field Summary

Fields

Modifier and Type	Field and Description
LongKeyHashMap	rowActionMap Map : rowID -> RowAction

Fields inherited from interface org.hsqldb.TransactionManager

ACTION_DUP, ACTION_READ, ACTION_REF, LOCKS, MVCC, MVLOCKS

Constructor Summary

Constructors

Constructor and Description
TransactionManager2PL(Database db)

Method Summary

Modifier and Type	Method and Description
RowAction	addDeleteAction(Session session, Table table, PersistentStore store, Row row, int[] colMap)
void	addInsertAction(Session session, Table table, PersistentStore store, Row row, int[] changedColumns)
void	addTransactionInfo(CachedObject object) store transaction info for a new row.
void	beginAction(Session session, Statement cs) add session to the end of queue when a transaction starts (depending on isolation mode)
void	beginActionResume(Session session)
void	beginTransaction(Session session)
boolean	canRead(Session session, PersistentStore store, long id, int mode)
boolean	canRead(Session session, PersistentStore store, Row row, int mode, int[] colMap)
boolean	commitTransaction(Session session)
void	completeActions(Session session)
long	getGlobalChangeTimestamp()
long	getNextGlobalChangeTimestamp() gets the next timestamp for an action
int	getTransactionControl()
boolean	isMVCC()
boolean	isMVRows()
boolean	prepareCommitActions(Session session)
void	removeTransactionInfo(CachedObject object) remove the transaction info
void	removeTransactionInfo(long id)
void	rollback(Session session)
void	rollbackAction(Session session)
void	rollbackPartial(Session session, int start, long timestamp) rollback the row actions from start index in list and the given timestamp
void	rollbackSavepoint(Session session, int index)
void	setTransactionControl(Session session, int mode)
void	setTransactionInfo(PersistentStore store, CachedObject object) add transaction info to a row just loaded from the cache.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hsqldb.TransactionManager

getNextGlobalChangeTimestamp

Field Detail

rowActionMap

public LongKeyHashMap rowActionMap

Map : rowID -> RowAction

Constructor Detail

TransactionManager2PL

public TransactionManager2PL(Database db)

Method Detail

getGlobalChangeTimestamp

public long getGlobalChangeTimestamp()

Specified by:

getGlobalChangeTimestamp in interface TransactionManager

isMVRows

public boolean isMVRows()

Specified by:

isMVRows in interface TransactionManager

isMVCC

public boolean isMVCC()

Specified by:

isMVCC in interface TransactionManager

getTransactionControl

public int getTransactionControl()

Specified by:

getTransactionControl in interface TransactionManager

setTransactionControl

public void setTransactionControl(Session session,
                                  int mode)

Specified by:

setTransactionControl in interface TransactionManager

completeActions

public void completeActions(Session session)

Specified by:

completeActions in interface TransactionManager

prepareCommitActions

public boolean prepareCommitActions(Session session)

Specified by:

prepareCommitActions in interface TransactionManager

commitTransaction

public boolean commitTransaction(Session session)

Specified by:

commitTransaction in interface TransactionManager

rollback

public void rollback(Session session)

Specified by:

rollback in interface TransactionManager

rollbackSavepoint

public void rollbackSavepoint(Session session,
                              int index)

Specified by:

rollbackSavepoint in interface TransactionManager

rollbackAction

public void rollbackAction(Session session)

Specified by:

rollbackAction in interface TransactionManager

rollbackPartial

public void rollbackPartial(Session session,
                            int start,
                            long timestamp)

rollback the row actions from start index in list and the given timestamp

Specified by:

rollbackPartial in interface TransactionManager

addDeleteAction

public RowAction addDeleteAction(Session session,
                                 Table table,
                                 PersistentStore store,
                                 Row row,
                                 int[] colMap)

Specified by:

addDeleteAction in interface TransactionManager

addInsertAction

public void addInsertAction(Session session,
                            Table table,
                            PersistentStore store,
                            Row row,
                            int[] changedColumns)

Specified by:

addInsertAction in interface TransactionManager

canRead

public boolean canRead(Session session,
                       PersistentStore store,
                       Row row,
                       int mode,
                       int[] colMap)

Specified by:

canRead in interface TransactionManager

canRead

public boolean canRead(Session session,
                       PersistentStore store,
                       long id,
                       int mode)

Specified by:

canRead in interface TransactionManager

addTransactionInfo

public void addTransactionInfo(CachedObject object)

Description copied from interface: TransactionManager

store transaction info for a new row. called only for CACHED tables

Specified by:

addTransactionInfo in interface TransactionManager

setTransactionInfo

public void setTransactionInfo(PersistentStore store,
                               CachedObject object)

add transaction info to a row just loaded from the cache. called only for CACHED tables

Specified by:

setTransactionInfo in interface TransactionManager

removeTransactionInfo

public void removeTransactionInfo(CachedObject object)

Description copied from interface: TransactionManager

remove the transaction info

Specified by:

removeTransactionInfo in interface TransactionManager

beginTransaction

public void beginTransaction(Session session)

Specified by:

beginTransaction in interface TransactionManager

beginAction

public void beginAction(Session session,
                        Statement cs)

add session to the end of queue when a transaction starts (depending on isolation mode)

Specified by:

beginAction in interface TransactionManager

beginActionResume

public void beginActionResume(Session session)

Specified by:

beginActionResume in interface TransactionManager

removeTransactionInfo

public void removeTransactionInfo(long id)

Specified by:

removeTransactionInfo in interface TransactionManager

getNextGlobalChangeTimestamp

public long getNextGlobalChangeTimestamp()

gets the next timestamp for an action