パッケージ org.springframework.data.cassandra.core.cql

インターフェース ReactiveStatementCallback<T>

型パラメーター:
T -
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface ReactiveStatementCallback<T>
CQL Statement を操作するコード用の汎用コールバックインターフェース。単一の Statement (たとえば単一の ReactiveSession.execute(Statement)) に対して任意の数の操作を実行できます。

ReactiveCqlTemplate によって内部的に使用されますが、アプリケーションコードにも役立ちます。

導入:
2.0
作成者:
Mark Paluch

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    org.reactivestreams.Publisher<T>
    doInStatement(ReactiveSession session, com.datastax.oss.driver.api.core.cql.Statement<?> stmt)
    アクティブな Cassandra セッションを持つ ReactiveCqlTemplate.execute(String) によって呼び出されます。

  • メソッドの詳細

    • doInStatement

      org.reactivestreams.Publisher<T> doInStatement(ReactiveSession session, com.datastax.oss.driver.api.core.cql.Statement<?> stmt) throws com.datastax.oss.driver.api.core.DriverException, DataAccessException
      アクティブな Cassandra セッションで ReactiveCqlTemplate.execute(String) によって呼び出されます。セッションを閉じる必要はありません。これはすべて Spring の ReactiveCqlTemplate によって処理されます。

      コールバック内で作成された結果オブジェクト (ドメインオブジェクトまたはドメインオブジェクトのコレクション) を返すことができます。単一ステップアクションに対する特別なサポートがあることに注意してください。ReactiveCqlTemplate.queryForObject(String, Class, Object...) などを参照してください。スローされた RuntimeException はアプリケーション例外として扱われ、テンプレートの呼び出し元に伝播されます。

      パラメーター:
      session - アクティブな Cassandra セッション。
      stmt - CQL ステートメント。
      戻り値:
      結果オブジェクトの発行者。
      例外:
      com.datastax.oss.driver.api.core.DriverException - セッションメソッドによってスローされた場合、DataAccessException に自動的に変換されます
      DataAccessException - カスタム例外の場合
      関連事項: