com.orientechnologies.orient.core.tx

Class OTransactionNoTx

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionNoTx

All Implemented Interfaces:

OBasicTransaction, OTransaction

public class OTransactionNoTx
extends OTransactionAbstract

No operation transaction.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

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

Constructor and Description
OTransactionNoTx(ODatabaseDocumentInternal iDatabase, Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)

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 indexName, OTransactionIndexChanges.OPERATION status, Object key, OIdentifiable value) Adds the transactional index entry in this transaction.
int	amountOfNestedTxs()
void	begin()
void	clearIndexEntries()
void	clearRecordEntries()
void	commit()
void	commit(boolean force)
void	deleteRecord(ORecord iRecord, ODatabase.OPERATION_MODE iMode) Deletes the record.
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 iName) 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.
List<String>	getInvolvedIndexes()
List<ORecordOperation>	getNewRecordEntriesByClass(OClass iClass, boolean iPolymorphic)
List<ORecordOperation>	getNewRecordEntriesByClusterIds(int[] iIds)
ORecord	getRecord(ORID rid) Resolves a record with the given RID in the context of this transaction.
int	getRecordEntriesSize()
ORecordOperation	getRecordEntry(ORID rid)
Collection<ORecordOperation>	getRecordOperations()
void	internalRollback()
boolean	isUsingLog()
ORecord	loadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache)
ORecord	loadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache, boolean iUpdateCache, boolean loadTombstone, OStorage.LOCKING_STRATEGY iLockingStrategy) Deprecated.
ORecord	loadRecord(ORID iRid, ORecord iRecord, String iFetchPlan, boolean ignoreCache, boolean loadTombstone, OStorage.LOCKING_STRATEGY iLockingStrategy) Deprecated.
ORecord	loadRecordIfVersionIsNotLatest(ORID rid, int recordVersion, String fetchPlan, boolean ignoreCache)
ORecord	reloadRecord(ORID rid, ORecord record, String fetchPlan, boolean ignoreCache)
ORecord	reloadRecord(ORID rid, ORecord record, String fetchPlan, boolean ignoreCache, boolean force)
void	rollback()
void	rollback(boolean force, int commitLevelDiff)
ORecord	saveRecord(ORecord iRecord, String iClusterName, ODatabase.OPERATION_MODE iMode, boolean iForceCreate, ORecordCallback<? extends Number> iRecordCreatedCallback, ORecordCallback<Integer> iRecordUpdatedCallback) Update the record.
void	setCustomData(String iName, Object iValue) Sets the custom value by its name stored in the context of this transaction.
OTransaction	setIsolationLevel(OTransaction.ISOLATION_LEVEL isolationLevel) Changes the isolation level.
void	setUsingLog(boolean useLog) If you set this flag to false, you are unable to Rollback data changes in case of exception Restore data in case of server crash
void	updateIdentityAfterCommit(ORID oldRid, ORID newRid) When commit in transaction is performed all new records will change their identity, but index values will contain stale links, to fix them given method will be called for each entry.

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

close, getDatabase, getInternalLocks, getIsolationLevel, getLockedRecords, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, setDatabase, 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.storage.OBasicTransaction

getClientTransactionId

Constructor Detail

OTransactionNoTx

public OTransactionNoTx(ODatabaseDocumentInternal iDatabase,
                        Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)

Method Detail

begin

public void begin()

commit

public void commit()

getEntryCount

public int getEntryCount()

commit

public void commit(boolean force)

rollback

public void rollback()

loadRecord

@Deprecated
public ORecord loadRecord(ORID iRid,
                                      ORecord iRecord,
                                      String iFetchPlan,
                                      boolean ignoreCache,
                                      boolean loadTombstone,
                                      OStorage.LOCKING_STRATEGY iLockingStrategy)

Deprecated.

loadRecord

@Deprecated
public ORecord loadRecord(ORID iRid,
                                      ORecord iRecord,
                                      String iFetchPlan,
                                      boolean ignoreCache,
                                      boolean iUpdateCache,
                                      boolean loadTombstone,
                                      OStorage.LOCKING_STRATEGY iLockingStrategy)

Deprecated.

loadRecord

public ORecord loadRecord(ORID iRid,
                          ORecord iRecord,
                          String iFetchPlan,
                          boolean ignoreCache)

reloadRecord

public ORecord reloadRecord(ORID rid,
                            ORecord record,
                            String fetchPlan,
                            boolean ignoreCache)

reloadRecord

public ORecord reloadRecord(ORID rid,
                            ORecord record,
                            String fetchPlan,
                            boolean ignoreCache,
                            boolean force)

loadRecordIfVersionIsNotLatest

public ORecord loadRecordIfVersionIsNotLatest(ORID rid,
                                              int recordVersion,
                                              String fetchPlan,
                                              boolean ignoreCache)
                                       throws ORecordNotFoundException

Throws:

ORecordNotFoundException

saveRecord

public ORecord saveRecord(ORecord iRecord,
                          String iClusterName,
                          ODatabase.OPERATION_MODE iMode,
                          boolean iForceCreate,
                          ORecordCallback<? extends Number> iRecordCreatedCallback,
                          ORecordCallback<Integer> iRecordUpdatedCallback)

Update the record.

Parameters:

iRecord -

iForceCreate -

iRecordCreatedCallback -

iRecordUpdatedCallback -

iClusterName - record's cluster name.

iMode - the operation mode.

Returns:

the record saved.

setIsolationLevel

public OTransaction setIsolationLevel(OTransaction.ISOLATION_LEVEL isolationLevel)

Description copied from interface: OTransaction

Changes the isolation level. Default is READ_COMMITTED. When REPEATABLE_READ is set, any record read from the storage is cached in memory to guarantee the repeatable reads. This affects the used RAM and speed (because JVM Garbage Collector job).

Specified by:

setIsolationLevel in interface OTransaction

Overrides:

setIsolationLevel in class OTransactionAbstract

Parameters:

isolationLevel - Isolation level to set

Returns:

Current object to allow call in chain

deleteRecord

public void deleteRecord(ORecord iRecord,
                         ODatabase.OPERATION_MODE iMode)

Deletes the record.

Parameters:

iRecord - the record to delete.

iMode - the operation mode.

getCurrentRecordEntries

public Collection<ORecordOperation> getCurrentRecordEntries()

getRecordOperations

public Collection<ORecordOperation> getRecordOperations()

getNewRecordEntriesByClass

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

getNewRecordEntriesByClusterIds

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

clearRecordEntries

public void clearRecordEntries()

getRecordEntriesSize

public int getRecordEntriesSize()

getRecord

public ORecord getRecord(ORID rid)

Description copied from interface: OBasicTransaction

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

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.

getRecordEntry

public ORecordOperation getRecordEntry(ORID rid)

isUsingLog

public boolean isUsingLog()

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.

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.

Parameters:

iName - the value name.

Returns:

the obtained value or null if no value found.

setUsingLog

public void setUsingLog(boolean useLog)

Description copied from interface: OTransaction

If you set this flag to false, you are unable to

1. Rollback data changes in case of exception
2. Restore data in case of server crash

So you practically unable to work in multithreaded environment and keep data consistent.

getIndexChanges

public ODocument getIndexChanges()

addIndexEntry

public void addIndexEntry(OIndex delegate,
                          String indexName,
                          OTransactionIndexChanges.OPERATION status,
                          Object key,
                          OIdentifiable value)

Description copied from interface: OBasicTransaction

Adds the transactional index entry in this transaction.

Parameters:

delegate - the index.

indexName - the index name.

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

Parameters:

document - the document to add.

clearIndexEntries

public void clearIndexEntries()

getIndexChanges

public OTransactionIndexChanges getIndexChanges(String iName)

Description copied from interface: OBasicTransaction

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

Parameters:

iName - the index name.

Returns:

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

getId

public int getId()

getInvolvedIndexes

public List<String> getInvolvedIndexes()

updateIdentityAfterCommit

public void updateIdentityAfterCommit(ORID oldRid,
                                      ORID newRid)

Description copied from interface: OTransaction

When commit in transaction is performed all new records will change their identity, but index values will contain stale links, to fix them given method will be called for each entry. This update local transaction maps too.

Parameters:

oldRid - Record identity before commit.

newRid - Record identity after commit.

amountOfNestedTxs

public int amountOfNestedTxs()

rollback

public void rollback(boolean force,
                     int commitLevelDiff)

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.

Parameters:

indexName - the index name.

Returns:

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

internalRollback

public void internalRollback()

Specified by:

internalRollback in class OTransactionAbstract