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

Modifier and Type	Class and Description
static class	OTransactionAbstract.LockedRecordMetadata

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 Map<ORID,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.
ODatabaseDocumentInternal	getDatabase()
Map<ORID,OTransactionAbstract.LockedRecordMetadata>	getInternalLocks()
OTransaction.ISOLATION_LEVEL	getIsolationLevel() Returns the current isolation level.
Set<ORID>	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)
void	setDatabase(ODatabaseDocumentInternal database)
OTransaction	setIsolationLevel(OTransaction.ISOLATION_LEVEL isolationLevel) Changes the isolation level.
protected void	setLocks(Map<ORID,OTransactionAbstract.LockedRecordMetadata> locks)
void	trackLockedRecord(ORID rid, OStorage.LOCKING_STRATEGY lockingStrategy)
OStorage.LOCKING_STRATEGY	trackUnlockRecord(ORID rid)
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, 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 Map<ORID,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

internalRollback

public abstract void internalRollback()

trackLockedRecord

public void trackLockedRecord(ORID rid,
                              OStorage.LOCKING_STRATEGY lockingStrategy)

trackUnlockRecord

public OStorage.LOCKING_STRATEGY trackUnlockRecord(ORID rid)

getInternalLocks

public Map<ORID,OTransactionAbstract.LockedRecordMetadata> getInternalLocks()

setLocks

protected void setLocks(Map<ORID,OTransactionAbstract.LockedRecordMetadata> locks)

getLockedRecords

public Set<ORID> getLockedRecords()

setDatabase

public void setDatabase(ODatabaseDocumentInternal database)