com.orientechnologies.orient.core.tx

Class OTransactionOptimistic

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionRealAbstract

com.orientechnologies.orient.core.tx.OTransactionOptimistic

All Implemented Interfaces:

OTransaction

Direct Known Subclasses:

OTransactionOptimisticProxy

public class OTransactionOptimistic
extends OTransactionRealAbstract

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.core.tx.OTransactionRealAbstract

OTransactionRealAbstract.OTransactionRecordIndexOperation

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

allEntries, changedDocuments, DELETED_RECORD, id, indexEntries, newObjectCounter, recordIndexOperations, updatedRids, userData

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

database, isolationLevel, locks, status

Constructor Summary

Constructors

Constructor and Description
OTransactionOptimistic(ODatabaseDocumentTx iDatabase)

Method Summary

Modifier and Type	Method and Description
void	addRecord(ORecord iRecord, byte iStatus, String iClusterName)
int	amountOfNestedTxs()
void	begin()
void	close() Closes the transaction and releases all the acquired locks.
void	commit()
void	commit(boolean force) The transaction is reentrant.
void	deleteRecord(ORecord iRecord, ODatabase.OPERATION_MODE iMode)
boolean	isUsingLog()
ORecord	loadRecord(ORID rid, ORecord record, String fetchPlan, boolean ignoreCache)
ORecord	loadRecord(ORID rid, ORecord iRecord, String fetchPlan, boolean ignoreCache, boolean iUpdateCache, boolean loadTombstone, OStorage.LOCKING_STRATEGY lockingStrategy)
ORecord	loadRecord(ORID rid, ORecord iRecord, String fetchPlan, boolean ignoreCache, boolean loadTombstone, OStorage.LOCKING_STRATEGY lockingStrategy)
ORecord	loadRecordIfVersionIsNotLatest(ORID rid, int recordVersion, String fetchPlan, boolean ignoreCache)
void	recycleRecord(ORecord iRecord)
ORecord	reloadRecord(ORID rid, ORecord iRecord, String fetchPlan, boolean ignoreCache)
ORecord	reloadRecord(ORID rid, ORecord passedRecord, 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)
void	setStatus(OTransaction.TXSTATUS iStatus)
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.
String	toString()

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

addChangedDocument, addIndexEntry, addIndexEntry, checkTransaction, clearIndexEntries, clearRecordEntries, getAllRecordEntries, getCurrentRecordEntries, getCustomData, getEntryCount, getId, getIndexChanges, getIndexChanges, getIndexEntries, getInvolvedIndexes, getNewRecordEntriesByClass, getNewRecordEntriesByClusterIds, getRecord, getRecordEntry, hasRecordCreation, restore, serializeIndexChangeEntry, setCustomData, updateIdentityAfterCommit

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

getClusterName, getDatabase, getIsolationLevel, getLockedRecords, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, setIsolationLevel, unlockRecord, updateCacheFromEntries

Methods inherited from class java.lang.Object

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

Constructor Detail

OTransactionOptimistic

public OTransactionOptimistic(ODatabaseDocumentTx iDatabase)

Method Detail

begin

public void begin()

commit

public void commit()

commit

public void commit(boolean force)

The transaction is reentrant. If begin() has been called several times, the actual commit happens only after the same amount of commit() calls

Parameters:

force - commit transaction even

amountOfNestedTxs

public int amountOfNestedTxs()

rollback

public void rollback()

rollback

public void rollback(boolean force,
                     int commitLevelDiff)

loadRecord

public ORecord loadRecord(ORID rid,
                          ORecord iRecord,
                          String fetchPlan,
                          boolean ignoreCache,
                          boolean loadTombstone,
                          OStorage.LOCKING_STRATEGY lockingStrategy)

loadRecord

public ORecord loadRecord(ORID rid,
                          ORecord iRecord,
                          String fetchPlan,
                          boolean ignoreCache,
                          boolean iUpdateCache,
                          boolean loadTombstone,
                          OStorage.LOCKING_STRATEGY lockingStrategy)

loadRecordIfVersionIsNotLatest

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

Throws:

ORecordNotFoundException

reloadRecord

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

reloadRecord

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

loadRecord

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

deleteRecord

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

recycleRecord

public void recycleRecord(ORecord iRecord)

saveRecord

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

toString

public String toString()

Overrides:

toString in class Object

isUsingLog

public boolean isUsingLog()

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.

setStatus

public void setStatus(OTransaction.TXSTATUS iStatus)

addRecord

public void addRecord(ORecord iRecord,
                      byte iStatus,
                      String iClusterName)

close

public void close()

Description copied from class: OTransactionAbstract

Closes the transaction and releases all the acquired locks.

Specified by:

close in interface OTransaction

Overrides:

close in class OTransactionRealAbstract