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 and Description
ODDLContextImpl(String query, OTransactionId preChangeId, OTransactionId afterChangeId, ODistributedRequestId requestId)

Method Summary

Modifier and Type	Method and Description
void	begin(ODatabaseDocumentInternal distributed, boolean local)
Set<ORecordId>	cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit(ODatabaseDocumentInternal database)
void	destroy()
OTransactionId	getAfterChangeId()
OTransactionId	getPreChangeId()
String	getQuery()
ODistributedRequestId	getReqId()
long	getStartedOn()
TxContextStatus	getStatus()
OTransactionInternal	getTransaction()
OTransactionId	getTransactionId()
void	lock(ORID rid)
void	lock(ORID rid, long timeout)
void	lockIndexKey(Object rid)
Set<ORecordId>	rollback(ODatabaseDocumentInternal database)
void	setStatus(TxContextStatus status)
void	unlock()

Methods inherited from class java.lang.Object

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

Constructor Detail

ODDLContextImpl

public ODDLContextImpl(String query,
                       OTransactionId preChangeId,
                       OTransactionId afterChangeId,
                       ODistributedRequestId requestId)

Method Detail

lock

public void lock(ORID rid)

Specified by:

lock in interface ODistributedTxContext

lock

public void lock(ORID rid,
                 long timeout)

Specified by:

lock in interface ODistributedTxContext

lockIndexKey

public void lockIndexKey(Object rid)

Specified by:

lockIndexKey in interface ODistributedTxContext

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

unlock

public void unlock()

Specified by:

unlock 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()

getQuery

public String getQuery()