public abstract class JdbcIteratingDataCaptureServiceImpl extends JdbcDataCaptureServiceImpl
JdbcDataCaptureServiceImpl.DatabaseActoractorlogCONFIRMATION_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, updateMetadataaddStatementParameter, getParameterApplicator, getStatementParameters, setParameterApplicator, setStatementParametersapplyTimeout, closeService, commit, createStatement, getConnection, getConnection, getStatementTimeout, initService, prepare, prepareStatement, prepareStatement, rollback, setConnection, setStatementTimeout, start, stopchangeState, close, continueOnFailure, createName, createQualifier, getContinueOnFail, getIsTrackingEndpoint, getLookupName, getUniqueId, init, isBranching, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setContinueOnFail, setIsTrackingEndpoint, setLookupName, setUniqueIdclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcontinueOnFailure, isBranching, setUniqueIdcreateName, createQualifier, isTrackingEndpointchangeState, requestClose, requestInit, requestStart, requestStop, retrieveComponentStategetUniqueIdclose, initgetLookupNameprotected void initJdbcService()
throws CoreException
initJdbcService in class JdbcDataCaptureServiceImplCoreExceptionpublic void doService(AdaptrisMessage msg) throws ServiceException
ServiceApply the service to the message.
msg - the AdaptrisMessage to processServiceException - wrapping any underlying Exceptionsprotected abstract long executeUpdate(java.sql.PreparedStatement insert)
throws java.sql.SQLException
java.sql.SQLExceptionprotected abstract long finishUpdate(java.sql.PreparedStatement insert)
throws java.sql.SQLException
java.sql.SQLExceptionpublic 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()