Package com.orientechnologies.orient.core.tx

Interface OTransactionInternal

All Superinterfaces:

OAllocationTransaction, OStorageTransaction, OTransaction

All Known Implementing Classes:

OTransactionOptimistic, OTransactionOptimisticClient, OTransactionOptimisticDistributed, OTransactionOptimisticProxy, OTransactionOptimisticServer

public interface OTransactionInternal
extends OStorageTransaction, OAllocationTransaction, OTransaction

Expose the api for extract the internal details needed by the storage for perform the transaction commit

Nested Class Summary

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

OTransaction.ISOLATION_LEVEL, OTransaction.TXSTATUS, OTransaction.TXTYPE

Method Summary

Modifier and Type	Method	Description
default void	fill(Iterator<ORecordOperation> operations)
ODatabaseDocumentInternal	getDatabase()	Access to the database of the transaction
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.
Set<ORID>	getLockedRecords()
default Optional<byte[]>	getMetadata()
ORecordOperation	getRecordEntry(ORID currentRid)	Extract a single change from a specified record id.
Collection<ORecordOperation>	getRecordOperations()	Extract all the record operations for the current transaction
Iterator<byte[]>	getSerializedOperations()
default boolean	isSequenceTransaction()
void	prepareSerializedOperations()
void	resetAllocatedIds()
void	setDatabase(ODatabaseDocumentInternal database)
void	setMetadataHolder(Optional<OTxMetadataHolder> metadata)
void	setStatus(OTransaction.TXSTATUS iStatus)	Change the status of the transaction.
default void	startedStorageTransaction()
void	updateIdentityAfterCommit(ORID oldRID, ORID rid)	Notify the transaction for the rid change, the changed will be tracked inside the transaction and used for remapping links.

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

getRecordChanges

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

getChangesForIndex, getId, getRecordChanges, updateCache

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

addChangedDocument, addIndexEntry, amountOfNestedTxs, begin, close, commit, commit, deleteRecord, getClientTransactionId, getCustomData, getEntryCount, getId, getIndexChanges, getIndexChanges, getIndexChangesInternal, getInvolvedIndexes, getIsolationLevel, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getRecord, getStatus, isActive, isLockedRecord, loadRecord, loadRecordIfVersionIsNotLatest, lockingStrategy, lockRecord, reloadRecord, reloadRecord, rollback, rollback, saveRecord, setCustomData, setIsolationLevel, unlockRecord

Method Details

getRecordOperations

Collection<ORecordOperation> getRecordOperations()

Extract all the record operations for the current transaction

Specified by:

getRecordOperations in interface OTransaction

Returns:

the record operations, the collection should not be modified.

getIndexOperations

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.

Returns:

the index changes, the map should not be modified.

setStatus

void setStatus(OTransaction.TXSTATUS iStatus)

Change the status of the transaction.

Parameters:

iStatus -

getDatabase

ODatabaseDocumentInternal getDatabase()

Access to the database of the transaction

Specified by:

getDatabase in interface OTransaction

Returns:

updateIdentityAfterCommit

void updateIdentityAfterCommit(ORID oldRID,
 ORID rid)

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 OAllocationTransaction

Specified by:

updateIdentityAfterCommit in interface OStorageTransaction

Specified by:

updateIdentityAfterCommit in interface OTransaction

Parameters:

oldRID - the id old value.

rid - the id new value.

getRecordEntry

ORecordOperation getRecordEntry(ORID currentRid)

Extract a single change from a specified record id.

Specified by:

getRecordEntry in interface OTransaction

Parameters:

currentRid - the record id for the change.

Returns:

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

getLockedRecords

Set<ORID> getLockedRecords()

Specified by:

getLockedRecords in interface OStorageTransaction

setDatabase

void setDatabase(ODatabaseDocumentInternal database)

isSequenceTransaction

default boolean isSequenceTransaction()

getMetadata

default Optional<byte[]> getMetadata()

Specified by:

getMetadata in interface OStorageTransaction

setMetadataHolder

void setMetadataHolder(Optional<OTxMetadataHolder> metadata)

startedStorageTransaction

default void startedStorageTransaction()

Specified by:

startedStorageTransaction in interface OStorageTransaction

prepareSerializedOperations

void prepareSerializedOperations()
                          throws IOException

Throws:

IOException

getSerializedOperations

Iterator<byte[]> getSerializedOperations()

Specified by:

getSerializedOperations in interface OStorageTransaction

fill

default void fill(Iterator<ORecordOperation> operations)

resetAllocatedIds

void resetAllocatedIds()