com.orientechnologies.orient.core.tx

Class OTransactionRealAbstract

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionRealAbstract

All Implemented Interfaces:

OBasicTransaction, OTransaction, OTransactionInternal

Direct Known Subclasses:

OTransactionOptimistic

public abstract class OTransactionRealAbstract
extends OTransactionAbstract
implements OTransactionInternal

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 and Description
protected Map<ORID,ORecordOperation>	allEntries
protected Set<ODocument>	changedDocuments token This set is used to track which documents are changed during tx, if documents are changed but not saved all changes are made during tx will be undone.
protected int	id
protected Map<String,OTransactionIndexChanges>	indexEntries
protected int	newObjectCounter
protected Map<ORID,List<OTransactionRecordIndexOperation>>	recordIndexOperations
protected Map<ORID,ORID>	updatedRids
protected Map<String,Object>	userData

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

database, isolationLevel, locks, status

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

DELETED_RECORD

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OTransactionRealAbstract(ODatabaseDocumentInternal database, int id)

Method Summary

Modifier and Type	Method and Description
void	addChangedDocument(ODocument document) Adds the given document to a set of changed documents known to this transaction.
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.
protected void	checkTransaction()
void	clearIndexEntries()
void	clearRecordEntries()
void	close() Closes the transaction and releases all the acquired locks.
Collection<ORecordOperation>	getCurrentRecordEntries()
Object	getCustomData(String iName) Obtains the custom value by its name stored in the context of this transaction.
int	getEntryCount()
int	getId()
ODocument	getIndexChanges()
OTransactionIndexChanges	getIndexChanges(String iIndexName) Bufferizes index changes to be flushed at commit time.
OTransactionIndexChanges	getIndexChangesInternal(String indexName) Does the same thing as OBasicTransaction.getIndexChanges(String), but handles remote storages in a special way.
Map<String,OTransactionIndexChanges>	getIndexOperations() Extract all the calculated index operations for the current transaction changes, the key of the map is the index name the value all the changes for the specified index.
List<String>	getInvolvedIndexes()
Optional<byte[]>	getMetadata()
int	getNewObjectCounter()
List<ORecordOperation>	getNewRecordEntriesByClass(OClass iClass, boolean iPolymorphic) Called by class iterator.
List<ORecordOperation>	getNewRecordEntriesByClusterIds(int[] iIds) Called by cluster iterator.
Map<ORID,OTransactionAbstract.LockedRecordMetadata>	getNoTxLocks()
ORecord	getRecord(ORID rid) Resolves a record with the given RID in the context of this transaction.
ORecordOperation	getRecordEntry(ORID rid) Extract a single change from a specified record id.
Collection<ORecordOperation>	getRecordOperations() Extract all the record operations for the current transaction
Iterator<byte[]>	getSerializedOperations()
Map<ORID,ORID>	getUpdatedRids()
void	prepareSerializedOperations()
void	restore()
protected ODocument	serializeIndexChangeEntry(OTransactionIndexChangesPerKey entry, ODocument indexDoc)
void	setCustomData(String iName, Object iValue) Sets the custom value by its name stored in the context of this transaction.
void	setMetadataHolder(Optional<OTxMetadataHolder> metadata)
void	setNoTxLocks(Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)
void	storageBegun()
void	updateIdentityAfterCommit(ORID oldRid, ORID newRid) Notify the transaction for the rid change, the changed will be tracked inside the transaction and used for remapping links.

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

getDatabase, getInternalLocks, getIsolationLevel, getLockedRecords, getStatus, internalRollback, isActive, isLockedRecord, lockingStrategy, lockRecord, setDatabase, setIsolationLevel, setLocks, trackLockedRecord, trackUnlockRecord, unlockRecord, updateCacheFromEntries

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

fill, getDatabase, getLockedRecords, isSequenceTransaction, isUsingLog, setDatabase, setStatus

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

deleteRecord, getClientTransactionId, isActive, saveRecord

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

amountOfNestedTxs, begin, commit, commit, isUsingLog, loadRecord, loadRecord, loadRecord, loadRecordIfVersionIsNotLatest, reloadRecord, reloadRecord, rollback, rollback, setUsingLog

Field Detail

updatedRids

protected Map<ORID,ORID> updatedRids

allEntries

protected Map<ORID,ORecordOperation> allEntries

indexEntries

protected Map<String,OTransactionIndexChanges> indexEntries

recordIndexOperations

protected Map<ORID,List<OTransactionRecordIndexOperation>> recordIndexOperations

id

protected int id

newObjectCounter

protected int newObjectCounter

userData

protected Map<String,Object> userData

changedDocuments

protected final Set<ODocument> changedDocuments

token This set is used to track which documents are changed during tx, if documents are changed but not saved all changes are made during tx will be undone.

Constructor Detail

OTransactionRealAbstract

protected OTransactionRealAbstract(ODatabaseDocumentInternal database,
                                   int id)

Method Detail

addChangedDocument

public void addChangedDocument(ODocument document)

Description copied from interface: OBasicTransaction

Adds the given document to a set of changed documents known to this transaction.

Specified by:

addChangedDocument in interface OBasicTransaction

Parameters:

document - the document to add.

close

public void close()

Description copied from class: OTransactionAbstract

Closes the transaction and releases all the acquired locks.

Specified by:

close in interface OTransaction

Overrides:

close in class OTransactionAbstract

getId

public int getId()

Specified by:

getId in interface OBasicTransaction

clearRecordEntries

public void clearRecordEntries()

Specified by:

clearRecordEntries in interface OTransaction

restore

public void restore()

getEntryCount

public int getEntryCount()

Specified by:

getEntryCount in interface OTransaction

getCurrentRecordEntries

public Collection<ORecordOperation> getCurrentRecordEntries()

Specified by:

getCurrentRecordEntries in interface OTransaction

getRecordOperations

public Collection<ORecordOperation> getRecordOperations()

Description copied from interface: OTransactionInternal

Extract all the record operations for the current transaction

Specified by:

getRecordOperations in interface OTransaction

Specified by:

getRecordOperations in interface OTransactionInternal

Returns:

the record operations, the collection should not be modified.

getRecordEntry

public ORecordOperation getRecordEntry(ORID rid)

Description copied from interface: OTransactionInternal

Extract a single change from a specified record id.

Specified by:

getRecordEntry in interface OTransaction

Specified by:

getRecordEntry in interface OTransactionInternal

Parameters:

rid - the record id for the change.

Returns:

the change or null if there is no change for the specified rid

getRecord

public ORecord getRecord(ORID rid)

Description copied from interface: OBasicTransaction

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

Specified by:

getRecord in interface OBasicTransaction

Parameters:

rid - the record RID.

Returns:

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

getNewRecordEntriesByClass

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

Called by class iterator.

Specified by:

getNewRecordEntriesByClass in interface OTransaction

getNewRecordEntriesByClusterIds

public List<ORecordOperation> getNewRecordEntriesByClusterIds(int[] iIds)

Called by cluster iterator.

Specified by:

getNewRecordEntriesByClusterIds in interface OTransaction

clearIndexEntries

public void clearIndexEntries()

Specified by:

clearIndexEntries in interface OTransaction

getInvolvedIndexes

public List<String> getInvolvedIndexes()

Specified by:

getInvolvedIndexes in interface OTransaction

getIndexChanges

public ODocument getIndexChanges()

Specified by:

getIndexChanges in interface OTransaction

getIndexOperations

public Map<String,OTransactionIndexChanges> getIndexOperations()

Description copied from interface: OTransactionInternal

Extract all the calculated index operations for the current transaction changes, the key of the map is the index name the value all the changes for the specified index.

Specified by:

getIndexOperations in interface OTransactionInternal

Returns:

the index changes, the map should not be modified.

getIndexChanges

public OTransactionIndexChanges getIndexChanges(String iIndexName)

Bufferizes index changes to be flushed at commit time.

Specified by:

getIndexChanges in interface OBasicTransaction

Parameters:

iIndexName - the index name.

Returns:

getIndexChangesInternal

public OTransactionIndexChanges getIndexChangesInternal(String indexName)

Description copied from interface: OBasicTransaction

Does the same thing as OBasicTransaction.getIndexChanges(String), but handles remote storages in a special way.

Specified by:

getIndexChangesInternal in interface OBasicTransaction

Parameters:

indexName - the index name.

Returns:

the index changes in question or null if index is not found or storage is remote.

addIndexEntry

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

Description copied from interface: OBasicTransaction

Adds the transactional index entry in this transaction.

Specified by:

addIndexEntry in interface OBasicTransaction

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)

Bufferizes index changes to be flushed at commit time.

updateIdentityAfterCommit

public void updateIdentityAfterCommit(ORID oldRid,
                                      ORID newRid)

Description copied from interface: OTransactionInternal

Notify the transaction for the rid change, the changed will be tracked inside the transaction and used for remapping links.

Specified by:

updateIdentityAfterCommit in interface OTransaction

Specified by:

updateIdentityAfterCommit in interface OTransactionInternal

Parameters:

oldRid - the id old value.

newRid - the id new value.

checkTransaction

protected void checkTransaction()

serializeIndexChangeEntry

protected ODocument serializeIndexChangeEntry(OTransactionIndexChangesPerKey entry,
                                              ODocument indexDoc)

setCustomData

public void setCustomData(String iName,
                          Object iValue)

Description copied from interface: OBasicTransaction

Sets the custom value by its name stored in the context of this transaction.

Specified by:

setCustomData in interface OBasicTransaction

Parameters:

iName - the value name.

iValue - the value to store.

getCustomData

public Object getCustomData(String iName)

Description copied from interface: OBasicTransaction

Obtains the custom value by its name stored in the context of this transaction.

Specified by:

getCustomData in interface OBasicTransaction

Parameters:

iName - the value name.

Returns:

the obtained value or null if no value found.

getUpdatedRids

public Map<ORID,ORID> getUpdatedRids()

getNewObjectCounter

public int getNewObjectCounter()

setNoTxLocks

public void setNoTxLocks(Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)

getNoTxLocks

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

getMetadata

public Optional<byte[]> getMetadata()

Specified by:

getMetadata in interface OTransactionInternal

storageBegun

public void storageBegun()

Specified by:

storageBegun in interface OTransactionInternal

setMetadataHolder

public void setMetadataHolder(Optional<OTxMetadataHolder> metadata)

Specified by:

setMetadataHolder in interface OTransactionInternal

prepareSerializedOperations

public void prepareSerializedOperations()
                                 throws IOException

Specified by:

prepareSerializedOperations in interface OTransactionInternal

Throws:

IOException

getSerializedOperations

public Iterator<byte[]> getSerializedOperations()

Specified by:

getSerializedOperations in interface OTransactionInternal