クラス JdbcPollingChannelAdapter

java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<ObjectSE>
org.springframework.integration.jdbc.inbound.JdbcPollingChannelAdapter
実装されているすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、MessageSource<ObjectSE>、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement
既知の直属サブクラス
JdbcPollingChannelAdapter
public class JdbcPollingChannelAdapter extends AbstractMessageSource<ObjectSE>
選択クエリを実行して返されたペイロードからメッセージを作成するポーリングチャネルアダプター。オプションで、処理された行を更新するために、選択後に更新を実行できます。
導入:
2.0
作成者:
Jonas Partner, Dave Syer, Artem Bilan

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

    • JdbcPollingChannelAdapter

      public JdbcPollingChannelAdapter(DataSourceSE dataSource, StringSE selectQuery)
      DB 接続を取得できる DataSourceSE と、新しい行を取得するために実行する選択クエリを取得するコンストラクター。
      パラメーター:
      dataSource - null であってはなりません
      selectQuery - 実行するクエリ

    • JdbcPollingChannelAdapter

      public JdbcPollingChannelAdapter(JdbcOperations jdbcOperations, StringSE selectQuery)
      クエリの実行に使用する JdbcOperations インスタンスと、新しい行を取得するために実行する選択クエリを取得するコンストラクター。
      パラメーター:
      jdbcOperations - クエリの実行に使用するインスタンス
      selectQuery - 実行するクエリ

  • メソッドの詳細

    • setRowMapper

      public void setRowMapper(@Nullable RowMapper<?> rowMapper)
      RowMapper を設定します。
      パラメーター:
      rowMapper - 使用する RowMapper。

    • setSelectQuery

      public final void setSelectQuery(StringSE selectQuery)
      選択クエリを設定します。
      パラメーター:
      selectQuery - クエリ。

    • setUpdateSql

      public void setUpdateSql(StringSE updateSql)
      更新クエリを設定します。
      パラメーター:
      updateSql - 使用する更新クエリ。

    • setUpdatePerRow

      public void setUpdatePerRow(boolean updatePerRow)
      レコードごとに更新するかどうかのフラグを設定します。デフォルトは false です。
      パラメーター:
      updatePerRow - レコードごとまたはバッチ全体の更新を制御するフラグ。

    • setUpdateSqlParameterSourceFactory

      public void setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)
      更新クエリの SqlParameterSourceFactory を設定します。
      パラメーター:
      sqlParameterSourceFactory - 使用する SqlParameterSourceFactory。

    • setSelectSqlParameterSource

      public void setSelectSqlParameterSource(@Nullable SqlParameterSource sqlQueryParameterSource)
      ポーリングに使用される選択クエリのパラメーターのソース。
      パラメーター:
      sqlQueryParameterSource - 設定する SQL クエリパラメーターソース

    • setMaxRows

      public void setMaxRows(int maxRows)
      クエリする行の最大数。デフォルトはゼロです - すべてのレコードを選択します。
      パラメーター:
      maxRows - 設定する最大行

    • onInit

      protected void onInit()
      オーバーライド:
      クラス AbstractExpressionEvaluator の onInit 

    • getComponentType

      public StringSE getComponentType()

    • doReceive

      protected @Nullable ObjectSE doReceive()
      提供されている場合は、選択クエリと更新クエリを実行します。選択クエリによって返された行を返します。RowMapper が指定されている場合、マップされた結果が返されます。
      次で指定:
      クラス AbstractMessageSource<ObjectSE> の doReceive 
      戻り値:
      返された値。

    • doPoll

      public ListSE<?> doPoll(@Nullable SqlParameterSource sqlQueryParameterSource)
      提供された SqlParameterSource に対して選択を実行します。
      パラメーター:
      sqlQueryParameterSource - 使用する SqlParameterSource。オプション。
      戻り値:
      クエリの結果。