com.orientechnologies.orient.core.tx

Class OTransactionAbstract

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

All Implemented Interfaces:

OBasicTransaction, 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 ODatabaseDocumentInternal	database
protected OTransaction.ISOLATION_LEVEL	isolationLevel
protected HashMap<ORID,com.orientechnologies.orient.core.tx.OTransactionAbstract.LockedRecordMetadata>	locks
protected OTransaction.TXSTATUS	status

Fields inherited from interface com.orientechnologies.orient.core.storage.OBasicTransaction

DELETED_RECORD

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OTransactionAbstract(ODatabaseDocumentInternal iDatabase)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the transaction and releases all the acquired locks.
String	getClusterName(ORecord record)
ODatabaseDocumentInternal	getDatabase()
OTransaction.ISOLATION_LEVEL	getIsolationLevel() Returns the current isolation level.
HashMap<ORID,OStorage.LOCKING_STRATEGY>	getLockedRecords()
OTransaction.TXSTATUS	getStatus()
abstract void	internalRollback()
boolean	isActive()
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(ODatabaseDocumentInternal database, 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

amountOfNestedTxs, begin, clearIndexEntries, clearRecordEntries, commit, commit, getCurrentRecordEntries, getEntryCount, getIndexChanges, getInvolvedIndexes, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getRecordEntry, getRecordOperations, hasRecordCreation, isUsingLog, loadRecord, loadRecord, loadRecord, loadRecordIfVersionIsNotLatest, reloadRecord, reloadRecord, rollback, rollback, setUsingLog, updateIdentityAfterCommit

Methods inherited from interface com.orientechnologies.orient.core.storage.OBasicTransaction

addChangedDocument, addIndexEntry, deleteRecord, getClientTransactionId, getCustomData, getId, getIndexChanges, getIndexChangesInternal, getRecord, saveRecord, setCustomData

Field Detail

database

protected ODatabaseDocumentInternal 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(ODatabaseDocumentInternal iDatabase)

Method Detail

updateCacheFromEntries

public static void updateCacheFromEntries(ODatabaseDocumentInternal database,
                                          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()

Specified by:

isActive in interface OBasicTransaction

Returns:

true if this transaction is active, false otherwise.

getStatus

public OTransaction.TXSTATUS getStatus()

Specified by:

getStatus in interface OTransaction

getDatabase

public ODatabaseDocumentInternal 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)

internalRollback

public abstract void internalRollback()