public class JdbcOutboundGateway extends AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
JdbcOutboundGateway(DataSourceSE dataSource, StringSE updateQuery) |
JdbcOutboundGateway(DataSourceSE dataSource, StringSE updateQuery, StringSE selectQuery) |
JdbcOutboundGateway(JdbcOperations jdbcOperations, StringSE updateQuery) |
JdbcOutboundGateway(JdbcOperations jdbcOperations, StringSE updateQuery, StringSE selectQuery) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doInit() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
protected ObjectSE | handleRequestMessage(Message<?> requestMessage) サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。 |
void | setKeysGenerated(boolean keysGenerated) 更新クエリが自動生成キーを使用した挿入であることを示すフラグ。デバッグレベルでログに記録されます。 |
void | setMaxRows(IntegerSE maxRows) クエリする行の最大数。 |
void | setReplySqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory) |
void | setRequestPreparedStatementSetter(MessagePreparedStatementSetter requestPreparedStatementSetter) |
void | setRequestSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory) |
void | setRowMapper(RowMapper<?> rowMapper) |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
afterPropertiesSet, 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, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getThisAs
getBeanName, getComponentName
public JdbcOutboundGateway(DataSourceSE dataSource, StringSE updateQuery)
public JdbcOutboundGateway(DataSourceSE dataSource, StringSE updateQuery, StringSE selectQuery)
public JdbcOutboundGateway(JdbcOperations jdbcOperations, StringSE updateQuery)
public JdbcOutboundGateway(JdbcOperations jdbcOperations, StringSE updateQuery, StringSE selectQuery)
public void setMaxRows(IntegerSE maxRows)
JdbcPollingChannelAdapter
に設定されます。また、応答を生成する前に確認するために使用されます。結果に項目が 1 つしかなく、maxRows
が 1
に設定または構成されていない場合は、その項目のみが返されます。それ以外の場合は、リスト全体です。指定されていない場合、この値はデフォルトで 1
になります。このパラメーターは、selectQuery が指定されている場合にのみ適用されます。NULL 値は許可されません。maxRows
- 選択する行数。null であってはなりません。JdbcPollingChannelAdapter.setMaxRows(int)
public void setKeysGenerated(boolean keysGenerated)
keysGenerated
- 設定するフラグ値 public void setRequestSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
public void setRequestPreparedStatementSetter(MessagePreparedStatementSetter requestPreparedStatementSetter)
public void setReplySqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
public void setRowMapper(RowMapper<?> rowMapper)
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
MessageHandlerSupport
の getComponentType
protected void doInit()
AbstractReplyProducingMessageHandler
の doInit
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の handleRequestMessage
requestMessage
- リクエストメッセージ。null