@ComponentProfile(summary="Capture data from the message and store it in a database", tag="service,jdbc", recommended=DatabaseConnection.class) public class JdbcDataCaptureService extends JdbcIteratingDataCaptureServiceImpl
While not deprecated; you are encouraged to use JdbcBatchingDataCaptureService
instead for performance reasons. Set the
JdbcBatchingDataCaptureService.setBatchWindow(Integer)
to 1
to have functionally equivalent behaviour to this
class.
If the DocumentBuilderFactoryBuilder
has been explicitly set to be not namespace aware and the document does in fact
contain namespaces, then Saxon can cause merry havoc in the sense that //NonNamespaceXpath
doesn't work if the document
has namespaces in it. We have included a shim so that behaviour can be toggled based on what you have configured.
XPath.newXPathInstance(DocumentBuilderFactoryBuilder, NamespaceContext)
In the adapter configuration file this class is aliased as jdbc-data-capture-service which is the preferred alternative to the fully qualified classname when building your configuration.
JdbcDataCaptureServiceImpl.DatabaseActor
actor
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
JdbcDataCaptureService() |
JdbcDataCaptureService(java.lang.String statement) |
Modifier and Type | Method and Description |
---|---|
protected long |
executeUpdate(java.sql.PreparedStatement insert) |
protected long |
finishUpdate(java.sql.PreparedStatement insert) |
doService, getIterates, getIterationXpath, getNamespaceContext, getXmlDocumentFactoryConfig, initJdbcService, setIterates, setIterationXpath, setNamespaceContext, setXmlDocumentFactoryConfig
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
public JdbcDataCaptureService()
public JdbcDataCaptureService(java.lang.String statement)
protected long executeUpdate(java.sql.PreparedStatement insert) throws java.sql.SQLException
executeUpdate
in class JdbcIteratingDataCaptureServiceImpl
java.sql.SQLException
protected long finishUpdate(java.sql.PreparedStatement insert) throws java.sql.SQLException
finishUpdate
in class JdbcIteratingDataCaptureServiceImpl
java.sql.SQLException