public class JdbcOutboundGateway
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
implements org.springframework.beans.factory.InitializingBean
messagingTemplate| Constructor and Description |
|---|
JdbcOutboundGateway(javax.sql.DataSource dataSource,
java.lang.String updateQuery) |
JdbcOutboundGateway(javax.sql.DataSource dataSource,
java.lang.String updateQuery,
java.lang.String selectQuery) |
JdbcOutboundGateway(org.springframework.jdbc.core.JdbcOperations jdbcOperations,
java.lang.String updateQuery) |
JdbcOutboundGateway(org.springframework.jdbc.core.JdbcOperations jdbcOperations,
java.lang.String updateQuery,
java.lang.String selectQuery) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doInit() |
java.lang.String |
getComponentType() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage) |
void |
setKeysGenerated(boolean keysGenerated)
Flag to indicate that the update query is an insert with auto-generated keys, which will be logged at debug level.
|
void |
setMaxRowsPerPoll(java.lang.Integer maxRowsPerPoll)
The maximum number of rows to pull out of the query results per poll (if
greater than zero, otherwise all rows will be packed into the outgoing
message).
|
void |
setReplySqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory) |
void |
setRequestPreparedStatementSetter(MessagePreparedStatementSetter requestPreparedStatementSetter) |
void |
setRequestSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory) |
void |
setRowMapper(org.springframework.jdbc.core.RowMapper<?> rowMapper) |
doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplycreateOutputMessage, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutputconfigureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic JdbcOutboundGateway(javax.sql.DataSource dataSource,
java.lang.String updateQuery)
public JdbcOutboundGateway(javax.sql.DataSource dataSource,
java.lang.String updateQuery,
java.lang.String selectQuery)
public JdbcOutboundGateway(org.springframework.jdbc.core.JdbcOperations jdbcOperations,
java.lang.String updateQuery)
public JdbcOutboundGateway(org.springframework.jdbc.core.JdbcOperations jdbcOperations,
java.lang.String updateQuery,
java.lang.String selectQuery)
public void setMaxRowsPerPoll(java.lang.Integer maxRowsPerPoll)
JdbcPollingChannelAdapter.
If not specified this value will default to zero.
This parameter is only applicable if a selectQuery was provided. Null values
are not permitted.maxRowsPerPoll - Must not be null.public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.AbstractMessageHandlerprotected void doInit()
doInit in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
handleRequestMessage in class org.springframework.integration.handler.AbstractReplyProducingMessageHandlerpublic void setKeysGenerated(boolean keysGenerated)
keysGenerated - the flag value to setpublic void setRequestSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
public void setRequestPreparedStatementSetter(MessagePreparedStatementSetter requestPreparedStatementSetter)
public void setReplySqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
public void setRowMapper(org.springframework.jdbc.core.RowMapper<?> rowMapper)