com.orientechnologies.orient.core.storage.impl.local

Class OMicroTransaction

java.lang.Object

com.orientechnologies.orient.core.storage.impl.local.OMicroTransaction

All Implemented Interfaces:

OBasicTransaction, OTransactionInternal

public final class OMicroTransaction
extends Object
implements OBasicTransaction, OTransactionInternal

The special micro transaction used to wrap non-transactional operations into implicit transactions. Such transactions are not visible on the database level.

Author:

Sergey Sitnikov

Field Summary

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

DELETED_RECORD

Constructor Summary

Constructors

Constructor and Description
OMicroTransaction(OAbstractPaginatedStorage storage, ODatabaseDocumentInternal database) Instantiates a new micro-transaction.

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<?> index, String indexName, OTransactionIndexChanges.OPERATION type, Object key, OIdentifiable value) Adds the transactional index entry in this transaction.
void	begin() Begins the micro-transaction.
void	commit() Commits the micro-transaction if it's a top-level micro-transaction.
void	deleteRecord(ORecord record, ODatabase.OPERATION_MODE mode) Deletes the given record in this transaction.
int	getClientTransactionId()
Object	getCustomData(String name) Obtains the custom value by its name stored in the context of this transaction.
ODatabaseDocumentInternal	getDatabase() Access to the database of the transaction
int	getId()
OTransactionIndexChanges	getIndexChanges(String indexName) Obtains the index changes done in the context of this transaction.
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.
ORecord	getRecord(ORID rid) Resolves a record with the given RID in the context of this transaction.
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
boolean	isActive()
boolean	isUsingLog() Retrieve if log is enabled for the transaction
void	rollback() Rollbacks the micro-transaction if it's a top-level micro-transaction.
void	rollbackAfterFailedCommit() Rollbacks the micro-transaction after failed commit attempt.
ORecord	saveRecord(ORecord record, String clusterName, ODatabase.OPERATION_MODE operationMode, boolean forceCreation, ORecordCallback<? extends Number> createdCallback, ORecordCallback<Integer> updatedCallback) Saves the given record in this transaction.
void	setCustomData(String name, Object value) Sets the custom value by its name stored in the context of this transaction.
void	setDatabase(ODatabaseDocumentInternal database)
void	setStatus(OTransaction.TXSTATUS iStatus) Change the status of the transaction.
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.
void	updateIdentityAfterRecordCommit(ORID oldRid, ORID newRid) Updates the record identity after its successful commit.
void	updateRecordCacheAfterRollback() Updates the record cache after unsuccessful micro-transaction commit.

Methods inherited from class java.lang.Object

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

Constructor Detail

OMicroTransaction

public OMicroTransaction(OAbstractPaginatedStorage storage,
                         ODatabaseDocumentInternal database)

Instantiates a new micro-transaction.

Parameters:

storage - the micro-transaction's storage.

database - the micro-transaction's database.

Method Detail

getId

public int getId()

Specified by:

getId in interface OBasicTransaction

Returns:

the unique id of this micro-transaction.

getClientTransactionId

public int getClientTransactionId()

Specified by:

getClientTransactionId in interface OBasicTransaction

Returns:

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

updateIdentityAfterCommit

public void updateIdentityAfterCommit(ORID oldRID,
                                      ORID rid)

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 OTransactionInternal

Parameters:

oldRID - the id old value.

rid - the id new value.

getDatabase

public ODatabaseDocumentInternal getDatabase()

Description copied from interface: OTransactionInternal

Access to the database of the transaction

Specified by:

getDatabase in interface OTransactionInternal

Returns:

the micro-transaction's database.

getRecordOperations

public Collection<ORecordOperation> getRecordOperations()

Description copied from interface: OTransactionInternal

Extract all the record operations for the current transaction

Specified by:

getRecordOperations in interface OTransactionInternal

Returns:

the record operations done in the context of this micro-transaction.

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 operations done in the context of this micro-transaction.

begin

public void begin()

Begins the micro-transaction. Micro-transactions may be nested.

commit

public void commit()

Commits the micro-transaction if it's a top-level micro-transaction.

rollback

public void rollback()

Rollbacks the micro-transaction if it's a top-level micro-transaction.

rollbackAfterFailedCommit

public void rollbackAfterFailedCommit()

Rollbacks the micro-transaction after failed commit attempt.

updateIdentityAfterRecordCommit

public void updateIdentityAfterRecordCommit(ORID oldRid,
                                            ORID newRid)

Updates the record identity after its successful commit.

updateRecordCacheAfterRollback

public void updateRecordCacheAfterRollback()

Updates the record cache after unsuccessful micro-transaction commit.

isActive

public boolean isActive()

Specified by:

isActive in interface OBasicTransaction

Returns:

true if this transaction is active, false otherwise.

saveRecord

public ORecord saveRecord(ORecord record,
                          String clusterName,
                          ODatabase.OPERATION_MODE operationMode,
                          boolean forceCreation,
                          ORecordCallback<? extends Number> createdCallback,
                          ORecordCallback<Integer> updatedCallback)

Description copied from interface: OBasicTransaction

Saves the given record in this transaction.

Specified by:

saveRecord in interface OBasicTransaction

Parameters:

record - the record to save.

clusterName - record's cluster name.

operationMode - the operation mode.

forceCreation - the force creation flag, true to force the creation of the record, false to allow updates.

createdCallback - the callback to invoke when the record save operation triggered the creation of the record.

updatedCallback - the callback to invoke when the record save operation triggered the update of the record.

Returns:

the record saved.

deleteRecord

public void deleteRecord(ORecord record,
                         ODatabase.OPERATION_MODE mode)

Description copied from interface: OBasicTransaction

Deletes the given record in this transaction.

Specified by:

deleteRecord in interface OBasicTransaction

Parameters:

record - the record to delete.

mode - the operation mode.

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.

getIndexChanges

public OTransactionIndexChanges getIndexChanges(String indexName)

Description copied from interface: OBasicTransaction

Obtains the index changes done in the context of this transaction.

Specified by:

getIndexChanges in interface OBasicTransaction

Parameters:

indexName - the index name.

Returns:

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

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.

getCustomData

public Object getCustomData(String name)

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:

name - the value name.

Returns:

the obtained value or null if no value found.

setCustomData

public void setCustomData(String name,
                          Object value)

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:

name - the value name.

value - the value to store.

addIndexEntry

public void addIndexEntry(OIndex<?> index,
                          String indexName,
                          OTransactionIndexChanges.OPERATION type,
                          Object key,
                          OIdentifiable value)

Description copied from interface: OBasicTransaction

Adds the transactional index entry in this transaction.

Specified by:

addIndexEntry in interface OBasicTransaction

Parameters:

index - the index.

indexName - the index name.

type - the index operation to register.

key - the index key.

value - the index key value.

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.

setStatus

public void setStatus(OTransaction.TXSTATUS iStatus)

Description copied from interface: OTransactionInternal

Change the status of the transaction.

Specified by:

setStatus in interface OTransactionInternal

isUsingLog

public boolean isUsingLog()

Description copied from interface: OTransactionInternal

Retrieve if log is enabled for the transaction

Specified by:

isUsingLog in interface OTransactionInternal

Returns:

getRecordEntry

public ORecordOperation getRecordEntry(ORID currentRid)

Description copied from interface: OTransactionInternal

Extract a single change from a specified record id.

Specified by:

getRecordEntry in interface OTransactionInternal

Parameters:

currentRid - the record id for the change.

Returns:

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

setDatabase

public void setDatabase(ODatabaseDocumentInternal database)

Specified by:

setDatabase in interface OTransactionInternal