インターフェース ConnectionAccessor
- すべての既知のサブインターフェース:
DatabaseClient
public interface ConnectionAccessor
コールバック
Function
SE を受け入れて Connection
のスコープ内で動作するメソッドを宣言するインターフェース。コールバック関数は提供された接続で動作し、接続がプールされたり、他の種類のリソース管理の対象となる可能性があるため、接続を閉じてはなりません。 コールバック関数は、割り当てられた Connection
が有効である期間のスコープを定義する Publisher
を作成する責任があります。パブリッシャーが終了すると、接続が解放されます。
これは、DatabaseClient
の基本インターフェースとして機能します。
- 導入:
- 5.3
- 作成者:
- Mark Paluch
- 関連事項:
メソッドのサマリー
修飾子と型メソッド説明<T> reactor.core.publisher.Mono<T>
inConnection
(FunctionSE<Connection, reactor.core.publisher.Mono<T>> action) Connection
スコープ内でコールバックFunction
SE を実行します。<T> reactor.core.publisher.Flux<T>
inConnectionMany
(FunctionSE<Connection, reactor.core.publisher.Flux<T>> action) Connection
スコープ内でコールバックFunction
SE を実行します。
メソッドの詳細
inConnection
<T> reactor.core.publisher.Mono<T> inConnection(FunctionSE<Connection, reactor.core.publisher.Mono<T>> action) Connection
スコープ内でコールバックFunction
SE を実行します。関数はMono
の作成を担当します。接続は、Mono
が終了した (またはサブスクリプションがキャンセルされた) 後に解放されます。接続リソースは、Function
SE クロージャーの外に渡してはなりません。そうしないと、リソースが機能しなくなる可能性があります。- パラメーター:
action
- 接続アクションを指定するコールバックオブジェクト- 戻り値:
- 結果の
Mono
- 例外:
DataAccessException
- エラーが発生した場合に備えて
inConnectionMany
<T> reactor.core.publisher.Flux<T> inConnectionMany(FunctionSE<Connection, reactor.core.publisher.Flux<T>> action) Connection
スコープ内でコールバックFunction
SE を実行します。関数はFlux
の作成を担当します。接続は、Flux
が終了した (またはサブスクリプションがキャンセルされた) 後に解放されます。接続リソースは、Function
SE クロージャーの外に渡してはなりません。そうしないと、リソースが機能しなくなる可能性があります。- パラメーター:
action
- 接続アクションを指定するコールバックオブジェクト- 戻り値:
- 結果の
Flux
- 例外:
DataAccessException
- エラーが発生した場合に備えて