fedora.server.storage
Class DefaultDOManager

java.lang.Object
  fedora.server.Parameterized
      fedora.server.Pluggable
          fedora.server.Module
              fedora.server.storage.DefaultDOManager

All Implemented Interfaces:

Constants, DOManager, RepositoryReader

Direct Known Subclasses:

GSearchDOManager, RebuildDOManager

public class DefaultDOManager
extends Module
implements DOManager

Manages the reading and writing of digital objects by instantiating an appropriate object reader or writer. Also, manages the object ingest process and the object replication process.

Version:

$Id: DefaultDOManager.java 7652 2008-08-05 13:53:52Z bbranan $, $Id: DefaultDOManager.java 7652 2008-08-05 13:53:52Z bbranan $

Author:

cwilper@cs.cornell.edu

Nested Class Summary

Nested classes/interfaces inherited from interface fedora.common.Constants

Constants.FedoraHome

Field Summary

static java.lang.String	DEFAULT_STATE
protected java.sql.Connection	m_connection
protected ConnectionPool	m_connectionPool
protected ExternalContentManager	m_contentManager
protected FieldSearch	m_fieldSearch
protected Management	m_management
protected ILowlevelStorage	m_permanentStore
protected PIDGenerator	m_pidGenerator
protected DOReplicator	m_replicator
protected ResourceIndex	m_resourceIndex
protected java.util.HashSet	m_retainPIDs
protected java.lang.String	m_storagePool
protected DOTranslator	m_translator
protected DOValidator	m_validator

Fields inherited from interface fedora.common.Constants

ACTION, BDEF, BMECH, DATASTREAM, DC, DISSEMINATOR, ENVIRONMENT, FEDORA, FEDORA_HOME, FEDORA_SYSTEM_DEF_PID, FEDORA_SYSTEM_DEF_URI, HTTP_REQUEST, MODEL, OBJECT, RDF, RECOVERY, RELS_EXT, RESOURCE, SUBJECT, TUCANA, VIEW, XSD

Constructor Summary

DefaultDOManager(java.util.Map moduleParameters, Server server, java.lang.String role)
Creates a new DefaultDOManager.

Method Summary

void	doCommit(boolean cachedObjectRequired, Context context, DigitalObject obj, java.lang.String logMessage, boolean remove) The doCommit method finalizes an ingest/update/remove of a digital object.
FieldSearchResult	findObjects(Context context, java.lang.String[] resultFields, int maxResults, FieldSearchQuery query)
BDefReader	getBDefReader(boolean cachedObjectRequired, Context context, java.lang.String pid) Gets a reader on an an existing behavior definition object.
BMechReader	getBMechReader(boolean cachedObjectRequired, Context context, java.lang.String pid) Gets a reader on an an existing behavior mechanism object.
ConnectionPool	getConnectionPool()
java.lang.String	getDefaultExportFormat()
DOValidator	getDOValidator()
DOWriter	getIngestWriter(boolean cachedObjectRequired, Context context, java.io.InputStream in, java.lang.String format, java.lang.String encoding, boolean newPid) Manages the INGEST process which includes validation of the ingest XML file, deserialization of the XML into a Digital Object instance, setting of properties on the object by the system (dates and states), PID validation or generation, object registry functions, getting a writer for the digital object, and ultimately writing the object to persistent storage via the writer.
java.lang.String[]	getNextPID(int numPIDs, java.lang.String namespace) Gets a list of the requested next available PIDs.
java.lang.String	getOwnerId(java.lang.String pid)
DOReader	getReader(boolean cachedObjectRequired, Context context, java.lang.String pid) Gets a reader on an an existing digital object.
DOReplicator	getReplicator()
java.lang.String	getRepositoryHash() Get a "hash" of the repository.
java.lang.String[]	getRequiredModuleRoles() Gets the names of the roles that are required by this Pluggable.
java.lang.String	getStorageCharacterEncoding()
java.lang.String	getStorageFormat()
DOTranslator	getTranslator()
DOWriter	getWriter(boolean cachedObjectRequired, Context context, java.lang.String pid) Gets a writer on an an existing object.
void	initModule() Gets initial param values.
protected void	initRetainPID()
java.lang.String[]	listObjectPIDs(Context context) Gets a list of PIDs (accessible in the given context) of all objects in the repository.
boolean	objectExists(java.lang.String pid) Checks the object registry for the given object.
void	postInitModule() Second stage of Module initialization.
void	releaseWriter(DOWriter writer) Relinquishes control of a DOWriter back to the DOManager.
void	reservePIDs(java.lang.String[] pidList) Reserve a series of PIDs so that they are never used for subsequent PID generations.
FieldSearchResult	resumeFindObjects(Context context, java.lang.String sessionToken)
void	shutdownModule() Frees system resources allocated by this Module.
static java.lang.String	toSql(java.lang.String name, java.lang.String in)

Methods inherited from class fedora.server.Module

getRole, getServer

Methods inherited from class fedora.server.Pluggable

getHelp, getOptionalParameters, getParameterHelp, getRequiredParameters

Methods inherited from class fedora.server.Parameterized

getParameter, getParameter, getParameters, parameterNames, setParameter, setParameters

Methods inherited from class java.lang.Object

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

Field Detail

m_storagePool

protected java.lang.String m_storagePool

m_pidGenerator

protected PIDGenerator m_pidGenerator

m_translator

protected DOTranslator m_translator

m_permanentStore

protected ILowlevelStorage m_permanentStore

m_replicator

protected DOReplicator m_replicator

m_validator

protected DOValidator m_validator

m_fieldSearch

protected FieldSearch m_fieldSearch

m_contentManager

protected ExternalContentManager m_contentManager

m_management

protected Management m_management

m_retainPIDs

protected java.util.HashSet m_retainPIDs

m_resourceIndex

protected ResourceIndex m_resourceIndex

m_connectionPool

protected ConnectionPool m_connectionPool

m_connection

protected java.sql.Connection m_connection

DEFAULT_STATE

public static java.lang.String DEFAULT_STATE

Constructor Detail

DefaultDOManager

public DefaultDOManager(java.util.Map moduleParameters,
                        Server server,
                        java.lang.String role)
                 throws ModuleInitializationException

Creates a new DefaultDOManager.

Throws:

ModuleInitializationException

Method Detail

initModule

public void initModule()
                throws ModuleInitializationException

Gets initial param values.

Overrides:

initModule in class Module

Throws:

ModuleInitializationException - If initialization values are invalid or initialization fails for some other reason.

initRetainPID

protected void initRetainPID()

postInitModule

public void postInitModule()
                    throws ModuleInitializationException

Description copied from class: Module

Second stage of Module initialization. This is guaranteed to run after all Module's initModule() methods have run.

Overrides:

postInitModule in class Module

Throws:

ModuleInitializationException - If initialization values are invalid or initialization fails for some other reason.

shutdownModule

public void shutdownModule()

Description copied from class: Module

Frees system resources allocated by this Module.

Overrides:

shutdownModule in class Module

releaseWriter

public void releaseWriter(DOWriter writer)

Description copied from interface: DOManager

Relinquishes control of a DOWriter back to the DOManager.

When a DOManager provides a DOWriter, it creates a session lock. This is used to guarantee that there will never be concurrent changes to the same object. To release the session lock, a DOWriter user calls this method.

Specified by:

releaseWriter in interface DOManager

Parameters:

writer - an instance of a digital object writer.

getConnectionPool

public ConnectionPool getConnectionPool()

getDOValidator

public DOValidator getDOValidator()

getReplicator

public DOReplicator getReplicator()

getRequiredModuleRoles

public java.lang.String[] getRequiredModuleRoles()

Description copied from class: Pluggable

Gets the names of the roles that are required by this Pluggable.

By default, no roles need to be fulfilled.

Overrides:

getRequiredModuleRoles in class Pluggable

Returns:

The roles.

getStorageFormat

public java.lang.String getStorageFormat()

getDefaultExportFormat

public java.lang.String getDefaultExportFormat()

getStorageCharacterEncoding

public java.lang.String getStorageCharacterEncoding()

getTranslator

public DOTranslator getTranslator()

getReader

public DOReader getReader(boolean cachedObjectRequired,
                          Context context,
                          java.lang.String pid)
                   throws ServerException

Gets a reader on an an existing digital object.

Specified by:

getReader in interface RepositoryReader

context - The context of this request.

pid - The PID of the object.

Returns:

A reader.

Throws:

ServerException - If anything went wrong.

getBMechReader

public BMechReader getBMechReader(boolean cachedObjectRequired,
                                  Context context,
                                  java.lang.String pid)
                           throws ServerException

Gets a reader on an an existing behavior mechanism object.

Specified by:

getBMechReader in interface RepositoryReader

Throws:

ServerException

getBDefReader

public BDefReader getBDefReader(boolean cachedObjectRequired,
                                Context context,
                                java.lang.String pid)
                         throws ServerException

Gets a reader on an an existing behavior definition object.

Specified by:

getBDefReader in interface RepositoryReader

Throws:

ServerException

getWriter

public DOWriter getWriter(boolean cachedObjectRequired,
                          Context context,
                          java.lang.String pid)
                   throws ServerException,
                          ObjectLockedException

Gets a writer on an an existing object.

Specified by:

getWriter in interface DOManager

context - The context of this request.

pid - The PID of the object.

Returns:

A writer, or null if the pid didn't point to an accessible object.

Throws:

ServerException - If anything went wrong.

ObjectLockedException

getIngestWriter

public DOWriter getIngestWriter(boolean cachedObjectRequired,
                                Context context,
                                java.io.InputStream in,
                                java.lang.String format,
                                java.lang.String encoding,
                                boolean newPid)
                         throws ServerException

Manages the INGEST process which includes validation of the ingest XML file, deserialization of the XML into a Digital Object instance, setting of properties on the object by the system (dates and states), PID validation or generation, object registry functions, getting a writer for the digital object, and ultimately writing the object to persistent storage via the writer.

Specified by:

getIngestWriter in interface DOManager

Parameters:

context -

in - the input stream that is the XML ingest file for a digital object

format - the format of the XML ingest file (e.g., FOXML, Fedora METS)

encoding - the character encoding of the XML ingest file (e.g., UTF-8)

newPid - true if the system should generate a new PID for the object

Returns:

a writer.

Throws:

ServerException - If anything went wrong.

doCommit

public void doCommit(boolean cachedObjectRequired,
                     Context context,
                     DigitalObject obj,
                     java.lang.String logMessage,
                     boolean remove)
              throws ServerException

The doCommit method finalizes an ingest/update/remove of a digital object. The process makes updates the object modified date, stores managed content datastreams, creates the final XML serialization of the digital object, saves the object to persistent storage, updates the object registry, and replicates the object's current version information to the relational db. In the case where it is not a deletion, the session lock (TODO) is released, too. This happens as the result of a writer.commit() call.

Throws:

ServerException

objectExists

public boolean objectExists(java.lang.String pid)
                     throws StorageDeviceException

Checks the object registry for the given object.

Throws:

StorageDeviceException

getOwnerId

public java.lang.String getOwnerId(java.lang.String pid)
                            throws StorageDeviceException,
                                   ObjectNotFoundException

Throws:

StorageDeviceException

ObjectNotFoundException

listObjectPIDs

public java.lang.String[] listObjectPIDs(Context context)
                                  throws StorageDeviceException

Description copied from interface: RepositoryReader

Gets a list of PIDs (accessible in the given context) of all objects in the repository.

Specified by:

listObjectPIDs in interface RepositoryReader

Throws:

StorageDeviceException

toSql

public static java.lang.String toSql(java.lang.String name,
                                     java.lang.String in)

findObjects

public FieldSearchResult findObjects(Context context,
                                     java.lang.String[] resultFields,
                                     int maxResults,
                                     FieldSearchQuery query)
                              throws ServerException

Specified by:

findObjects in interface DOManager

Throws:

ServerException

resumeFindObjects

public FieldSearchResult resumeFindObjects(Context context,
                                           java.lang.String sessionToken)
                                    throws ServerException

Specified by:

resumeFindObjects in interface DOManager

Throws:

ServerException

getNextPID

public java.lang.String[] getNextPID(int numPIDs,
                                     java.lang.String namespace)
                              throws ServerException

Gets a list of the requested next available PIDs. the number of PIDs.

Specified by:

getNextPID in interface DOManager

Parameters:

numPIDs - The number of PIDs to generate. Defaults to 1 if the number is not a positive integer.

namespace - The namespace to be used when generating the PIDs. If null, the namespace defined by the pidNamespace parameter in the fedora.fcfg configuration file is used.

Returns:

An array of PIDs.

Throws:

ServerException - If an error occurs in generating the PIDs.

reservePIDs

public void reservePIDs(java.lang.String[] pidList)
                 throws ServerException

Description copied from interface: DOManager

Reserve a series of PIDs so that they are never used for subsequent PID generations.

Specified by:

reservePIDs in interface DOManager

Throws:

ServerException

getRepositoryHash

public java.lang.String getRepositoryHash()
                                   throws ServerException

Description copied from interface: DOManager

Get a "hash" of the repository. This value can be compared to a previous value to determine whether the content of the repository has changed. It is not necessary for this value to precisely reflect the state of the repository, but if the repository hasn't changed, subsequent calls should return the same value.

Specified by:

getRepositoryHash in interface DOManager

Throws:

ServerException