org.resoa.persistence.btree

Class BTreeTransition

java.lang.Object

org.resoa.persistence.btree.BTreeTransition

All Implemented Interfaces:

DatabaseTransition

public class BTreeTransition
extends java.lang.Object
implements DatabaseTransition

Constructor Summary

Constructors

Constructor and Description
BTreeTransition() Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	backup(PersistentDomain domain) Backup a persistent domain
void	closePersistenceDomain(java.lang.String domain) Stop persistence service for a domain
void	deleteRecord(TransactionContext context, PersistentType<?> peristentType, java.lang.String taskID, Instruction instruction) Execute an instruction delete
boolean	exists(TransactionContext context, PersistentType<?> persistentType, java.lang.Object key) Checks, if an object exists
org.resoa.json.JSONObject	finalizeRelations(TransactionContext context, PersistentType<?> persistentType, org.resoa.json.JSONObject json) Finalize persistent relations
java.lang.Object	getDatabase()
<T> T	getInstance(TransactionContext context, PersistentType<T> persistentType, java.lang.Object key) read with strict type binding
java.lang.String	getJSONFromDB(TransactionContext context, PersistentType<?> persistentType, java.lang.Object key) Provide an unprocessed JSON string
BTreeStorage	getStorage()
void	init(PersistentDomain domain) Initialize the database
void	newPersistenceType(PersistentType<?> persistentType) Activate persistence for a new type
org.resoa.grid.RecordSet	readRecords(TransactionContext context, PersistentType<?> peristentType, org.resoa.grid.RecordSet result, boolean keysOnly) Read a set of records from database
void	setStorage(BTreeStorage storage)
TransactionContext	startTransaction(java.lang.String domain, TransactionContext.TransactionType type) Start a transaction for a persistent service domain
void	stop() Clear all locks
void	storeRecord(TransactionContext context, PersistentType<?> peristentType, java.lang.String taskID, Instruction instruction) Store a single instruction

Methods inherited from class java.lang.Object

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

Constructor Detail

BTreeTransition

public BTreeTransition()

Constructor

Method Detail

setStorage

public void setStorage(BTreeStorage storage)

Parameters:

storage - the storage to set

getStorage

public BTreeStorage getStorage()

Returns:

the storage

init

public void init(PersistentDomain domain)
          throws org.resoa.exception.PersistenceException

Description copied from interface: DatabaseTransition

Initialize the database

Specified by:

init in interface DatabaseTransition

Throws:

org.resoa.exception.PersistenceException

newPersistenceType

public void newPersistenceType(PersistentType<?> persistentType)
                        throws org.resoa.exception.PersistenceException

Description copied from interface: DatabaseTransition

Activate persistence for a new type

Specified by:

newPersistenceType in interface DatabaseTransition

Throws:

org.resoa.exception.PersistenceException

closePersistenceDomain

public void closePersistenceDomain(java.lang.String domain)

Description copied from interface: DatabaseTransition

Stop persistence service for a domain

Specified by:

closePersistenceDomain in interface DatabaseTransition

stop

public void stop()

Clear all locks

Specified by:

stop in interface DatabaseTransition

startTransaction

public TransactionContext startTransaction(java.lang.String domain,
                                  TransactionContext.TransactionType type)
                                    throws org.resoa.exception.PersistenceException

Description copied from interface: DatabaseTransition

Start a transaction for a persistent service domain

Specified by:

startTransaction in interface DatabaseTransition

Throws:

org.resoa.exception.PersistenceException

getJSONFromDB

public java.lang.String getJSONFromDB(TransactionContext context,
                             PersistentType<?> persistentType,
                             java.lang.Object key)

Provide an unprocessed JSON string

Specified by:

getJSONFromDB in interface DatabaseTransition

Parameters:

persistentType - the PersistentType descriptor

key - the key

Returns:

the JSON string as available in Storage

getInstance

public <T> T getInstance(TransactionContext context,
                PersistentType<T> persistentType,
                java.lang.Object key)

read with strict type binding

Specified by:

getInstance in interface DatabaseTransition

Parameters:

persistentType - the PersistentDescriptor

key - the key

Returns:

the ummarshalled object instance or null, if key not found

exists

public boolean exists(TransactionContext context,
             PersistentType<?> persistentType,
             java.lang.Object key)

Checks, if an object exists

Specified by:

exists in interface DatabaseTransition

Parameters:

persistentType - the PersistentDescriptor

key - the key

Returns:

true, if the object exists

Throws:

LockException

storeRecord

public void storeRecord(TransactionContext context,
               PersistentType<?> peristentType,
               java.lang.String taskID,
               Instruction instruction)
                 throws org.resoa.exception.PersistenceException

Description copied from interface: DatabaseTransition

Store a single instruction

Specified by:

storeRecord in interface DatabaseTransition

Throws:

org.resoa.exception.PersistenceException

deleteRecord

public void deleteRecord(TransactionContext context,
                PersistentType<?> peristentType,
                java.lang.String taskID,
                Instruction instruction)
                  throws org.resoa.exception.PersistenceException

Description copied from interface: DatabaseTransition

Execute an instruction delete

Specified by:

deleteRecord in interface DatabaseTransition

Throws:

org.resoa.exception.PersistenceException

readRecords

public org.resoa.grid.RecordSet readRecords(TransactionContext context,
                                   PersistentType<?> peristentType,
                                   org.resoa.grid.RecordSet result,
                                   boolean keysOnly)

Description copied from interface: DatabaseTransition

Read a set of records from database

Specified by:

readRecords in interface DatabaseTransition

finalizeRelations

public org.resoa.json.JSONObject finalizeRelations(TransactionContext context,
                                          PersistentType<?> persistentType,
                                          org.resoa.json.JSONObject json)

Description copied from interface: DatabaseTransition

Finalize persistent relations

Specified by:

finalizeRelations in interface DatabaseTransition

getDatabase

public java.lang.Object getDatabase()

Specified by:

getDatabase in interface DatabaseTransition

Returns:

the underlying database. Within SQLTransition it is the SQL DatabaseManager, within BTREE the Storage implementation instance

backup

public void backup(PersistentDomain domain)
            throws org.resoa.exception.PersistenceException

Description copied from interface: DatabaseTransition

Backup a persistent domain

Specified by:

backup in interface DatabaseTransition

Throws:

org.resoa.exception.PersistenceException