Package com.orientechnologies.orient.server.tx

Class OTransactionOptimisticServer

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionOptimistic

com.orientechnologies.orient.server.tx.OTransactionOptimisticServer

All Implemented Interfaces:

OAllocationTransaction, OStorageTransaction, OTransaction, OTransactionInternal

public class OTransactionOptimisticServer
extends OTransactionOptimistic

Created by tglman on 28/12/16.

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

Modifier and Type	Field	Description
protected final int	clientTxId
protected final Map<ORecordId,ORecord>	createdRecords
protected final Set<ORID>	deletedRecord
protected final List<IndexChange>	indexChanges
protected Map<ORID,ORecordOperation>	oldTxEntries
protected List<ORecordOperationRequest>	operations
protected final Map<ORID,ORecordOperation>	tempEntries
protected final Map<ORecordId,ORecord>	updatedRecords

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
OTransactionOptimisticServer(ODatabaseDocumentInternal database, int txId, List<ORecordOperationRequest> operations, List<IndexChange> indexChanges)

Method Summary

Modifier and Type	Method	Description
void	addIndexEntry(OIndex delegate, String iIndexName, OTransactionIndexChanges.OPERATION iOperation, Object key, OIdentifiable iValue)	Adds the transactional index entry in this transaction.
void	addIndexEntry(OIndex delegate, String iIndexName, OTransactionIndexChanges.OPERATION iOperation, Object key, OIdentifiable iValue, boolean clientTrackOnly)	Bufferizes index changes to be flushed at commit time.
ORecordOperation	addRecord(ORecord iRecord, byte iStatus, String iClusterName)
void	addRecord(ORecord iRecord, byte iStatus, String iClusterName, Map<ORID,ORecordOperation> oldTx)
void	assignClusters()
void	begin()
protected OCompositeKey	checkCompositeKeyId(OCompositeKey key)
int	getClientTransactionId()
Map<ORecordId,ORecord>	getCreatedRecords()
Set<ORID>	getDeletedRecord()
ORecord	getRecord(ORID rid)	Resolves a record with the given RID in the context of this transaction.
Map<ORecordId,ORecord>	getUpdatedRecords()
protected void	unmarshallRecord(ORecord iRecord)	Unmarshalls collections.

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

addChangedDocument, amountOfNestedTxs, checkTransactionValid, close, commit, commit, commitPreallocate, deleteRecord, fill, getChangesForIndex, getCustomData, getEntryCount, getId, getIndexChanges, getIndexChanges, getIndexChangesInternal, getIndexOperations, getInvolvedIndexes, getLockedRecords, getMetadata, getNewObjectCounter, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getNoTxLocks, 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, setDatabase, 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

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

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

getDatabase, isSequenceTransaction, setDatabase

Field Details

tempEntries

protected final Map<ORID,ORecordOperation> tempEntries

createdRecords

protected final Map<ORecordId,ORecord> createdRecords

updatedRecords

protected final Map<ORecordId,ORecord> updatedRecords

deletedRecord

protected final Set<ORID> deletedRecord

clientTxId

protected final int clientTxId

indexChanges

protected final List<IndexChange> indexChanges

oldTxEntries

protected Map<ORID,ORecordOperation> oldTxEntries

operations

protected List<ORecordOperationRequest> operations

Constructor Details

OTransactionOptimisticServer

public OTransactionOptimisticServer(ODatabaseDocumentInternal database,
 int txId,
 List<ORecordOperationRequest> operations,
 List<IndexChange> indexChanges)

Method Details

begin

public void begin()

Specified by:

begin in interface OTransaction

Overrides:

begin in class OTransactionOptimistic

getClientTransactionId

public int getClientTransactionId()

Returns:

this transaction ID as seen by the client of this transaction.

checkCompositeKeyId

protected OCompositeKey checkCompositeKeyId(OCompositeKey key)

getRecord

public ORecord getRecord(ORID rid)

Description copied from interface: OTransaction

Resolves a record with the given RID in the context of this transaction.

Specified by:

getRecord in interface OTransaction

Overrides:

getRecord in class OTransactionOptimistic

Parameters:

rid - the record RID.

Returns:

the resolved record, or null if no record is found, or OTransactionAbstract.DELETED_RECORD if the record was deleted in this transaction.

getCreatedRecords

public Map<ORecordId,ORecord> getCreatedRecords()

getUpdatedRecords

public Map<ORecordId,ORecord> getUpdatedRecords()

getDeletedRecord

public Set<ORID> getDeletedRecord()

unmarshallRecord

protected void unmarshallRecord(ORecord iRecord)

Unmarshalls collections. This prevent temporary RIDs remains stored as are.

addRecord

public ORecordOperation addRecord(ORecord iRecord,
 byte iStatus,
 String iClusterName)

Overrides:

addRecord in class OTransactionOptimistic

addRecord

public void addRecord(ORecord iRecord,
 byte iStatus,
 String iClusterName,
 Map<ORID,ORecordOperation> oldTx)

assignClusters

public void assignClusters()

addIndexEntry

public void addIndexEntry(OIndex delegate,
 String iIndexName,
 OTransactionIndexChanges.OPERATION iOperation,
 Object key,
 OIdentifiable iValue)

Description copied from interface: OTransaction

Adds the transactional index entry in this transaction.

Specified by:

addIndexEntry in interface OTransaction

Overrides:

addIndexEntry in class OTransactionOptimistic

Parameters:

delegate - the index.

iIndexName - the index name.

iOperation - the index operation to register.

key - the index key.

iValue - the index key value.

addIndexEntry

public void addIndexEntry(OIndex delegate,
 String iIndexName,
 OTransactionIndexChanges.OPERATION iOperation,
 Object key,
 OIdentifiable iValue,
 boolean clientTrackOnly)

Description copied from class: OTransactionOptimistic

Bufferizes index changes to be flushed at commit time.

Overrides:

addIndexEntry in class OTransactionOptimistic