Package com.orientechnologies.orient.core.tx

Class OTransactionAbstract

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

All Implemented Interfaces:

OTransaction

Direct Known Subclasses:

OTransactionNoTx, OTransactionOptimistic

public abstract class OTransactionAbstract
extends Object
implements OTransaction

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final 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	Description
protected ODatabaseDocumentInternal	database
static final ORecord	DELETED_RECORD	Indicates the record deleted in a transaction.
protected OTransaction.ISOLATION_LEVEL	isolationLevel
protected Map<ORID,OTransactionAbstract.LockedRecordMetadata>	locks
protected OTransaction.TXSTATUS	status

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OTransactionAbstract(ODatabaseDocumentInternal iDatabase)

Method Summary

Modifier and Type	Method	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)
ORecordOperation	newOp(OIdentifiable iRecord, byte iStatus)
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 keepInCache)

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

addChangedDocument, addIndexEntry, amountOfNestedTxs, begin, commit, commit, deleteRecord, getClientTransactionId, getCustomData, getEntryCount, getId, getIndexChanges, getIndexChanges, getIndexChangesInternal, getInvolvedIndexes, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getRecord, getRecordEntry, getRecordOperations, loadRecord, loadRecordIfVersionIsNotLatest, reloadRecord, reloadRecord, rollback, rollback, saveRecord, setCustomData, updateIdentityAfterCommit

Field Details

database

protected ODatabaseDocumentInternal database

status

protected OTransaction.TXSTATUS status

isolationLevel

protected OTransaction.ISOLATION_LEVEL isolationLevel

locks

protected Map<ORID,OTransactionAbstract.LockedRecordMetadata> locks

DELETED_RECORD

public static final ORecord DELETED_RECORD

Indicates the record deleted in a transaction.

See Also:

• OTransaction.getRecord(ORID)

Constructor Details

OTransactionAbstract

protected OTransactionAbstract(ODatabaseDocumentInternal iDatabase)

Method Details

updateCacheFromEntries

public static void updateCacheFromEntries(ODatabaseDocumentInternal database,
 Iterable<? extends ORecordOperation> entries,
 boolean keepInCache)

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 OTransaction

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)

newOp

public ORecordOperation newOp(OIdentifiable iRecord,
 byte iStatus)