Package com.orientechnologies.orient.server.distributed.impl

Class ODDLContextImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODDLContextImpl

All Implemented Interfaces:

ODistributedTxContext

public class ODDLContextImpl
extends Object
implements ODistributedTxContext

Constructor Summary

Constructors

Constructor	Description
ODDLContextImpl(ODistributedDatabase shared, String query, OTransactionIdPromise preChangeId, OTransactionIdPromise afterChangeId, ODistributedRequestId requestId)

Method Summary

Modifier and Type	Method	Description
OTransactionId	acquireIndexKeyPromise(Object key, int version, boolean force)
OTransactionId	acquirePromise(ORID rid, int version, boolean force)
void	begin(ODatabaseDocumentInternal distributed, boolean local)
Set<ORecordId>	cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit(ODatabaseDocumentInternal database)
void	destroy()
OTransactionId	getAfterChangeId()
OTransactionIdPromise	getAfterChangePromise()
OTransactionId	getPreChangeId()
OTransactionIdPromise	getPreChangePromise()
String	getQuery()
ODistributedRequestId	getReqId()
long	getStartedOn()
TxContextStatus	getStatus()
OTransactionInternal	getTransaction()
OTransactionId	getTransactionId()
void	releasePromises()
Set<ORecordId>	rollback(ODatabaseDocumentInternal database)
void	setStatus(TxContextStatus status)

Methods inherited from class java.lang.Object

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

Constructor Details

ODDLContextImpl

public ODDLContextImpl(ODistributedDatabase shared,
 String query,
 OTransactionIdPromise preChangeId,
 OTransactionIdPromise afterChangeId,
 ODistributedRequestId requestId)

Method Details

getReqId

public ODistributedRequestId getReqId()

Specified by:

getReqId in interface ODistributedTxContext

commit

public void commit(ODatabaseDocumentInternal database)

Specified by:

commit in interface ODistributedTxContext

rollback

public Set<ORecordId> rollback(ODatabaseDocumentInternal database)

Specified by:

rollback in interface ODistributedTxContext

destroy

public void destroy()

Specified by:

destroy in interface ODistributedTxContext

clearUndo

public void clearUndo()

Specified by:

clearUndo in interface ODistributedTxContext

getStartedOn

public long getStartedOn()

Specified by:

getStartedOn in interface ODistributedTxContext

cancel

public Set<ORecordId> cancel(ODistributedServerManager current,
 ODatabaseDocumentInternal database)

Specified by:

cancel in interface ODistributedTxContext

getTransaction

public OTransactionInternal getTransaction()

Specified by:

getTransaction in interface ODistributedTxContext

getTransactionId

public OTransactionId getTransactionId()

Specified by:

getTransactionId in interface ODistributedTxContext

begin

public void begin(ODatabaseDocumentInternal distributed,
 boolean local)

Specified by:

begin in interface ODistributedTxContext

setStatus

public void setStatus(TxContextStatus status)

getStatus

public TxContextStatus getStatus()

getPreChangeId

public OTransactionId getPreChangeId()

getAfterChangeId

public OTransactionId getAfterChangeId()

getPreChangePromise

public OTransactionIdPromise getPreChangePromise()

getAfterChangePromise

public OTransactionIdPromise getAfterChangePromise()

getQuery

public String getQuery()

acquirePromise

public OTransactionId acquirePromise(ORID rid,
 int version,
 boolean force)

Specified by:

acquirePromise in interface ODistributedTxContext

acquireIndexKeyPromise

public OTransactionId acquireIndexKeyPromise(Object key,
 int version,
 boolean force)

Specified by:

acquireIndexKeyPromise in interface ODistributedTxContext

releasePromises

public void releasePromises()

Specified by:

releasePromises in interface ODistributedTxContext