com.orientechnologies.orient.core.tx

Interface OTransactionInternal

All Superinterfaces:

OBasicTransaction

All Known Implementing Classes:

OMicroTransaction, OTransactionOptimistic, OTransactionOptimisticClient, OTransactionOptimisticDistributed, OTransactionOptimisticProxy, OTransactionOptimisticServer, OTransactionRealAbstract

public interface OTransactionInternal
extends OBasicTransaction

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

Field Summary

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

DELETED_RECORD

Method Summary

Modifier and Type	Method and 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()
boolean	isUsingLog() Deprecated.
void	prepareSerializedOperations()
void	setDatabase(ODatabaseDocumentInternal database)
void	setMetadataHolder(Optional<OTxMetadataHolder> metadata)
void	setStatus(OTransaction.TXSTATUS iStatus) Change the status of the transaction.
default void	storageBegun()
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.OBasicTransaction

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

Method Detail

getRecordOperations

Collection<ORecordOperation> getRecordOperations()

Extract all the record operations for the current transaction

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

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.

Parameters:

oldRID - the id old value.

rid - the id new value.

isUsingLog

@Deprecated
boolean isUsingLog()

Deprecated.

Retrieve if log is enabled for the transaction

getRecordEntry

ORecordOperation getRecordEntry(ORID currentRid)

Extract a single change from a specified record id.

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

setDatabase

void setDatabase(ODatabaseDocumentInternal database)

isSequenceTransaction

default boolean isSequenceTransaction()

getMetadata

default Optional<byte[]> getMetadata()

setMetadataHolder

void setMetadataHolder(Optional<OTxMetadataHolder> metadata)

storageBegun

default void storageBegun()

prepareSerializedOperations

void prepareSerializedOperations()
                          throws IOException

Throws:

IOException

getSerializedOperations

Iterator<byte[]> getSerializedOperations()

fill

default void fill(Iterator<ORecordOperation> operations)