クラス ReactiveMongoTemplate

java.lang.ObjectSE
org.springframework.data.mongodb.core.ReactiveMongoTemplate
実装済みのインターフェース一覧:
Aware, ApplicationContextAware, ReactiveAggregationOperation, ReactiveChangeStreamOperation, ReactiveFindOperation, ReactiveFluentMongoOperations, ReactiveInsertOperation, ReactiveMapReduceOperation, ReactiveMongoOperations, ReactiveRemoveOperation, ReactiveUpdateOperation

public class ReactiveMongoTemplate extends ObjectSE implements ReactiveMongoOperations, ApplicationContextAware
ReactiveMongoOperations の主な実装。Reactive MongoDB の使用を簡素化し、一般的なエラーを回避できます。コア MongoDB ワークフローを実行し、アプリケーションコードに Document を提供して結果を抽出させます。このクラスは BSON クエリまたは更新を実行し、FindPublisher の反復処理を開始し、MongoDB 例外をキャッチして、org.springframework.dao パッケージで定義されている汎用的でより情報量の多い例外階層に変換します。ReactiveMongoDatabaseFactory 参照を使用して直接インスタンス化することでサービス実装内で使用することも、アプリケーションコンテキストで準備して Bean 参照としてサービスに提供することもできます。

メモ: ReactiveMongoDatabaseFactory は、アプリケーションコンテキストでは常に Bean として構成する必要があります。最初のケースではサービスに直接指定され、2 番目のケースでは準備されたテンプレートに指定されます。

ReadPreference および ReadConcern

ReadPreference および ReadConcern は通常、特定の MongoCollection で実行されるアクションの Query および AggregationOptions オブジェクトから考慮されます。

テンプレートレベルでデフォルトの ReadPreference を設定して、通常 ReadPreference を適用することもできます。

トランザクションを使用する場合は、ReactiveMongoTransactionManager の作成にも使用される同じ ReactiveMongoDatabaseFactory を使用してこのテンプレートを作成してください。

導入:
2.0
作成者:
Mark Paluch, Christoph Strobl, Roman Puchkovskiy, Mathieu Ouellet, Yadhukrishna S Pai, Florian L ü diger
  • フィールドの詳細

    • NO_OP_REF_RESOLVER

      public static final DbRefResolver NO_OP_REF_RESOLVER
  • コンストラクターの詳細

    • ReactiveMongoTemplate

      public ReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient mongoClient, StringSE databaseName)
      基本的なテンプレート設定に使用されるコンストラクター。

      トランザクションを使用する場合は、必ず ReactiveMongoTemplate(ReactiveMongoDatabaseFactory) または ReactiveMongoTemplate(ReactiveMongoDatabaseFactory, MongoConverter) コンストラクターを使用してください。そうしないと、ReactiveMongoTransactionManager はトランザクション参加に構成された ReactiveMongoDatabaseFactory を厳密に使用するため、このテンプレートはデフォルトの SessionSynchronization.ON_ACTUAL_TRANSACTION 設定を使用してトランザクションに参加しません。

      パラメーター:
      mongoClient - null であってはなりません。
      databaseName - null または空であってはなりません。
    • ReactiveMongoTemplate

      public ReactiveMongoTemplate(ReactiveMongoDatabaseFactory mongoDatabaseFactory)
      基本的なテンプレート設定に使用されるコンストラクター。
      パラメーター:
      mongoDatabaseFactory - null であってはなりません。
    • ReactiveMongoTemplate

      public ReactiveMongoTemplate(ReactiveMongoDatabaseFactory mongoDatabaseFactory, @Nullable MongoConverter mongoConverter)
      基本的なテンプレート設定に使用されるコンストラクター。
      パラメーター:
      mongoDatabaseFactory - null であってはなりません。
      mongoConverter - null でもかまいません。
    • ReactiveMongoTemplate

      public ReactiveMongoTemplate(ReactiveMongoDatabaseFactory mongoDatabaseFactory, @Nullable MongoConverter mongoConverter, ConsumerSE<ThrowableSE> subscriptionExceptionHandler)
      基本的なテンプレート設定に使用されるコンストラクター。
      パラメーター:
      mongoDatabaseFactory - null であってはなりません。
      mongoConverter - null でもかまいません。
      subscriptionExceptionHandler - Publisher.subscribe(Subscriber) を介したリアクティブ型の実体化時に Flux.doOnError(Consumer) によって呼び出される例外ハンドラー。このコールバックは、たとえば Publisher のインデックス作成などのノンブロッキングサブスクリプション中に使用されます。null にすることはできません。
      導入:
      2.1
  • メソッドの詳細

    • setWriteResultChecking

      public void setWriteResultChecking(@Nullable WriteResultChecking resultChecking)
      WriteResultChecking をテンプレートで使用するように設定します。null を設定すると、デフォルトの DEFAULT_WRITE_RESULT_CHECKING がリセットされます。
      パラメーター:
      resultChecking -
    • setWriteConcern

      public void setWriteConcern(@Nullable com.mongodb.WriteConcern writeConcern)
      テンプレートで使用するために WriteConcern を設定します。何も設定されていない場合は、MongoDatabaseFactory で設定されている WriteConcern が適用されます。
      パラメーター:
      writeConcern - null でもかまいません。
    • setWriteConcernResolver

      public void setWriteConcernResolver(@Nullable WriteConcernResolver writeConcernResolver)
      テンプレートで使用するために WriteConcernResolver を構成します。
      パラメーター:
      writeConcernResolver - null でもかまいません。
    • setReadPreference

      public void setReadPreference(com.mongodb.ReadPreference readPreference)
      使用者
      無効な @link
      {@link {@link
      #prepareCollection(MongoCollection)} を使用して、操作を実行する前に ReadPreference を設定します。
      パラメーター:
      readPreference -
    • setEntityLifecycleEventsEnabled

      public void setEntityLifecycleEventsEnabled(boolean enabled)
      AfterLoadEventBeforeSaveEvent などのライフサイクルイベントを発行するかどうか、発行を抑制するかどうかを構成します。デフォルトで有効になっています。
      パラメーター:
      enabled - エンティティのライフサイクルイベントを有効にする true。エンティティのライフサイクルイベントを無効にする false
      導入:
      4.0
      関連事項:
    • setApplicationContext

      public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
      次で指定:
      インターフェース ApplicationContextAwaresetApplicationContext 
      例外:
      BeansException
    • setEntityCallbacks

      public void setEntityCallbacks(ReactiveEntityCallbacks entityCallbacks)
      ReactiveBeforeSaveCallback と同様に callbacks を呼び出すときに使用する ReactiveEntityCallbacks インスタンスを設定します。
      潜在的に存在する ReactiveEntityCallbacks をオーバーライドします。
      パラメーター:
      entityCallbacks - null であってはなりません。
      例外:
      IllegalArgumentExceptionSE - 指定されたインスタンスが null の場合。
      導入:
      2.2
    • useEstimatedCount

      public void useEstimatedCount(boolean enabled)
      推定回数を使用するかどうかを設定します。デフォルトは正確なカウントです。
      パラメーター:
      enabled - ページなしの場合は MongoCollection.estimatedDocumentCount() を使用し、true の場合は空の queries を使用します。
      導入:
      3.4
    • getConverter

      public MongoConverter getConverter()
      デフォルトの MongoConverter を返します。
      次で指定:
      インターフェース ReactiveMongoOperationsgetConverter 
      戻り値:
    • indexOps

      public ReactiveIndexOperations indexOps(StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      インデックスに対して実行できるリアクティブ操作を返します
      次で指定:
      インターフェース ReactiveMongoOperationsindexOps 
      パラメーター:
      collectionName - null であってはなりません。
      戻り値:
      名前付きコレクションに対するインデックス操作
    • indexOps

      public ReactiveIndexOperations indexOps(ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      インデックスに対して実行できるリアクティブ操作を返します
      次で指定:
      インターフェース ReactiveMongoOperationsindexOps 
      パラメーター:
      entityClass - null であってはなりません。
      戻り値:
      指定されたエンティティクラスに関連付けられた名前付きコレクションに対するインデックス操作
    • getCollectionName

      public StringSE getCollectionName(ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      このテンプレートによって指定されたクラスに使用されるコレクション名。
      次で指定:
      インターフェース ReactiveMongoOperationsgetCollectionName 
      パラメーター:
      entityClass - null であってはなりません。
      戻り値:
      決して null にはなりません。
    • executeCommand

      public Mono<org.bson.Document> executeCommand(StringSE jsonCommand)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      JSON 文字列として表現された MongoDB コマンドを実行します。これにより、MongoDB ドライバーの一部であるメソッド JSON.parse が呼び出され、JSON 文字列がドキュメントに変換されます。このコマンドの実行によって発生したエラーはすべて、Spring の DAO 例外階層に変換されます。
      次で指定:
      インターフェース ReactiveMongoOperationsexecuteCommand 
      パラメーター:
      jsonCommand - JSON 文字列として表現された MongoDB コマンド。
      戻り値:
      アクションによって返される結果オブジェクト
    • executeCommand

      public Mono<org.bson.Document> executeCommand(org.bson.Document command)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      MongoDB コマンドを実行します。このコマンドの実行によって発生するエラーはすべて、Spring の DAO 例外階層に変換されます。
      次で指定:
      インターフェース ReactiveMongoOperationsexecuteCommand 
      パラメーター:
      command - MongoDB コマンド。
      戻り値:
      アクションによって返される結果オブジェクト
    • executeCommand

      public Mono<org.bson.Document> executeCommand(org.bson.Document command, @Nullable com.mongodb.ReadPreference readPreference)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      MongoDB コマンドを実行します。このコマンドの実行によって発生したエラーは、Spring のデータアクセス例外階層に変換されます。
      次で指定:
      インターフェース ReactiveMongoOperationsexecuteCommand 
      パラメーター:
      command - MongoDB コマンドは null であってはなりません。
      readPreference - 使用する読み取り設定は、null にすることもできます。
      戻り値:
      アクションによって返される結果オブジェクト。
    • execute

      public <T> Flux<T> execute(ClassSE<?> entityClass, ReactiveCollectionCallback<T> action)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたクラスのエンティティコレクションに対して指定された ReactiveCollectionCallback を実行します。
      結果オブジェクト、つまりドメインオブジェクトまたはドメインオブジェクトのコレクションを返すことができます。
      次で指定:
      インターフェース ReactiveMongoOperationsexecute 
      型パラメーター:
      T - 戻りの型。
      パラメーター:
      entityClass - 使用するコレクションを決定するクラス。null であってはなりません。
      action - MongoDB アクションを指定するコールバックオブジェクト。null であってはなりません。
      戻り値:
      アクションによって返された結果オブジェクト、または null。
    • execute

      public <T> Flux<T> execute(ReactiveDatabaseCallback<T> action)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      必要に応じて例外を変換する ReactiveDatabaseCallback を実行します。
      結果オブジェクト、つまりドメインオブジェクトまたはドメインオブジェクトのコレクションを返すことができます。
      次で指定:
      インターフェース ReactiveMongoOperationsexecute 
      型パラメーター:
      T - 戻りの型。
      パラメーター:
      action - 渡された DB インスタンスに対して実行する MongoDB アクションを指定するコールバックオブジェクト。null であってはなりません。
      戻り値:
      アクションによって返される結果オブジェクト
    • execute

      public <T> Flux<T> execute(StringSE collectionName, ReactiveCollectionCallback<T> callback)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前のコレクションに対して指定された ReactiveCollectionCallback を実行します。
      結果オブジェクト、つまりドメインオブジェクトまたはドメインオブジェクトのコレクションを返すことができます。
      次で指定:
      インターフェース ReactiveMongoOperationsexecute 
      型パラメーター:
      T - 戻りの型。
      パラメーター:
      collectionName - どの MongoCollection インスタンスが渡されるかを指定するコレクションの名前。null または空であってはなりません。
      callback - MongoDB アクションのコールバックアクションを指定するコールバックオブジェクト。null であってはなりません。
      戻り値:
      アクションによって返された結果オブジェクト、または null。
    • withSession

      public ReactiveSessionScoped withSession(Publisher<com.mongodb.reactivestreams.client.ClientSession> sessionProvider)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された Publisher によって提供される ClientSession を MongoDB に対して発行されたすべてのコマンドにバインドする、ReactiveSessionScoped の session バインドインスタンスを取得します。
      ClientSession ライフサイクルの管理は呼び出し元が行います。完了したら ClientSession を処理するためのフックを提供するには、ReactiveSessionScoped.execute(ReactiveSessionCallback, Consumer) を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationswithSession 
      パラメーター:
      sessionProvider - null であってはなりません。
      戻り値:
      ReactiveSessionScoped の新しいインスタンス。null になることはありません。
    • setSessionSynchronization

      public void setSessionSynchronization(SessionSynchronization sessionSynchronization)
      ReactiveMongoTemplate がトランザクションに参加するかどうかを定義します。デフォルトは SessionSynchronization.ON_ACTUAL_TRANSACTION に設定されています。

      注意 : MongoDB トランザクションには少なくとも MongoDB 4.0 が必要です。

      導入:
      2.2
    • withSession

      public ReactiveMongoOperations withSession(com.mongodb.reactivestreams.client.ClientSession session)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      ReactiveMongoOperations の ClientSession バインドされたインスタンスを取得します。
      ClientSession ライフサイクルを管理するのは呼び出し元の責任です。
      次で指定:
      インターフェース ReactiveMongoOperationswithSession 
      戻り値:
      ClientSession ReactiveMongoOperations のバインドされたインスタンス。
    • withSession

      public ReactiveSessionScoped withSession(com.mongodb.ClientSessionOptions sessionOptions)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      MongoDB に対して発行されたすべてのコマンドに、指定された sessionOptions を持つ新しい ClientSession をバインドする SessionScoped の session バインドインスタンスを取得します。
      ClientSession ライフサイクルの管理は呼び出し元が行います。完了したら ClientSession を処理するためのフックを提供するには、ReactiveSessionScoped.execute(ReactiveSessionCallback, Consumer) を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationswithSession 
      パラメーター:
      sessionOptions - null であってはなりません。
      戻り値:
      ReactiveSessionScoped の新しいインスタンス。null になることはありません。
    • createFlux

      public <T> Flux<T> createFlux(ReactiveDatabaseCallback<T> callback)
      ReactiveDatabaseCallback 用に再利用可能な Flux を作成します。新しい Flux を取得するか、Flux を再利用するかは開発者の判断に委ねられます。
      パラメーター:
      callback - null であってはなりません
      戻り値:
      ReactiveDatabaseCallback をラップする Flux
    • createMono

      public <T> Mono<T> createMono(ReactiveDatabaseCallback<T> callback)
      ReactiveDatabaseCallback 用に再利用可能な Mono を作成します。新しい Flux を取得するか、Flux を再利用するかは開発者の判断に委ねられます。
      パラメーター:
      callback - null であってはなりません
      戻り値:
      ReactiveDatabaseCallback をラップする Mono
    • createFlux

      public <T> Flux<T> createFlux(StringSE collectionName, ReactiveCollectionCallback<T> callback)
      collectionName および ReactiveCollectionCallback 用に再利用可能な Flux を作成します。
      パラメーター:
      collectionName - 空または null であってはなりません。
      callback - null であってはなりません。
      戻り値:
      ReactiveCollectionCallback を包む再利用可能な Flux
    • createMono

      public <T> Mono<T> createMono(StringSE collectionName, ReactiveCollectionCallback<T> callback)
      collectionName および ReactiveCollectionCallback 用に再利用可能な Mono を作成します。
      型パラメーター:
      T -
      パラメーター:
      collectionName - 空または null であってはなりません。
      callback - null であってはなりません。
      戻り値:
      ReactiveCollectionCallback を包む再利用可能な Mono
    • createCollection

      public <T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      提供されたエンティティクラスに基づいた名前で上限のないコレクションを作成します。

      このメソッドは、Document および TimeSeries アノテーションを使用して、指定された entityClass から CollectionOptions を導出し、次のことを決定します。

      • 照合
      • TimeSeries の時間とメタフィールド、粒度と expireAfter
      変更ストリームオプション、スキーマベースの詳細 (検証、暗号化) などのその他のオプションは考慮されず、ReactiveMongoOperations.createCollection(Class, Function) または ReactiveMongoOperations.createCollection(Class, CollectionOptions) を通じて提供する必要があります。
      次で指定:
      インターフェース ReactiveMongoOperationscreateCollection 
      パラメーター:
      entityClass - 作成するコレクションを決定するクラス。
      戻り値:
      作成されたコレクション。
      関連事項:
    • createCollection

      public <T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass, FunctionSE<? super CollectionOptions, ? extends CollectionOptions> collectionOptionsCustomizer)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      提供されたエンティティクラスに基づいて名前を持つ、キャップなしのコレクションを作成し、派生した CollectionOptions をカスタマイズできるようにします。

      このメソッドは、Document および TimeSeries アノテーションを使用して、指定された entityClass から CollectionOptions を導出し、次のことを決定します。

      • 照合
      • TimeSeries の時間とメタフィールド、粒度と expireAfter
      変更ストリームオプション、スキーマベースの詳細 (検証、暗号化) などのその他のオプションは考慮されず、CollectionOptions を通じて提供される必要があります。
      次で指定:
      インターフェース ReactiveMongoOperationscreateCollection 
      パラメーター:
      entityClass - 作成するコレクションを決定するクラス。
      collectionOptionsCustomizer - 派生した CollectionOptions をカスタマイズするためのカスタマイザー関数。
      戻り値:
      作成されたコレクション。
      関連事項:
    • createCollection

      public <T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass, @Nullable CollectionOptions collectionOptions)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      オプションを使用して、指定されたエンティティクラスに基づく名前のコレクションを作成します。
      次で指定:
      インターフェース ReactiveMongoOperationscreateCollection 
      パラメーター:
      entityClass - 作成するコレクションを決定するクラス。null であってはなりません。
      collectionOptions - コレクションを作成するときに使用するオプション。
      戻り値:
      作成されたコレクション。
    • createCollection

      public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前で上限のないコレクションを作成します。
      次で指定:
      インターフェース ReactiveMongoOperationscreateCollection 
      パラメーター:
      collectionName - コレクションの名前。
      戻り値:
      作成されたコレクション。
    • createCollection

      public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(StringSE collectionName, @Nullable CollectionOptions collectionOptions)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前とオプションでコレクションを作成します。
      次で指定:
      インターフェース ReactiveMongoOperationscreateCollection 
      パラメーター:
      collectionName - コレクションの名前。null または空であってはなりません。
      collectionOptions - コレクションを作成するときに使用するオプション。
      戻り値:
      作成されたコレクション。
    • createView

      public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createView(StringSE name, ClassSE<?> source, AggregationPipeline pipeline, @Nullable ViewOptions options)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前でビューを作成します。ビューのコンテンツは、指定された source type によって識別される別のコレクションまたはビューの pipeline によって定義されます。
      次で指定:
      インターフェース ReactiveMongoOperationscreateView 
      パラメーター:
      name - 作成するビューの名前。
      source - ビューのソースコレクションを定義する型。
      pipeline - ビューのコンテンツを定義する AggregationPipeline
      options - ビューを作成するときに適用する追加設定。null にすることができます。
    • createView

      public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createView(StringSE name, StringSE source, AggregationPipeline pipeline, @Nullable ViewOptions options)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前でビューを作成します。ビューのコンテンツは、指定されたソースによって識別される別のコレクションまたはビューの pipeline によって定義されます。
      次で指定:
      インターフェース ReactiveMongoOperationscreateView 
      パラメーター:
      name - 作成するビューの名前。
      source - 作成するビューのソースを定義するコレクションまたはビューの名前。
      pipeline - ビューのコンテンツを定義する AggregationPipeline
      options - ビューを作成するときに適用する追加設定。null にすることができます。
    • doCreateView

      protected Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> doCreateView(StringSE name, StringSE source, ListSE<org.bson.Document> pipeline, @Nullable ViewOptions options)
    • getCollection

      public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> getCollection(StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      名前で MongoCollection を取得します。返されるコレクションはまだ存在しない可能性があり (ローカルメモリを除く)、サーバーとの最初のやり取りで作成されます。コレクションは、ReactiveMongoOperations.createCollection(Class) を介して明示的に作成できます。最初にコレクションが exists であるかどうかを確認します。
      必要に応じて例外を変換します。
      次で指定:
      インターフェース ReactiveMongoOperationsgetCollection 
      パラメーター:
      collectionName - コレクションの名前。
      戻り値:
      既存のコレクション、または最初のサーバーとのやり取りで作成されたコレクション。
    • collectionExists

      public <T> Mono<BooleanSE> collectionExists(ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスによって示された名前を持つコレクションが存在するかどうかを確認します。
      必要に応じて例外を変換します。
      次で指定:
      インターフェース ReactiveMongoOperationscollectionExists 
      パラメーター:
      entityClass - コレクションの名前を決定するクラス。null であってはなりません。
      戻り値:
      指定された名前のコレクションが見つかった場合は true、それ以外の場合は false。
    • collectionExists

      public Mono<BooleanSE> collectionExists(StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前のコレクションが存在するかどうかを確認します。
      必要に応じて例外を変換してください。
      次で指定:
      インターフェース ReactiveMongoOperationscollectionExists 
      パラメーター:
      collectionName - コレクションの名前。null であってはなりません。
      戻り値:
      指定された名前のコレクションが見つかった場合は true、それ以外の場合は false。
    • dropCollection

      public <T> Mono<VoidSE> dropCollection(ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスで指定された名前のコレクションをドロップします。
      必要に応じて例外を変換してください。
      次で指定:
      インターフェース ReactiveMongoOperationsdropCollection 
      パラメーター:
      entityClass - ドロップ / 削除するコレクションを決定するクラス。null であってはなりません。
    • dropCollection

      public Mono<VoidSE> dropCollection(StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された名前のコレクションをドロップします。
      必要に応じて例外を変換してください。
      次で指定:
      インターフェース ReactiveMongoOperationsdropCollection 
      パラメーター:
      collectionName - ドロップ / 削除するコレクションの名前。
    • bulkOps

      public ReactiveBulkOperations bulkOps(BulkOperations.BulkMode mode, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションの新しい ReactiveBulkOperations を返します。
      : フィールドマッピングなどの追加サポートは、ドメイン型情報が不足しているため、一括モードでの更新または削除操作には利用できません。完全な型固有のサポートを取得するには、ReactiveMongoOperations.bulkOps(BulkMode, Class, String) を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationsbulkOps 
      パラメーター:
      mode - 一括操作に使用する BulkOperations.BulkMode は null であってはなりません。
      collectionName - 作業するコレクションの名前は、null または空であってはなりません。
      戻り値:
      指定されたコレクションの ReactiveBulkOperations
    • bulkOps

      public ReactiveBulkOperations bulkOps(BulkOperations.BulkMode mode, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたエンティティ型の新しい ReactiveBulkOperations を返します。
      次で指定:
      インターフェース ReactiveMongoOperationsbulkOps 
      パラメーター:
      mode - 一括操作に使用する BulkOperations.BulkMode は null であってはなりません。
      entityClass - エンティティクラスの名前は null であってはなりません。
      戻り値:
      指定されたエンティティクラスに関連付けられた名前付きコレクションに対する ReactiveBulkOperations
    • bulkOps

      public ReactiveBulkOperations bulkOps(BulkOperations.BulkMode mode, @Nullable ClassSE<?> entityType, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたエンティティ型とコレクション名の新しい ReactiveBulkOperations を返します。
      次で指定:
      インターフェース ReactiveMongoOperationsbulkOps 
      パラメーター:
      mode - 一括操作に使用する BulkOperations.BulkMode は null であってはなりません。
      entityType - エンティティクラスの名前。null にすることもできます。
      collectionName - 作業するコレクションの名前は、null または空であってはなりません。
      戻り値:
      指定されたエンティティクラスに関連付けられた名前付きコレクションに対する ReactiveBulkOperations
    • getCollectionNames

      public Flux<StringSE> getCollectionNames()
      インターフェースからコピーされた説明: ReactiveMongoOperations
      コレクション名のセット。
      次で指定:
      インターフェース ReactiveMongoOperationsgetCollectionNames 
      戻り値:
      コレクション名の Flux。
    • getMongoDatabase

      public Mono<com.mongodb.reactivestreams.client.MongoDatabase> getMongoDatabase()
    • doGetDatabase

      protected Mono<com.mongodb.reactivestreams.client.MongoDatabase> doGetDatabase()
    • findOne

      public <T> Mono<T> findOne(Query query, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationsfindOne 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。
      entityClass - 返される Mono のパラメーター化された型。
      戻り値:
      変換されたオブジェクト。
    • findOne

      public <T> Mono<T> findOne(Query query, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。他に構成されていない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationsfindOne 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。
      entityClass - 返される Mono のパラメーター化された型。
      collectionName - オブジェクトを取得するコレクションの名前。
      戻り値:
      変換されたオブジェクト。
    • exists

      public Mono<BooleanSE> exists(Query query, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された Query の結果に少なくとも 1 つの要素が含まれるかを判定します。
      次で指定:
      インターフェース ReactiveMongoOperationsexists 
      パラメーター:
      query - ドキュメントの検索に使用される条件を指定する Query クラス。
      entityClass - パラメーター化された型。
      戻り値:
      クエリが結果を生成する場合は true。
    • exists

      public Mono<BooleanSE> exists(Query query, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された Query の結果に少なくとも 1 つの要素が含まれるかを判定します。
      : ドメイン型情報が不足しているため、クエリ / フィールドマッピングなどの追加サポートは利用できません。完全な型固有のサポートを取得するには、ReactiveMongoOperations.exists(Query, Class, String) を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationsexists 
      パラメーター:
      query - ドキュメントの検索に使用される条件を指定する Query クラス。
      collectionName - オブジェクトをチェックするコレクションの名前。
      戻り値:
      クエリが結果を生成する場合は true。
    • exists

      public Mono<BooleanSE> exists(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された Query の結果に少なくとも 1 つの要素が含まれるかを判定します。
      次で指定:
      インターフェース ReactiveMongoOperationsexists 
      パラメーター:
      query - ドキュメントの検索に使用される条件を指定する Query クラス。
      entityClass - パラメーター化された型。null にすることもできます。
      collectionName - オブジェクトをチェックするコレクションの名前。
      戻り値:
      クエリが結果を生成する場合は true。
    • find

      public <T> Flux<T> find(Query query, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型の Flux にマップします。
      オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、これは BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationsfind 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。
      entityClass - 返される Flux のパラメーター化された型。null であってはなりません。
      戻り値:
      変換されたオブジェクトの Flux
    • find

      public <T> Flux<T> find(@Nullable Query query, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションに対するアドホッククエリの結果を、指定された型の Flux にマップします。
      オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、これは BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationsfind 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。
      entityClass - 返される Flux のパラメーター化された型。
      collectionName - オブジェクトを取得するコレクションの名前。null であってはなりません。
      戻り値:
      変換されたオブジェクトの Flux
    • scroll

      public <T> Mono<Window<T>> scroll(Query query, ClassSE<T> entityType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから型 T のオブジェクトのスクロールを照会します。
      効率的なスクロールのために大きなクエリ結果を制限するために、Query.skip(long) または Query.with(KeysetScrollPosition)Query.limit(int) とともに必ず設定してください。
      結果オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定されていない限り、MappingMongoConverter のインスタンスが使用されます。
      コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。

      KeysetScrollPosition を使用する場合は、MongoDB が $gt/$lt 演算子を使用して存在しないドキュメントフィールドまたは null 値からクエリ結果を再構築するための条件をサポートしていないため、null 非許容の sort properties を必ず使用してください。

      次で指定:
      インターフェース ReactiveMongoOperationsscroll 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。
      entityType - 返されるリストのパラメーター化された型。
      戻り値:
      変換されたウィンドウを放出する Mono
      関連事項:
    • scroll

      public <T> Mono<Window<T>> scroll(Query query, ClassSE<T> entityType, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから型 T のオブジェクトのウィンドウを照会します。
      効率的なスクロールのために大きなクエリ結果を制限するために、Query.skip(long) または Query.with(KeysetScrollPosition)Query.limit(int) とともに必ず設定してください。
      結果オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定されていない限り、MappingMongoConverter のインスタンスが使用されます。
      コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。

      KeysetScrollPosition を使用する場合は、MongoDB が $gt/$lt 演算子を使用して存在しないドキュメントフィールドまたは null 値からクエリ結果を再構築するための条件をサポートしていないため、null 非許容の sort properties を必ず使用してください。

      次で指定:
      インターフェース ReactiveMongoOperationsscroll 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。
      entityType - 返されるリストのパラメーター化された型。
      collectionName - オブジェクトを取得するコレクションの名前。
      戻り値:
      変換されたウィンドウを放出する Mono
      関連事項:
    • findById

      public <T> Mono<T> findById(ObjectSE id, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたクラスにマップされた指定された ID を持つドキュメントを返します。クエリが実行されるコレクションも、指定されたターゲットクラスから派生します。
      次で指定:
      インターフェース ReactiveMongoOperationsfindById 
      パラメーター:
      id - 返されるドキュメントの ID。null であってはなりません。
      entityClass - ドキュメントが変換される型。null であってはなりません。
      戻り値:
      指定されたターゲットクラスにマップされた指定された ID を持つドキュメント。
    • findById

      public <T> Mono<T> findById(ObjectSE id, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたターゲットクラスにマップされた指定されたコレクションから指定された ID を持つドキュメントを返します。
      次で指定:
      インターフェース ReactiveMongoOperationsfindById 
      パラメーター:
      id - 返されるドキュメントの ID。
      entityClass - ドキュメントを変換する型。
      collectionName - ドキュメントをクエリするコレクション。
      戻り値:
      変換されたオブジェクト。
    • findDistinct

      public <T> Flux<T> findDistinct(Query query, StringSE field, ClassSE<?> entityClass, ClassSE<T> resultClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      単一の MongoCollection またはビュー全体で指定されたフィールドの個別の値を検索し、その結果を Flux に返します。
      次で指定:
      インターフェース ReactiveMongoOperationsfindDistinct 
      パラメーター:
      query - Query をフィルターして検索を制限します。null であってはなりません。
      field - 個別の値をインスペクションするフィールドの名前。null であってはなりません。
      entityClass - 実際の MongoCollection を決定し、Query をドメイン型 フィールドにマッピングするために使用されるドメイン型。null にすることはできません。
      resultClass - 結果の型。null であってはなりません。
      戻り値:
      決して null にはなりません。
    • findDistinct

      public <T> Flux<T> findDistinct(Query query, StringSE field, StringSE collectionName, ClassSE<?> entityClass, ClassSE<T> resultClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      単一の MongoCollection またはビュー全体で指定されたフィールドの個別の値を検索し、その結果を Flux に返します。
      次で指定:
      インターフェース ReactiveMongoOperationsfindDistinct 
      パラメーター:
      query - Query をフィルターして検索を制限します。null であってはなりません。
      field - 個別の値をインスペクションするフィールドの名前。null であってはなりません。
      collectionName - 実際の MongoCollection の明示的な名前。null であってはなりません。
      entityClass - Query をドメイン型 フィールドにマッピングするために使用されるドメイン型。
      resultClass - 結果の型。null であってはなりません。
      戻り値:
      決して null にはなりません。
    • aggregate

      public <O> Flux<O> aggregate(TypedAggregation<?> aggregation, StringSE inputCollectionName, ClassSE<O> outputType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      集計操作を実行します。

      生の結果は指定されたエンティティクラスにマッピングされます。

      集約ストリーミングは、aggregation explain でも AggregationOptions.getCursorBatchSize() でも使用できません。説明モードを有効にするか、バッチサイズを設定すると、IllegalArgumentExceptionSE が発生します。

      次で指定:
      インターフェース ReactiveMongoOperationsaggregate 
      パラメーター:
      aggregation - 集計操作を保持する TypedAggregation 仕様。null にすることはできません。
      inputCollectionName - 集計に使用する入力コレクションの名前。null にすることはできません。
      outputType - 返される Flux のパラメーター化された型。null にすることはできません。
      戻り値:
      集計操作の結果。
    • aggregate

      public <O> Flux<O> aggregate(TypedAggregation<?> aggregation, ClassSE<O> outputType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      集計操作を実行します。
      生の結果は指定されたエンティティクラスにマップされ、ストリームとして返されます。inputCollection の名前は aggregation input type から派生しています。
      集約ストリーミングは、aggregation explain または AggregationOptions.getCursorBatchSize() では使用できません。説明モードを有効にするか、バッチサイズを設定すると、IllegalArgumentExceptionSE が発生します。
      次で指定:
      インターフェース ReactiveMongoOperationsaggregate 
      パラメーター:
      aggregation - 集計操作を保持する TypedAggregation 仕様。null にすることはできません。
      outputType - 返される Flux のパラメーター化された型。null にすることはできません。
      戻り値:
      集計操作の結果。
    • aggregate

      public <O> Flux<O> aggregate(Aggregation aggregation, ClassSE<?> inputType, ClassSE<O> outputType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      集計操作を実行します。
      生の結果は指定された ouputType にマッピングされます。inputCollection の名前は inputType から派生したものです。
      集約ストリーミングは、aggregation explain でも AggregationOptions.getCursorBatchSize() でも使用できません。説明モードを有効にするか、バッチサイズを設定すると、IllegalArgumentExceptionSE が発生します。
      次で指定:
      インターフェース ReactiveMongoOperationsaggregate 
      パラメーター:
      aggregation - 集計操作を保持する Aggregation 仕様。null にすることはできません。
      inputType - 集計操作が読み取られる inputType。null にすることはできません。
      outputType - 返される Flux のパラメーター化された型。null にすることはできません。
      戻り値:
      集計操作の結果。
    • aggregate

      public <O> Flux<O> aggregate(Aggregation aggregation, StringSE collectionName, ClassSE<O> outputType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      集計操作を実行します。
      生の結果は指定されたエンティティクラスにマッピングされます。
      集約ストリーミングは、aggregation explain でも AggregationOptions.getCursorBatchSize() でも使用できません。説明モードを有効にするか、バッチサイズを設定すると、IllegalArgumentExceptionSE が発生します。
      次で指定:
      インターフェース ReactiveMongoOperationsaggregate 
      パラメーター:
      aggregation - 集計操作を保持する Aggregation 仕様。null にすることはできません。
      collectionName - 集計操作が読み取られるコレクション。null または空であってはなりません。
      outputType - 返される Flux のパラメーター化された型。null にすることはできません。
      戻り値:
      集計操作の結果。
    • doAggregate

      protected <O> Flux<O> doAggregate(Aggregation aggregation, StringSE collectionName, @Nullable ClassSE<?> inputType, ClassSE<O> outputType)
    • geoNear

      public <T> Flux<GeoResult<T>> geoNear(NearQuery near, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された NearQuery に一致するすべてのエンティティの GeoResult のうち Flux を返します。クエリの実行対象となるコレクションを決定するために、エンティティマッピング情報が考慮されます。MongoDB はデフォルトで結果件数に制限を設けています。特定の件数の結果が予想される場合は、NearQuery に明示的な制限を追加してください。

      MongoDB 4.2 では、geoNear コマンドが削除されました。このメソッドは、バージョン 2.2 以降の集計と $geoNear 集計コマンドを使用して、geoNear コマンドの機能をエミュレートします。集計を直接使用することをお勧めします。

      TypedAggregation<T> geoNear = TypedAggregation.newAggregation(entityClass, Aggregation.geoNear(near, "dis"))
                      .withOptions(AggregationOptions.builder().collation(near.getCollation()).build());
      Flux<Document> results = aggregate(geoNear, Document.class);
      
      次で指定:
      インターフェース ReactiveMongoOperationsgeoNear 
      パラメーター:
      near - null であってはなりません。
      entityClass - null であってはなりません。
      戻り値:
      変換された GeoResult s。
    • geoNear

      public <T> Flux<GeoResult<T>> geoNear(NearQuery near, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された NearQuery に一致するすべてのエンティティの GeoResult のうち Flux を返します。MongoDB はデフォルトで結果件数に制限を設けていることに注意してください。特定の件数の結果が期待される場合は、NearQuery に明示的な制限を追加してください。

      MongoDB 4.2 では、geoNear コマンドが削除されました。このメソッドは、バージョン 2.2 以降の集計と $geoNear 集計コマンドを使用して、geoNear コマンドの機能をエミュレートします。集計を直接使用することをお勧めします。

      TypedAggregation<T> geoNear = TypedAggregation.newAggregation(entityClass, Aggregation.geoNear(near, "dis"))
                      .withOptions(AggregationOptions.builder().collation(near.getCollation()).build());
      Flux<Document> results = aggregate(geoNear, Document.class);
      
      次で指定:
      インターフェース ReactiveMongoOperationsgeoNear 
      パラメーター:
      near - null であってはなりません。
      entityClass - null であってはなりません。
      collectionName - クエリをトリガーするコレクション。コレクション名が指定されていない場合は、エンティティクラスがインスペクションされます。
      戻り値:
      変換された GeoResult s。
    • geoNear

      protected <T> Flux<GeoResult<T>> geoNear(NearQuery near, ClassSE<?> entityClass, StringSE collectionName, ClassSE<T> returnType)
    • findAndModify

      public <T> Mono<T> findAndModify(Query query, UpdateDefinition update, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      findAndModify をトリガーして、指定された QueryCriteria に一致するドキュメントに指定された Update を適用します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsfindAndModify 
      パラメーター:
      query - ドキュメントの検索に使用される Criteria とオプションのフィールド仕様を指定する Query クラス。null にすることはできません。
      update - 一致するドキュメントに適用する UpdateDefinition。null にすることはできません。
      entityClass - パラメーター化された型。null であってはなりません。
      戻り値:
      更新される前に更新された変換されたオブジェクト。
      関連事項:
    • findAndModify

      public <T> Mono<T> findAndModify(Query query, UpdateDefinition update, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      findAndModify をトリガーして、指定された QueryCriteria に一致するドキュメントに指定された Update を適用します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsfindAndModify 
      パラメーター:
      query - ドキュメントの検索に使用される Criteria とオプションのフィールド仕様を指定する Query クラス。null にすることはできません。
      update - 一致するドキュメントに適用する UpdateDefinition。null にすることはできません。
      entityClass - パラメーター化された型。null であってはなりません。
      collectionName - クエリするコレクション。null にすることはできません。
      戻り値:
      更新される前に更新された変換されたオブジェクト。
      関連事項:
    • findAndModify

      public <T> Mono<T> findAndModify(Query query, UpdateDefinition update, FindAndModifyOptions options, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      findAndModify をトリガーして、FindAndModifyOptions を考慮して、指定された QueryCriteria に一致するドキュメントに指定された Update を適用します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsfindAndModify 
      パラメーター:
      query - ドキュメントの検索に使用される Criteria とオプションのフィールド仕様を指定する Query クラス。
      update - 一致するドキュメントに適用する UpdateDefinition
      options - 追加情報を保持する FindAndModifyOptions
      entityClass - パラメーター化された型。
      戻り値:
      更新された変換されたオブジェクト。FindAndModifyOptions.isReturnNew() の値に応じて、更新前のオブジェクトまたは更新後のオブジェクトになります。
      関連事項:
    • findAndModify

      public <S,T> Mono<T> findAndModify(Query query, UpdateDefinition update, FindAndModifyOptions options, ClassSE<S> entityClass, StringSE collectionName, QueryResultConverter<? super S, ? extends T> resultConverter)
    • findAndModify

      public <T> Mono<T> findAndModify(Query query, UpdateDefinition update, FindAndModifyOptions options, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      findAndModify をトリガーして、FindAndModifyOptions を考慮して、指定された QueryCriteria に一致するドキュメントに指定された Update を適用します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsfindAndModify 
      パラメーター:
      query - ドキュメントの検索に使用される Criteria とオプションのフィールド仕様を指定する Query クラス。null にすることはできません。
      update - 一致するドキュメントに適用する UpdateDefinition。null にすることはできません。
      options - 追加情報を保持する FindAndModifyOptions。null にすることはできません。
      entityClass - パラメーター化された型。null であってはなりません。
      collectionName - クエリするコレクション。null にすることはできません。
      戻り値:
      更新された変換されたオブジェクト。FindAndModifyOptions.isReturnNew() の値に応じて、更新前のオブジェクトまたは更新後のオブジェクトになります。
      関連事項:
    • findAndReplace

      public <S,T> Mono<T> findAndReplace(Query query, S replacement, FindAndReplaceOptions options, ClassSE<S> entityType, StringSE collectionName, ClassSE<T> resultType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      findOneAndReplace をトリガーして、指定された QueryCriteria に一致する単一のドキュメントを、FindAndReplaceOptions を考慮して replacement ドキュメントに置き換えます。
      注意 : 置換エンティティは ID を保持してはなりません。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAndReplace 
      パラメーター:
      query - ドキュメントの検索に使用される Criteria とオプションのフィールド仕様を指定する Query クラス。null にすることはできません。
      replacement - 置換ドキュメント。null にすることはできません。
      options - 追加情報を保持する FindAndModifyOptions。null にすることはできません。
      entityType - Query をドメイン型 フィールドにマッピングし、そこからコレクションを派生するために使用される型。null にすることはできません。
      collectionName - クエリするコレクション。null にすることはできません。
      resultType - resultType はパラメーター化された型射影の戻り型です。null であってはなりません。代わりに Object.class のドメイン型を使用してください。
      戻り値:
      更新された変換済みオブジェクト、または見つからない場合は Mono.empty()FindAndReplaceOptions.isReturnNew() の値に応じて、更新前のオブジェクトまたは更新後のオブジェクトになります。
    • findAndReplace

      public <S,T,R> Mono<R> findAndReplace(Query query, S replacement, FindAndReplaceOptions options, ClassSE<S> entityType, StringSE collectionName, ClassSE<T> resultType, QueryResultConverter<? super T, ? extends R> resultConverter)
    • findAndRemove

      public <T> Mono<T> findAndRemove(Query query, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティ型のコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。クエリに一致する最初のドキュメントが返され、データベースのコレクションからも削除されます。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。
      クエリは Query として指定され、BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAndRemove 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。
      entityClass - 返される Mono のパラメーター化された型。
      戻り値:
      変換されたオブジェクト
    • findAndRemove

      public <T> Mono<T> findAndRemove(Query query, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。クエリに一致する最初のドキュメントが返され、データベースのコレクションからも削除されます。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAndRemove 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。
      entityClass - 返される Mono のパラメーター化された型。
      collectionName - オブジェクトを取得するコレクションの名前。
      戻り値:
      変換されたオブジェクト。
    • count

      public Mono<LongSE> count(Query query, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたエンティティクラスのコレクションを照会して、指定された Query のドキュメントの数を返します。
      : クエリ offset および limit は、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
      この方法では、パフォーマンスに影響を与える可能性のある aggregation execution を実行する代わりに、空のクエリに対して ReactiveMongoOperations.estimatedCount(Class) を使用することを選択する場合があります。
      次で指定:
      インターフェース ReactiveMongoOperationscount 
      パラメーター:
      query - ドキュメントの検索に使用する条件を指定する Query クラス。null にすることはできません。
      entityClass - 使用するコレクションを決定するクラス。null であってはなりません。
      戻り値:
      一致するドキュメントの数。
      関連事項:
    • count

      public Mono<LongSE> count(Query query, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションを照会する指定された Query のドキュメントの数を返します。指定された Query は、潜在的なプロパティ参照をドキュメントフィールドにマップするための型情報がないため、ドキュメントフィールド参照のみで構成されている必要があります。完全な型固有のサポートを得るには、ReactiveMongoOperations.count(Query, Class, String) を使用します。
      : クエリ offset および limit は、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
      この方法では、パフォーマンスに影響を与える可能性のある aggregation execution を実行する代わりに、空のクエリに対して ReactiveMongoOperations.estimatedCount(Class) を使用することを選択する場合があります。
      次で指定:
      インターフェース ReactiveMongoOperationscount 
      パラメーター:
      query - ドキュメントの検索に使用する条件を指定する Query クラス。
      collectionName - null または空であってはなりません。
      戻り値:
      一致するドキュメントの数。
      関連事項:
    • count

      public Mono<LongSE> count(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたエンティティクラスを使用して指定されたコレクションを照会し、指定された Query をマップすることにより、指定された Query のドキュメントの数を返します。
      : クエリ offset および limit は、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
      この方法では、パフォーマンスに影響を与える可能性のある aggregation execution を実行する代わりに、空のクエリに対して ReactiveMongoOperations.estimatedCount(Class) を使用することを選択する場合があります。
      次で指定:
      インターフェース ReactiveMongoOperationscount 
      パラメーター:
      query - ドキュメントの検索に使用する条件を指定する Query クラス。null にすることはできません。
      entityClass - パラメーター化された型。null にすることもできます。
      collectionName - null または空であってはなりません。
      戻り値:
      一致するドキュメントの数。
      関連事項:
    • doCount

      protected Mono<LongSE> doCount(StringSE collectionName, org.bson.Document filter, com.mongodb.client.model.CountOptions options)
      指定された名前のコレクションに対して実際のカウント操作を実行します。
      パラメーター:
      collectionName - 一致するドキュメントをカウントするコレクションの名前。
      filter - 適用するフィルター。null にすることはできません。
      options - 適用するオプション。照合など。
      戻り値:
    • estimatedCount

      public Mono<LongSE> estimatedCount(StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      コレクションの統計に基づいて、指定されたコレクション内のドキュメントの数を推定します。
      シャードクラスターや内部トランザクションなどの制限については、MongoDB リファレンスドキュメントを必ず参照してください。
      次で指定:
      インターフェース ReactiveMongoOperationsestimatedCount 
      パラメーター:
      collectionName - null であってはなりません。
      戻り値:
      推定されたドキュメント数を発行する Mono
    • doEstimatedCount

      protected Mono<LongSE> doEstimatedCount(StringSE collectionName, com.mongodb.client.model.EstimatedDocumentCountOptions options)
    • exactCount

      public Mono<LongSE> exactCount(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたエンティティクラスを使用して指定されたコレクションを照会し、指定された Query をマップすることにより、指定された Query のドキュメントの数を返します。
      : クエリ offset および limit は、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
      この方法では、空の queries に対しても aggregation execution が使用されるため、パフォーマンスに影響する可能性がありますが、シャード、セッション、トランザクションのコンプライアンスが保証されます。不正確なカウントがアプリケーションのニーズを満たす場合は、代わりに空のクエリに対して ReactiveMongoOperations.estimatedCount(String) を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationsexactCount 
      パラメーター:
      query - ドキュメントの検索に使用する条件を指定する Query クラス。null にすることはできません。
      entityClass - パラメーター化された型。null にすることもできます。
      collectionName - null または空であってはなりません。
      戻り値:
      一致するドキュメントの数。
    • doExactCount

      protected Mono<LongSE> doExactCount(StringSE collectionName, org.bson.Document filter, com.mongodb.client.model.CountOptions options)
    • countCanBeEstimated

      protected Mono<BooleanSE> countCanBeEstimated(org.bson.Document filter, com.mongodb.client.model.CountOptions options)
    • insert

      public <T> Mono<T> insert(Mono<? extends T> objectToSave)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      保存するオブジェクトのエンティティ型のコレクションにオブジェクトを挿入します。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。
      オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。
      Insert は、オブジェクトを最初にデータベースに保存するために使用されます。既存のオブジェクトを更新するには、save メソッドを使用します。

      潜在的な Version プロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。

      次で指定:
      インターフェース ReactiveMongoOperationsinsert 
      パラメーター:
      objectToSave - コレクションに格納するオブジェクト。null にすることはできません。
      戻り値:
      挿入されたオブジェクト。
    • insertAll

      public <T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> batchToSave, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      データベースへの 1 回のバッチ書き込みで、オブジェクトのコレクションをコレクションに挿入します。

      バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      次で指定:
      インターフェース ReactiveMongoOperationsinsertAll 
      パラメーター:
      batchToSave - 保存するオブジェクトを提供する発行者。null にすることはできません。
      entityClass - 使用するコレクションを決定するクラス。null であってはなりません。
      戻り値:
      挿入されたオブジェクト。
    • insertAll

      public <T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> batchToSave, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      データベースへの単一のバッチ書き込みで、指定されたコレクションにオブジェクトを挿入します。

      バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      次で指定:
      インターフェース ReactiveMongoOperationsinsertAll 
      パラメーター:
      batchToSave - 保存するオブジェクトを提供する発行者。null にすることはできません。
      collectionName - オブジェクトを格納するコレクションの名前。null にすることはできません。
      戻り値:
      挿入されたオブジェクト。
    • insert

      public <T> Mono<T> insert(T objectToSave)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      保存するオブジェクトのエンティティ型のコレクションにオブジェクトを挿入します。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。
      オブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。Id プロパティが文字列の場合、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。
      Insert は、オブジェクトを最初にデータベースに保存するために使用されます。既存のオブジェクトを更新するには、save メソッドを使用します。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      objectToSave はコレクションのようなものであってはなりません。

      次で指定:
      インターフェース ReactiveMongoOperationsinsert 
      パラメーター:
      objectToSave - コレクションに格納するオブジェクト。null にすることはできません。
      戻り値:
      挿入されたオブジェクト。
    • insert

      public <T> Mono<T> insert(T objectToSave, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションにオブジェクトを挿入します。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      Insert は、オブジェクトを最初にデータベースに保存するために使用されます。既存のオブジェクトを更新するには、save メソッドを使用します。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      objectToSave はコレクションのようなものであってはなりません。

      次で指定:
      インターフェース ReactiveMongoOperationsinsert 
      パラメーター:
      objectToSave - コレクションに格納するオブジェクト。null にすることはできません。
      collectionName - オブジェクトを格納するコレクションの名前。null にすることはできません。
      戻り値:
      挿入されたオブジェクト。
    • doInsert

      protected <T> Mono<T> doInsert(StringSE collectionName, T objectToSave, MongoWriter<ObjectSE> writer)
    • insert

      public <T> Flux<T> insert(CollectionSE<? extends T> batchToSave, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      データベースへの 1 回のバッチ書き込みで、オブジェクトのコレクションをコレクションに挿入します。

      バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      次で指定:
      インターフェース ReactiveMongoOperationsinsert 
      パラメーター:
      batchToSave - 保存するオブジェクトのバッチ。null にすることはできません。
      entityClass - 使用するコレクションを決定するクラス。null であってはなりません。
      戻り値:
      挿入されたオブジェクト。
    • insert

      public <T> Flux<T> insert(CollectionSE<? extends T> batchToSave, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      データベースへの単一のバッチ書き込みで、指定されたコレクションにオブジェクトのバッチを挿入します。

      バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      次で指定:
      インターフェース ReactiveMongoOperationsinsert 
      パラメーター:
      batchToSave - 保存するオブジェクトのリスト。null にすることはできません。
      collectionName - オブジェクトを格納するコレクションの名前。null にすることはできません。
      戻り値:
      挿入されたオブジェクト。
    • insertAll

      public <T> Flux<T> insertAll(CollectionSE<? extends T> objectsToSave)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      オブジェクトの混合コレクションをデータベースコレクションに挿入し、クラスに基づいて使用するコレクション名を決定します。

      バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      次で指定:
      インターフェース ReactiveMongoOperationsinsertAll 
      パラメーター:
      objectsToSave - 保存するオブジェクトのリスト。null にすることはできません。
      戻り値:
      保存されたオブジェクト。
    • insertAll

      public <T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> objectsToSave)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      オブジェクトの混合コレクションをデータベースコレクションに挿入し、クラスに基づいて使用するコレクション名を決定します。

      バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。

      新しいオブジェクトを挿入すると、Version プロパティの初期化がトリガーされます。

      次で指定:
      インターフェース ReactiveMongoOperationsinsertAll 
      パラメーター:
      objectsToSave - 保存するオブジェクトを提供する発行者。null にすることはできません。
      戻り値:
      挿入されたオブジェクト。
    • doInsertAll

      protected <T> Flux<T> doInsertAll(CollectionSE<? extends T> listToSave, MongoWriter<ObjectSE> writer)
    • doInsertBatch

      protected <T> Flux<T> doInsertBatch(StringSE collectionName, CollectionSE<? extends T> batchToSave, MongoWriter<ObjectSE> writer)
    • save

      public <T> Mono<T> save(Mono<? extends T> objectToSave)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      保存するオブジェクトのエンティティ型のコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入 (つまり、"upsert" ) が実行されます。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。

      潜在的な Version プロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。

      次で指定:
      インターフェース ReactiveMongoOperationssave 
      パラメーター:
      objectToSave - コレクションに格納するオブジェクト。null にすることはできません。
      戻り値:
      保存されたオブジェクト。
    • save

      public <T> Mono<T> save(Mono<? extends T> objectToSave, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入、つまり "upsert" が実行されます。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。

      潜在的な Version プロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。

      次で指定:
      インターフェース ReactiveMongoOperationssave 
      パラメーター:
      objectToSave - collReactiveMongoOperationsection に格納するオブジェクト。null にすることはできません。
      collectionName - オブジェクトを格納するコレクションの名前。null にすることはできません。
      戻り値:
      保存されたオブジェクト。
    • save

      public <T> Mono<T> save(T objectToSave)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      保存するオブジェクトのエンティティ型のコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入 (つまり、"upsert" ) が実行されます。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。

      潜在的な Version プロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。

      objectToSave はコレクションのようなものであってはなりません。

      次で指定:
      インターフェース ReactiveMongoOperationssave 
      パラメーター:
      objectToSave - コレクションに格納するオブジェクト。null にすることはできません。
      戻り値:
      保存されたオブジェクト。
    • save

      public <T> Mono<T> save(T objectToSave, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入、つまり "upsert" が実行されます。
      オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverter のインスタンスが使用されます。
      オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。

      潜在的な Version プロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。

      次で指定:
      インターフェース ReactiveMongoOperationssave 
      パラメーター:
      objectToSave - コレクションに格納するオブジェクト。null にすることはできません。
      collectionName - オブジェクトを格納するコレクションの名前。null にすることはできません。
      戻り値:
      保存されたオブジェクト。
    • doSave

      protected <T> Mono<T> doSave(StringSE collectionName, T objectToSave, MongoWriter<ObjectSE> writer)
    • insertDocument

      protected Mono<ObjectSE> insertDocument(StringSE collectionName, org.bson.Document dbDoc, ClassSE<?> entityClass)
    • insertDocumentList

      protected Flux<org.bson.types.ObjectId> insertDocumentList(StringSE collectionName, ListSE<org.bson.Document> dbDocList)
    • saveDocument

      protected Mono<ObjectSE> saveDocument(StringSE collectionName, org.bson.Document document, ClassSE<?> entityClass)
    • upsert

      public Mono<com.mongodb.client.result.UpdateResult> upsert(Query query, UpdateDefinition update, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      アップサートを実行します。クエリに一致するドキュメントが見つからない場合は、クエリドキュメントと更新ドキュメントを組み合わせて新しいドキュメントが作成され、挿入されます。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      注意 : sorting は db.collection.updateOne ではサポートされていません。代わりに ReactiveMongoOperations.findAndModify(Query, UpdateDefinition, Class) を使用してください。

      次で指定:
      インターフェース ReactiveMongoOperationsupsert 
      パラメーター:
      query - アップサートするドキュメントを選択するために使用される条件を指定するクエリドキュメント。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition、または既存のオブジェクトを操作するための $ 演算子。null にすることはできません。
      entityClass - 使用するコレクションを決定するクラス。null であってはなりません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • upsert

      public Mono<com.mongodb.client.result.UpdateResult> upsert(Query query, UpdateDefinition update, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      アップサートを実行します。クエリに一致するドキュメントが見つからない場合は、クエリドキュメントと更新ドキュメントを組み合わせて新しいドキュメントが作成され、挿入されます。
      : ドメイン型情報が不足しているため、フィールドマッピング、バージョンなどの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.upsert(Query, UpdateDefinition, Class, String) を使用してください。
      次で指定:
      インターフェース ReactiveMongoOperationsupsert 
      パラメーター:
      query - アップサートするドキュメントを選択するために使用される条件を指定するクエリドキュメント。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition、または既存のオブジェクトを操作するための $ 演算子。null にすることはできません。
      collectionName - オブジェクトを更新するコレクションの名前。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • upsert

      public Mono<com.mongodb.client.result.UpdateResult> upsert(Query query, UpdateDefinition update, ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      アップサートを実行します。クエリに一致するドキュメントが見つからない場合は、クエリドキュメントと更新ドキュメントを組み合わせて新しいドキュメントが作成され、挿入されます。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsupsert 
      パラメーター:
      query - アップサートするドキュメントを選択するために使用される条件を指定するクエリドキュメント。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition、または既存のオブジェクトを操作するための $ 演算子。null にすることはできません。
      entityClass - 操作対象となる pojo のクラス。null にすることはできません。
      collectionName - オブジェクトを更新するコレクションの名前。null にすることはできません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • updateFirst

      public Mono<com.mongodb.client.result.UpdateResult> updateFirst(Query query, UpdateDefinition update, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      クエリドキュメントと一致するエンティティクラスのコレクション内で見つかった最初のオブジェクトを、指定された更新ドキュメントで更新します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsupdateFirst 
      パラメーター:
      query - 更新するドキュメントを選択するために使用される条件を指定するクエリドキュメント。Query は、複数の候補に一致する可能性がある場合に更新するドキュメントに影響を与える sort order を定義する場合があります。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition または既存のオブジェクトを操作する $ 演算子。null にすることはできません。
      entityClass - 使用するコレクションを決定するクラス。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • updateFirst

      public Mono<com.mongodb.client.result.UpdateResult> updateFirst(Query query, UpdateDefinition update, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクション内で、クエリドキュメントの条件に一致する最初のオブジェクトを、提供された更新されたドキュメントに更新します。
      : ドメイン型情報が不足しているため、フィールドマッピング、バージョンなどの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.updateFirst(Query, UpdateDefinition, Class, String) を使用してください。
      次で指定:
      インターフェース ReactiveMongoOperationsupdateFirst 
      パラメーター:
      query - 更新するドキュメントを選択するために使用される条件を指定するクエリドキュメント。Query は、複数の候補に一致する可能性がある場合に更新するドキュメントに影響を与える sort order を定義する場合があります。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition または既存のオブジェクトを操作する $ 演算子。null にすることはできません。
      collectionName - オブジェクトを更新するコレクションの名前。null にすることはできません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • updateFirst

      public Mono<com.mongodb.client.result.UpdateResult> updateFirst(Query query, UpdateDefinition update, ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクション内でクエリドキュメントの条件に一致する最初のオブジェクトを、提供された更新されたドキュメントに更新します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsupdateFirst 
      パラメーター:
      query - 更新するドキュメントを選択するために使用される条件を指定するクエリドキュメント。Query は、複数の候補に一致する可能性がある場合に更新するドキュメントに影響を与える sort order を定義する場合があります。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition または既存のオブジェクトを操作する $ 演算子。null にすることはできません。
      entityClass - 操作対象となる pojo のクラス。null にすることはできません。
      collectionName - オブジェクトを更新するコレクションの名前。null にすることはできません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • updateMulti

      public Mono<com.mongodb.client.result.UpdateResult> updateMulti(Query query, UpdateDefinition update, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      クエリドキュメント条件に一致するエンティティクラスのコレクション内で見つかったすべてのオブジェクトを、指定された更新されたドキュメントで更新します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsupdateMulti 
      パラメーター:
      query - 更新するドキュメントを選択するために使用される条件を指定するクエリドキュメント。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition または既存のオブジェクトを操作する $ 演算子。null にすることはできません。
      entityClass - 操作対象となる pojo のクラス。null にすることはできません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • updateMulti

      public Mono<com.mongodb.client.result.UpdateResult> updateMulti(Query query, UpdateDefinition update, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクション内で見つかった、クエリドキュメントの条件に一致するすべてのオブジェクトを、提供された更新されたドキュメントに更新します。
      : ドメイン型情報が不足しているため、フィールドマッピング、バージョンなどの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.updateMulti(Query, UpdateDefinition, Class, String) を使用してください。
      次で指定:
      インターフェース ReactiveMongoOperationsupdateMulti 
      パラメーター:
      query - 更新するドキュメントを選択するために使用される条件を指定するクエリドキュメント。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition または既存のオブジェクトを操作する $ 演算子。null にすることはできません。
      collectionName - オブジェクトを更新するコレクションの名前。null にすることはできません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • updateMulti

      public Mono<com.mongodb.client.result.UpdateResult> updateMulti(Query query, UpdateDefinition update, ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      クエリドキュメント条件に一致するエンティティクラスのコレクション内で見つかったすべてのオブジェクトを、指定された更新されたドキュメントで更新します。

      entityClass の潜在的な Version プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。

      次で指定:
      インターフェース ReactiveMongoOperationsupdateMulti 
      パラメーター:
      query - 更新するドキュメントを選択するために使用される条件を指定するクエリドキュメント。null にすることはできません。
      update - 更新されたオブジェクトを含む UpdateDefinition または既存のオブジェクトを操作する $ 演算子。null にすることはできません。
      entityClass - 操作対象となる pojo のクラス。null にすることはできません。
      collectionName - オブジェクトを更新するコレクションの名前。null にすることはできません。
      戻り値:
      前回の書き込みの結果にアクセスできる UpdateResult
      関連事項:
    • doUpdate

      protected Mono<com.mongodb.client.result.UpdateResult> doUpdate(StringSE collectionName, Query query, UpdateDefinition update, @Nullable ClassSE<?> entityClass, boolean upsert, boolean multi)
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(Mono<? extends ObjectSE> objectToRemove)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      ID および (該当する場合) Version によって、コレクションから指定されたオブジェクトを削除します。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      objectToRemove - null であってはなりません。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(Mono<? extends ObjectSE> objectToRemove, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから、指定されたオブジェクトを ID と (該当する場合) Version で削除します。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      objectToRemove - null であってはなりません。
      collectionName - ドキュメントが削除されるコレクションの名前。null または空であってはなりません。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(ObjectSE object)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      ID および (該当する場合) Version によって、コレクションから指定されたオブジェクトを削除します。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      object - null であってはなりません。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(ObjectSE object, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから指定されたオブジェクトを削除します。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      object - null であってはなりません。
      collectionName - ドキュメントが削除されるコレクションの名前。null または空であってはなりません。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(Query query, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから、提供されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。ID フィールドを使用する条件に対しては、変換 / マッピングは実行されません。
      : ドメイン型情報が不足しているため、フィールドマッピングの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.remove(Query, Class, String) を使用してください。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      query - ドキュメントを削除するために使用される条件を指定するクエリドキュメント。
      collectionName - ドキュメントが削除されるコレクションの名前。null または空であってはなりません。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(Query query, ClassSE<?> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      entityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。Class パラメーターは、クエリ内に存在する場合、オブジェクトの ID を変換するためにも使用されます。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      query - ドキュメントを削除するために使用される条件を指定するクエリドキュメント。
      entityClass - 使用するコレクションを決定するクラス。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • remove

      public Mono<com.mongodb.client.result.DeleteResult> remove(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      entityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。Class パラメーターは、クエリ内に存在する場合、オブジェクトの ID を変換するためにも使用されます。
      次で指定:
      インターフェース ReactiveMongoOperationsremove 
      パラメーター:
      query - ドキュメントを削除するために使用される条件を指定するクエリドキュメント。
      entityClass - 操作対象となる pojo のクラス。null にすることもできます。
      collectionName - ドキュメントが削除されるコレクションの名前。null または空であってはなりません。
      戻り値:
      前回の削除の結果にアクセスできる DeleteResult
    • doRemove

      protected <T> Mono<com.mongodb.client.result.DeleteResult> doRemove(StringSE collectionName, Query query, @Nullable ClassSE<T> entityClass)
    • findAll

      public <T> Flux<T> findAll(ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスによって使用されるコレクションから、型 T のオブジェクトの Flux をクエリします。
      オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverter のインスタンスが使用されます。
      コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAll 
      パラメーター:
      entityClass - 返される Flux のパラメーター化された型。
      戻り値:
      変換されたコレクション。
    • findAll

      public <T> Flux<T> findAll(ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから型 T のオブジェクトの Flux を照会します。
      オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverter のインスタンスが使用されます。
      コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAll 
      パラメーター:
      entityClass - 返される Flux のパラメーター化された型。
      collectionName - オブジェクトを取得するコレクションの名前。
      戻り値:
      変換されたコレクション。
    • findAllAndRemove

      public <T> Flux<T> findAllAndRemove(Query query, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定されたコレクションから、指定されたクエリに一致するすべてのドキュメントを返して削除します。
      : ドメイン型情報が不足しているため、フィールドマッピングの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.findAllAndRemove(Query, Class, String) を使用してください。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAllAndRemove 
      パラメーター:
      query - ドキュメントの検索と削除に使用する条件を指定するクエリドキュメント。
      collectionName - ドキュメントが削除されるコレクションの名前。null または空であってはなりません。
      戻り値:
      この操作によって削除された Flux 変換オブジェクト。
    • findAllAndRemove

      public <T> Flux<T> findAllAndRemove(Query query, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      entityClass を格納するために使用されたコレクションから、指定されたクエリに一致するすべてのドキュメントを返して削除します。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAllAndRemove 
      パラメーター:
      query - ドキュメントの検索と削除に使用する条件を指定するクエリドキュメント。
      entityClass - 操作対象となる pojo のクラス。
      戻り値:
      この操作によって削除された Flux 変換オブジェクト。
    • findAllAndRemove

      public <T> Flux<T> findAllAndRemove(Query query, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      entityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを返して削除します。Class パラメーターは、クエリ内に存在する場合、オブジェクトの ID を変換するのにも使用されます。
      次で指定:
      インターフェース ReactiveMongoOperationsfindAllAndRemove 
      パラメーター:
      query - ドキュメントの検索と削除に使用する条件を指定するクエリドキュメント。
      entityClass - 操作対象となる pojo のクラス。
      collectionName - ドキュメントが削除されるコレクションの名前。null または空であってはなりません。
      戻り値:
      この操作によって削除された Flux 変換オブジェクト。
    • replace

      public <T> Mono<com.mongodb.client.result.UpdateResult> replace(Query query, T replacement, ReplaceOptions options, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      指定された QueryCriteria に一致する単一のドキュメントを、ReplaceOptions を考慮して replacement ドキュメントに置き換えます。
      次で指定:
      インターフェース ReactiveMongoOperationsreplace 
      パラメーター:
      query - ドキュメントの検索に使用する Criteria を指定する Query クラス。クエリには、使用するインデックス hint または collation が含まれる場合があります。Query は、複数の候補に一致する可能性がある場合にどのドキュメントを置き換えるかを制御する sort order を定義する場合があります。null にすることはできません。
      replacement - 置換ドキュメント。null にすることはできません。
      options - 追加情報を保持する ReplaceOptions。null にすることはできません。
      戻り値:
      UpdateResult を使用すると、以前の置換の結果にアクセスできます。
    • replace

      protected <S,T> Mono<com.mongodb.client.result.UpdateResult> replace(Query query, ClassSE<S> entityType, T replacement, ReplaceOptions options, StringSE collectionName)
    • tail

      public <T> Flux<T> tail(Query query, ClassSE<T> entityClass)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトのストリームにマッピングします。ストリームは tailable カーソルを使用しますが、これは無限ストリームになる場合があります。Subscriptioncanceled でない限り、ストリームは完了しません。
      オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、これは BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationstail 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。
      entityClass - 返される Flux のパラメーター化された型。
      戻り値:
      変換されたオブジェクトの Flux
    • tail

      public <T> Flux<T> tail(@Nullable Query query, ClassSE<T> entityClass, StringSE collectionName)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトのストリームにマッピングします。ストリームは tailable カーソルを使用しますが、これは無限ストリームになる場合があります。Subscriptioncanceled でない限り、ストリームは完了しません。
      オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverter のインスタンスが使用されます。
      クエリは Query として指定され、これは BasicQuery またはより機能が豊富な Query を使用して作成できます。
      次で指定:
      インターフェース ReactiveMongoOperationstail 
      パラメーター:
      query - ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。
      entityClass - 返される Flux のパラメーター化された型。
      collectionName - オブジェクトを取得するコレクションの名前。
      戻り値:
      変換されたオブジェクトの Flux
    • changeStream

      public <T> Flux<ChangeStreamEvent<T>> changeStream(@Nullable StringSE database, @Nullable StringSE collectionName, ChangeStreamOptions options, ClassSE<T> targetType)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      リアクティブインフラストラクチャを介して MongoDB ストリームの変更をサブスクライブします。イベントをフィルタリングするには、オプションで提供される Aggregation を使用します。Subscriptioncanceled でない限り、ストリームは完了しません。
      ChangeStreamEvent.getBody() は resultType にマップされ、ChangeStreamEvent.getRaw() には変更されていないペイロードが含まれます。
      変更ストリームを再開するための the resumseToken のような引数を設定するには、ChangeStreamOptions を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationschangeStream 
      型パラメーター:
      T -
      パラメーター:
      database - 監視するデータベース。null にすることもできますが、その場合は設定されたデフォルトが使用されます。
      collectionName - 監視するコレクション。null にすることもできます。その場合はすべてのコレクションを監視します。
      options - null にすることはできません。ChangeStreamOptions.empty() を使用してください。
      targetType - 使用する結果型。
      戻り値:
      Flux は到着すると events を発信します。
      関連事項:
    • mapReduce

      public <T> Flux<T> mapReduce(Query filterQuery, ClassSE<?> domainType, ClassSE<T> resultType, StringSE mapFunction, StringSE reduceFunction, MapReduceOptions options)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      マップ削減操作を実行します。オプションで出力コレクションやその他の引数を指定するには、MapReduceOptions を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationsmapReduce 
      パラメーター:
      filterQuery - マップ関数に入力されるドキュメントの選択条件。null にすることはできません。
      domainType - 入力コレクション名を決定し、フィルター Query をマップするために使用されるソース型。null にすることはできません。
      resultType - 操作結果ドキュメントのマッピングターゲット。null にすることはできません。
      mapFunction - JavaScript マップ関数。null にすることはできません。
      reduceFunction - JavaScript 削減関数。null であってはなりません。
      options - 出力コレクションなどの追加オプション。null にすることはできません。
      戻り値:
      結果ドキュメントシーケンスを出力する Flux。null にはなりません。
    • mapReduce

      public <T> Flux<T> mapReduce(Query filterQuery, ClassSE<?> domainType, StringSE inputCollectionName, ClassSE<T> resultType, StringSE mapFunction, StringSE reduceFunction, MapReduceOptions options)
      インターフェースからコピーされた説明: ReactiveMongoOperations
      マップ削減操作を実行します。オプションで出力コレクションやその他の引数を指定するには、MapReduceOptions を使用します。
      次で指定:
      インターフェース ReactiveMongoOperationsmapReduce 
      パラメーター:
      filterQuery - マップ関数に入力されるドキュメントの選択条件。null にすることはできません。
      domainType - フィルター Query をマップするために使用されるソース型。null にすることはできません。
      inputCollectionName - 入力コレクション。
      resultType - 操作結果ドキュメントのマッピングターゲット。null にすることはできません。
      mapFunction - JavaScript マップ関数。null にすることはできません。
      reduceFunction - JavaScript 削減関数。null であってはなりません。
      options - 出力コレクションなどの追加オプション。null にすることはできません。
      戻り値:
      結果ドキュメントシーケンスを出力する Flux。null にはなりません。
    • query

      public <T> ReactiveFindOperation.ReactiveFind<T> query(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveFindOperation
      指定された domainType の検索操作の作成を開始します。
      次で指定:
      インターフェース ReactiveFindOperationquery 
      パラメーター:
      domainType - null であってはなりません。
      戻り値:
      ReactiveFindOperation.ReactiveFind の新しいインスタンス。null になることはありません。
    • update

      public <T> ReactiveUpdateOperation.ReactiveUpdate<T> update(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveUpdateOperation
      指定された domainType の更新操作の作成を開始します。
      次で指定:
      インターフェース ReactiveUpdateOperationupdate 
      パラメーター:
      domainType - null であってはなりません。
      戻り値:
      ReactiveUpdateOperation.ReactiveUpdate の新しいインスタンス。null になることはありません。
    • remove

      public <T> ReactiveRemoveOperation.ReactiveRemove<T> remove(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveRemoveOperation
      指定された domainType の削除操作の作成を開始します。
      次で指定:
      インターフェース ReactiveRemoveOperationremove 
      パラメーター:
      domainType - null であってはなりません。
      戻り値:
      ReactiveRemoveOperation.ReactiveRemove の新しいインスタンス。null になることはありません。
    • insert

      public <T> ReactiveInsertOperation.ReactiveInsert<T> insert(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveInsertOperation
      指定された domainType の挿入操作の作成を開始します。
      次で指定:
      インターフェース ReactiveInsertOperationinsert 
      パラメーター:
      domainType - null であってはなりません。
      戻り値:
      ReactiveInsertOperation.ReactiveInsert の新しいインスタンス。null になることはありません。
    • aggregateAndReturn

      public <T> ReactiveAggregationOperation.ReactiveAggregation<T> aggregateAndReturn(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveAggregationOperation
      指定されたドメイン型にマップされた結果を返す集計操作の作成を開始します。
      集計の潜在的に異なる入力型を指定するには、TypedAggregation を使用します。
      次で指定:
      インターフェース ReactiveAggregationOperationaggregateAndReturn 
      パラメーター:
      domainType - null であってはなりません。
      戻り値:
      ReactiveAggregationOperation.ReactiveAggregation の新しいインスタンス。null になることはありません。
    • mapReduce

      public <T> ReactiveMapReduceOperation.ReactiveMapReduce<T> mapReduce(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveMapReduceOperation
      指定された domainType の mapReduce 操作の作成を開始します。
      次で指定:
      インターフェース ReactiveMapReduceOperationmapReduce 
      パラメーター:
      domainType - null であってはなりません。
      戻り値:
      ExecutableFindOperation.ExecutableFind の新しいインスタンス。
    • changeStream

      public <T> ReactiveChangeStreamOperation.ReactiveChangeStream<T> changeStream(ClassSE<T> domainType)
      インターフェースからコピーされた説明: ReactiveChangeStreamOperation
      データベース内のすべてのコレクションを監視しながら、指定された domainType の変更ストリーム操作の作成を開始します。
      collection および / または filter を定義してイベントを制限することを検討してください。
      次で指定:
      インターフェース ReactiveChangeStreamOperationchangeStream 
      パラメーター:
      domainType - null であってはなりません。生の要素を取得するには Document を使用します。
      戻り値:
      ReactiveChangeStreamOperation.ReactiveChangeStream の新しいインスタンス。null になることはありません。
    • doFindAndDelete

      protected <T> Flux<T> doFindAndDelete(StringSE collectionName, Query query, ClassSE<T> entityClass)
      find(Query, Class, String) および remove(Query, Class, String) を呼び出して、指定された query に一致するすべてのドキュメントを取得および削除します。一方、remove(Query, Class, String)Query は検索結果から構築されます。
      パラメーター:
      collectionName -
      query -
      entityClass -
      戻り値:
    • doCreateCollection

      protected Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> doCreateCollection(StringSE collectionName, com.mongodb.client.model.CreateCollectionOptions collectionOptions)
      提供されたオプションを使用して、指定されたコレクションを作成します
      パラメーター:
      collectionName -
      collectionOptions -
      戻り値:
      作成されたコレクション
    • doFindOne

      protected <T> Mono<T> doFindOne(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document query, @Nullable org.bson.Document fields, ClassSE<T> entityClass, @Nullable Collation collation)
      テンプレートのコンバーターを使用して、デフォルトの MongoDB コレクションに対するアドホッククエリの結果をオブジェクトにマップします。クエリドキュメントは標準の Document として指定され、フィールド仕様も同様です。
      パラメーター:
      collectionName - オブジェクトを取得するコレクションの名前。
      collectionPreparer - 作成者は、実際の使用に備えてコレクションを準備します。
      query - レコードの検索に使用する条件を指定するクエリドキュメント。
      fields - 返されるフィールドを指定するドキュメント。
      entityClass - 返されるリストのパラメーター化された型。
      collation - null でもかまいません。
      戻り値:
      変換されたオブジェクトの ListSE
    • doFindOne

      protected <T> Mono<T> doFindOne(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document query, @Nullable org.bson.Document fields, ClassSE<T> entityClass, FindPublisherPreparer preparer)
      テンプレートのコンバーターを使用して、デフォルトの MongoDB コレクションに対するアドホッククエリの結果をオブジェクトにマップします。クエリドキュメントは標準の Document として指定され、フィールド仕様も同様です。
      パラメーター:
      collectionName - オブジェクトを取得するコレクションの名前。
      collectionPreparer - 作成者は、実際の使用に備えてコレクションを準備します。
      query - レコードの検索に使用する条件を指定するクエリドキュメント。
      fields - 返されるフィールドを指定するドキュメント。
      entityClass - 返されるリストのパラメーター化された型。
      preparer - 作成者はニーズに合わせてコレクションと発行者を変更します。
      戻り値:
      変換されたオブジェクトの ListSE
      導入:
      2.2
    • doFind

      protected <T> Flux<T> doFind(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document query, org.bson.Document fields, ClassSE<T> entityClass)
      テンプレートのコンバーターを使用して、デフォルトの MongoDB コレクションに対するアドホッククエリの結果をリストにマップします。クエリドキュメントは標準のドキュメントとして指定され、フィールド仕様も同様に指定されます。
      パラメーター:
      collectionName - オブジェクトを取得するコレクションの名前
      collectionPreparer - 作成者は、実際の使用に備えてコレクションを準備します。
      query - レコードの検索に使用する条件を指定するクエリドキュメント
      fields - 返されるフィールドを指定するドキュメント
      entityClass - 返されるリストのパラメーター化された型。
      戻り値:
      変換されたオブジェクトのリスト。
    • doFind

      protected <T> Flux<T> doFind(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document query, org.bson.Document fields, ClassSE<T> entityClass, FindPublisherPreparer preparer)
      デフォルトの MongoDB コレクションに対するアドホッククエリの結果を、指定された型のリストにマップします。オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。クエリドキュメントは標準の Document として指定され、フィールド仕様も同様に指定されます。
      パラメーター:
      collectionName - オブジェクトを取得するコレクションの名前。
      collectionPreparer - 作成者は、実際の使用に備えてコレクションを準備します。
      query - レコードの検索に使用する条件を指定するクエリドキュメント。
      fields - 返されるフィールドを指定するドキュメント。
      entityClass - 返されるリストのパラメーター化された型。
      preparer - 結果セットを反復処理するときに使用される FindIterable のカスタマイズが可能になります (制限の適用、スキップなど)。
      戻り値:
      変換されたオブジェクトの ListSE
    • doFind

      protected <S,T> Flux<T> doFind(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document query, org.bson.Document fields, ClassSE<S> entityClass, @Nullable FindPublisherPreparer preparer, org.springframework.data.mongodb.core.ReactiveMongoTemplate.DocumentCallback<T> objectCallback)
    • convertToCreateCollectionOptions

      protected com.mongodb.client.model.CreateCollectionOptions convertToCreateCollectionOptions(@Nullable CollectionOptions collectionOptions)
    • convertToCreateCollectionOptions

      protected com.mongodb.client.model.CreateCollectionOptions convertToCreateCollectionOptions(@Nullable CollectionOptions collectionOptions, ClassSE<?> entityType)
    • doFindAndRemove

      protected <T> Mono<T> doFindAndRemove(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document query, org.bson.Document fields, @Nullable org.bson.Document sort, @Nullable Collation collation, ClassSE<T> entityClass)
      テンプレートのコンバーターを使用して、デフォルトの MongoDB コレクションに対するアドホッククエリの結果をオブジェクトにマップします。クエリに一致する最初のドキュメントが返され、データベースのコレクションからも削除されます。
      クエリドキュメントは標準ドキュメントとして指定され、フィールド仕様も同様に指定されます。
      パラメーター:
      collectionName - オブジェクトを取得するコレクションの名前。
      collectionPreparer - 作成者は、実際の使用に備えてコレクションを準備します。
      query - レコードの検索に使用する条件を指定するクエリドキュメント。
      collation - 照合。
      entityClass - 返されるリストのパラメーター化された型。
      戻り値:
      変換されたオブジェクトのリスト。
    • doFindAndReplace

      protected <T> Mono<T> doFindAndReplace(StringSE collectionName, CollectionPreparer<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> collectionPreparer, org.bson.Document mappedQuery, org.bson.Document mappedFields, org.bson.Document mappedSort, com.mongodb.client.model.Collation collation, ClassSE<?> entityType, org.bson.Document replacement, FindAndReplaceOptions options, ClassSE<T> resultType)
      このパーツを findAndReplace 用にカスタマイズします。
      パラメーター:
      collectionName - 操作を実行するコレクションの名前。
      collectionPreparer - 作成者は、実際の使用に備えてコレクションを準備します。
      mappedQuery - ドキュメントを検索するためのクエリ。
      mappedFields - 結果を投影するフィールド。
      mappedSort - クエリを実行するときに適用される並べ替え。
      collation - クエリの照合設定。null にすることができます。
      entityType - ソースドメインの種類。
      replacement - 交換用 Document
      options - 適用可能なオプション。
      resultType - ターゲットドメイン型。
      戻り値:
      Mono.empty() オブジェクトが存在しない場合は、return new は false になり、upsert は false になります。
      導入:
      2.1
    • maybeEmitEvent

      protected <E extends MongoMappingEvent<T>, T> E maybeEmitEvent(E event)
    • maybeCallBeforeConvert

      protected <T> Mono<T> maybeCallBeforeConvert(T object, StringSE collection)
    • maybeCallBeforeSave

      protected <T> Mono<T> maybeCallBeforeSave(T object, org.bson.Document document, StringSE collection)
    • maybeCallAfterSave

      protected <T> Mono<T> maybeCallAfterSave(T object, org.bson.Document document, StringSE collection)
    • maybeCallAfterConvert

      protected <T> Mono<T> maybeCallAfterConvert(T object, org.bson.Document document, StringSE collection)
    • ensureNotCollectionLike

      protected void ensureNotCollectionLike(@Nullable ObjectSE source)
      指定されたソースが ArraySECollectionSE、または IteratorSE でないことを確認してください。
      パラメーター:
      source - null でもかまいません。
      導入:
      3.2.
    • prepareCollection

      protected com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> prepareCollection(com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> collection)
      コレクションを使用して処理を行う前に、コレクションを準備します。これにより、withCodecRegistry() などの設定を簡単に適用できます。サブクラスでオーバーライドできます。
      パラメーター:
      collection -
    • prepareDatabase

      protected com.mongodb.reactivestreams.client.MongoDatabase prepareDatabase(com.mongodb.reactivestreams.client.MongoDatabase database)
      パラメーター:
      database -
      戻り値:
      導入:
      2.1
    • prepareWriteConcern

      protected @Nullable com.mongodb.WriteConcern prepareWriteConcern(MongoAction mongoAction)
      WriteConcern を用いて処理を行う前に、これを準備しておきます。これにより、サブクラスでカスタム設定を簡単に適用できるようになります。返される WriteConcern は、WriteResultCheckingWriteResultChecking.EXCEPTION に設定されている場合、デフォルトで WriteConcern.ACKNOWLEDGED になります。
      パラメーター:
      mongoAction - すでに構成されている WriteConcern または null。
      戻り値:
      準備された WriteConcern または null。
      関連事項:
    • getMongoDatabaseFactory

      public ReactiveMongoDatabaseFactory getMongoDatabaseFactory()
      戻り値:
      使用中の MongoDatabaseFactory
      導入:
      3.1.4