クラス ConnectionFactoryUtils

メソッドの詳細

• getConnection

  public static reactor.core.publisher.Mono<Connection> getConnection(ConnectionFactory connectionFactory)

  指定された ConnectionFactory から Connection を取得します。例外を未チェックのジェネリクスデータアクセス例外の Spring 階層に変換し、コードの呼び出しを簡素化し、スローされる例外をより意味のあるものにします。

  現在の TransactionSynchronizationManager にバインドされている対応する接続を認識しています。トランザクション同期がアクティブな場合、接続を TransactionSynchronizationManager にバインドします。

  パラメーター:

  connectionFactory - から Connections を取得する ConnectionFactory

  戻り値:

  指定された ConnectionFactory からの R2DBC 接続

  例外:

  DataAccessResourceFailureException - Connection の取得に失敗した場合

  関連事項:

  • releaseConnection(io.r2dbc.spi.Connection, io.r2dbc.spi.ConnectionFactory)

• doGetConnection

  public static reactor.core.publisher.Mono<Connection> doGetConnection(ConnectionFactory connectionFactory)

  指定された ConnectionFactory から実際に R2DBC 接続を取得します。getConnection(io.r2dbc.spi.ConnectionFactory) と同じですが、元の例外を保持します。

  現在の TransactionSynchronizationManager にバインドされている対応する接続を認識しています。トランザクション同期がアクティブな場合、接続を TransactionSynchronizationManager にバインドします

  パラメーター:

  connectionFactory - から接続を取得する ConnectionFactory

  戻り値:

  指定された ConnectionFactory からの R2DBC Connection。

• releaseConnection

  public static reactor.core.publisher.Mono<VoidSE> releaseConnection(Connection con, ConnectionFactory connectionFactory)

  外部で管理されていない（つまり、サブスクリプションにバインドされていない）場合は、指定された ConnectionFactory から取得された指定された Connection を閉じます。

  パラメーター:

  con - 必要に応じて Connection を閉じる

  connectionFactory - 接続が取得された ConnectionFactory

  関連事項:

  • getConnection(io.r2dbc.spi.ConnectionFactory)

• doReleaseConnection

  public static reactor.core.publisher.Mono<VoidSE> doReleaseConnection(Connection connection, ConnectionFactory connectionFactory)

  指定された ConnectionFactory から取得された指定された Connection を実際に閉じます。releaseConnection(io.r2dbc.spi.Connection, io.r2dbc.spi.ConnectionFactory) と同じですが、元の例外を保持します。

  パラメーター:

  connection - 必要に応じて Connection を閉じる

  connectionFactory - 接続が取得された ConnectionFactory

  関連事項:

  • doGetConnection(io.r2dbc.spi.ConnectionFactory)

• currentConnectionFactory

  public static reactor.core.publisher.Mono<ConnectionFactory> currentConnectionFactory(ConnectionFactory connectionFactory)

  現在の TransactionSynchronizationManager から ConnectionFactory を取得します。

  パラメーター:

  connectionFactory - 接続が取得された ConnectionFactory

  関連事項:

  • TransactionSynchronizationManager

• convertR2dbcException

  public static DataAccessException convertR2dbcException(StringSE task, @Nullable StringSE sql, R2dbcException ex)

  指定された R2dbcException を汎用 DataAccessException に変換します。

  返された DataAccessException には、根本原因として元の R2dbcException が含まれているはずです。ただし、DataAccessExceptions は他のリソース API によっても発生している可能性があるため、クライアントコードは通常これに依存しない場合があります。とはいえ、R2DBC ベースのアクセスが発生したと予想される場合、getRootCause() instanceof R2dbcException チェック（およびその後のキャスト）は信頼できると見なされます。

  パラメーター:

  task - 試行されているタスクを説明する読み取り可能なテキスト

  sql - 問題を引き起こした SQL クエリまたは更新 (既知の場合)

  ex - 問題のある R2dbcException

  戻り値:

  対応する DataAccessException インスタンス

• getTargetConnection

  public static Connection getTargetConnection(Connection con)

  指定された Connection の最も内側のターゲット Connection を返します。指定された Connection がラップされている場合、プレーンな Connection が見つかるまでラップが解除されます。それ以外の場合、渡された接続はそのまま返されます。

  パラメーター:

  con - アンラップする Connection ラッパー

  戻り値:

  最も内側のターゲット接続、またはラップされていない場合は渡された接続

  関連事項:

  • Wrapped.unwrap()