Package com.orientechnologies.orient.core.tx

Class OTransactionOptimistic

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionOptimistic

All Implemented Interfaces:

OAllocationTransaction, OStorageTransaction, OTransaction, OTransactionInternal

Direct Known Subclasses:

OTransactionOptimisticClient, OTransactionOptimisticDistributed, OTransactionOptimisticProxy, OTransactionOptimisticServer

public class OTransactionOptimistic
extends OTransactionAbstract
implements OTransactionInternal

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

Modifier and Type	Field	Description
protected Map<ORID,ORecordOperation>	allEntries
protected boolean	changed
protected final Set<ODocument>	changedDocuments	token This set is used to track which documents are changed during tx, if documents are changed but not saved all changes are made during tx will be undone.
protected int	id
protected Map<String,OTransactionIndexChanges>	indexEntries
protected int	newObjectCounter
protected Map<ORID,List<OTransactionRecordIndexOperation>>	recordIndexOperations
protected Map<ORID,ORID>	updatedRids
protected Map<String,Object>	userData

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

database, DELETED_RECORD, isolationLevel, locks, status

Constructor Summary

Constructors

Constructor	Description
OTransactionOptimistic(ODatabaseDocumentInternal iDatabase)

Method Summary

Modifier and Type	Method	Description
void	addChangedDocument(ODocument document)	Adds the given document to a set of changed documents known to this transaction.
void	addIndexEntry(OIndex delegate, String iIndexName, OTransactionIndexChanges.OPERATION iOperation, Object key, OIdentifiable iValue)	Adds the transactional index entry in this transaction.
void	addIndexEntry(OIndex delegate, String iIndexName, OTransactionIndexChanges.OPERATION iOperation, Object key, OIdentifiable iValue, boolean clientTrackOnly)	Bufferizes index changes to be flushed at commit time.
ORecordOperation	addRecord(ORecord iRecord, byte iStatus, String iClusterName)
int	amountOfNestedTxs()
void	begin()
protected void	checkTransactionValid()
void	close()	Closes the transaction and releases all the acquired locks.
void	commit()
void	commit(boolean force)	The transaction is reentrant.
void	commitPreallocate()
void	deleteRecord(ORecord iRecord)	Deletes the given record in this transaction.
void	fill(Iterator<ORecordOperation> operations)
SortedMap<String,OStorageTransactionIndexChanges>	getChangesForIndex()
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 iIndexName)	Bufferizes index changes to be flushed at commit time.
OTransactionIndexChanges	getIndexChangesInternal(String indexName)	Does the same thing as OTransaction.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.
List<String>	getInvolvedIndexes()
Set<ORID>	getLockedRecords()
Optional<byte[]>	getMetadata()
int	getNewObjectCounter()
List<ORecordOperation>	getNewRecordEntriesByClass(OClass iClass, boolean iPolymorphic)	Called by class iterator.
List<ORecordOperation>	getNewRecordEntriesByClusterIds(int[] iIds)	Called by cluster iterator.
Map<ORID,OTransactionAbstract.LockedRecordMetadata>	getNoTxLocks()
ORecord	getRecord(ORID rid)	Resolves a record with the given RID in the context of this transaction.
Collection<OStorageRecordOperation>	getRecordChanges()
ORecordOperation	getRecordEntry(ORID ridPar)	Extract a single change from a specified record id.
Collection<ORecordOperation>	getRecordOperations()	Extract all the record operations for the current transaction
boolean	getSentToServer()
Iterator<byte[]>	getSerializedOperations()
protected int	getTxStartCounter()
Map<ORID,ORID>	getUpdatedRids()
void	internalRollback()
boolean	isAlreadyCleared()
boolean	isChanged()
ORecord	loadRecord(ORID rid, ORecord record, String fetchPlan, boolean ignoreCache)
ORecord	loadRecord(ORID rid, ORecord iRecord, String fetchPlan, boolean ignoreCache, boolean iUpdateCache)
ORecord	loadRecordIfVersionIsNotLatest(ORID rid, int recordVersion, String fetchPlan, boolean ignoreCache)
void	prepareSerializedOperations()
ORecord	reloadRecord(ORID rid, ORecord iRecord, String fetchPlan, boolean ignoreCache)
ORecord	reloadRecord(ORID rid, ORecord passedRecord, String fetchPlan, boolean ignoreCache, boolean force)
void	resetAllocatedIds()
void	resetChangesTracking()
protected void	resolveTracking(ORecordOperation change)
void	rollback()
void	rollback(boolean force, int commitLevelDiff)
ORecord	saveRecord(ORecord iRecord, String iClusterName, boolean iForceCreate)	Saves the given record in this transaction.
protected ODocument	serializeIndexChangeEntry(OTransactionIndexChangesPerKey entry, ODocument indexDoc)
void	setCustomData(String iName, Object iValue)	Sets the custom value by its name stored in the context of this transaction.
void	setMetadataHolder(Optional<OTxMetadataHolder> metadata)
void	setNoTxLocks(Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)
void	setSentToServer(boolean sentToServer)
void	setStatus(OTransaction.TXSTATUS iStatus)	Change the status of the transaction.
void	startedStorageTransaction()
String	toString()
void	updateCache(boolean keepInCache)
void	updateIdentityAfterCommit(ORID oldRid, ORID newRid)	Notify the transaction for the rid change, the changed will be tracked inside the transaction and used for remapping links.

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

getDatabase, getInternalLocks, getIsolationLevel, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, newOp, setDatabase, setIsolationLevel, setLocks, trackLockedRecord, trackUnlockRecord, unlockRecord, updateCacheFromEntries

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.tx.OTransaction

getClientTransactionId, getIsolationLevel, getStatus, isActive, isLockedRecord, lockingStrategy, lockRecord, setIsolationLevel, unlockRecord

Methods inherited from interface com.orientechnologies.orient.core.tx.OTransactionInternal

getDatabase, isSequenceTransaction, setDatabase

Field Details

updatedRids

protected Map<ORID,ORID> updatedRids

allEntries

protected Map<ORID,ORecordOperation> allEntries

indexEntries

protected Map<String,OTransactionIndexChanges> indexEntries

recordIndexOperations

protected Map<ORID,List<OTransactionRecordIndexOperation>> recordIndexOperations

id

protected int id

newObjectCounter

protected int newObjectCounter

userData

protected Map<String,Object> userData

changedDocuments

protected final Set<ODocument> changedDocuments

token This set is used to track which documents are changed during tx, if documents are changed but not saved all changes are made during tx will be undone.

changed

protected boolean changed

Constructor Details

OTransactionOptimistic

public OTransactionOptimistic(ODatabaseDocumentInternal iDatabase)

Method Details

begin

public void begin()

Specified by:

begin in interface OTransaction

commit

public void commit()

Specified by:

commit in interface OTransaction

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

Specified by:

commit in interface OTransaction

Parameters:

force - commit transaction even

commitPreallocate

public void commitPreallocate()

amountOfNestedTxs

public int amountOfNestedTxs()

Specified by:

amountOfNestedTxs in interface OTransaction

rollback

public void rollback()

Specified by:

rollback in interface OTransaction

internalRollback

public void internalRollback()

Specified by:

internalRollback in class OTransactionAbstract

rollback

public void rollback(boolean force,
 int commitLevelDiff)

Specified by:

rollback in interface OTransaction

loadRecord

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

loadRecordIfVersionIsNotLatest

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

Specified by:

loadRecordIfVersionIsNotLatest in interface OTransaction

Throws:

ORecordNotFoundException

reloadRecord

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

Specified by:

reloadRecord in interface OTransaction

reloadRecord

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

Specified by:

reloadRecord in interface OTransaction

loadRecord

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

Specified by:

loadRecord in interface OTransaction

deleteRecord

public void deleteRecord(ORecord iRecord)

Description copied from interface: OTransaction

Deletes the given record in this transaction.

Specified by:

deleteRecord in interface OTransaction

Parameters:

iRecord - the record to delete.

saveRecord

public ORecord saveRecord(ORecord iRecord,
 String iClusterName,
 boolean iForceCreate)

Description copied from interface: OTransaction

Saves the given record in this transaction.

Specified by:

saveRecord in interface OTransaction

Parameters:

iRecord - the record to save.

iClusterName - record's cluster name.

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

Returns:

the record saved.

toString

public String toString()

Overrides:

toString in class Object

setStatus

public void setStatus(OTransaction.TXSTATUS iStatus)

Description copied from interface: OTransactionInternal

Change the status of the transaction.

Specified by:

setStatus in interface OTransactionInternal

addRecord

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

resetChangesTracking

public void resetChangesTracking()

isChanged

public boolean isChanged()

isAlreadyCleared

public boolean isAlreadyCleared()

getLockedRecords

public Set<ORID> getLockedRecords()

Specified by:

getLockedRecords in interface OStorageTransaction

Specified by:

getLockedRecords in interface OTransactionInternal

Overrides:

getLockedRecords in class OTransactionAbstract

setSentToServer

public void setSentToServer(boolean sentToServer)

getSentToServer

public boolean getSentToServer()

fill

public void fill(Iterator<ORecordOperation> operations)

Specified by:

fill in interface OTransactionInternal

resolveTracking

protected void resolveTracking(ORecordOperation change)

getTxStartCounter

protected int getTxStartCounter()

addChangedDocument

public void addChangedDocument(ODocument document)

Description copied from interface: OTransaction

Adds the given document to a set of changed documents known to this transaction.

Specified by:

addChangedDocument in interface OTransaction

Parameters:

document - the document to add.

getId

public int getId()

Specified by:

getId in interface OStorageTransaction

Specified by:

getId in interface OTransaction

getEntryCount

public int getEntryCount()

Specified by:

getEntryCount in interface OTransaction

getRecordOperations

public Collection<ORecordOperation> getRecordOperations()

Description copied from interface: OTransactionInternal

Extract all the record operations for the current transaction

Specified by:

getRecordOperations in interface OTransaction

Specified by:

getRecordOperations in interface OTransactionInternal

Returns:

the record operations, the collection should not be modified.

getRecordEntry

public ORecordOperation getRecordEntry(ORID ridPar)

Description copied from interface: OTransactionInternal

Extract a single change from a specified record id.

Specified by:

getRecordEntry in interface OTransaction

Specified by:

getRecordEntry in interface OTransactionInternal

Parameters:

ridPar - the record id for the change.

Returns:

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

getRecord

public ORecord getRecord(ORID rid)

Description copied from interface: OTransaction

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

Specified by:

getRecord in interface OTransaction

Parameters:

rid - the record RID.

Returns:

the resolved record, or null if no record is found, or OTransactionAbstract.DELETED_RECORD if the record was deleted in this transaction.

getNewRecordEntriesByClass

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

Called by class iterator.

Specified by:

getNewRecordEntriesByClass in interface OTransaction

getNewRecordEntriesByClusterIds

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

Called by cluster iterator.

Specified by:

getNewRecordEntriesByClusterIds in interface OTransaction

getInvolvedIndexes

public List<String> getInvolvedIndexes()

Specified by:

getInvolvedIndexes in interface OTransaction

getIndexChanges

public ODocument getIndexChanges()

Specified by:

getIndexChanges in interface OTransaction

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 changes, the map should not be modified.

getIndexChanges

public OTransactionIndexChanges getIndexChanges(String iIndexName)

Bufferizes index changes to be flushed at commit time.

Specified by:

getIndexChanges in interface OTransaction

Parameters:

iIndexName - the index name.

Returns:

getIndexChangesInternal

public OTransactionIndexChanges getIndexChangesInternal(String indexName)

Description copied from interface: OTransaction

Does the same thing as OTransaction.getIndexChanges(String), but handles remote storages in a special way.

Specified by:

getIndexChangesInternal in interface OTransaction

Parameters:

indexName - the index name.

Returns:

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

addIndexEntry

public void addIndexEntry(OIndex delegate,
 String iIndexName,
 OTransactionIndexChanges.OPERATION iOperation,
 Object key,
 OIdentifiable iValue)

Description copied from interface: OTransaction

Adds the transactional index entry in this transaction.

Specified by:

addIndexEntry in interface OTransaction

Parameters:

delegate - the index.

iIndexName - the index name.

iOperation - the index operation to register.

key - the index key.

iValue - the index key value.

addIndexEntry

public void addIndexEntry(OIndex delegate,
 String iIndexName,
 OTransactionIndexChanges.OPERATION iOperation,
 Object key,
 OIdentifiable iValue,
 boolean clientTrackOnly)

Bufferizes index changes to be flushed at commit time.

updateIdentityAfterCommit

public void updateIdentityAfterCommit(ORID oldRid,
 ORID newRid)

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 OAllocationTransaction

Specified by:

updateIdentityAfterCommit in interface OStorageTransaction

Specified by:

updateIdentityAfterCommit in interface OTransaction

Specified by:

updateIdentityAfterCommit in interface OTransactionInternal

Parameters:

oldRid - the id old value.

newRid - the id new value.

checkTransactionValid

protected void checkTransactionValid()

serializeIndexChangeEntry

protected ODocument serializeIndexChangeEntry(OTransactionIndexChangesPerKey entry,
 ODocument indexDoc)

setCustomData

public void setCustomData(String iName,
 Object iValue)

Description copied from interface: OTransaction

Sets the custom value by its name stored in the context of this transaction.

Specified by:

setCustomData in interface OTransaction

Parameters:

iName - the value name.

iValue - the value to store.

getCustomData

public Object getCustomData(String iName)

Description copied from interface: OTransaction

Obtains the custom value by its name stored in the context of this transaction.

Specified by:

getCustomData in interface OTransaction

Parameters:

iName - the value name.

Returns:

the obtained value or null if no value found.

getUpdatedRids

public Map<ORID,ORID> getUpdatedRids()

getNewObjectCounter

public int getNewObjectCounter()

setNoTxLocks

public void setNoTxLocks(Map<ORID,OTransactionAbstract.LockedRecordMetadata> noTxLocks)

getNoTxLocks

public Map<ORID,OTransactionAbstract.LockedRecordMetadata> getNoTxLocks()

getMetadata

public Optional<byte[]> getMetadata()

Specified by:

getMetadata in interface OStorageTransaction

Specified by:

getMetadata in interface OTransactionInternal

startedStorageTransaction

public void startedStorageTransaction()

Specified by:

startedStorageTransaction in interface OStorageTransaction

Specified by:

startedStorageTransaction in interface OTransactionInternal

setMetadataHolder

public void setMetadataHolder(Optional<OTxMetadataHolder> metadata)

Specified by:

setMetadataHolder in interface OTransactionInternal

prepareSerializedOperations

public void prepareSerializedOperations()
                                 throws IOException

Specified by:

prepareSerializedOperations in interface OTransactionInternal

Throws:

IOException

getSerializedOperations

public Iterator<byte[]> getSerializedOperations()

Specified by:

getSerializedOperations in interface OStorageTransaction

Specified by:

getSerializedOperations in interface OTransactionInternal

resetAllocatedIds

public void resetAllocatedIds()

Specified by:

resetAllocatedIds in interface OTransactionInternal

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 OTransactionAbstract

updateCache

public void updateCache(boolean keepInCache)

Specified by:

updateCache in interface OStorageTransaction

getChangesForIndex

public SortedMap<String,OStorageTransactionIndexChanges> getChangesForIndex()

Specified by:

getChangesForIndex in interface OStorageTransaction

getRecordChanges

public Collection<OStorageRecordOperation> getRecordChanges()

Specified by:

getRecordChanges in interface OAllocationTransaction

Specified by:

getRecordChanges in interface OStorageTransaction