com.orientechnologies.orient.core.tx

Interface OTransaction

All Superinterfaces:

OBasicTransaction

All Known Implementing Classes:

OTransactionAbstract, OTransactionNoTx, OTransactionOptimistic, OTransactionOptimisticClient, OTransactionOptimisticDistributed, OTransactionOptimisticProxy, OTransactionOptimisticServer, OTransactionRealAbstract

public interface OTransaction
extends OBasicTransaction

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	OTransaction.ISOLATION_LEVEL
static class	OTransaction.TXSTATUS
static class	OTransaction.TXTYPE

Field Summary

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

DELETED_RECORD

Method Summary

Modifier and Type	Method and Description
int	amountOfNestedTxs()
void	begin()
void	clearIndexEntries() Deprecated.
void	clearRecordEntries() Deprecated.
void	close()
void	commit()
void	commit(boolean force)
Iterable<? extends ORecordOperation>	getCurrentRecordEntries() Deprecated.
ODatabaseDocument	getDatabase()
int	getEntryCount()
ODocument	getIndexChanges()
List<String>	getInvolvedIndexes()
OTransaction.ISOLATION_LEVEL	getIsolationLevel() Returns the current isolation level.
List<ORecordOperation>	getNewRecordEntriesByClass(OClass iClass, boolean iPolymorphic)
List<ORecordOperation>	getNewRecordEntriesByClusterIds(int[] iIds)
ORecordOperation	getRecordEntry(ORID rid)
Iterable<? extends ORecordOperation>	getRecordOperations()
OTransaction.TXSTATUS	getStatus()
boolean	isLockedRecord(OIdentifiable iRecord)
boolean	isUsingLog()
ORecord	loadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache)
ORecord	loadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache, boolean iUpdateCache, boolean loadTombstone, OStorage.LOCKING_STRATEGY iLockingStrategy) Deprecated.
ORecord	loadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache, boolean loadTombstone, OStorage.LOCKING_STRATEGY iLockingStrategy) Deprecated.
ORecord	loadRecordIfVersionIsNotLatest(ORID rid, int recordVersion, String fetchPlan, boolean ignoreCache)
OStorage.LOCKING_STRATEGY	lockingStrategy(OIdentifiable iRecord) Deprecated.
OTransaction	lockRecord(OIdentifiable iRecord, OStorage.LOCKING_STRATEGY iLockingStrategy) Deprecated.
ORecord	reloadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache)
ORecord	reloadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache, boolean force)
void	rollback()
void	rollback(boolean force, int commitLevelDiff)
OTransaction	setIsolationLevel(OTransaction.ISOLATION_LEVEL iIsolationLevel) Changes the isolation level.
void	setUsingLog(boolean useLog) Deprecated. This option has no effect
OTransaction	unlockRecord(OIdentifiable iRecord) Deprecated.
void	updateIdentityAfterCommit(ORID oldRid, ORID newRid) When commit in transaction is performed all new records will change their identity, but index values will contain stale links, to fix them given method will be called for each entry.

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

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

Method Detail

begin

void begin()

commit

void commit()

commit

void commit(boolean force)

rollback

void rollback()

getIsolationLevel

OTransaction.ISOLATION_LEVEL getIsolationLevel()

Returns the current isolation level.

setIsolationLevel

OTransaction setIsolationLevel(OTransaction.ISOLATION_LEVEL iIsolationLevel)

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).

Parameters:

iIsolationLevel - Isolation level to set

Returns:

Current object to allow call in chain

rollback

void rollback(boolean force,
              int commitLevelDiff)

getDatabase

ODatabaseDocument getDatabase()

clearRecordEntries

@Deprecated
void clearRecordEntries()

Deprecated.

loadRecord

@Deprecated
ORecord loadRecord(ORID iRid,
                               ORecord iRecord,
                               String iFetchPlan,
                               boolean ignoreCache,
                               boolean loadTombstone,
                               OStorage.LOCKING_STRATEGY iLockingStrategy)

Deprecated.

loadRecord

@Deprecated
ORecord loadRecord(ORID iRid,
                               ORecord iRecord,
                               String iFetchPlan,
                               boolean ignoreCache,
                               boolean iUpdateCache,
                               boolean loadTombstone,
                               OStorage.LOCKING_STRATEGY iLockingStrategy)

Deprecated.

loadRecord

ORecord loadRecord(ORID iRid,
                   ORecord iRecord,
                   String iFetchPlan,
                   boolean ignoreCache)

reloadRecord

ORecord reloadRecord(ORID iRid,
                     ORecord iRecord,
                     String iFetchPlan,
                     boolean ignoreCache)

reloadRecord

ORecord reloadRecord(ORID iRid,
                     ORecord iRecord,
                     String iFetchPlan,
                     boolean ignoreCache,
                     boolean force)

loadRecordIfVersionIsNotLatest

ORecord loadRecordIfVersionIsNotLatest(ORID rid,
                                       int recordVersion,
                                       String fetchPlan,
                                       boolean ignoreCache)
                                throws ORecordNotFoundException

Throws:

ORecordNotFoundException

getStatus

OTransaction.TXSTATUS getStatus()

getCurrentRecordEntries

@Deprecated
Iterable<? extends ORecordOperation> getCurrentRecordEntries()

Deprecated.

getRecordOperations

Iterable<? extends ORecordOperation> getRecordOperations()

getNewRecordEntriesByClass

List<ORecordOperation> getNewRecordEntriesByClass(OClass iClass,
                                                  boolean iPolymorphic)

getNewRecordEntriesByClusterIds

List<ORecordOperation> getNewRecordEntriesByClusterIds(int[] iIds)

getRecordEntry

ORecordOperation getRecordEntry(ORID rid)

getInvolvedIndexes

List<String> getInvolvedIndexes()

getIndexChanges

ODocument getIndexChanges()

clearIndexEntries

@Deprecated
void clearIndexEntries()

Deprecated.

isUsingLog

boolean isUsingLog()

setUsingLog

@Deprecated
void setUsingLog(boolean useLog)

Deprecated. This option has no effect

If you set this flag to false, you are unable to

1. Rollback data changes in case of exception
2. Restore data in case of server crash

So you practically unable to work in multithreaded environment and keep data consistent.

close

void close()

updateIdentityAfterCommit

void updateIdentityAfterCommit(ORID oldRid,
                               ORID newRid)

When commit in transaction is performed all new records will change their identity, but index values will contain stale links, to fix them given method will be called for each entry. This update local transaction maps too.

Parameters:

oldRid - Record identity before commit.

newRid - Record identity after commit.

amountOfNestedTxs

int amountOfNestedTxs()

isLockedRecord

boolean isLockedRecord(OIdentifiable iRecord)

lockingStrategy

@Deprecated
OStorage.LOCKING_STRATEGY lockingStrategy(OIdentifiable iRecord)

Deprecated.

lockRecord

@Deprecated
OTransaction lockRecord(OIdentifiable iRecord,
                                    OStorage.LOCKING_STRATEGY iLockingStrategy)

Deprecated.

unlockRecord

@Deprecated
OTransaction unlockRecord(OIdentifiable iRecord)

Deprecated.

getEntryCount

int getEntryCount()