public abstract class JdbcIteratingDataCaptureServiceImpl extends JdbcDataCaptureServiceImpl
JdbcDataCaptureServiceImpl.DatabaseActor
actor
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
JdbcIteratingDataCaptureServiceImpl() |
Modifier and Type | Method and Description |
---|---|
void |
doService(AdaptrisMessage msg)
Apply the service to the message.
|
protected abstract long |
executeUpdate(java.sql.PreparedStatement insert) |
protected abstract long |
finishUpdate(java.sql.PreparedStatement insert) |
java.lang.Boolean |
getIterates()
Get the configured iteration flag.
|
java.lang.String |
getIterationXpath()
Get the configured iteration xpath.
|
KeyValuePairSet |
getNamespaceContext() |
DocumentBuilderFactoryBuilder |
getXmlDocumentFactoryConfig() |
protected void |
initJdbcService() |
void |
setIterates(java.lang.Boolean iterates)
Set the service to iterate on the given xpath.
|
void |
setIterationXpath(java.lang.String xpath)
An Xpath that can be iterated on.
|
void |
setNamespaceContext(KeyValuePairSet kvps)
Set the namespace context for resolving namespaces.
|
void |
setXmlDocumentFactoryConfig(DocumentBuilderFactoryBuilder xml) |
closeJdbcService, configureActor, getRowsUpdatedMetadataKey, getSaveReturnedKeys, getStatement, prepareService, saveKeys, saveReturnedKeys, setRowsUpdatedMetadataKey, setSaveReturnedKeys, setStatement, startService, stopService, updateMetadata
addStatementParameter, getParameterApplicator, getStatementParameters, setParameterApplicator, setStatementParameters
applyTimeout, closeService, commit, createStatement, getConnection, getConnection, getStatementTimeout, initService, prepare, prepareStatement, prepareStatement, rollback, setConnection, setStatementTimeout, start, stop
changeState, close, continueOnFailure, createName, createQualifier, getContinueOnFail, getIsTrackingEndpoint, getLookupName, getUniqueId, init, isBranching, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setContinueOnFail, setIsTrackingEndpoint, setLookupName, setUniqueId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
continueOnFailure, isBranching, setUniqueId
createName, createQualifier, isTrackingEndpoint
changeState, requestClose, requestInit, requestStart, requestStop, retrieveComponentState
getUniqueId
close, init
getLookupName
protected void initJdbcService() throws CoreException
initJdbcService
in class JdbcDataCaptureServiceImpl
CoreException
public void doService(AdaptrisMessage msg) throws ServiceException
Service
Apply the service to the message.
msg
- the AdaptrisMessage
to processServiceException
- wrapping any underlying Exception
sprotected abstract long executeUpdate(java.sql.PreparedStatement insert) throws java.sql.SQLException
java.sql.SQLException
protected abstract long finishUpdate(java.sql.PreparedStatement insert) throws java.sql.SQLException
java.sql.SQLException
public KeyValuePairSet getNamespaceContext()
public void setNamespaceContext(KeyValuePairSet kvps)
kvps
- the namespace contextSimpleNamespaceContext.create(KeyValuePairSet)
public DocumentBuilderFactoryBuilder getXmlDocumentFactoryConfig()
public void setXmlDocumentFactoryConfig(DocumentBuilderFactoryBuilder xml)
public void setIterationXpath(java.lang.String xpath)
An Xpath that can be iterated on.
An Iteration Xpath defines some repeating element or value in the payload.
xpath
- the xpathsetIterates(Boolean)
public java.lang.String getIterationXpath()
public void setIterates(java.lang.Boolean iterates)
Set the service to iterate on the given xpath.
If set to true, then it is expected that there is a configured iteration xpath available for use. If this is not the case, then results are undefined, and depends on the underlying Xpath implementation
iterates
- the flag.setIterationXpath(String)
public java.lang.Boolean getIterates()