public class JdbcOutboundGateway
extends org.springframework.integration.handler.AbstractReplyProducingMessageHandler
messagingTemplateEXPRESSION_PARSER, logger| 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 |
setMaxRows(java.lang.Integer maxRows)
The maximum number of rows to query.
|
void |
setReplySqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory) |
void |
setRequestPreparedStatementSetter(MessagePreparedStatementSetter requestPreparedStatementSetter) |
void |
setRequestSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory) |
void |
setRowMapper(org.springframework.jdbc.core.RowMapper<?> rowMapper) |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadershandleMessage, onComplete, onError, onNext, onSubscribebuildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, 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 setMaxRows(java.lang.Integer maxRows)
JdbcPollingChannelAdapter.
Also used to check before producing reply:
if result has only one item and maxRows is not set or configured to 1,
only that item is returned. Otherwise the whole list.
If not specified this value will default to 1.
This parameter is only applicable if a selectQuery was provided. Null values
are not permitted.maxRows - the number of rows to select. Must not be null.JdbcPollingChannelAdapter.setMaxRows(int)public 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)
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.MessageHandlerSupportprotected 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.AbstractReplyProducingMessageHandler