org.resoa.persistence.btree

Class BerkeleyStorage

java.lang.Object

org.resoa.persistence.btree.BerkeleyStorage

All Implemented Interfaces:

BTreeStorage

public class BerkeleyStorage
extends java.lang.Object
implements BTreeStorage

The Oracle Berkeley DB Java Edition Storage interface implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BerkeleyStorage.BerkeleyTransaction Berkeley TransactionContext implementation

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BACKUPDIR The directory of the storage execution log
static int	INTERNALCACHE_PERCENT The percentage of memory cache, Berkeley should use internally.

Constructor Summary

Constructors

Constructor and Description
BerkeleyStorage() Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Called by kernel on shut down
void	closeStorage(java.lang.String domain) Close a storage
void	createHotBackup(java.lang.String domain) Copy the domain database to a mirrored location and clear up the Execution log
void	deleteDatabase(java.lang.String domain, java.lang.String entity) Delete a complete entity table
void	deleteRecord(TransactionContext context, java.lang.String taskID, java.lang.String domain, java.lang.String entity, java.lang.Object key) Dedicated deletion of an object
boolean	exists(java.lang.String domain, java.lang.String entity, java.lang.Object key) Check if a record exists in Storage
org.resoa.util.SymCipher	getAes() The internal symmetric cipher, used for TaskLog encryption
com.sleepycat.je.Database	getDatabase(java.lang.String domain, java.lang.String entity) get a direct handle to a database
static com.sleepycat.je.DatabaseConfig	getDBConfig() Returns a DB configuration handle
static com.sleepycat.je.EnvironmentConfig	getEnvConfig() Returns an environment handle
<T> void	openOrCreateStorage(PersistentType<T> persistentType, java.lang.String storagePath) Create a new Storage for a persistent type
void	openOrCreateStorage(java.lang.String domain, java.lang.String entity, java.lang.String storagePath, org.resoa.util.SymCipher aes, boolean isCompressed) Creates a storage
java.lang.String	readRecord(java.lang.String domain, java.lang.String entity, java.lang.Object key) Read Data from storage
org.resoa.grid.RecordSet	readRecords(java.lang.String domain, java.lang.String entity, org.resoa.grid.RecordSet rules, SqlSelectExpression sqlExpression, boolean keysOnly) Read key data from storage
TransactionContext	startTransaction(java.lang.String domain, TransactionContext.TransactionType type) Start a transaction for a persistent service domain
void	storeRecord(TransactionContext context, java.lang.String taskID, java.lang.String domain, java.lang.String entity, java.lang.Object key, byte[] valueBytes) Dedicated store of an object

Methods inherited from class java.lang.Object

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

Field Detail

INTERNALCACHE_PERCENT

public static int INTERNALCACHE_PERCENT

The percentage of memory cache, Berkeley should use internally. by default it is 1%, as EHCache is used.

BACKUPDIR

public static java.lang.String BACKUPDIR

The directory of the storage execution log

Constructor Detail

BerkeleyStorage

public BerkeleyStorage()

Constructor

Method Detail

getEnvConfig

public static com.sleepycat.je.EnvironmentConfig getEnvConfig()

Returns an environment handle

Returns:

the Environment configuration

getDBConfig

public static com.sleepycat.je.DatabaseConfig getDBConfig()

Returns a DB configuration handle

Returns:

the Database Configuration

getAes

public org.resoa.util.SymCipher getAes()

Description copied from interface: BTreeStorage

The internal symmetric cipher, used for TaskLog encryption

Specified by:

getAes in interface BTreeStorage

openOrCreateStorage

public void openOrCreateStorage(java.lang.String domain,
                       java.lang.String entity,
                       java.lang.String storagePath,
                       org.resoa.util.SymCipher aes,
                       boolean isCompressed)
                         throws StorageException

Creates a storage

Specified by:

openOrCreateStorage in interface BTreeStorage

Parameters:

domain -

entity -

storagePath -

aes -

isCompressed -

Throws:

StorageException

openOrCreateStorage

public <T> void openOrCreateStorage(PersistentType<T> persistentType,
                           java.lang.String storagePath)
                         throws StorageException

Description copied from interface: BTreeStorage

Create a new Storage for a persistent type

Specified by:

openOrCreateStorage in interface BTreeStorage

Parameters:

persistentType - the PersistentType descriptor

storagePath - the path to the storage

Throws:

StorageException

getDatabase

public com.sleepycat.je.Database getDatabase(java.lang.String domain,
                                    java.lang.String entity)

get a direct handle to a database

Parameters:

domain -

entity -

Returns:

the Database handle

createHotBackup

public void createHotBackup(java.lang.String domain)
                     throws StorageException

Description copied from interface: BTreeStorage

Copy the domain database to a mirrored location and clear up the Execution log

Specified by:

createHotBackup in interface BTreeStorage

Parameters:

domain - the domain

Throws:

StorageException

closeStorage

public void closeStorage(java.lang.String domain)

Description copied from interface: BTreeStorage

Close a storage

Specified by:

closeStorage in interface BTreeStorage

Parameters:

domain - the domain to close

close

public void close()

Description copied from interface: BTreeStorage

Called by kernel on shut down

Specified by:

close in interface BTreeStorage

readRecords

public org.resoa.grid.RecordSet readRecords(java.lang.String domain,
                                   java.lang.String entity,
                                   org.resoa.grid.RecordSet rules,
                                   SqlSelectExpression sqlExpression,
                                   boolean keysOnly)

Description copied from interface: BTreeStorage

Read key data from storage

Specified by:

readRecords in interface BTreeStorage

Parameters:

domain - the domain

entity - the internal id

rules - a result set with additional restrictions (indices, max records)

sqlExpression - the sqlExpression handle

keysOnly - if true, only keys will be read

Returns:

A RecordSet handle

readRecord

public java.lang.String readRecord(java.lang.String domain,
                          java.lang.String entity,
                          java.lang.Object key)

Description copied from interface: BTreeStorage

Read Data from storage

Specified by:

readRecord in interface BTreeStorage

Parameters:

domain - the domain

entity - the internal id

key - the key

Returns:

Value String or null, in case object does not exists

exists

public boolean exists(java.lang.String domain,
             java.lang.String entity,
             java.lang.Object key)

Description copied from interface: BTreeStorage

Check if a record exists in Storage

Specified by:

exists in interface BTreeStorage

Parameters:

domain - the domain

entity - the internal id

key - the key

Returns:

true if the record exists

storeRecord

public void storeRecord(TransactionContext context,
               java.lang.String taskID,
               java.lang.String domain,
               java.lang.String entity,
               java.lang.Object key,
               byte[] valueBytes)
                 throws StorageException

Description copied from interface: BTreeStorage

Dedicated store of an object

Specified by:

storeRecord in interface BTreeStorage

taskID - the taskID

domain - the domain

entity - the internal id

key - the key

valueBytes - the value to store

Throws:

StorageException

deleteRecord

public void deleteRecord(TransactionContext context,
                java.lang.String taskID,
                java.lang.String domain,
                java.lang.String entity,
                java.lang.Object key)
                  throws StorageException

Description copied from interface: BTreeStorage

Dedicated deletion of an object

Specified by:

deleteRecord in interface BTreeStorage

taskID - the taskID

domain - the domain

entity - the internal id

key - the key

Throws:

StorageException

deleteDatabase

public void deleteDatabase(java.lang.String domain,
                  java.lang.String entity)
                    throws StorageException

Description copied from interface: BTreeStorage

Delete a complete entity table

Specified by:

deleteDatabase in interface BTreeStorage

Throws:

StorageException

startTransaction

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

Description copied from interface: BTreeStorage

Start a transaction for a persistent service domain

Specified by:

startTransaction in interface BTreeStorage

Throws:

org.resoa.exception.PersistenceException