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:

OTransaction

public class OTransactionNoTx
extends OTransactionAbstract

No operation transaction.

Author:

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

Nested Class Summary

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

Constructor Summary

Constructors

Constructor and Description
OTransactionNoTx(ODatabaseDocumentTx iDatabase)

Method Summary

Modifier and Type	Method and Description
void	addIndexEntry(OIndex<?> delegate, String indexName, OTransactionIndexChanges.OPERATION status, Object key, OIdentifiable value)
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>	getAllRecordEntries()
Collection<ORecordOperation>	getCurrentRecordEntries()
Object	getCustomData(String iName)
int	getEntryCount()
int	getId()
ODocument	getIndexChanges()
OTransactionIndexChanges	getIndexChanges(String iName)
List<String>	getInvolvedIndexes()
List<ORecordOperation>	getNewRecordEntriesByClass(OClass iClass, boolean iPolymorphic)
List<ORecordOperation>	getNewRecordEntriesByClusterIds(int[] iIds)
ORecord	getRecord(ORID rid)
int	getRecordEntriesSize()
ORecordOperation	getRecordEntry(ORID rid)
boolean	hasRecordCreation()
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)
void	recycleRecord(ORecord iRecord) Recycles the record.
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	saveNew(ODocument document, ODirtyManager manager, String iClusterName, ORecord original, ODatabase.OPERATION_MODE iMode, boolean iForceCreate, ORecordCallback<? extends Number> iRecordCreatedCallback, ORecordCallback<Integer> iRecordUpdatedCallback)
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)
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 So you practically unable to work in multithreaded environment and keep data consistent.
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, getClusterName, getDatabase, getIsolationLevel, getLockedRecords, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, unlockRecord, updateCacheFromEntries

Methods inherited from class java.lang.Object

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

Constructor Detail

OTransactionNoTx

public OTransactionNoTx(ODatabaseDocumentTx iDatabase)

Method Detail

begin

public void begin()

commit

public void commit()

getEntryCount

public int getEntryCount()

hasRecordCreation

public boolean hasRecordCreation()

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 -

saveNew

public ORecord saveNew(ODocument document,
                       ODirtyManager manager,
                       String iClusterName,
                       ORecord original,
                       ODatabase.OPERATION_MODE iMode,
                       boolean iForceCreate,
                       ORecordCallback<? extends Number> iRecordCreatedCallback,
                       ORecordCallback<Integer> iRecordUpdatedCallback)

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.

recycleRecord

public void recycleRecord(ORecord iRecord)

Recycles the record.

getCurrentRecordEntries

public Collection<ORecordOperation> getCurrentRecordEntries()

getAllRecordEntries

public Collection<ORecordOperation> getAllRecordEntries()

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)

getRecordEntry

public ORecordOperation getRecordEntry(ORID rid)

isUsingLog

public boolean isUsingLog()

setCustomData

public void setCustomData(String iName,
                          Object iValue)

getCustomData

public Object getCustomData(String iName)

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)

clearIndexEntries

public void clearIndexEntries()

getIndexChanges

public OTransactionIndexChanges getIndexChanges(String iName)

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)