net.cnri.apps.doserver

Class AbstractStorage

java.lang.Object

net.cnri.apps.doserver.AbstractStorage

All Implemented Interfaces:

Storage

Direct Known Subclasses:

HashDirectoryStorage

public abstract class AbstractStorage
extends java.lang.Object
implements Storage

This abstract class implements the enhanced logging functions for Storage (without enhancements!) in order to ease making old implementations compatible.

Constructor Summary

Constructors

Constructor and Description
AbstractStorage()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	createObject(java.lang.String objectID, java.lang.String objectName, HeaderSet txnMetadata, long timestamp) Version with enhanced logging (stores txnMetadata in transaction)
void	deleteAttributes(java.lang.String objectID, java.lang.String elementID, java.lang.String[] attributeKeys, HeaderSet txnMetadata, long timestamp) Version with enhanced logging (stores txnMetadata in transaction)
boolean	deleteDataElement(java.lang.String objectID, java.lang.String elementID, HeaderSet txnMetadata, long timestamp) Version with enhanced logging (stores txnMetadata in transaction)
void	deleteObject(java.lang.String objectID, HeaderSet txnMetadata, long asOfTimestamp) Version with enhanced logging (stores txnMetadata in transaction)
AbstractTransactionQueue	getTransactionQueue() Returns the transaction queue set up by this storage
void	initTransactionQueue(java.io.File txnDir) Initialize the transaction queue in the given directory---server calls this after initializing storage
static boolean	isConcatenatedQueueNeeded(java.io.File txnDir)
void	setAttributes(java.lang.String objectID, java.lang.String elementID, HeaderSet attributes, HeaderSet txnMetadata, long timestamp) Version with enhanced logging (stores txnMetadata in transaction)
void	setTransactionQueue(AbstractTransactionQueue txnQueue) Set the transaction queue (used e.g.
void	storeDataElement(java.lang.String objectID, java.lang.String elementID, java.io.InputStream input, HeaderSet txnMetadata, boolean append, long timestamp) Version with enhanced logging (stores txnMetadata in transaction)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.cnri.apps.doserver.Storage

close, createObject, createObject, deleteAttributes, deleteDataElement, deleteDataElement, deleteObject, deleteObject, deserializeObject, doesDataElementExist, doesObjectExist, getAttributes, getDataElement, getFileForDataElement, getObjectInfo, initWithDirectory, listDataElements, listObjects, serializeObject, setAttributes, setObjectInfo, storeDataElement, storeDataElement

Constructor Detail

AbstractStorage

public AbstractStorage()

Method Detail

initTransactionQueue

public void initTransactionQueue(java.io.File txnDir)
                          throws java.lang.Exception

Description copied from interface: Storage

Initialize the transaction queue in the given directory---server calls this after initializing storage

Specified by:

initTransactionQueue in interface Storage

Throws:

java.lang.Exception

isConcatenatedQueueNeeded

public static boolean isConcatenatedQueueNeeded(java.io.File txnDir)

getTransactionQueue

public AbstractTransactionQueue getTransactionQueue()

Description copied from interface: Storage

Returns the transaction queue set up by this storage

Specified by:

getTransactionQueue in interface Storage

setTransactionQueue

public void setTransactionQueue(AbstractTransactionQueue txnQueue)

Description copied from interface: Storage

Set the transaction queue (used e.g. by Multi-Storage to arrange for a unique queue)

Specified by:

setTransactionQueue in interface Storage

createObject

public java.lang.String createObject(java.lang.String objectID,
                            java.lang.String objectName,
                            HeaderSet txnMetadata,
                            long timestamp)
                              throws DOException

Description copied from interface: Storage

Version with enhanced logging (stores txnMetadata in transaction)

Specified by:

createObject in interface Storage

Throws:

DOException

deleteObject

public void deleteObject(java.lang.String objectID,
                HeaderSet txnMetadata,
                long asOfTimestamp)
                  throws DOException

Description copied from interface: Storage

Version with enhanced logging (stores txnMetadata in transaction)

Specified by:

deleteObject in interface Storage

Throws:

DOException

storeDataElement

public void storeDataElement(java.lang.String objectID,
                    java.lang.String elementID,
                    java.io.InputStream input,
                    HeaderSet txnMetadata,
                    boolean append,
                    long timestamp)
                      throws DOException

Description copied from interface: Storage

Version with enhanced logging (stores txnMetadata in transaction)

Specified by:

storeDataElement in interface Storage

Throws:

DOException

deleteDataElement

public boolean deleteDataElement(java.lang.String objectID,
                        java.lang.String elementID,
                        HeaderSet txnMetadata,
                        long timestamp)
                          throws DOException

Description copied from interface: Storage

Version with enhanced logging (stores txnMetadata in transaction)

Specified by:

deleteDataElement in interface Storage

Throws:

DOException

setAttributes

public void setAttributes(java.lang.String objectID,
                 java.lang.String elementID,
                 HeaderSet attributes,
                 HeaderSet txnMetadata,
                 long timestamp)
                   throws DOException

Description copied from interface: Storage

Version with enhanced logging (stores txnMetadata in transaction)

Specified by:

setAttributes in interface Storage

Throws:

DOException

deleteAttributes

public void deleteAttributes(java.lang.String objectID,
                    java.lang.String elementID,
                    java.lang.String[] attributeKeys,
                    HeaderSet txnMetadata,
                    long timestamp)
                      throws DOException

Description copied from interface: Storage

Version with enhanced logging (stores txnMetadata in transaction)

Specified by:

deleteAttributes in interface Storage

Throws:

DOException