public abstract class JdbcDataCaptureServiceImpl extends JdbcServiceWithParameters
Modifier and Type | Class and Description |
---|---|
protected class |
JdbcDataCaptureServiceImpl.DatabaseActor |
Modifier and Type | Field and Description |
---|---|
protected JdbcDataCaptureServiceImpl.DatabaseActor |
actor |
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
JdbcDataCaptureServiceImpl() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeJdbcService()
Close the service.
|
protected JdbcDataCaptureServiceImpl.DatabaseActor |
configureActor(AdaptrisMessage msg) |
java.lang.String |
getRowsUpdatedMetadataKey() |
java.lang.Boolean |
getSaveReturnedKeys()
Get the configured flag.
|
java.lang.String |
getStatement()
The configured Statement.
|
protected void |
initJdbcService() |
protected void |
prepareService() |
protected void |
saveKeys(AdaptrisMessage msg,
java.sql.Statement stmt) |
boolean |
saveReturnedKeys() |
void |
setRowsUpdatedMetadataKey(java.lang.String key)
Set the metadata key which will contain the number of rows updated by this service.
|
void |
setSaveReturnedKeys(java.lang.Boolean save)
Store any return value from the SQL statement as metadata.
|
void |
setStatement(java.lang.String s)
SQL statement to perform.
|
protected void |
startService()
Start the service.
|
protected void |
stopService()
Stop the service.
|
protected void |
updateMetadata(AdaptrisMessage msg,
long value) |
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, doService, isBranching, setUniqueId
createName, createQualifier, isTrackingEndpoint
changeState, requestClose, requestInit, requestStart, requestStop, retrieveComponentState
getUniqueId
close, init
getLookupName
protected transient JdbcDataCaptureServiceImpl.DatabaseActor actor
protected void initJdbcService() throws CoreException
initJdbcService
in class JdbcService
CoreException
protected void startService() throws CoreException
JdbcService
This is called after the connection is started
startService
in class JdbcService
CoreException
protected void stopService()
JdbcService
This is called after before the connection is stopped
stopService
in class JdbcService
protected void closeJdbcService()
JdbcService
This is called before the connection is closed
closeJdbcService
in class JdbcService
public void setStatement(java.lang.String s)
s
- the statement.public java.lang.String getStatement()
public boolean saveReturnedKeys()
public void setSaveReturnedKeys(java.lang.Boolean save)
save
- the falg.public java.lang.Boolean getSaveReturnedKeys()
public java.lang.String getRowsUpdatedMetadataKey()
public void setRowsUpdatedMetadataKey(java.lang.String key)
The precise value will depend on the statement(s) being executed; this is simply an aggregation
of the values returned by Statement.executeUpdate(String)
.
key
- the metadata key, if set this metadata will contain the number of rows affected.protected void updateMetadata(AdaptrisMessage msg, long value)
protected void saveKeys(AdaptrisMessage msg, java.sql.Statement stmt) throws java.sql.SQLException
java.sql.SQLException
protected JdbcDataCaptureServiceImpl.DatabaseActor configureActor(AdaptrisMessage msg) throws java.sql.SQLException
java.sql.SQLException
protected void prepareService() throws CoreException
prepareService
in class JdbcService
CoreException