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

インターフェース DatabaseClient

すべてのスーパーインターフェース:
ConnectionAccessor
public interface DatabaseClient extends ConnectionAccessor
Reactive Streams バックプレッシャーを使用してデータベース呼び出しを実行するためのノンブロッキングのリアクティブクライアント。R2DBC クライアントライブラリを介して、より高いレベルの共通 API を提供します。エラーの DataAccessException バリアントを伝播します。

静的ファクトリメソッド create(ConnectionFactory) を使用するか、ビルダーを取得してインスタンスを作成します。

使用例:

 ConnectionFactory factory = …

 DatabaseClient client = DatabaseClient.create(factory);
 Mono<Actor> actor = client.sql("select first_name, last_name from t_actor")
     .map(row -> new Actor(row.get("first_name", String.class),
          row.get("last_name", String.class)))
     .first();
導入:
5.3
作成者:
Mark Paluch, Juergen Hoeller

  • メソッドの詳細

    • getConnectionFactory

      ConnectionFactory getConnectionFactory()
      このクライアントが使用する ConnectionFactory を取得します。
      戻り値:
      接続ファクトリ

    • sql

      DatabaseClient.GenericExecuteSpec sql(StringSE sql)
      実行する静的 sql ステートメントを指定します。実行につながるオプションとともに SQL 呼び出しを指定するための契約。NamedParameterExpander が有効な場合、SQL 文字列にはネイティブパラメーターバインドマーカーまたは名前付きパラメーター (:foo、: bar など) を含めることができます。
      パラメーター:
      sql - SQL ステートメント
      戻り値:
      新しい DatabaseClient.GenericExecuteSpec
      関連事項:

    • sql

      DatabaseClient.GenericExecuteSpec sql(SupplierSE<StringSE> sqlSupplier)
      実行する SQL を提供する SQL サプライヤーSEを指定します。実行につながるオプションとともに SQL 呼び出しを指定するための契約。NamedParameterExpander が有効な場合、SQL 文字列にはネイティブパラメーターバインドマーカーまたは名前付きパラメーター (:foo、: bar など) を含めることができます。

      PreparedOperation を SQL として受け入れ、SupplierSE をバインドします。

      DatabaseClient の実装では、SQL 文字列の解決を可能な限り、理想的には Subscription が発生するまで延期する必要があります。これは、デフォルトの実装の場合です。

      パラメーター:
      sqlSupplier - SQL ステートメントのサプライヤー
      戻り値:
      新しい DatabaseClient.GenericExecuteSpec
      関連事項:

    • create

      static DatabaseClient create(ConnectionFactory factory)
      提供された ConnectionFactory を使用する DatabaseClient を作成します。
      パラメーター:
      factory - 接続の取得に使用する ConnectionFactory 
      戻り値:
      新しい DatabaseClient; 決して null

    • builder

      static DatabaseClient.Builder builder()
      DatabaseClient ビルダーを入手します。