|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectfedora.server.Parameterized
fedora.server.Pluggable
fedora.server.Module
fedora.server.storage.replication.DefaultDOReplicator
public class DefaultDOReplicator
Title: DefaultDOReplicator.java
Description: A Module that replicates digital object information to the dissemination database.
Converts data read from the object reader interfaces and creates or updates the corresponding database rows in the dissemination database.
| Nested Class Summary |
|---|
| Nested classes/interfaces inherited from interface fedora.common.Constants |
|---|
Constants.FedoraHome |
| Field Summary | |
|---|---|
static java.util.regex.Pattern |
s_fedoraLocalPattern
|
static java.util.regex.Pattern |
s_relativeGetPattern
|
static java.util.regex.Pattern |
s_relativeGetPatternAsParm
|
static java.util.regex.Pattern |
s_relativePattern
|
static java.util.regex.Pattern |
s_relativeSearchPattern
|
static java.util.regex.Pattern |
s_relativeSearchPatternAsParm
|
| 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 | |
|---|---|
DefaultDOReplicator(java.util.Map moduleParameters,
Server server,
java.lang.String role)
|
|
| Method Summary | |
|---|---|
void |
delete(java.lang.String pid)
Removes a digital object from the dissemination database. |
void |
initModule()
Initializes the Module based on configuration parameters. |
void |
insertBehaviorDefinitionRow(java.sql.Connection connection,
java.lang.String bDefPID,
java.lang.String bDefLabel,
java.lang.String bDefState)
Inserts a Behavior Definition row. |
void |
insertBehaviorMechanismRow(java.sql.Connection connection,
java.lang.String bDefDbID,
java.lang.String bMechPID,
java.lang.String bMechLabel,
java.lang.String bMechState)
Inserts a Behavior Mechanism row. |
void |
insertDataStreamBindingMapRow(java.sql.Connection connection,
java.lang.String bMechDbID,
java.lang.String dsBindMapID,
java.lang.String dsBindMapLabel)
Inserts a dsBindMap row. |
void |
insertDataStreamBindingRow(java.sql.Connection connection,
java.lang.String doDbID,
java.lang.String dsBindKeyDbID,
java.lang.String dsBindMapDbID,
java.lang.String dsBindKeySeq,
java.lang.String dsID,
java.lang.String dsLabel,
java.lang.String dsMIME,
java.lang.String dsLocation,
java.lang.String dsControlGroupType,
java.lang.String dsCurrentVersionID,
java.lang.String policyDbID,
java.lang.String dsState)
Inserts a DataStreamBindingRow row. |
void |
insertDataStreamBindingSpecRow(java.sql.Connection connection,
java.lang.String bMechDbID,
java.lang.String dsBindSpecName,
java.lang.String dsBindSpecOrdinality,
java.lang.String dsBindSpecCardinality,
java.lang.String dsBindSpecLabel)
Inserts a dsBindSpec row. |
void |
insertDataStreamMIMERow(java.sql.Connection connection,
java.lang.String dsBindKeyDbID,
java.lang.String dsMIMEName)
Inserts a dsMIME row. |
void |
insertDigitalObjectDissAssocRow(java.sql.Connection connection,
java.lang.String doDbID,
java.lang.String dissDbID)
Inserts a doDissAssoc row. |
void |
insertDigitalObjectRow(java.sql.Connection connection,
java.lang.String doPID,
java.lang.String doLabel,
java.lang.String doState)
Inserts a do row. |
void |
insertDisseminatorRow(java.sql.Connection connection,
java.lang.String bDefDbID,
java.lang.String bMechDbID,
java.lang.String dissID,
java.lang.String dissLabel,
java.lang.String dissState)
Inserts a Disseminator row. |
void |
insertGen(java.sql.Connection connection,
java.lang.String insertionStatement)
General JDBC row insertion method. |
void |
insertMechanismImplRow(java.sql.Connection connection,
java.lang.String bMechDbID,
java.lang.String bDefDbID,
java.lang.String methodDbID,
java.lang.String dsBindKeyDbID,
java.lang.String protocolType,
java.lang.String returnType,
java.lang.String addressLocation,
java.lang.String operationLocation,
java.lang.String policyDbID)
Inserts a mechImpl row. |
void |
insertMechDefaultMethodParmRow(java.sql.Connection connection,
java.lang.String methDBID,
java.lang.String bmechDBID,
java.lang.String parmName,
java.lang.String parmDefaultValue,
java.lang.String parmDomainValues,
java.lang.String parmRequiredFlag,
java.lang.String parmLabel,
java.lang.String parmType)
|
void |
insertMethodParmRow(java.sql.Connection connection,
java.lang.String methDBID,
java.lang.String bdefDBID,
java.lang.String parmName,
java.lang.String parmDefaultValue,
java.lang.String parmDomainValues,
java.lang.String parmRequiredFlag,
java.lang.String parmLabel,
java.lang.String parmType)
|
void |
insertMethodRow(java.sql.Connection connection,
java.lang.String bDefDbID,
java.lang.String methodName,
java.lang.String methodLabel)
Inserts a method row. |
java.lang.String |
lookupBehaviorDefinitionDBID(java.sql.Connection connection,
java.lang.String bDefPID)
Looks up a BehaviorDefinition DBID. |
java.lang.String |
lookupBehaviorMechanismDBID(java.sql.Connection connection,
java.lang.String bMechPID)
Looks up a BehaviorMechanism DBID. |
java.lang.String |
lookupDataStreamBinding(java.sql.Connection connection,
java.lang.String doDbID,
java.lang.String dsBindKeyDbID,
java.lang.String dsBindMapDbID,
java.lang.String dsBindKeySeq,
java.lang.String dsID,
java.lang.String dsLocation,
java.lang.String dsState)
|
java.lang.String |
lookupDataStreamBindingMapDBID(java.sql.Connection connection,
java.lang.String bMechDBID,
java.lang.String dsBindingMapID)
Looks up a dsBindMap DBID. |
java.lang.String |
lookupDataStreamBindingSpecDBID(java.sql.Connection connection,
java.lang.String bMechDBID,
java.lang.String dsBindingSpecName)
Looks up a dsBindSpec DBID. |
java.lang.String |
lookupDBID1(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName,
java.lang.String lookupColumnValue)
General JDBC lookup method with 1 lookup column value. |
java.lang.String |
lookupDBID2(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName1,
java.lang.String lookupColumnValue1,
java.lang.String lookupColumnName2,
java.lang.String lookupColumnValue2)
General JDBC lookup method with 2 lookup column values. |
java.lang.String |
lookupDBID2FirstNum(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName1,
java.lang.String lookupColumnValue1,
java.lang.String lookupColumnName2,
java.lang.String lookupColumnValue2)
|
java.lang.String |
lookupDBID4(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName1,
java.lang.String lookupColumnValue1,
java.lang.String lookupColumnName2,
java.lang.String lookupColumnValue2,
java.lang.String lookupColumnName3,
java.lang.String lookupColumnValue3,
java.lang.String lookupColumnName4,
java.lang.String lookupColumnValue4,
java.lang.String lookupColumnName5,
java.lang.String lookupColumnValue5,
java.lang.String lookupColumnName6,
java.lang.String lookupColumnValue6,
java.lang.String lookupColumnName7,
java.lang.String lookupColumnValue7)
|
java.lang.String |
lookupDigitalObjectDBID(java.sql.Connection connection,
java.lang.String doPID)
Looks up a do DBID. |
java.lang.String |
lookupDisseminatorDBID(java.sql.Connection connection,
java.lang.String bDefDBID,
java.lang.String bMechDBID,
java.lang.String dissID)
Looks up a Disseminator DBID. |
java.lang.String |
lookupMethodDBID(java.sql.Connection connection,
java.lang.String bDefDBID,
java.lang.String methName)
Looks up a method DBID. |
void |
postInitModule()
Second stage of Module initialization. |
void |
replicate(BDefReader bDefReader)
Replicates a Fedora behavior definition object. |
void |
replicate(BMechReader bMechReader)
Replicates a Fedora behavior mechanism object. |
void |
replicate(DOReader doReader)
Replicates a Fedora data object. |
| Methods inherited from class fedora.server.Module |
|---|
getRole, getServer, shutdownModule |
| Methods inherited from class fedora.server.Pluggable |
|---|
getHelp, getOptionalParameters, getParameterHelp, getRequiredModuleRoles, 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 |
|---|
public static java.util.regex.Pattern s_fedoraLocalPattern
public static java.util.regex.Pattern s_relativePattern
public static java.util.regex.Pattern s_relativeGetPattern
public static java.util.regex.Pattern s_relativeSearchPattern
public static java.util.regex.Pattern s_relativeGetPatternAsParm
public static java.util.regex.Pattern s_relativeSearchPatternAsParm
| Constructor Detail |
|---|
public DefaultDOReplicator(java.util.Map moduleParameters,
Server server,
java.lang.String role)
throws ModuleInitializationException
ModuleInitializationException| Method Detail |
|---|
public void initModule()
Module
initModule in class Module
public void postInitModule()
throws ModuleInitializationException
Module
postInitModule in class ModuleModuleInitializationException - If initialization values are
invalid or initialization fails for some other reason.
public void replicate(BDefReader bDefReader)
throws ReplicationException,
java.sql.SQLException
replicate in interface DOReplicatorbDefReader - behavior definition reader
ReplicationException - replication processing error
java.sql.SQLException - JDBC, SQL error
public void replicate(BMechReader bMechReader)
throws ReplicationException,
java.sql.SQLException
replicate in interface DOReplicatorbMechReader - behavior mechanism reader
ReplicationException - replication processing error
java.sql.SQLException - JDBC, SQL error
public void replicate(DOReader doReader)
throws ReplicationException,
java.sql.SQLException
replicate in interface DOReplicatordoReader - data object reader
ReplicationException - replication processing error
java.sql.SQLException - JDBC, SQL error
public void delete(java.lang.String pid)
throws ReplicationException
delete in interface DOReplicatorpid - The pid of the object to delete.
ReplicationException - If the request couldn't be fulfilled for
any reason.
public void insertBehaviorDefinitionRow(java.sql.Connection connection,
java.lang.String bDefPID,
java.lang.String bDefLabel,
java.lang.String bDefState)
throws java.sql.SQLException
connection - JDBC DBMS connectionbDefPID - Behavior definition PIDbDefLabel - Behavior definition labelbDefState - State of behavior definition object.
java.sql.SQLException - JDBC, SQL error
public void insertBehaviorMechanismRow(java.sql.Connection connection,
java.lang.String bDefDbID,
java.lang.String bMechPID,
java.lang.String bMechLabel,
java.lang.String bMechState)
throws java.sql.SQLException
connection - JDBC DBMS connectionbDefDbID - Behavior definition DBIDbMechPID - Behavior mechanism DBIDbMechLabel - Behavior mechanism labelbMechState - Statye of behavior mechanism object.
java.sql.SQLException - JDBC, SQL error
public void insertDataStreamBindingRow(java.sql.Connection connection,
java.lang.String doDbID,
java.lang.String dsBindKeyDbID,
java.lang.String dsBindMapDbID,
java.lang.String dsBindKeySeq,
java.lang.String dsID,
java.lang.String dsLabel,
java.lang.String dsMIME,
java.lang.String dsLocation,
java.lang.String dsControlGroupType,
java.lang.String dsCurrentVersionID,
java.lang.String policyDbID,
java.lang.String dsState)
throws java.sql.SQLException
connection - JDBC DBMS connectiondoDbID - Digital object DBIDdsBindKeyDbID - Datastream binding key DBIDdsBindMapDbID - Binding map DBIDdsBindKeySeq - Datastream binding key sequence numberdsID - Datastream IDdsLabel - Datastream labeldsMIME - Datastream mime typedsLocation - Datastream locationdsControlGroupType - Datastream typedsCurrentVersionID - Datastream current version IDpolicyDbID - Policy DBIDdsState - State of datastream.
java.sql.SQLException - JDBC, SQL error
public void insertDataStreamBindingMapRow(java.sql.Connection connection,
java.lang.String bMechDbID,
java.lang.String dsBindMapID,
java.lang.String dsBindMapLabel)
throws java.sql.SQLException
connection - JDBC DBMS connectionbMechDbID - Behavior mechanism DBIDdsBindMapID - Datastream binding map IDdsBindMapLabel - Datastream binding map label
java.sql.SQLException - JDBC, SQL error
public void insertDataStreamBindingSpecRow(java.sql.Connection connection,
java.lang.String bMechDbID,
java.lang.String dsBindSpecName,
java.lang.String dsBindSpecOrdinality,
java.lang.String dsBindSpecCardinality,
java.lang.String dsBindSpecLabel)
throws java.sql.SQLException
connection - JDBC DBMS connectionbMechDbID - Behavior mechanism DBIDdsBindSpecName - Datastream binding spec namedsBindSpecOrdinality - Datastream binding spec ordinality flagdsBindSpecCardinality - Datastream binding cardinalitydsBindSpecLabel - Datastream binding spec lable
java.sql.SQLException - JDBC, SQL error
public void insertDataStreamMIMERow(java.sql.Connection connection,
java.lang.String dsBindKeyDbID,
java.lang.String dsMIMEName)
throws java.sql.SQLException
connection - JDBC DBMS connectiondsBindKeyDbID - Datastream binding key DBIDdsMIMEName - Datastream MIME type name
java.sql.SQLException - JDBC, SQL error
public void insertDigitalObjectRow(java.sql.Connection connection,
java.lang.String doPID,
java.lang.String doLabel,
java.lang.String doState)
throws java.sql.SQLException
connection - JDBC DBMS connectiondoPID - DigitalObject PIDdoLabel - DigitalObject labeldoState - State of digital object.
java.sql.SQLException - JDBC, SQL error
public void insertDigitalObjectDissAssocRow(java.sql.Connection connection,
java.lang.String doDbID,
java.lang.String dissDbID)
throws java.sql.SQLException
connection - JDBC DBMS connectiondoDbID - DigitalObject DBIDdissDbID - Disseminator DBID
java.sql.SQLException - JDBC, SQL error
public void insertDisseminatorRow(java.sql.Connection connection,
java.lang.String bDefDbID,
java.lang.String bMechDbID,
java.lang.String dissID,
java.lang.String dissLabel,
java.lang.String dissState)
throws java.sql.SQLException
connection - JDBC DBMS connectionbDefDbID - Behavior definition DBIDbMechDbID - Behavior mechanism DBIDdissID - Disseminator IDdissLabel - Disseminator labeldissState - State of disseminator.
java.sql.SQLException - JDBC, SQL error
public void insertMechanismImplRow(java.sql.Connection connection,
java.lang.String bMechDbID,
java.lang.String bDefDbID,
java.lang.String methodDbID,
java.lang.String dsBindKeyDbID,
java.lang.String protocolType,
java.lang.String returnType,
java.lang.String addressLocation,
java.lang.String operationLocation,
java.lang.String policyDbID)
throws java.sql.SQLException
connection - JDBC DBMS connectionbMechDbID - Behavior mechanism DBIDbDefDbID - Behavior definition DBIDmethodDbID - Method DBIDdsBindKeyDbID - Datastream binding key DBIDprotocolType - Mechanism implementation protocol typereturnType - Mechanism implementation return typeaddressLocation - Mechanism implementation address locationoperationLocation - Mechanism implementation operation locationpolicyDbID - Policy DBID
java.sql.SQLException - JDBC, SQL error
public void insertMethodRow(java.sql.Connection connection,
java.lang.String bDefDbID,
java.lang.String methodName,
java.lang.String methodLabel)
throws java.sql.SQLException
connection - JDBC DBMS connectionbDefDbID - Behavior definition DBIDmethodName - Behavior definition labelmethodLabel - Behavior definition label
java.sql.SQLException - JDBC, SQL error
public void insertMethodParmRow(java.sql.Connection connection,
java.lang.String methDBID,
java.lang.String bdefDBID,
java.lang.String parmName,
java.lang.String parmDefaultValue,
java.lang.String parmDomainValues,
java.lang.String parmRequiredFlag,
java.lang.String parmLabel,
java.lang.String parmType)
throws java.sql.SQLException
connection - An SQL Connection.methDBID - The method database ID.bdefDBID - The behavior Definition object database ID.parmName - the parameter name.parmDefaultValue - A default value for the parameter.parmDomainValues - A list of possible values for the parameter.parmRequiredFlag - A boolean flag indicating whether the
parameter is required or not.parmLabel - The parameter label.parmType - The parameter type.
java.sql.SQLException - JDBC, SQL error
public void insertMechDefaultMethodParmRow(java.sql.Connection connection,
java.lang.String methDBID,
java.lang.String bmechDBID,
java.lang.String parmName,
java.lang.String parmDefaultValue,
java.lang.String parmDomainValues,
java.lang.String parmRequiredFlag,
java.lang.String parmLabel,
java.lang.String parmType)
throws java.sql.SQLException
connection - An SQL Connection.methDBID - The method database ID.bmechDBID - The behavior Mechanism object database ID.parmName - the parameter name.parmDefaultValue - A default value for the parameter.parmRequiredFlag - A boolean flag indicating whether the
parameter is required or not.parmDomainValues - A list of possible values for the parameter.parmLabel - The parameter label.parmType - The parameter type.
java.sql.SQLException - JDBC, SQL error
public void insertGen(java.sql.Connection connection,
java.lang.String insertionStatement)
throws java.sql.SQLException
connection - JDBC DBMS connectioninsertionStatement - SQL row insertion statement
java.sql.SQLException - JDBC, SQL error
public java.lang.String lookupBehaviorDefinitionDBID(java.sql.Connection connection,
java.lang.String bDefPID)
throws StorageDeviceException
connection - JDBC DBMS connectionbDefPID - Behavior definition PID
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupBehaviorMechanismDBID(java.sql.Connection connection,
java.lang.String bMechPID)
throws StorageDeviceException
connection - JDBC DBMS connectionbMechPID - Behavior mechanism PID
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDataStreamBindingMapDBID(java.sql.Connection connection,
java.lang.String bMechDBID,
java.lang.String dsBindingMapID)
throws StorageDeviceException
connection - JDBC DBMS connectionbMechDBID - Behavior mechanism DBIDdsBindingMapID - Data stream binding map ID
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDataStreamBinding(java.sql.Connection connection,
java.lang.String doDbID,
java.lang.String dsBindKeyDbID,
java.lang.String dsBindMapDbID,
java.lang.String dsBindKeySeq,
java.lang.String dsID,
java.lang.String dsLocation,
java.lang.String dsState)
throws StorageDeviceException
StorageDeviceException
public java.lang.String lookupDataStreamBindingSpecDBID(java.sql.Connection connection,
java.lang.String bMechDBID,
java.lang.String dsBindingSpecName)
throws StorageDeviceException
connection - JDBC DBMS connectionbMechDBID - Behavior mechanism DBIDdsBindingSpecName - Data stream binding spec name
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDigitalObjectDBID(java.sql.Connection connection,
java.lang.String doPID)
throws StorageDeviceException
connection - JDBC DBMS connectiondoPID - Data object PID
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDisseminatorDBID(java.sql.Connection connection,
java.lang.String bDefDBID,
java.lang.String bMechDBID,
java.lang.String dissID)
throws StorageDeviceException
connection - JDBC DBMS connectionbDefDBID - Behavior definition DBIDbMechDBID - Behavior mechanism DBIDdissID - Disseminator ID
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupMethodDBID(java.sql.Connection connection,
java.lang.String bDefDBID,
java.lang.String methName)
throws StorageDeviceException
connection - JDBC DBMS connectionbDefDBID - Behavior definition DBIDmethName - Method name
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDBID1(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName,
java.lang.String lookupColumnValue)
throws StorageDeviceException
connection - JDBC DBMS connectionDBIDName - DBID column nametableName - Table namelookupColumnName - Lookup column namelookupColumnValue - Lookup column value
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDBID2(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName1,
java.lang.String lookupColumnValue1,
java.lang.String lookupColumnName2,
java.lang.String lookupColumnValue2)
throws StorageDeviceException
connection - JDBC DBMS connectionDBIDName - DBID Column nametableName - Table namelookupColumnName1 - First lookup column namelookupColumnValue1 - First lookup column valuelookupColumnName2 - Second lookup column namelookupColumnValue2 - Second lookup column value
StorageDeviceException - if db lookup fails for any reason.
public java.lang.String lookupDBID4(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName1,
java.lang.String lookupColumnValue1,
java.lang.String lookupColumnName2,
java.lang.String lookupColumnValue2,
java.lang.String lookupColumnName3,
java.lang.String lookupColumnValue3,
java.lang.String lookupColumnName4,
java.lang.String lookupColumnValue4,
java.lang.String lookupColumnName5,
java.lang.String lookupColumnValue5,
java.lang.String lookupColumnName6,
java.lang.String lookupColumnValue6,
java.lang.String lookupColumnName7,
java.lang.String lookupColumnValue7)
throws StorageDeviceException
StorageDeviceException
public java.lang.String lookupDBID2FirstNum(java.sql.Connection connection,
java.lang.String DBIDName,
java.lang.String tableName,
java.lang.String lookupColumnName1,
java.lang.String lookupColumnValue1,
java.lang.String lookupColumnName2,
java.lang.String lookupColumnValue2)
throws StorageDeviceException
StorageDeviceException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||