org.treetank.access

Class BucketWriteTrx

java.lang.Object

org.treetank.access.BucketWriteTrx

All Implemented Interfaces:

IBucketReadTrx, IBucketWriteTrx

public final class BucketWriteTrx
extends Object
implements IBucketWriteTrx

BucketWriteTrx

See BucketReadTrx.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BucketWriteTrx(ISession pSession, UberBucket pUberBucket, IBackendWriter pWriter, long pRepresentRev) Standard constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	clearLog()
boolean	close() Close the transaction.
void	commit() Simple commit of this bucket transaction to store the newest version.
void	commitBlocked() Simple commit blocked of this bucket transaction to store the newest version.
IData	getData(long pDataKey) Getting the data related to a key.
MetaBucket	getMetaBucket() Getting the map with the entire mapping for retrieving meta-information related to the bundle.
long	getRevision() Getting the revision number of this transaction
long	incrementDataKey() Getting most recent data key and incrementing it.
boolean	isClosed() Check if transaction is closed.
void	removeData(IData pData) Removing the data from the storage.
long	setData(IData pData) Setting a data and storing the data in the bucket-layer.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketWriteTrx

protected BucketWriteTrx(ISession pSession,
              UberBucket pUberBucket,
              IBackendWriter pWriter,
              long pRepresentRev)
                  throws TTException

Standard constructor.

Parameters:

pSession - ISession reference

pUberBucket - root of resource

pWriter - writer where this transaction should write to

pRepresentRev - revision represent

Throws:

TTIOException - if IO Error

TTException

Method Detail

setData

public long setData(IData pData)
             throws TTException

Setting a data and storing the data in the bucket-layer.

Specified by:

setData in interface IBucketWriteTrx

Parameters:

pData - the data to be stored.

Throws:

TTException - if anything weird happens.

removeData

public void removeData(IData pData)
                throws TTException

Removing the data from the storage.

Specified by:

removeData in interface IBucketWriteTrx

Parameters:

pData - to be removed

Throws:

TTException

getData

public IData getData(long pDataKey)
              throws TTIOException

Getting the data related to a key.

Specified by:

getData in interface IBucketReadTrx

Parameters:

pDataKey - the key of the data

Returns:

a suitable IData

Throws:

TTIOException

commit

public void commit()
            throws TTException

Simple commit of this bucket transaction to store the newest version.

Specified by:

commit in interface IBucketWriteTrx

Throws:

TTException

commitBlocked

public void commitBlocked()
                   throws TTException

Simple commit blocked of this bucket transaction to store the newest version.

Specified by:

commitBlocked in interface IBucketWriteTrx

Throws:

TTException

clearLog

public void clearLog()
              throws TTIOException

Throws:

TTIOException

close

public boolean close()
              throws TTIOException

Close the transaction.

Specified by:

close in interface IBucketReadTrx

Returns:

true if successful, false otherwise

Throws:

TTIOException - if anything weird happens

incrementDataKey

public long incrementDataKey()

Getting most recent data key and incrementing it.

Specified by:

incrementDataKey in interface IBucketWriteTrx

Returns:

the most recent data key.

getRevision

public long getRevision()
                 throws TTIOException

Getting the revision number of this transaction

Specified by:

getRevision in interface IBucketReadTrx

Returns:

the revision number of this transaction

Throws:

TTIOException - if deserialization fails.

isClosed

public boolean isClosed()

Check if transaction is closed.

Specified by:

isClosed in interface IBucketReadTrx

Returns:

true if closed, false otherwise

getMetaBucket

public MetaBucket getMetaBucket()

Getting the map with the entire mapping for retrieving meta-information related to the bundle.

Specified by:

getMetaBucket in interface IBucketReadTrx

Returns:

the meta bucket

toString

public String toString()

Overrides:

toString in class Object