Package com.orientechnologies.orient.server.distributed.impl

Class OTransactionOptimisticDistributed

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionOptimistic

com.orientechnologies.orient.server.distributed.impl.OTransactionOptimisticDistributed

All Implemented Interfaces:

OAllocationTransaction, OStorageTransaction, OTransaction, OTransactionInternal

public class OTransactionOptimisticDistributed
extends OTransactionOptimistic

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.tx.OTransactionAbstract

OTransactionAbstract.LockedRecordMetadata

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

OTransaction.ISOLATION_LEVEL, OTransaction.TXSTATUS, OTransaction.TXTYPE

Field Summary

Fields inherited from class com.orientechnologies.orient.core.tx.OTransactionOptimistic

allEntries, changed, changedDocuments, id, indexEntries, newObjectCounter, recordIndexOperations, updatedRids, userData

Fields inherited from class com.orientechnologies.orient.core.tx.OTransactionAbstract

database, DELETED_RECORD, isolationLevel, locks, status

Constructor Summary

Constructors

Constructor	Description
OTransactionOptimisticDistributed(ODatabaseDocumentInternal database, List<ORecordOperation> changes, SortedSet<OTransactionUniqueKey> uniqueIndexKeys)

Method Summary

Modifier and Type	Method	Description
void	begin()
int	getVersionForKey(String index, Object key)
void	setDatabase(ODatabaseDocumentInternal database)

Methods inherited from class com.orientechnologies.orient.core.tx.OTransactionOptimistic

addChangedDocument, addIndexEntry, addIndexEntry, addRecord, amountOfNestedTxs, checkTransactionValid, close, commit, commit, commitPreallocate, deleteRecord, fill, getChangesForIndex, getCustomData, getEntryCount, getId, getIndexChanges, getIndexChanges, getIndexChangesInternal, getIndexOperations, getInvolvedIndexes, getLockedRecords, getMetadata, getNewObjectCounter, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getNoTxLocks, getRecord, getRecordChanges, getRecordEntry, getRecordOperations, getSentToServer, getSerializedOperations, getTxStartCounter, getUpdatedRids, internalRollback, isAlreadyCleared, isChanged, loadRecord, loadRecord, loadRecordIfVersionIsNotLatest, prepareSerializedOperations, reloadRecord, reloadRecord, resetAllocatedIds, resetChangesTracking, resolveTracking, rollback, rollback, saveRecord, serializeIndexChangeEntry, setCustomData, setMetadataHolder, setNoTxLocks, setSentToServer, setStatus, startedStorageTransaction, toString, updateCache, updateIdentityAfterCommit

Methods inherited from class com.orientechnologies.orient.core.tx.OTransactionAbstract

getDatabase, getInternalLocks, getIsolationLevel, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, newOp, setIsolationLevel, setLocks, trackLockedRecord, trackUnlockRecord, unlockRecord, updateCacheFromEntries

Methods inherited from class java.lang.Object

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

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

getClientTransactionId, getIsolationLevel, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, setIsolationLevel, unlockRecord

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

getDatabase, isSequenceTransaction

Constructor Details

OTransactionOptimisticDistributed

public OTransactionOptimisticDistributed(ODatabaseDocumentInternal database,
 List<ORecordOperation> changes,
 SortedSet<OTransactionUniqueKey> uniqueIndexKeys)

Method Details

begin

public void begin()

Specified by:

begin in interface OTransaction

Overrides:

begin in class OTransactionOptimistic

setDatabase

public void setDatabase(ODatabaseDocumentInternal database)

Specified by:

setDatabase in interface OTransactionInternal

Overrides:

setDatabase in class OTransactionAbstract

getVersionForKey

public int getVersionForKey(String index,
 Object key)