|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.ojb.odmg.TransactionImpl
Implementation of Transaction for org.odmg.Transaction.
Field Summary | |
protected PersistenceBroker |
broker
|
Fields inherited from interface org.odmg.Transaction |
READ, UPGRADE, WRITE |
Constructor Summary | |
TransactionImpl(DatabaseImpl theCurrentDB)
Creates new Transaction |
Method Summary | |
void |
abort()
Abort and close the transaction. |
void |
afterMaterialization(IndirectionHandler handler,
java.lang.Object materializedObject)
this callback is invoked after an Object is materialized within an IndirectionHandler. |
void |
beforeMaterialization(IndirectionHandler handler,
Identity oid)
this callback is invoked before an Object is materialized within an IndirectionHandler. |
void |
begin()
Start a transaction. |
void |
checkpoint()
Commit the transaction, but reopen the transaction, retaining all locks. |
void |
commit()
Commit and close the transaction. |
void |
configure(Configuration config)
configure an object using the Configuration pConfig |
protected void |
doAbort()
Do the Aborts, but don't release the locks. |
protected void |
doClose()
Close a transaction and do all the cleanup associated with it. |
void |
flush()
Calling flush flushes persistent object modifications
made within the ODMG transaction since the last checkpoint to the underlying
database transaction, but does commit the database transaction. |
DatabaseImpl |
getAssociatedDatabase()
Returns the associated database |
PersistenceBroker |
getBroker()
Gets the broker associated with the transaction. |
java.lang.String |
getGUID()
|
(package private) Identity |
getNrmEntry(java.lang.String name)
lookup an identity from the transactions temporary nrm table. |
java.lang.Object |
getObjectByIdentity(Identity id)
Get object by identity. |
protected int |
getStatus()
|
boolean |
isDeleted(Identity id)
Checks if the object with the given identity has been deleted within the transaction. |
boolean |
isOpen()
Determine whether the transaction is open or not. |
void |
join()
Attach the caller's thread to this Transaction and detach the
thread from any former Transaction the thread may have been
associated with. |
void |
leave()
Detach the caller's thread from this Transaction , but do not
attach the thread to another Transaction . |
void |
lock(java.lang.Object obj,
int lockMode)
Upgrade the lock on the given object to the given lock mode. |
void |
markDelete(java.lang.Object anObject)
marks an object for deletion without locking the object. |
void |
markDirty(java.lang.Object anObject)
marks an object as dirty without locking the object. |
protected boolean |
prepare()
Prepare does the actual work of moving the changes at the object level into storage (the underlying rdbms for instance). |
(package private) void |
putNrmEntry(java.lang.String key,
Identity value)
make a binding name/identity to the transactions temporary nrm table. |
protected void |
refresh()
cleanup tx and prepare for reuse |
protected void |
registerToIndirectionHandler(IndirectionHandler handler)
|
protected void |
registerUnmaterializedLocks(java.lang.Object obj)
register proxy objects that were locked but haven't been materialized yet so they can be unlocked when closing the transaction |
void |
setImplicitLocking(boolean value)
This method can be used to activate or deactivate the implicit locking mechanism for the current transaction. |
protected void |
setStatus(int status)
|
boolean |
tryLock(java.lang.Object obj,
int lockMode)
Upgrade the lock on the given object to the given lock mode. |
(package private) boolean |
unbindNrmEntry(java.lang.String key)
unbind an entry from the transactions temporary nrm table. |
protected void |
unRegisterFromAllIndirectionHandlers()
|
protected void |
unregisterFromIndirectionHandler(IndirectionHandler handler)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected PersistenceBroker broker
Constructor Detail |
public TransactionImpl(DatabaseImpl theCurrentDB)
theCurrentDB
- - create a transaction that is associated with the database.Method Detail |
public DatabaseImpl getAssociatedDatabase()
protected int getStatus()
protected void setStatus(int status)
public boolean isOpen()
begin
, but a subsequent call to
either commit
or abort
has not been made.
isOpen
in interface Transaction
public void join()
Transaction
and detach the
thread from any former Transaction
the thread may have been
associated with.
join
in interface Transaction
public void lock(java.lang.Object obj, int lockMode) throws LockNotGrantedException
lock
in interface Transaction
obj
- object to acquire a lock on.lockMode
- lock mode to acquire. The lock modes
are READ
, UPGRADE
, and WRITE
.
LockNotGrantedException
- Description of Exceptionpublic void leave()
Transaction
, but do not
attach the thread to another Transaction
.
leave
in interface Transaction
protected void doAbort()
protected void doClose()
protected void refresh()
public void checkpoint()
checkpoint
commits persistent object modifications
made within the transaction since the last checkpoint to the database. The
transaction retains all locks it held on those objects at the time the
checkpoint was invoked.
checkpoint
in interface Transaction
public void flush()
TransactionExt
Calling flush
flushes persistent object modifications
made within the ODMG transaction since the last checkpoint to the underlying
database transaction, but does commit the database transaction.
The ODMG transaction retains all locks it held on those objects at the time the flush
was invoked.
Transaction.checkpoint()
.
flush
in interface TransactionExt
TransactionExt.flush()
public void markDelete(java.lang.Object anObject)
TransactionExt
markDelete
in interface TransactionExt
anObject
- Object to be markedTransactionExt.markDelete(java.lang.Object)
public void markDirty(java.lang.Object anObject)
TransactionExt
markDirty
in interface TransactionExt
anObject
- Object to be markedTransactionExt.markDirty(java.lang.Object)
public boolean tryLock(java.lang.Object obj, int lockMode)
tryLock
is the same as lock
except it returns a boolean
indicating whether the lock was granted instead of generating an exception.
tryLock
in interface Transaction
obj
- Description of ParameterlockMode
- Description of Parameter
UPGRADE
, and WRITE
.public void commit()
commit
commits to
the database all persistent object modifications within the transaction and
releases any locks held by the transaction. A persistent object
modification is an update of any field of an existing persistent object, or
an update or creation of a new named object in the database. If a
persistent object modification results in a reference from an existing
persistent object to a transient object, the transient object is moved to
the database, and all references to it updated accordingly. Note that the
act of moving a transient object to the database may create still more
persistent references to transient objects, so its referents must be
examined and moved as well. This process continues until the database
contains no references to transient objects, a condition that is guaranteed
as part of transaction commit. Committing a transaction does not remove
from memory transient objects created during the transaction.
The updateObjectList contains a list of all objects for which this transaction
has write privledge to. We need to update these objects.
commit
in interface Transaction
protected boolean prepare() throws TransactionAbortedException, LockNotGrantedException
TransactionAbortedException
- if the transaction has been aborted
for any reason.
java.lang.IllegalStateException
- Method called if transaction is
not in the proper state to perform this operation
TransactionNotInProgressException
- if the transaction is closed.
LockNotGrantedException
public void abort()
abort
in interface Transaction
public void begin()
begin
multiple times on the same
transaction object, without an intervening call to commit
or
abort
, causes the exception
TransactionInProgressException
to be thrown on the second and
subsequent calls. Operations executed before a transaction has been opened,
or before reopening after a transaction is aborted or committed, have
undefined results; these may throw a
TransactionNotInProgressException
exception.
begin
in interface Transaction
public java.lang.String getGUID()
public java.lang.Object getObjectByIdentity(Identity id) throws PersistenceBrokerException
id
- The identity
PersistenceBrokerException
public boolean isDeleted(Identity id)
id
- The identity
PersistenceBrokerException
Identity getNrmEntry(java.lang.String name)
name
- - the name to lookup.
void putNrmEntry(java.lang.String key, Identity value)
key
- - the identifying namevalue
- the Identity to storeboolean unbindNrmEntry(java.lang.String key)
key
- - the identifying string whose entry is to be deleted.public void beforeMaterialization(IndirectionHandler handler, Identity oid)
beforeMaterialization
in interface MaterializationListener
handler
- the invoking handleroid
- the identity of the object to be materializedpublic void afterMaterialization(IndirectionHandler handler, java.lang.Object materializedObject)
afterMaterialization
in interface MaterializationListener
handler
- the invoking handlermaterializedObject
- the materialized Objectprotected void unRegisterFromAllIndirectionHandlers()
protected void unregisterFromIndirectionHandler(IndirectionHandler handler)
protected void registerToIndirectionHandler(IndirectionHandler handler)
protected void registerUnmaterializedLocks(java.lang.Object obj)
public PersistenceBroker getBroker()
getBroker
in interface HasBroker
TransactionNotInProgressException
- is the transaction is not open;public void configure(Configuration config) throws ConfigurationException
Configurable
configure
in interface Configurable
config
- the Configuration object used to configure current instance
ConfigurationException
public void setImplicitLocking(boolean value)
TransactionExt
setImplicitLocking
in interface TransactionExt
value
- if set to true implicit locking is enabled,
if false, implicit locking is disabled.TransactionExt.setImplicitLocking(boolean)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |