インターフェース ReactiveSessionCallback<T>
- 型パラメーター:
T
-
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
CQL
ReactiveSession
で動作するコード用の汎用コールバックインターフェース。任意の型と数のステートメントを使用して、単一の ReactiveSession
で任意の数の操作を実行できます。 これは、ReactiveSession
が動作し、DriverException
をスローすることを期待する既存のデータアクセスコードに委譲する場合に特に便利です。新しく記述されたコードの場合は、クエリや更新バリアントなど、CqlTemplate
のより具体的な操作を使用することを強くお勧めします。
- 導入:
- 2.0
- 作成者:
- Mark Paluch
- 関連事項:
メソッドのサマリー
修飾子と型メソッド説明org.reactivestreams.Publisher<T>
doInSession
(ReactiveSession session) アクティブな Cassandra セッションを持つReactiveCqlTemplate.execute(ReactiveSessionCallback)
によって呼び出されます。
メソッドの詳細
doInSession
org.reactivestreams.Publisher<T> doInSession(ReactiveSession session) throws com.datastax.oss.driver.api.core.DriverException, DataAccessException アクティブな Cassandra セッションを持つReactiveCqlTemplate.execute(ReactiveSessionCallback)
によって呼び出されます。ReactiveSession
のアクティブ化やクローズを気にする必要はありません。コールバック内で作成された結果オブジェクト (ドメインオブジェクトまたはドメインオブジェクトのコレクション) を返すことができます。単一ステップアクションには特別なサポートがあることに注意してください。
ReactiveCqlTemplate.queryForObject(Statement, Class)
などを参照してください。スローされたRuntimeException
SE はアプリケーション例外として扱われ、テンプレートの呼び出し元に伝播されます。- パラメーター:
session
- アクティブな Cassandra セッション。- 戻り値:
- 結果オブジェクトの発行者。
- 例外:
com.datastax.oss.driver.api.core.DriverException
- セッションメソッドによってスローされた場合、DataAccessException
に自動的に変換されます。DataAccessException
- カスタム例外の場合。- 関連事項: