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 |
getSaveReturnedKeysColumn()
Deprecated.
since 3.6.2
Statement.RETURN_GENERATED_KEYS has been available since java 1.4, surely your JDBC driver is
newer than that! |
java.lang.String |
getSaveReturnedKeysTable()
Deprecated.
since 3.6.2
Statement.RETURN_GENERATED_KEYS has been available since java 1.4, surely your JDBC driver is
newer than that! |
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 |
setSaveReturnedKeysColumn(java.lang.String col)
Deprecated.
since 3.6.2
Statement.RETURN_GENERATED_KEYS has been available since java 1.4, surely your JDBC driver is
newer than that! |
void |
setSaveReturnedKeysTable(java.lang.String table)
Deprecated.
since 3.6.2
Statement.RETURN_GENERATED_KEYS has been available since java 1.4, surely your JDBC driver is
newer than that! |
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, getIsConfirmation, getIsTrackingEndpoint, getLookupName, getUniqueId, init, isBranching, isConfirmation, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, rethrowServiceException, retrieveComponentState, setContinueOnFail, setIsConfirmation, setIsTrackingEndpoint, setLookupName, setUniqueId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
continueOnFailure, doService, isBranching, setUniqueId
createName, createQualifier, isConfirmation, 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()
@Deprecated @Removal(version="3.9.0") public void setSaveReturnedKeysColumn(java.lang.String col)
Statement.RETURN_GENERATED_KEYS
has been available since java 1.4, surely your JDBC driver is
newer than that!
This is only applicable of the JDBC driver in question doesn't support Statement.RETURN_GENERATED_KEYS
col
- the column@Deprecated @Removal(version="3.9.0") public java.lang.String getSaveReturnedKeysColumn()
Statement.RETURN_GENERATED_KEYS
has been available since java 1.4, surely your JDBC driver is
newer than that!
This is only applicable of the JDBC driver in question doesn't support Statement.RETURN_GENERATED_KEYS
@Deprecated @Removal(version="3.9.0") public void setSaveReturnedKeysTable(java.lang.String table)
Statement.RETURN_GENERATED_KEYS
has been available since java 1.4, surely your JDBC driver is
newer than that!
This is only applicable of the JDBC driver in question doesn't support Statement.RETURN_GENERATED_KEYS
table
- the table@Deprecated @Removal(version="3.9.0") public java.lang.String getSaveReturnedKeysTable()
Statement.RETURN_GENERATED_KEYS
has been available since java 1.4, surely your JDBC driver is
newer than that!
This is only applicable of the JDBC driver in question doesn't support Statement.RETURN_GENERATED_KEYS
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