インターフェース ReactiveStatementCallback<T>
- 型パラメーター:
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
- カスタム例外の場合- 関連事項: