クラス JdbcMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.jdbc.outbound.JdbcMessageHandler
org.springframework.integration.jdbc.JdbcMessageHandler
実装されているすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>
@DeprecatedSE(forRemoval=true, since="7.0") public class JdbcMessageHandler extends JdbcMessageHandler
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
7.0 以降、JdbcMessageHandler を推奨
SQL 更新を実行するメッセージハンドラー。動的クエリパラメーターは、SqlParameterSourceFactory 抽象化を通じてサポートされます。SqlParameterSourceFactory のデフォルト実装は、メッセージをラップして、その Bean プロパティをクエリ文字列で名前で参照できるようにします。
 INSERT INTO ITEMS (MESSAGE_ID, PAYLOAD) VALUES (:headers[id], :payload)

メッセージペイロードが IterableSE のインスタンスである場合、NamedParameterJdbcOperations.batchUpdate(String, SqlParameterSource[]) が実行されます。各 SqlParameterSource インスタンスは、リクエストメッセージのヘッダーを使用して内部 Message 実装にラップされた項目に基づいています。項目はまだ Message でない場合のみ折り返しされます。

N.B. ヘッダーキーをエスケープするために引用符を使用しないでください。デフォルトの SQL パラメーターソース（Spring JDBC から）は、ドット付きの名前のヘッダーも処理できます (たとえば business.id)

導入:
2.0
作成者:
Dave Syer, Artem Bilan, Trung Pham

  • コンストラクターの詳細

    • JdbcMessageHandler

      public JdbcMessageHandler(DataSourceSE dataSource, StringSE updateSql)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      DB 接続を取得できる DataSourceSE と、新しい行を取得するために実行する選択クエリを取得するコンストラクター。
      パラメーター:
      dataSource - null であってはなりません
      updateSql - 実行するクエリ

    • JdbcMessageHandler

      public JdbcMessageHandler(JdbcOperations jdbcOperations, StringSE updateSql)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      クエリの実行に使用する JdbcOperations インスタンスと、新しい行を取得するために実行する選択クエリを取得するコンストラクター。
      パラメーター:
      jdbcOperations - クエリの実行に使用するインスタンス
      updateSql - 実行するクエリ