com.orientechnologies.orient.core.tx

Class OTransactionRealAbstract

java.lang.Object

com.orientechnologies.orient.core.tx.OTransactionAbstract

com.orientechnologies.orient.core.tx.OTransactionRealAbstract

All Implemented Interfaces:

OTransaction

Direct Known Subclasses:

OTransactionOptimistic

public abstract class OTransactionRealAbstract
extends OTransactionAbstract

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OTransactionRealAbstract.OTransactionRecordIndexOperation Represents information for each index operation for each record in DB.

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 and Description
protected Map<ORID,ORecordOperation>	allEntries
protected Set<ODocument>	changedDocuments 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.
static ORecord	DELETED_RECORD USE THIS AS RESPONSE TO REPORT A DELETED RECORD IN TX
protected int	id
protected Map<String,OTransactionIndexChanges>	indexEntries
protected int	newObjectCounter
protected Map<ORID,List<OTransactionRealAbstract.OTransactionRecordIndexOperation>>	recordIndexOperations
protected Map<ORID,ORID>	updatedRids
protected Map<String,Object>	userData

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

database, isolationLevel, locks, status

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OTransactionRealAbstract(ODatabaseDocumentTx database, int id)

Method Summary

Modifier and Type	Method and Description
void	addChangedDocument(ODocument document)
void	addIndexEntry(OIndex<?> delegate, String iIndexName, OTransactionIndexChanges.OPERATION iOperation, Object key, OIdentifiable iValue)
void	addIndexEntry(OIndex<?> delegate, String iIndexName, OTransactionIndexChanges.OPERATION iOperation, Object key, OIdentifiable iValue, boolean clientTrackOnly) Bufferizes index changes to be flushed at commit time.
protected void	checkTransaction()
void	clearIndexEntries()
void	clearRecordEntries()
void	close() Closes the transaction and releases all the acquired locks.
Collection<ORecordOperation>	getAllRecordEntries()
Collection<ORecordOperation>	getCurrentRecordEntries()
Object	getCustomData(String iName)
int	getEntryCount()
int	getId()
ODocument	getIndexChanges()
OTransactionIndexChanges	getIndexChanges(String iIndexName) Bufferizes index changes to be flushed at commit time.
Map<String,OTransactionIndexChanges>	getIndexEntries()
List<String>	getInvolvedIndexes()
List<ORecordOperation>	getNewRecordEntriesByClass(OClass iClass, boolean iPolymorphic) Called by class iterator.
List<ORecordOperation>	getNewRecordEntriesByClusterIds(int[] iIds) Called by cluster iterator.
ORecord	getRecord(ORID rid)
ORecordOperation	getRecordEntry(ORID rid)
boolean	hasRecordCreation()
void	restore()
protected ODocument	serializeIndexChangeEntry(OTransactionIndexChangesPerKey entry, ODocument indexDoc)
void	setCustomData(String iName, Object iValue)
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

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, toString, wait, wait, wait

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

amountOfNestedTxs, begin, commit, commit, deleteRecord, isUsingLog, loadRecord, loadRecord, loadRecord, loadRecordIfVersionIsNotLatest, recycleRecord, reloadRecord, reloadRecord, rollback, rollback, saveRecord, setUsingLog

Field Detail

DELETED_RECORD

public static final ORecord DELETED_RECORD

USE THIS AS RESPONSE TO REPORT A DELETED RECORD IN TX

updatedRids

protected Map<ORID,ORID> updatedRids

allEntries

protected Map<ORID,ORecordOperation> allEntries

indexEntries

protected Map<String,OTransactionIndexChanges> indexEntries

recordIndexOperations

protected Map<ORID,List<OTransactionRealAbstract.OTransactionRecordIndexOperation>> recordIndexOperations

id

protected int id

newObjectCounter

protected int newObjectCounter

userData

protected Map<String,Object> userData

changedDocuments

protected final Set<ODocument> changedDocuments

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.

Constructor Detail

OTransactionRealAbstract

protected OTransactionRealAbstract(ODatabaseDocumentTx database,
                                   int id)

Method Detail

hasRecordCreation

public boolean hasRecordCreation()

addChangedDocument

public void addChangedDocument(ODocument document)

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

getId

public int getId()

clearRecordEntries

public void clearRecordEntries()

restore

public void restore()

getEntryCount

public int getEntryCount()

getCurrentRecordEntries

public Collection<ORecordOperation> getCurrentRecordEntries()

getAllRecordEntries

public Collection<ORecordOperation> getAllRecordEntries()

getRecordEntry

public ORecordOperation getRecordEntry(ORID rid)

getRecord

public ORecord getRecord(ORID rid)

getNewRecordEntriesByClass

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

Called by class iterator.

getNewRecordEntriesByClusterIds

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

Called by cluster iterator.

clearIndexEntries

public void clearIndexEntries()

getInvolvedIndexes

public List<String> getInvolvedIndexes()

getIndexChanges

public ODocument getIndexChanges()

getIndexEntries

public Map<String,OTransactionIndexChanges> getIndexEntries()

getIndexChanges

public OTransactionIndexChanges getIndexChanges(String iIndexName)

Bufferizes index changes to be flushed at commit time.

Returns:

addIndexEntry

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

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

checkTransaction

protected void checkTransaction()

serializeIndexChangeEntry

protected ODocument serializeIndexChangeEntry(OTransactionIndexChangesPerKey entry,
                                              ODocument indexDoc)

setCustomData

public void setCustomData(String iName,
                          Object iValue)

getCustomData

public Object getCustomData(String iName)