パッケージ org.springframework.data.mongodb

クラス ReactiveMongoDatabaseUtils

java.lang.ObjectSE
org.springframework.data.mongodb.ReactiveMongoDatabaseUtils
public class ReactiveMongoDatabaseUtils extends ObjectSE
ReactiveMongoDatabaseFactory を介してリアクティブ MongoDatabase インスタンスを管理するためのヘルパークラス。トランザクションの使用に適した MongoDatabase や MongoCollection などの session bound リソースを取得するために使用されます。
注 : 社内使用のみを目的としています。
導入:
2.2
作成者:
Mark Paluch, Christoph Strobl, Mathieu Ouellet

  • コンストラクターの詳細

    • ReactiveMongoDatabaseUtils

      public ReactiveMongoDatabaseUtils()

  • メソッドの詳細

    • isTransactionActive

      public static reactor.core.publisher.Mono<BooleanSE> isTransactionActive(ReactiveMongoDatabaseFactory databaseFactory)
      ReactiveMongoDatabaseFactory が実際にアクティブなトランザクションを持つ ClientSession にバインドされているかどうか、TransactionSynchronization が resource に登録されているかどうか、および関連付けられた ClientSession に active transaction があるかどうかを確認します。
      パラメーター:
      databaseFactory - トランザクションをチェックするリソース。null にすることはできません。
      戻り値:
      ファクトリに進行中のトランザクションがある場合に true を発行する Mono。

    • getDatabase

      public static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> getDatabase(ReactiveMongoDatabaseFactory factory)
      native session synchronization を使用して、指定された factory からデフォルトの database を取得します。
      synchronization is active の場合、サブスクライバー Context 内に MongoDB specific transaction synchronization を登録します。
      パラメーター:
      factory - ReactiveMongoDatabaseFactory から MongoDatabase を取得します。
      戻り値:
      トランザクション ClientSession と潜在的に関連付けられている MongoDatabase。

    • getDatabase

      public static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> getDatabase(ReactiveMongoDatabaseFactory factory, SessionSynchronization sessionSynchronization)
      指定された factory からデフォルトの database を取得します。
      synchronization is active の場合、サブスクライバー Context 内に MongoDB specific transaction synchronization を登録します。
      パラメーター:
      factory - ReactiveMongoDatabaseFactory から MongoDatabase を取得します。
      sessionSynchronization - 使用する同期。null にすることはできません。
      戻り値:
      トランザクション ClientSession と潜在的に関連付けられている MongoDatabase。

    • getDatabase

      public static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> getDatabase(StringSE dbName, ReactiveMongoDatabaseFactory factory)
      native session synchronization を使用して、指定された factory から指定された名前の database を取得します。
      synchronization is active の場合、サブスクライバー Context 内に MongoDB specific transaction synchronization を登録します。
      パラメーター:
      dbName - 取得する MongoDatabase の名前。
      factory - ReactiveMongoDatabaseFactory から MongoDatabase を取得します。
      戻り値:
      トランザクション ClientSession と潜在的に関連付けられている MongoDatabase。

    • getDatabase

      public static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.MongoDatabase> getDatabase(StringSE dbName, ReactiveMongoDatabaseFactory factory, SessionSynchronization sessionSynchronization)
      指定された factory から指定された名前の database を取得します。
      synchronization is active の場合、サブスクライバー Context 内に MongoDB specific transaction synchronization を登録します。
      パラメーター:
      dbName - 取得する MongoDatabase の名前。
      factory - ReactiveMongoDatabaseFactory から MongoDatabase を取得します。
      sessionSynchronization - 使用する同期。null にすることはできません。
      戻り値:
      トランザクション ClientSession と潜在的に関連付けられている MongoDatabase。