com.orientechnologies.orient.core.tx

Class OTransactionAbstract

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

All Implemented Interfaces:

OTransaction

Direct Known Subclasses:

OTransactionNoTx, OTransactionRealAbstract

public abstract class OTransactionAbstract
extends Object
implements OTransaction

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.tx.OTransaction

OTransaction.ISOLATION_LEVEL, OTransaction.TXSTATUS, OTransaction.TXTYPE

Field Summary

Fields

Modifier and Type	Field and Description
protected ODatabaseDocumentTx	database
protected OTransaction.ISOLATION_LEVEL	isolationLevel
protected HashMap<ORID,com.orientechnologies.orient.core.tx.OTransactionAbstract.LockedRecordMetadata>	locks
protected OTransaction.TXSTATUS	status

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OTransactionAbstract(ODatabaseDocumentTx iDatabase)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the transaction and releases all the acquired locks.
String	getClusterName(ORecord record)
ODatabaseDocumentTx	getDatabase()
OTransaction.ISOLATION_LEVEL	getIsolationLevel() Returns the current isolation level.
HashMap<ORID,OStorage.LOCKING_STRATEGY>	getLockedRecords()
OTransaction.TXSTATUS	getStatus()
boolean	isActive() Tells if the transaction is active.
boolean	isLockedRecord(OIdentifiable iRecord)
OStorage.LOCKING_STRATEGY	lockingStrategy(OIdentifiable record)
OTransaction	lockRecord(OIdentifiable iRecord, OStorage.LOCKING_STRATEGY lockingStrategy)
OTransaction	setIsolationLevel(OTransaction.ISOLATION_LEVEL isolationLevel) Changes the isolation level.
OTransaction	unlockRecord(OIdentifiable iRecord)
static void	updateCacheFromEntries(OTransaction tx, Iterable<? extends ORecordOperation> entries, boolean updateStrategy)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.tx.OTransaction

addIndexEntry, amountOfNestedTxs, begin, clearIndexEntries, clearRecordEntries, commit, commit, deleteRecord, getAllRecordEntries, getCurrentRecordEntries, getCustomData, getEntryCount, getId, getIndexChanges, getIndexChanges, getInvolvedIndexes, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getRecord, getRecordEntry, hasRecordCreation, isUsingLog, loadRecord, loadRecord, loadRecord, loadRecordIfVersionIsNotLatest, recycleRecord, reloadRecord, reloadRecord, rollback, rollback, saveRecord, setCustomData, setUsingLog, updateIdentityAfterCommit

Field Detail

database

protected final ODatabaseDocumentTx database

status

protected OTransaction.TXSTATUS status

isolationLevel

protected OTransaction.ISOLATION_LEVEL isolationLevel

locks

protected HashMap<ORID,com.orientechnologies.orient.core.tx.OTransactionAbstract.LockedRecordMetadata> locks

Constructor Detail

OTransactionAbstract

protected OTransactionAbstract(ODatabaseDocumentTx iDatabase)

Method Detail

updateCacheFromEntries

public static void updateCacheFromEntries(OTransaction tx,
                                          Iterable<? extends ORecordOperation> entries,
                                          boolean updateStrategy)

getIsolationLevel

public OTransaction.ISOLATION_LEVEL getIsolationLevel()

Description copied from interface: OTransaction

Returns the current isolation level.

Specified by:

getIsolationLevel in interface OTransaction

setIsolationLevel

public OTransaction setIsolationLevel(OTransaction.ISOLATION_LEVEL isolationLevel)

Description copied from interface: OTransaction

Changes the isolation level. Default is READ_COMMITTED. When REPEATABLE_READ is set, any record read from the storage is cached in memory to guarantee the repeatable reads. This affects the used RAM and speed (because JVM Garbage Collector job).

Specified by:

setIsolationLevel in interface OTransaction

Parameters:

isolationLevel - Isolation level to set

Returns:

Current object to allow call in chain

isActive

public boolean isActive()

Description copied from interface: OTransaction

Tells if the transaction is active.

Specified by:

isActive in interface OTransaction

Returns:

getStatus

public OTransaction.TXSTATUS getStatus()

Specified by:

getStatus in interface OTransaction

getDatabase

public ODatabaseDocumentTx getDatabase()

Specified by:

getDatabase in interface OTransaction

close

public void close()

Closes the transaction and releases all the acquired locks.

Specified by:

close in interface OTransaction

lockRecord

public OTransaction lockRecord(OIdentifiable iRecord,
                               OStorage.LOCKING_STRATEGY lockingStrategy)

Specified by:

lockRecord in interface OTransaction

isLockedRecord

public boolean isLockedRecord(OIdentifiable iRecord)

Specified by:

isLockedRecord in interface OTransaction

lockingStrategy

public OStorage.LOCKING_STRATEGY lockingStrategy(OIdentifiable record)

Specified by:

lockingStrategy in interface OTransaction

unlockRecord

public OTransaction unlockRecord(OIdentifiable iRecord)

Specified by:

unlockRecord in interface OTransaction

getLockedRecords

public HashMap<ORID,OStorage.LOCKING_STRATEGY> getLockedRecords()

Specified by:

getLockedRecords in interface OTransaction

getClusterName

public String getClusterName(ORecord record)