パッケージ org.springframework.r2dbc.core

インターフェース ConnectionAccessor

すべての既知のサブインターフェース:
DatabaseClient
public interface ConnectionAccessor
コールバック FunctionSE を受け入れて Connection のスコープ内で動作するメソッドを宣言するインターフェース。コールバック関数は提供された接続で動作し、接続がプールされたり、他の種類のリソース管理の対象となる可能性があるため、接続を閉じてはなりません。

コールバック関数は、割り当てられた Connection が有効である期間のスコープを定義する Publisher を作成する責任があります。パブリッシャーが終了すると、接続が解放されます。

これは、DatabaseClient の基本インターフェースとして機能します。

導入:
5.3
作成者:
Mark Paluch
関連事項:

  • メソッドの詳細

    • inConnection

      <T> reactor.core.publisher.Mono<T> inConnection(FunctionSE<Connection,reactor.core.publisher.Mono<T>> action)
      Connection スコープ内でコールバック FunctionSE を実行します。関数は Mono の作成を担当します。接続は、Mono が終了した (またはサブスクリプションがキャンセルされた) 後に解放されます。接続リソースは、FunctionSE クロージャーの外に渡してはなりません。そうしないと、リソースが機能しなくなる可能性があります。
      パラメーター:
      action - 接続アクションを指定するコールバックオブジェクト
      戻り値:
      結果の Mono
      例外:
      DataAccessException - エラーが発生した場合に備えて

    • inConnectionMany

      <T> reactor.core.publisher.Flux<T> inConnectionMany(FunctionSE<Connection,reactor.core.publisher.Flux<T>> action)
      Connection スコープ内でコールバック FunctionSE を実行します。関数は Flux の作成を担当します。接続は、Flux が終了した (またはサブスクリプションがキャンセルされた) 後に解放されます。接続リソースは、FunctionSE クロージャーの外に渡してはなりません。そうしないと、リソースが機能しなくなる可能性があります。
      パラメーター:
      action - 接続アクションを指定するコールバックオブジェクト
      戻り値:
      結果の Flux
      例外:
      DataAccessException - エラーが発生した場合に備えて