コンストラクターの詳細

• 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)

• setSelectQuery

  public final void setSelectQuery(StringSE selectQuery)

  選択クエリを設定します。

  パラメーター:

  selectQuery - クエリ。

  導入:

  5.2.1

• setUpdateSql

  public void setUpdateSql(StringSE updateSql)

• setUpdatePerRow

  public void setUpdatePerRow(boolean updatePerRow)

• setUpdateSqlParameterSourceFactory

  public void setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)

• setSelectSqlParameterSource

  public void setSelectSqlParameterSource(@Nullable
                                          SqlParameterSource sqlQueryParameterSource)

  ポーリングに使用される選択クエリのパラメーターのソース。

  パラメーター:

  sqlQueryParameterSource - 設定する SQL クエリパラメーターソース

• setMaxRows

  public void setMaxRows(int maxRows)

  クエリする行の最大数。デフォルトはゼロです - すべてのレコードを選択します。

  パラメーター:

  maxRows - 設定する最大行

  導入:

  5.1

• onInit

  protected void onInit()

  オーバーライド:

  クラス AbstractExpressionEvaluator の onInit 

• getComponentType

  public StringSE getComponentType()

• doReceive

  protected ObjectSE doReceive()

  提供されている場合は、選択クエリと更新クエリを実行します。選択クエリによって返された行を返します。RowMapper が指定されている場合、マップされた結果が返されます。

  次で指定:

  クラス AbstractMessageSource<ObjectSE> の doReceive 

  戻り値:

  返された値。

• doPoll

  protected ListSE<?> doPoll(@Nullable
                           SqlParameterSource sqlQueryParameterSource)