クラス ReactiveMongoTemplate
- 実装済みのインターフェース一覧:
Aware, ApplicationContextAware, ReactiveAggregationOperation, ReactiveChangeStreamOperation, ReactiveFindOperation, ReactiveFluentMongoOperations, ReactiveInsertOperation, ReactiveMapReduceOperation, ReactiveMongoOperations, ReactiveRemoveOperation, ReactiveUpdateOperation
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
ネストされたクラスの概要
インターフェース ReactiveAggregationOperation から継承されたネストクラス / インターフェース
ReactiveAggregationOperation.AggregationOperationWithAggregation<T>, ReactiveAggregationOperation.AggregationOperationWithCollection<T>, ReactiveAggregationOperation.ReactiveAggregation<T>, ReactiveAggregationOperation.TerminatingAggregationOperation<T>インターフェース ReactiveChangeStreamOperation から継承されたネストクラス / インターフェース
ReactiveChangeStreamOperation.ChangeStreamWithCollection<T>, ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T>, ReactiveChangeStreamOperation.ChangeStreamWithOptions<T>, ReactiveChangeStreamOperation.ReactiveChangeStream<T>, ReactiveChangeStreamOperation.ResumingChangeStream<T>, ReactiveChangeStreamOperation.TerminatingChangeStream<T>インターフェース ReactiveFindOperation から継承されたネストクラス / インターフェース
ReactiveFindOperation.DistinctWithProjection, ReactiveFindOperation.DistinctWithQuery<T>, ReactiveFindOperation.FindDistinct, ReactiveFindOperation.FindWithCollection<T>, ReactiveFindOperation.FindWithProjection<T>, ReactiveFindOperation.FindWithQuery<T>, ReactiveFindOperation.ReactiveFind<T>, ReactiveFindOperation.TerminatingDistinct<T>, ReactiveFindOperation.TerminatingFind<T>, ReactiveFindOperation.TerminatingFindNear<T>, ReactiveFindOperation.TerminatingProjection, ReactiveFindOperation.TerminatingResults<T>インターフェース ReactiveInsertOperation から継承されたネストクラス / インターフェース
ReactiveInsertOperation.InsertWithCollection<T>, ReactiveInsertOperation.ReactiveInsert<T>, ReactiveInsertOperation.TerminatingInsert<T>インターフェース ReactiveMapReduceOperation から継承されたネストクラス / インターフェース
ReactiveMapReduceOperation.MapReduceWithCollection<T>, ReactiveMapReduceOperation.MapReduceWithMapFunction<T>, ReactiveMapReduceOperation.MapReduceWithOptions<T>, ReactiveMapReduceOperation.MapReduceWithProjection<T>, ReactiveMapReduceOperation.MapReduceWithQuery<T>, ReactiveMapReduceOperation.MapReduceWithReduceFunction<T>, ReactiveMapReduceOperation.ReactiveMapReduce<T>, ReactiveMapReduceOperation.TerminatingMapReduce<T>インターフェース ReactiveRemoveOperation から継承されたネストクラス / インターフェース
ReactiveRemoveOperation.ReactiveRemove<T>, ReactiveRemoveOperation.RemoveWithCollection<T>, ReactiveRemoveOperation.RemoveWithQuery<T>, ReactiveRemoveOperation.TerminatingRemove<T>, ReactiveRemoveOperation.TerminatingResults<T>インターフェース ReactiveUpdateOperation から継承されたネストクラス / インターフェース
ReactiveUpdateOperation.FindAndModifyWithOptions<T>, ReactiveUpdateOperation.FindAndReplaceWithOptions<T>, ReactiveUpdateOperation.FindAndReplaceWithProjection<T>, ReactiveUpdateOperation.ReactiveUpdate<T>, ReactiveUpdateOperation.ReplaceWithOptions, ReactiveUpdateOperation.TerminatingFindAndModify<T>, ReactiveUpdateOperation.TerminatingFindAndReplace<T>, ReactiveUpdateOperation.TerminatingReplace, ReactiveUpdateOperation.TerminatingUpdate<T>, ReactiveUpdateOperation.UpdateWithCollection<T>, ReactiveUpdateOperation.UpdateWithQuery<T>, ReactiveUpdateOperation.UpdateWithUpdate<T>フィールド概要
フィールドコンストラクター概要
コンストラクターコンストラクター説明ReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient mongoClient, StringSE databaseName) 基本的なテンプレート設定に使用されるコンストラクター。ReactiveMongoTemplate(ReactiveMongoDatabaseFactory mongoDatabaseFactory) 基本的なテンプレート設定に使用されるコンストラクター。ReactiveMongoTemplate(ReactiveMongoDatabaseFactory mongoDatabaseFactory, @Nullable MongoConverter mongoConverter) 基本的なテンプレート設定に使用されるコンストラクター。ReactiveMongoTemplate(ReactiveMongoDatabaseFactory mongoDatabaseFactory, @Nullable MongoConverter mongoConverter, ConsumerSE<ThrowableSE> subscriptionExceptionHandler) 基本的なテンプレート設定に使用されるコンストラクター。方法の概要
修飾子と型メソッド説明<O> Flux<O> aggregate(Aggregation aggregation, ClassSE<?> inputType, ClassSE<O> outputType) 集計操作を実行します。<O> Flux<O> aggregate(Aggregation aggregation, StringSE collectionName, ClassSE<O> outputType) 集計操作を実行します。<O> Flux<O> aggregate(TypedAggregation<?> aggregation, ClassSE<O> outputType) 集計操作を実行します。<O> Flux<O> aggregate(TypedAggregation<?> aggregation, StringSE inputCollectionName, ClassSE<O> outputType) 集計操作を実行します。aggregateAndReturn(ClassSE<T> domainType) 指定されたドメイン型にマップされた結果を返す集計操作の作成を開始します。bulkOps(BulkOperations.BulkMode mode, @Nullable ClassSE<?> entityType, StringSE collectionName) 指定されたエンティティ型とコレクション名の新しいReactiveBulkOperationsを返します。bulkOps(BulkOperations.BulkMode mode, ClassSE<?> entityClass) 指定されたエンティティ型の新しいReactiveBulkOperationsを返します。bulkOps(BulkOperations.BulkMode mode, StringSE collectionName) 指定されたコレクションの新しいReactiveBulkOperationsを返します。<T> Flux<ChangeStreamEvent<T>> changeStream(@Nullable StringSE database, @Nullable StringSE collectionName, ChangeStreamOptions options, ClassSE<T> targetType) リアクティブインフラストラクチャ経由で MongoDB ストリームの変更をサブスクライブします。changeStream(ClassSE<T> domainType) データベース内のすべてのコレクションを監視しながら、指定された domainType の変更ストリーム操作の作成を開始します。collectionExists(ClassSE<T> entityClass) エンティティクラスで示された名前のコレクションが存在するかどうかを確認します。collectionExists(StringSE collectionName) 指定された名前のコレクションが存在するかどうかを確認します。protected com.mongodb.client.model.CreateCollectionOptionsconvertToCreateCollectionOptions(@Nullable CollectionOptions collectionOptions) protected com.mongodb.client.model.CreateCollectionOptionsconvertToCreateCollectionOptions(@Nullable CollectionOptions collectionOptions, ClassSE<?> entityType) 指定されたエンティティクラスのコレクションをクエリすることにより、指定されたQueryのドキュメントの数を返します。指定されたコレクションをクエリして、指定されたQueryのドキュメントの数を返します。countCanBeEstimated(org.bson.Document filter, com.mongodb.client.model.CountOptions options) <T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass) 提供されたエンティティクラスに基づいた名前で上限のないコレクションを作成します。<T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass, FunctionSE<? super CollectionOptions, ? extends CollectionOptions> collectionOptionsCustomizer) 提供されたエンティティクラスに基づいて名前を持つ、キャップなしのコレクションを作成し、派生したCollectionOptionsをカスタマイズできるようにします。<T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass, @Nullable CollectionOptions collectionOptions) オプションを使用して、指定されたエンティティクラスに基づく名前のコレクションを作成します。Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(StringSE collectionName) 指定された名前で上限のないコレクションを作成します。Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(StringSE collectionName, @Nullable CollectionOptions collectionOptions) 指定された名前とオプションでコレクションを作成します。<T> Flux<T> createFlux(StringSE collectionName, ReactiveCollectionCallback<T> callback) <T> Flux<T> createFlux(ReactiveDatabaseCallback<T> callback) ReactiveDatabaseCallback用の再利用可能な Flux を作成します。<T> Mono<T> createMono(StringSE collectionName, ReactiveCollectionCallback<T> callback) <T> Mono<T> createMono(ReactiveDatabaseCallback<T> callback) ReactiveDatabaseCallback用の再利用可能な Mono を作成します。Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createView(StringSE name, ClassSE<?> source, AggregationPipeline pipeline, @Nullable ViewOptions options) 指定された名前でビューを作成します。Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createView(StringSE name, StringSE source, AggregationPipeline pipeline, @Nullable ViewOptions options) 指定された名前でビューを作成します。protected <O> Flux<O> doAggregate(Aggregation aggregation, StringSE collectionName, @Nullable ClassSE<?> inputType, ClassSE<O> outputType) doCount(StringSE collectionName, org.bson.Document filter, com.mongodb.client.model.CountOptions options) 指定された名前のコレクションに対して実際のカウント操作を実行します。protected Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> doCreateCollection(StringSE collectionName, com.mongodb.client.model.CreateCollectionOptions collectionOptions) 提供されたオプションを使用して、指定されたコレクションを作成しますprotected Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> doCreateView(StringSE name, StringSE source, ListSE<org.bson.Document> pipeline, @Nullable ViewOptions options) doEstimatedCount(StringSE collectionName, com.mongodb.client.model.EstimatedDocumentCountOptions options) doExactCount(StringSE collectionName, org.bson.Document filter, com.mongodb.client.model.CountOptions options) 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) 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 コレクションに対するアドホッククエリの結果をリストにマップします。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 コレクションに対するアドホッククエリの結果を、指定された型のリストにマップします。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は検索結果から構築されます。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 コレクションに対するアドホッククエリの結果をオブジェクトにマップします。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 用にカスタマイズします。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 コレクションに対するアドホッククエリの結果をオブジェクトにマップします。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 コレクションに対するアドホッククエリの結果をオブジェクトにマップします。protected Mono<com.mongodb.reactivestreams.client.MongoDatabase> protected <T> Mono<T> doInsert(StringSE collectionName, T objectToSave, MongoWriter<ObjectSE> writer) protected <T> Flux<T> doInsertAll(CollectionSE<? extends T> listToSave, MongoWriter<ObjectSE> writer) protected <T> Flux<T> doInsertBatch(StringSE collectionName, CollectionSE<? extends T> batchToSave, MongoWriter<ObjectSE> writer) protected <T> Mono<com.mongodb.client.result.DeleteResult> protected <T> Mono<T> doSave(StringSE collectionName, T objectToSave, MongoWriter<ObjectSE> writer) protected Mono<com.mongodb.client.result.UpdateResult> doUpdate(StringSE collectionName, Query query, UpdateDefinition update, @Nullable ClassSE<?> entityClass, boolean upsert, boolean multi) dropCollection(ClassSE<T> entityClass) エンティティクラスで指定された名前のコレクションをドロップします。dropCollection(StringSE collectionName) 指定された名前のコレクションをドロップします。protected voidensureNotCollectionLike(@Nullable ObjectSE source) estimatedCount(StringSE collectionName) コレクションの統計に基づいて、指定されたコレクション内のドキュメントの数を推定します。exactCount(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName) <T> Flux<T> execute(ClassSE<?> entityClass, ReactiveCollectionCallback<T> action) 指定されたクラスのエンティティコレクションに対して指定されたReactiveCollectionCallbackを実行します。<T> Flux<T> execute(StringSE collectionName, ReactiveCollectionCallback<T> callback) 指定された名前のコレクションに対して指定されたReactiveCollectionCallbackを実行します。<T> Flux<T> execute(ReactiveDatabaseCallback<T> action) 必要に応じて例外を変換するReactiveDatabaseCallbackを実行します。Mono<org.bson.Document> executeCommand(StringSE jsonCommand) JSON 文字列として表現された MongoDB コマンドを実行します。Mono<org.bson.Document> executeCommand(org.bson.Document command) MongoDB コマンドを実行します。Mono<org.bson.Document> executeCommand(org.bson.Document command, @Nullable com.mongodb.ReadPreference readPreference) MongoDB コマンドを実行します。指定されたQueryの結果に少なくとも 1 つの要素が含まれるかを判定します。指定されたQueryの結果に少なくとも 1 つの要素が含まれるかを判定します。指定されたQueryの結果に少なくとも 1 つの要素が含まれるかを判定します。<T> Flux<T> 指定されたコレクションに対するアドホッククエリの結果を、指定された型のFluxにマップします。<T> Flux<T> エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のFluxにマップします。<T> Flux<T> エンティティクラスによって使用されるコレクションから、型 T のオブジェクトのFluxをクエリします。<T> Flux<T> 指定されたコレクションから型 T のオブジェクトのFluxを照会します。<T> Flux<T> findAllAndRemove(Query query, ClassSE<T> entityClass) entityClass を格納するために使用されたコレクションから、指定されたクエリに一致するすべてのドキュメントを返して削除します。<T> Flux<T> findAllAndRemove(Query query, ClassSE<T> entityClass, StringSE collectionName) entityClass を格納するために使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを返して削除します。<T> Flux<T> findAllAndRemove(Query query, StringSE collectionName) 指定されたコレクションから、指定されたクエリに一致するすべてのドキュメントを返して削除します。<T> Mono<T> findAndModify(Query query, UpdateDefinition update, ClassSE<T> entityClass) <T> Mono<T> findAndModify(Query query, UpdateDefinition update, ClassSE<T> entityClass, StringSE collectionName) <S,T> Mono <T> findAndModify(Query query, UpdateDefinition update, FindAndModifyOptions options, ClassSE<S> entityClass, StringSE collectionName, QueryResultConverter<? super S, ? extends T> resultConverter) <T> Mono<T> findAndModify(Query query, UpdateDefinition update, FindAndModifyOptions options, ClassSE<T> entityClass) findAndModify をトリガーして、FindAndModifyOptionsを考慮して、指定されたQueryのCriteriaに一致するドキュメントに指定されたUpdateを適用します。<T> Mono<T> findAndModify(Query query, UpdateDefinition update, FindAndModifyOptions options, ClassSE<T> entityClass, StringSE collectionName) findAndModify をトリガーして、FindAndModifyOptionsを考慮して、指定されたQueryのCriteriaに一致するドキュメントに指定されたUpdateを適用します。<T> Mono<T> findAndRemove(Query query, ClassSE<T> entityClass) エンティティ型のコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。<T> Mono<T> findAndRemove(Query query, ClassSE<T> entityClass, StringSE collectionName) 指定されたコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。<S,T> Mono <T> findAndReplace(Query query, S replacement, FindAndReplaceOptions options, ClassSE<S> entityType, StringSE collectionName, ClassSE<T> resultType) findOneAndReplace をトリガーして、指定されたQueryのCriteriaに一致する単一のドキュメントを、FindAndReplaceOptionsを考慮してreplacementドキュメントに置き換えます。<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) <T> Mono<T> 指定されたクラスにマップされた指定された ID を持つドキュメントを返します。<T> Mono<T> 指定されたターゲットクラスにマップされた指定されたコレクションから指定された ID を持つドキュメントを返します。<T> Flux<T> findDistinct(Query query, StringSE field, ClassSE<?> entityClass, ClassSE<T> resultClass) 単一のMongoCollectionまたはビュー全体で指定されたフィールドの個別の値を検索し、その結果をFluxに返します。<T> Flux<T> findDistinct(Query query, StringSE field, StringSE collectionName, ClassSE<?> entityClass, ClassSE<T> resultClass) 単一のMongoCollectionまたはビュー全体で指定されたフィールドの個別の値を検索し、その結果をFluxに返します。<T> Mono<T> エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。<T> Mono<T> 指定されたコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> getCollection(StringSE collectionName) 名前でMongoCollectionを取得します。getCollectionName(ClassSE<?> entityClass) このテンプレートによって指定されたクラスに使用されるコレクション名。コレクション名のセット。デフォルトのMongoConverterを返します。Mono<com.mongodb.reactivestreams.client.MongoDatabase> インデックスに対して実行できるリアクティブ操作を返しますインデックスに対して実行できるリアクティブ操作を返します指定された domainType の挿入操作の作成を開始します。<T> Flux<T> insert(CollectionSE<? extends T> batchToSave, ClassSE<?> entityClass) データベースへの 1 回のバッチ書き込みで、オブジェクトのコレクションをコレクションに挿入します。<T> Flux<T> insert(CollectionSE<? extends T> batchToSave, StringSE collectionName) データベースへの単一のバッチ書き込みで、指定されたコレクションにオブジェクトのバッチを挿入します。<T> Mono<T> 保存するオブジェクトのエンティティ型のコレクションにオブジェクトを挿入します。<T> Mono<T> insert(T objectToSave) 保存するオブジェクトのエンティティ型のコレクションにオブジェクトを挿入します。<T> Mono<T> 指定されたコレクションにオブジェクトを挿入します。<T> Flux<T> insertAll(CollectionSE<? extends T> objectsToSave) オブジェクトの混合コレクションをデータベースコレクションに挿入し、クラスに基づいて使用するコレクション名を決定します。<T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> objectsToSave) オブジェクトの混合コレクションをデータベースコレクションに挿入し、クラスに基づいて使用するコレクション名を決定します。<T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> batchToSave, ClassSE<?> entityClass) データベースへの 1 回のバッチ書き込みで、オブジェクトのコレクションをコレクションに挿入します。<T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> batchToSave, StringSE collectionName) データベースへの単一のバッチ書き込みで、指定されたコレクションにオブジェクトを挿入します。insertDocument(StringSE collectionName, org.bson.Document dbDoc, ClassSE<?> entityClass) protected Flux<org.bson.types.ObjectId> insertDocumentList(StringSE collectionName, ListSE<org.bson.Document> dbDocList) 指定された domainType の mapReduce 操作の作成を開始します。<T> Flux<T> mapReduce(Query filterQuery, ClassSE<?> domainType, ClassSE<T> resultType, StringSE mapFunction, StringSE reduceFunction, MapReduceOptions options) マップリデュース操作を実行します。<T> Flux<T> mapReduce(Query filterQuery, ClassSE<?> domainType, StringSE inputCollectionName, ClassSE<T> resultType, StringSE mapFunction, StringSE reduceFunction, MapReduceOptions options) マップリデュース操作を実行します。protected <T> Mono<T> maybeCallAfterConvert(T object, org.bson.Document document, StringSE collection) protected <T> Mono<T> maybeCallAfterSave(T object, org.bson.Document document, StringSE collection) protected <T> Mono<T> maybeCallBeforeConvert(T object, StringSE collection) protected <T> Mono<T> maybeCallBeforeSave(T object, org.bson.Document document, StringSE collection) protected <E extends MongoMappingEvent<T>, T>
EmaybeEmitEvent(E event) protected com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> prepareCollection(com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> collection) コレクションを使用して処理を行う前に、コレクションを準備します。protected com.mongodb.reactivestreams.client.MongoDatabaseprepareDatabase(com.mongodb.reactivestreams.client.MongoDatabase database) protected @Nullable com.mongodb.WriteConcernprepareWriteConcern(MongoAction mongoAction) WriteConcern を使用して処理を行う前に、WriteConcern を準備します。指定された domainType の検索操作の作成を開始します。指定された domainType の削除操作の作成を開始します。Mono<com.mongodb.client.result.DeleteResult> ID および (該当する場合)Versionによって、コレクションから指定されたオブジェクトを削除します。Mono<com.mongodb.client.result.DeleteResult> 指定されたコレクションから指定されたオブジェクトを削除します。Mono<com.mongodb.client.result.DeleteResult> entityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。Mono<com.mongodb.client.result.DeleteResult> entityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。Mono<com.mongodb.client.result.DeleteResult> 指定されたクエリドキュメント条件に一致する、指定されたコレクションからすべてのドキュメントを削除します。Mono<com.mongodb.client.result.DeleteResult> ID および (該当する場合)Versionによって、コレクションから指定されたオブジェクトを削除します。Mono<com.mongodb.client.result.DeleteResult> 指定されたコレクションから、指定されたオブジェクトを ID と (該当する場合)Versionで削除します。protected <S,T> Mono <com.mongodb.client.result.UpdateResult> replace(Query query, ClassSE<S> entityType, T replacement, ReplaceOptions options, StringSE collectionName) <T> Mono<com.mongodb.client.result.UpdateResult> replace(Query query, T replacement, ReplaceOptions options, StringSE collectionName) <T> Mono<T> 保存するオブジェクトのエンティティ型のコレクションにオブジェクトを保存します。<T> Mono<T> オブジェクトを指定されたコレクションに保存します。<T> Mono<T> save(T objectToSave) 保存するオブジェクトのエンティティ型のコレクションにオブジェクトを保存します。<T> Mono<T> オブジェクトを指定されたコレクションに保存します。saveDocument(StringSE collectionName, org.bson.Document document, ClassSE<?> entityClass) 指定されたコレクションから型 T のオブジェクトのスクロールを照会します。指定されたコレクションから型 T のオブジェクトのウィンドウをクエリします。voidsetApplicationContext(ApplicationContext applicationContext) voidsetEntityCallbacks(ReactiveEntityCallbacks entityCallbacks) voidsetEntityLifecycleEventsEnabled(boolean enabled) AfterLoadEvent、BeforeSaveEventなどのライフサイクルイベントを発行するかどうか、発行を抑制するかどうかを構成します。voidsetReadPreference(com.mongodb.ReadPreference readPreference) 使用者#prepareCollection(MongoCollection)} を使用して、操作を実行する前に無効な @link
{@link {@linkReadPreferenceを設定します。voidsetSessionSynchronization(SessionSynchronization sessionSynchronization) ReactiveMongoTemplateがトランザクションに参加するかどうかを定義します。voidsetWriteConcern(@Nullable com.mongodb.WriteConcern writeConcern) WriteConcernをテンプレートで使用するように設定します。voidsetWriteConcernResolver(@Nullable WriteConcernResolver writeConcernResolver) テンプレートで使用するためにWriteConcernResolverを構成します。voidsetWriteResultChecking(@Nullable WriteResultChecking resultChecking) テンプレートで使用するためにWriteResultCheckingを構成します。<T> Flux<T> エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトのストリームにマップします。<T> Flux<T> エンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトのストリームにマップします。指定された domainType の更新操作の作成を開始します。Mono<com.mongodb.client.result.UpdateResult> updateFirst(Query query, UpdateDefinition update, ClassSE<?> entityClass) クエリドキュメントと一致するエンティティクラスのコレクション内で見つかった最初のオブジェクトを、指定された更新ドキュメントで更新します。Mono<com.mongodb.client.result.UpdateResult> updateFirst(Query query, UpdateDefinition update, ClassSE<?> entityClass, StringSE collectionName) 指定されたコレクション内でクエリドキュメントの条件に一致する最初のオブジェクトを、提供された更新されたドキュメントに更新します。Mono<com.mongodb.client.result.UpdateResult> updateFirst(Query query, UpdateDefinition update, StringSE collectionName) 指定されたコレクション内でクエリドキュメントの条件に一致する最初のオブジェクトを、提供された更新されたドキュメントに更新します。Mono<com.mongodb.client.result.UpdateResult> updateMulti(Query query, UpdateDefinition update, ClassSE<?> entityClass) クエリドキュメント条件に一致するエンティティクラスのコレクション内で見つかったすべてのオブジェクトを、指定された更新されたドキュメントで更新します。Mono<com.mongodb.client.result.UpdateResult> updateMulti(Query query, UpdateDefinition update, ClassSE<?> entityClass, StringSE collectionName) クエリドキュメント条件に一致するエンティティクラスのコレクション内で見つかったすべてのオブジェクトを、指定された更新されたドキュメントで更新します。Mono<com.mongodb.client.result.UpdateResult> updateMulti(Query query, UpdateDefinition update, StringSE collectionName) 指定されたコレクション内で見つかった、クエリドキュメント条件に一致するすべてのオブジェクトを、指定された更新されたドキュメントで更新します。Mono<com.mongodb.client.result.UpdateResult> upsert(Query query, UpdateDefinition update, ClassSE<?> entityClass) アップサートを実行します。Mono<com.mongodb.client.result.UpdateResult> upsert(Query query, UpdateDefinition update, ClassSE<?> entityClass, StringSE collectionName) アップサートを実行します。Mono<com.mongodb.client.result.UpdateResult> upsert(Query query, UpdateDefinition update, StringSE collectionName) アップサートを実行します。voiduseEstimatedCount(boolean enabled) 推定カウントを使用するかどうかを構成します。withSession(com.mongodb.ClientSessionOptions sessionOptions) MongoDB に対して発行されたすべてのコマンドに、指定された sessionOptions を持つ新しいClientSessionをバインドするSessionScopedのsessionバインドインスタンスを取得します。withSession(com.mongodb.reactivestreams.client.ClientSession session) ReactiveMongoOperationsのClientSessionバインドされたインスタンスを取得します。withSession(Publisher<com.mongodb.reactivestreams.client.ClientSession> sessionProvider) 指定されたPublisherによって提供されるClientSessionを MongoDB に対して発行されたすべてのコマンドにバインドする、ReactiveSessionScopedのsessionバインドインスタンスを取得します。
フィールドの詳細
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
基本的なテンプレート設定に使用されるコンストラクター。- パラメーター:
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
WriteResultCheckingをテンプレートで使用するように設定します。null を設定すると、デフォルトのDEFAULT_WRITE_RESULT_CHECKINGがリセットされます。- パラメーター:
resultChecking-
setWriteConcern
public void setWriteConcern(@Nullable com.mongodb.WriteConcern writeConcern) テンプレートで使用するためにWriteConcernを設定します。何も設定されていない場合は、MongoDatabaseFactoryで設定されているWriteConcernが適用されます。- パラメーター:
writeConcern- null でもかまいません。
setWriteConcernResolver
テンプレートで使用するためにWriteConcernResolverを構成します。- パラメーター:
writeConcernResolver- null でもかまいません。
setReadPreference
public void setReadPreference(com.mongodb.ReadPreference readPreference) 使用者#prepareCollection(MongoCollection)} を使用して、操作を実行する前に無効な @link
{@link {@linkReadPreferenceを設定します。- パラメーター:
readPreference-
setEntityLifecycleEventsEnabled
public void setEntityLifecycleEventsEnabled(boolean enabled) AfterLoadEvent、BeforeSaveEventなどのライフサイクルイベントを発行するかどうか、発行を抑制するかどうかを構成します。デフォルトで有効になっています。- パラメーター:
enabled- エンティティのライフサイクルイベントを有効にするtrue。エンティティのライフサイクルイベントを無効にするfalse。- 導入:
- 4.0
- 関連事項:
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAwareのsetApplicationContext - 例外:
BeansException
setEntityCallbacks
ReactiveBeforeSaveCallbackと同様にcallbacksを呼び出すときに使用するReactiveEntityCallbacksインスタンスを設定します。
潜在的に存在するReactiveEntityCallbacksをオーバーライドします。- パラメーター:
entityCallbacks- null であってはなりません。- 例外:
IllegalArgumentExceptionSE- 指定されたインスタンスが null の場合。- 導入:
- 2.2
useEstimatedCount
public void useEstimatedCount(boolean enabled) 推定回数を使用するかどうかを設定します。デフォルトは正確なカウントです。- パラメーター:
enabled- ページなしの場合はMongoCollection.estimatedDocumentCount()を使用し、trueの場合は空のqueriesを使用します。- 導入:
- 3.4
getConverter
デフォルトのMongoConverterを返します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのgetConverter - 戻り値:
indexOps
インターフェースからコピーされた説明:ReactiveMongoOperationsインデックスに対して実行できるリアクティブ操作を返します- 次で指定:
- インターフェース
ReactiveMongoOperationsのindexOps - パラメーター:
collectionName- null であってはなりません。- 戻り値:
- 名前付きコレクションに対するインデックス操作
indexOps
インターフェースからコピーされた説明:ReactiveMongoOperationsインデックスに対して実行できるリアクティブ操作を返します- 次で指定:
- インターフェース
ReactiveMongoOperationsのindexOps - パラメーター:
entityClass- null であってはなりません。- 戻り値:
- 指定されたエンティティクラスに関連付けられた名前付きコレクションに対するインデックス操作
getCollectionName
インターフェースからコピーされた説明:ReactiveMongoOperationsこのテンプレートによって指定されたクラスに使用されるコレクション名。- 次で指定:
- インターフェース
ReactiveMongoOperationsのgetCollectionName - パラメーター:
entityClass- null であってはなりません。- 戻り値:
- 決して null にはなりません。
executeCommand
インターフェースからコピーされた説明:ReactiveMongoOperationsJSON 文字列として表現された MongoDB コマンドを実行します。これにより、MongoDB ドライバーの一部であるメソッド JSON.parse が呼び出され、JSON 文字列がドキュメントに変換されます。このコマンドの実行によって発生したエラーはすべて、Spring の DAO 例外階層に変換されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexecuteCommand - パラメーター:
jsonCommand- JSON 文字列として表現された MongoDB コマンド。- 戻り値:
- アクションによって返される結果オブジェクト
executeCommand
インターフェースからコピーされた説明:ReactiveMongoOperationsMongoDB コマンドを実行します。このコマンドの実行によって発生するエラーはすべて、Spring の DAO 例外階層に変換されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexecuteCommand - パラメーター:
command- MongoDB コマンド。- 戻り値:
- アクションによって返される結果オブジェクト
executeCommand
public Mono<org.bson.Document> executeCommand(org.bson.Document command, @Nullable com.mongodb.ReadPreference readPreference) インターフェースからコピーされた説明:ReactiveMongoOperationsMongoDB コマンドを実行します。このコマンドの実行によって発生したエラーは、Spring のデータアクセス例外階層に変換されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexecuteCommand - パラメーター:
command- MongoDB コマンドは null であってはなりません。readPreference- 使用する読み取り設定は、null にすることもできます。- 戻り値:
- アクションによって返される結果オブジェクト。
execute
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたクラスのエンティティコレクションに対して指定されたReactiveCollectionCallbackを実行します。
結果オブジェクト、つまりドメインオブジェクトまたはドメインオブジェクトのコレクションを返すことができます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexecute - 型パラメーター:
T- 戻りの型。- パラメーター:
entityClass- 使用するコレクションを決定するクラス。null であってはなりません。action- MongoDB アクションを指定するコールバックオブジェクト。null であってはなりません。- 戻り値:
- アクションによって返された結果オブジェクト、または null。
execute
インターフェースからコピーされた説明:ReactiveMongoOperations必要に応じて例外を変換するReactiveDatabaseCallbackを実行します。
結果オブジェクト、つまりドメインオブジェクトまたはドメインオブジェクトのコレクションを返すことができます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexecute - 型パラメーター:
T- 戻りの型。- パラメーター:
action- 渡された DB インスタンスに対して実行する MongoDB アクションを指定するコールバックオブジェクト。null であってはなりません。- 戻り値:
- アクションによって返される結果オブジェクト
execute
インターフェースからコピーされた説明:ReactiveMongoOperations指定された名前のコレクションに対して指定されたReactiveCollectionCallbackを実行します。
結果オブジェクト、つまりドメインオブジェクトまたはドメインオブジェクトのコレクションを返すことができます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexecute - 型パラメーター:
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)を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのwithSession - パラメーター:
sessionProvider- null であってはなりません。- 戻り値:
ReactiveSessionScopedの新しいインスタンス。null になることはありません。
setSessionSynchronization
ReactiveMongoTemplateがトランザクションに参加するかどうかを定義します。デフォルトはSessionSynchronization.ON_ACTUAL_TRANSACTIONに設定されています。注意 : MongoDB トランザクションには少なくとも MongoDB 4.0 が必要です。
- 導入:
- 2.2
withSession
public ReactiveMongoOperations withSession(com.mongodb.reactivestreams.client.ClientSession session) インターフェースからコピーされた説明:ReactiveMongoOperationsReactiveMongoOperationsのClientSessionバインドされたインスタンスを取得します。
注 :ClientSessionライフサイクルを管理するのは呼び出し元の責任です。- 次で指定:
- インターフェース
ReactiveMongoOperationsのwithSession - 戻り値:
ClientSessionReactiveMongoOperationsのバインドされたインスタンス。
withSession
インターフェースからコピーされた説明:ReactiveMongoOperationsMongoDB に対して発行されたすべてのコマンドに、指定された sessionOptions を持つ新しいClientSessionをバインドするSessionScopedのsessionバインドインスタンスを取得します。
注 :ClientSessionライフサイクルの管理は呼び出し元が行います。完了したらClientSessionを処理するためのフックを提供するには、ReactiveSessionScoped.execute(ReactiveSessionCallback, Consumer)を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのwithSession - パラメーター:
sessionOptions- null であってはなりません。- 戻り値:
ReactiveSessionScopedの新しいインスタンス。null になることはありません。
createFlux
- パラメーター:
callback- null であってはなりません- 戻り値:
ReactiveDatabaseCallbackをラップするFlux。
createMono
- パラメーター:
callback- null であってはなりません- 戻り値:
ReactiveDatabaseCallbackをラップするMono。
createFlux
- パラメーター:
collectionName- 空または null であってはなりません。callback- null であってはなりません。- 戻り値:
ReactiveCollectionCallbackを包む再利用可能なFlux。
createMono
- 型パラメーター:
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)を通じて提供する必要があります。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateCollection - パラメーター:
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を通じて提供される必要があります。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateCollection - パラメーター:
entityClass- 作成するコレクションを決定するクラス。collectionOptionsCustomizer- 派生したCollectionOptionsをカスタマイズするためのカスタマイザー関数。- 戻り値:
- 作成されたコレクション。
- 関連事項:
createCollection
public <T> Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(ClassSE<T> entityClass, @Nullable CollectionOptions collectionOptions) インターフェースからコピーされた説明:ReactiveMongoOperationsオプションを使用して、指定されたエンティティクラスに基づく名前のコレクションを作成します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateCollection - パラメーター:
entityClass- 作成するコレクションを決定するクラス。null であってはなりません。collectionOptions- コレクションを作成するときに使用するオプション。- 戻り値:
- 作成されたコレクション。
createCollection
public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperations指定された名前で上限のないコレクションを作成します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateCollection - パラメーター:
collectionName- コレクションの名前。- 戻り値:
- 作成されたコレクション。
createCollection
public Mono<com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document>> createCollection(StringSE collectionName, @Nullable CollectionOptions collectionOptions) インターフェースからコピーされた説明:ReactiveMongoOperations指定された名前とオプションでコレクションを作成します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateCollection - パラメーター:
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によって定義されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateView - パラメーター:
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によって定義されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcreateView - パラメーター:
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であるかどうかを確認します。
必要に応じて例外を変換します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのgetCollection - パラメーター:
collectionName- コレクションの名前。- 戻り値:
- 既存のコレクション、または最初のサーバーとのやり取りで作成されたコレクション。
collectionExists
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスによって示された名前を持つコレクションが存在するかどうかを確認します。
必要に応じて例外を変換します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcollectionExists - パラメーター:
entityClass- コレクションの名前を決定するクラス。null であってはなりません。- 戻り値:
- 指定された名前のコレクションが見つかった場合は true、それ以外の場合は false。
collectionExists
インターフェースからコピーされた説明:ReactiveMongoOperations指定された名前のコレクションが存在するかどうかを確認します。
必要に応じて例外を変換してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcollectionExists - パラメーター:
collectionName- コレクションの名前。null であってはなりません。- 戻り値:
- 指定された名前のコレクションが見つかった場合は true、それ以外の場合は false。
dropCollection
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスで指定された名前のコレクションをドロップします。
必要に応じて例外を変換してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのdropCollection - パラメーター:
entityClass- ドロップ / 削除するコレクションを決定するクラス。null であってはなりません。
dropCollection
インターフェースからコピーされた説明:ReactiveMongoOperations指定された名前のコレクションをドロップします。
必要に応じて例外を変換してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのdropCollection - パラメーター:
collectionName- ドロップ / 削除するコレクションの名前。
bulkOps
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションの新しいReactiveBulkOperationsを返します。
注 : フィールドマッピングなどの追加サポートは、ドメイン型情報が不足しているため、一括モードでの更新または削除操作には利用できません。完全な型固有のサポートを取得するには、ReactiveMongoOperations.bulkOps(BulkMode, Class, String)を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのbulkOps - パラメーター:
mode- 一括操作に使用するBulkOperations.BulkModeは null であってはなりません。collectionName- 作業するコレクションの名前は、null または空であってはなりません。- 戻り値:
- 指定されたコレクションの
ReactiveBulkOperations
bulkOps
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたエンティティ型の新しいReactiveBulkOperationsを返します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのbulkOps - パラメーター:
mode- 一括操作に使用するBulkOperations.BulkModeは null であってはなりません。entityClass- エンティティクラスの名前は null であってはなりません。- 戻り値:
- 指定されたエンティティクラスに関連付けられた名前付きコレクションに対する
ReactiveBulkOperations。
bulkOps
public ReactiveBulkOperations bulkOps(BulkOperations.BulkMode mode, @Nullable ClassSE<?> entityType, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperations指定されたエンティティ型とコレクション名の新しいReactiveBulkOperationsを返します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのbulkOps - パラメーター:
mode- 一括操作に使用するBulkOperations.BulkModeは null であってはなりません。entityType- エンティティクラスの名前。null にすることもできます。collectionName- 作業するコレクションの名前は、null または空であってはなりません。- 戻り値:
- 指定されたエンティティクラスに関連付けられた名前付きコレクションに対する
ReactiveBulkOperations。
getCollectionNames
インターフェースからコピーされた説明:ReactiveMongoOperationsコレクション名のセット。- 次で指定:
- インターフェース
ReactiveMongoOperationsのgetCollectionNames - 戻り値:
- コレクション名の Flux。
getMongoDatabase
doGetDatabase
findOne
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、BasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindOne - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。entityClass- 返されるMonoのパラメーター化された型。- 戻り値:
- 変換されたオブジェクト。
findOne
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。他に構成されていない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、BasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindOne - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。entityClass- 返されるMonoのパラメーター化された型。collectionName- オブジェクトを取得するコレクションの名前。- 戻り値:
- 変換されたオブジェクト。
exists
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたQueryの結果に少なくとも 1 つの要素が含まれるかを判定します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexists - パラメーター:
query- ドキュメントの検索に使用される条件を指定するQueryクラス。entityClass- パラメーター化された型。- 戻り値:
- クエリが結果を生成する場合は true。
exists
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたQueryの結果に少なくとも 1 つの要素が含まれるかを判定します。
注 : ドメイン型情報が不足しているため、クエリ / フィールドマッピングなどの追加サポートは利用できません。完全な型固有のサポートを取得するには、ReactiveMongoOperations.exists(Query, Class, String)を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexists - パラメーター:
query- ドキュメントの検索に使用される条件を指定するQueryクラス。collectionName- オブジェクトをチェックするコレクションの名前。- 戻り値:
- クエリが結果を生成する場合は true。
exists
public Mono<BooleanSE> exists(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperations指定されたQueryの結果に少なくとも 1 つの要素が含まれるかを判定します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexists - パラメーター:
query- ドキュメントの検索に使用される条件を指定するQueryクラス。entityClass- パラメーター化された型。null にすることもできます。collectionName- オブジェクトをチェックするコレクションの名前。- 戻り値:
- クエリが結果を生成する場合は true。
find
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のFluxにマップします。
オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、これはBasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfind - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。entityClass- 返されるFluxのパラメーター化された型。null であってはなりません。- 戻り値:
- 変換されたオブジェクトの
Flux。
find
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションに対するアドホッククエリの結果を、指定された型のFluxにマップします。
オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、これはBasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfind - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。entityClass- 返されるFluxのパラメーター化された型。collectionName- オブジェクトを取得するコレクションの名前。null であってはなりません。- 戻り値:
- 変換されたオブジェクトの
Flux。
scroll
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから型 T のオブジェクトのスクロールを照会します。
効率的なスクロールのために大きなクエリ結果を制限するために、Query.skip(long)またはQuery.with(KeysetScrollPosition)をQuery.limit(int)とともに必ず設定してください。
結果オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定されていない限り、MappingMongoConverterのインスタンスが使用されます。
コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。KeysetScrollPositionを使用する場合は、MongoDB が$gt/$lt演算子を使用して存在しないドキュメントフィールドまたは null 値からクエリ結果を再構築するための条件をサポートしていないため、null 非許容のsort propertiesを必ず使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのscroll - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。entityType- 返されるリストのパラメーター化された型。- 戻り値:
- 変換されたウィンドウを放出する
Mono。 - 関連事項:
scroll
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから型 T のオブジェクトのウィンドウを照会します。
効率的なスクロールのために大きなクエリ結果を制限するために、Query.skip(long)またはQuery.with(KeysetScrollPosition)をQuery.limit(int)とともに必ず設定してください。
結果オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定されていない限り、MappingMongoConverterのインスタンスが使用されます。
コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。KeysetScrollPositionを使用する場合は、MongoDB が$gt/$lt演算子を使用して存在しないドキュメントフィールドまたは null 値からクエリ結果を再構築するための条件をサポートしていないため、null 非許容のsort propertiesを必ず使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのscroll - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。null であってはなりません。entityType- 返されるリストのパラメーター化された型。collectionName- オブジェクトを取得するコレクションの名前。- 戻り値:
- 変換されたウィンドウを放出する
Mono。 - 関連事項:
findById
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたクラスにマップされた指定された ID を持つドキュメントを返します。クエリが実行されるコレクションも、指定されたターゲットクラスから派生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindById - パラメーター:
id- 返されるドキュメントの ID。null であってはなりません。entityClass- ドキュメントが変換される型。null であってはなりません。- 戻り値:
- 指定されたターゲットクラスにマップされた指定された ID を持つドキュメント。
findById
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたターゲットクラスにマップされた指定されたコレクションから指定された ID を持つドキュメントを返します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindById - パラメーター:
id- 返されるドキュメントの ID。entityClass- ドキュメントを変換する型。collectionName- ドキュメントをクエリするコレクション。- 戻り値:
- 変換されたオブジェクト。
findDistinct
public <T> Flux<T> findDistinct(Query query, StringSE field, ClassSE<?> entityClass, ClassSE<T> resultClass) インターフェースからコピーされた説明:ReactiveMongoOperations単一のMongoCollectionまたはビュー全体で指定されたフィールドの個別の値を検索し、その結果をFluxに返します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindDistinct - パラメーター:
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に返します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindDistinct - パラメーター:
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 が発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのaggregate - パラメーター:
aggregation- 集計操作を保持するTypedAggregation仕様。null にすることはできません。inputCollectionName- 集計に使用する入力コレクションの名前。null にすることはできません。outputType- 返されるFluxのパラメーター化された型。null にすることはできません。- 戻り値:
- 集計操作の結果。
aggregate
インターフェースからコピーされた説明:ReactiveMongoOperations集計操作を実行します。
生の結果は指定されたエンティティクラスにマップされ、ストリームとして返されます。inputCollection の名前はaggregation input typeから派生しています。
集約ストリーミングは、aggregation explainまたはAggregationOptions.getCursorBatchSize()では使用できません。説明モードを有効にするか、バッチサイズを設定すると、IllegalArgumentExceptionSE が発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのaggregate - パラメーター:
aggregation- 集計操作を保持するTypedAggregation仕様。null にすることはできません。outputType- 返されるFluxのパラメーター化された型。null にすることはできません。- 戻り値:
- 集計操作の結果。
aggregate
インターフェースからコピーされた説明:ReactiveMongoOperations集計操作を実行します。
生の結果は指定されたouputTypeにマッピングされます。inputCollection の名前はinputTypeから派生したものです。
集約ストリーミングは、aggregation explainでもAggregationOptions.getCursorBatchSize()でも使用できません。説明モードを有効にするか、バッチサイズを設定すると、IllegalArgumentExceptionSE が発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのaggregate - パラメーター:
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 が発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのaggregate - パラメーター:
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
インターフェースからコピーされた説明: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);- 次で指定:
- インターフェース
ReactiveMongoOperationsのgeoNear - パラメーター:
near- null であってはなりません。entityClass- null であってはなりません。- 戻り値:
- 変換された
GeoResults。
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);- 次で指定:
- インターフェース
ReactiveMongoOperationsのgeoNear - パラメーター:
near- null であってはなりません。entityClass- null であってはなりません。collectionName- クエリをトリガーするコレクション。コレクション名が指定されていない場合は、エンティティクラスがインスペクションされます。- 戻り値:
- 変換された
GeoResults。
geoNear
findAndModify
インターフェースからコピーされた説明:ReactiveMongoOperationsfindAndModify をトリガーして、指定されたQueryのCriteriaに一致するドキュメントに指定されたUpdateを適用します。entityClass の潜在的な
Versionプロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndModify - パラメーター:
query- ドキュメントの検索に使用されるCriteriaとオプションのフィールド仕様を指定するQueryクラス。null にすることはできません。update- 一致するドキュメントに適用するUpdateDefinition。null にすることはできません。entityClass- パラメーター化された型。null であってはなりません。- 戻り値:
- 更新される前に更新された変換されたオブジェクト。
- 関連事項:
findAndModify
public <T> Mono<T> findAndModify(Query query, UpdateDefinition update, ClassSE<T> entityClass, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperationsfindAndModify をトリガーして、指定されたQueryのCriteriaに一致するドキュメントに指定されたUpdateを適用します。entityClass の潜在的な
Versionプロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndModify - パラメーター:
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) インターフェースからコピーされた説明:ReactiveMongoOperationsfindAndModify をトリガーして、FindAndModifyOptionsを考慮して、指定されたQueryのCriteriaに一致するドキュメントに指定されたUpdateを適用します。entityClass の潜在的な
Versionプロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndModify - パラメーター:
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) インターフェースからコピーされた説明:ReactiveMongoOperationsfindAndModify をトリガーして、FindAndModifyOptionsを考慮して、指定されたQueryのCriteriaに一致するドキュメントに指定されたUpdateを適用します。entityClass の潜在的な
Versionプロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndModify - パラメーター:
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) インターフェースからコピーされた説明:ReactiveMongoOperationsfindOneAndReplace をトリガーして、指定されたQueryのCriteriaに一致する単一のドキュメントを、FindAndReplaceOptionsを考慮してreplacementドキュメントに置き換えます。
注意 : 置換エンティティは ID を保持してはなりません。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndReplace - パラメーター:
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, Mono<R> findAndReplaceR> (Query query, S replacement, FindAndReplaceOptions options, ClassSE<S> entityType, StringSE collectionName, ClassSE<T> resultType, QueryResultConverter<? super T, ? extends R> resultConverter) findAndRemove
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティ型のコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。クエリに一致する最初のドキュメントが返され、データベースのコレクションからも削除されます。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。
クエリはQueryとして指定され、BasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndRemove - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。entityClass- 返されるMonoのパラメーター化された型。- 戻り値:
- 変換されたオブジェクト
findAndRemove
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトの単一インスタンスにマップします。クエリに一致する最初のドキュメントが返され、データベースのコレクションからも削除されます。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現から変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、BasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAndRemove - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。entityClass- 返されるMonoのパラメーター化された型。collectionName- オブジェクトを取得するコレクションの名前。- 戻り値:
- 変換されたオブジェクト。
count
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたエンティティクラスのコレクションを照会して、指定されたQueryのドキュメントの数を返します。
注 : クエリoffsetおよびlimitは、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
この方法では、パフォーマンスに影響を与える可能性のあるaggregation executionを実行する代わりに、空のクエリに対してReactiveMongoOperations.estimatedCount(Class)を使用することを選択する場合があります。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcount - パラメーター:
query- ドキュメントの検索に使用する条件を指定するQueryクラス。null にすることはできません。entityClass- 使用するコレクションを決定するクラス。null であってはなりません。- 戻り値:
- 一致するドキュメントの数。
- 関連事項:
count
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションを照会する指定されたQueryのドキュメントの数を返します。指定されたQueryは、潜在的なプロパティ参照をドキュメントフィールドにマップするための型情報がないため、ドキュメントフィールド参照のみで構成されている必要があります。完全な型固有のサポートを得るには、ReactiveMongoOperations.count(Query, Class, String)を使用します。
注 : クエリoffsetおよびlimitは、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
この方法では、パフォーマンスに影響を与える可能性のあるaggregation executionを実行する代わりに、空のクエリに対してReactiveMongoOperations.estimatedCount(Class)を使用することを選択する場合があります。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcount - パラメーター:
query- ドキュメントの検索に使用する条件を指定するQueryクラス。collectionName- null または空であってはなりません。- 戻り値:
- 一致するドキュメントの数。
- 関連事項:
count
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたエンティティクラスを使用して指定されたコレクションを照会し、指定されたQueryをマップすることにより、指定されたQueryのドキュメントの数を返します。
注 : クエリoffsetおよびlimitは、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
この方法では、パフォーマンスに影響を与える可能性のあるaggregation executionを実行する代わりに、空のクエリに対してReactiveMongoOperations.estimatedCount(Class)を使用することを選択する場合があります。- 次で指定:
- インターフェース
ReactiveMongoOperationsのcount - パラメーター:
query- ドキュメントの検索に使用する条件を指定するQueryクラス。null にすることはできません。entityClass- パラメーター化された型。null にすることもできます。collectionName- null または空であってはなりません。- 戻り値:
- 一致するドキュメントの数。
- 関連事項:
doCount
estimatedCount
インターフェースからコピーされた説明:ReactiveMongoOperationsコレクションの統計に基づいて、指定されたコレクション内のドキュメントの数を推定します。
シャードクラスターや内部トランザクションなどの制限については、MongoDB リファレンスドキュメントを必ず参照してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのestimatedCount - パラメーター:
collectionName- null であってはなりません。- 戻り値:
- 推定されたドキュメント数を発行する
Mono。
doEstimatedCount
exactCount
public Mono<LongSE> exactCount(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperations指定されたエンティティクラスを使用して指定されたコレクションを照会し、指定されたQueryをマップすることにより、指定されたQueryのドキュメントの数を返します。
注 : クエリoffsetおよびlimitは、それらの値がサーバーに渡され、サーバーがカウント操作を実行する範囲と順序を制限する可能性があるため、結果として見つかるドキュメントの数に直接影響を与える可能性があります。すべての一致をカウントするには、ページングされていないクエリを使用します。
この方法では、空のqueriesに対してもaggregation executionが使用されるため、パフォーマンスに影響する可能性がありますが、シャード、セッション、トランザクションのコンプライアンスが保証されます。不正確なカウントがアプリケーションのニーズを満たす場合は、代わりに空のクエリに対してReactiveMongoOperations.estimatedCount(String)を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのexactCount - パラメーター:
query- ドキュメントの検索に使用する条件を指定するQueryクラス。null にすることはできません。entityClass- パラメーター化された型。null にすることもできます。collectionName- null または空であってはなりません。- 戻り値:
- 一致するドキュメントの数。
doExactCount
countCanBeEstimated
insert
インターフェースからコピーされた説明:ReactiveMongoOperations保存するオブジェクトのエンティティ型のコレクションにオブジェクトを挿入します。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。
オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。
Insert は、オブジェクトを最初にデータベースに保存するために使用されます。既存のオブジェクトを更新するには、save メソッドを使用します。潜在的な
Versionプロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsert - パラメーター:
objectToSave- コレクションに格納するオブジェクト。null にすることはできません。- 戻り値:
- 挿入されたオブジェクト。
insertAll
public <T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> batchToSave, ClassSE<?> entityClass) インターフェースからコピーされた説明:ReactiveMongoOperationsデータベースへの 1 回のバッチ書き込みで、オブジェクトのコレクションをコレクションに挿入します。バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。
新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsertAll - パラメーター:
batchToSave- 保存するオブジェクトを提供する発行者。null にすることはできません。entityClass- 使用するコレクションを決定するクラス。null であってはなりません。- 戻り値:
- 挿入されたオブジェクト。
insertAll
public <T> Flux<T> insertAll(Mono<? extends CollectionSE<? extends T>> batchToSave, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperationsデータベースへの単一のバッチ書き込みで、指定されたコレクションにオブジェクトを挿入します。バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。
新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsertAll - パラメーター:
batchToSave- 保存するオブジェクトを提供する発行者。null にすることはできません。collectionName- オブジェクトを格納するコレクションの名前。null にすることはできません。- 戻り値:
- 挿入されたオブジェクト。
insert
インターフェースからコピーされた説明:ReactiveMongoOperations保存するオブジェクトのエンティティ型のコレクションにオブジェクトを挿入します。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。
オブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。Id プロパティが文字列の場合、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。
Insert は、オブジェクトを最初にデータベースに保存するために使用されます。既存のオブジェクトを更新するには、save メソッドを使用します。新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。objectToSaveはコレクションのようなものであってはなりません。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsert - パラメーター:
objectToSave- コレクションに格納するオブジェクト。null にすることはできません。- 戻り値:
- 挿入されたオブジェクト。
insert
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションにオブジェクトを挿入します。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
Insert は、オブジェクトを最初にデータベースに保存するために使用されます。既存のオブジェクトを更新するには、save メソッドを使用します。新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。objectToSaveはコレクションのようなものであってはなりません。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsert - パラメーター:
objectToSave- コレクションに格納するオブジェクト。null にすることはできません。collectionName- オブジェクトを格納するコレクションの名前。null にすることはできません。- 戻り値:
- 挿入されたオブジェクト。
doInsert
protected <T> Mono<T> doInsert(StringSE collectionName, T objectToSave, MongoWriter<ObjectSE> writer) insert
インターフェースからコピーされた説明:ReactiveMongoOperationsデータベースへの 1 回のバッチ書き込みで、オブジェクトのコレクションをコレクションに挿入します。バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。
新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsert - パラメーター:
batchToSave- 保存するオブジェクトのバッチ。null にすることはできません。entityClass- 使用するコレクションを決定するクラス。null であってはなりません。- 戻り値:
- 挿入されたオブジェクト。
insert
インターフェースからコピーされた説明:ReactiveMongoOperationsデータベースへの単一のバッチ書き込みで、指定されたコレクションにオブジェクトのバッチを挿入します。バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。
新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsert - パラメーター:
batchToSave- 保存するオブジェクトのリスト。null にすることはできません。collectionName- オブジェクトを格納するコレクションの名前。null にすることはできません。- 戻り値:
- 挿入されたオブジェクト。
insertAll
インターフェースからコピーされた説明:ReactiveMongoOperationsオブジェクトの混合コレクションをデータベースコレクションに挿入し、クラスに基づいて使用するコレクション名を決定します。バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。
新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsertAll - パラメーター:
objectsToSave- 保存するオブジェクトのリスト。null にすることはできません。- 戻り値:
- 保存されたオブジェクト。
insertAll
インターフェースからコピーされた説明:ReactiveMongoOperationsオブジェクトの混合コレクションをデータベースコレクションに挿入し、クラスに基づいて使用するコレクション名を決定します。バッチ内のオブジェクトに null 値を保持する Id プロパティがある場合、MongoDB から生成された Id が設定されます。
新しいオブジェクトを挿入すると、
Versionプロパティの初期化がトリガーされます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのinsertAll - パラメーター:
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
インターフェースからコピーされた説明:ReactiveMongoOperations保存するオブジェクトのエンティティ型のコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入 (つまり、"upsert" ) が実行されます。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。潜在的な
Versionプロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのsave - パラメーター:
objectToSave- コレクションに格納するオブジェクト。null にすることはできません。- 戻り値:
- 保存されたオブジェクト。
save
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入、つまり "upsert" が実行されます。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。潜在的な
Versionプロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのsave - パラメーター:
objectToSave- collReactiveMongoOperationsection に格納するオブジェクト。null にすることはできません。collectionName- オブジェクトを格納するコレクションの名前。null にすることはできません。- 戻り値:
- 保存されたオブジェクト。
save
インターフェースからコピーされた説明:ReactiveMongoOperations保存するオブジェクトのエンティティ型のコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入 (つまり、"upsert" ) が実行されます。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。潜在的な
Versionプロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。objectToSaveはコレクションのようなものであってはなりません。- 次で指定:
- インターフェース
ReactiveMongoOperationsのsave - パラメーター:
objectToSave- コレクションに格納するオブジェクト。null にすることはできません。- 戻り値:
- 保存されたオブジェクト。
save
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションにオブジェクトを保存します。オブジェクトがまだ存在しない場合は挿入、つまり "upsert" が実行されます。
オブジェクトは、のインスタンスを使用して MongoDB ネイティブ表現に変換されます。特に設定しない限り、MappingMongoConverterのインスタンスが使用されます。
オブジェクトに "Id" プロパティがある場合は、MongoDB から生成された Id で設定されます。Id プロパティが文字列の場合は、MongoDB ObjectId を使用してその文字列が入力されます。それ以外の場合、ObjectId からプロパティ型への変換は、Type Conversion API を活用する Spring の BeanWrapper クラスによって処理されます。詳細については、Spring の型変換を参照してください。潜在的な
Versionプロパティは自動的に増分されます。その間にドキュメントが変更された場合、操作によってエラーが発生します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのsave - パラメーター:
objectToSave- コレクションに格納するオブジェクト。null にすることはできません。collectionName- オブジェクトを格納するコレクションの名前。null にすることはできません。- 戻り値:
- 保存されたオブジェクト。
doSave
insertDocument
insertDocumentList
saveDocument
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)を使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupsert - パラメーター:
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)を使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupsert - パラメーター:
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プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupsert - パラメーター:
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プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupdateFirst - パラメーター:
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)を使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupdateFirst - パラメーター:
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プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupdateFirst - パラメーター:
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プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupdateMulti - パラメーター:
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)を使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupdateMulti - パラメーター:
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プロパティは、更新時に明示的に指定されていない場合は自動的に増分されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのupdateMulti - パラメーター:
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
インターフェースからコピーされた説明:ReactiveMongoOperationsID および (該当する場合)Versionによって、コレクションから指定されたオブジェクトを削除します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
objectToRemove- null であってはなりません。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
remove
public Mono<com.mongodb.client.result.DeleteResult> remove(Mono<? extends ObjectSE> objectToRemove, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから、指定されたオブジェクトを ID と (該当する場合)Versionで削除します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
objectToRemove- null であってはなりません。collectionName- ドキュメントが削除されるコレクションの名前。null または空であってはなりません。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
remove
インターフェースからコピーされた説明:ReactiveMongoOperationsID および (該当する場合)Versionによって、コレクションから指定されたオブジェクトを削除します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
object- null であってはなりません。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
remove
public Mono<com.mongodb.client.result.DeleteResult> remove(ObjectSE object, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから指定されたオブジェクトを削除します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
object- null であってはなりません。collectionName- ドキュメントが削除されるコレクションの名前。null または空であってはなりません。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
remove
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから、提供されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。ID フィールドを使用する条件に対しては、変換 / マッピングは実行されません。
注 : ドメイン型情報が不足しているため、フィールドマッピングの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.remove(Query, Class, String)を使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
query- ドキュメントを削除するために使用される条件を指定するクエリドキュメント。collectionName- ドキュメントが削除されるコレクションの名前。null または空であってはなりません。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
remove
インターフェースからコピーされた説明:ReactiveMongoOperationsentityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。Class パラメーターは、クエリ内に存在する場合、オブジェクトの ID を変換するためにも使用されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
query- ドキュメントを削除するために使用される条件を指定するクエリドキュメント。entityClass- 使用するコレクションを決定するクラス。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
remove
public Mono<com.mongodb.client.result.DeleteResult> remove(Query query, @Nullable ClassSE<?> entityClass, StringSE collectionName) インターフェースからコピーされた説明:ReactiveMongoOperationsentityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを削除します。Class パラメーターは、クエリ内に存在する場合、オブジェクトの ID を変換するためにも使用されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのremove - パラメーター:
query- ドキュメントを削除するために使用される条件を指定するクエリドキュメント。entityClass- 操作対象となる pojo のクラス。null にすることもできます。collectionName- ドキュメントが削除されるコレクションの名前。null または空であってはなりません。- 戻り値:
- 前回の削除の結果にアクセスできる
DeleteResult。
doRemove
findAll
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスによって使用されるコレクションから、型 T のオブジェクトのFluxをクエリします。
オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverterのインスタンスが使用されます。
コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAll - パラメーター:
entityClass- 返されるFluxのパラメーター化された型。- 戻り値:
- 変換されたコレクション。
findAll
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから型 T のオブジェクトのFluxを照会します。
オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverterのインスタンスが使用されます。
コレクションに同種の型のコレクションが含まれていない場合、クラス型のテストはサーバーではなくクライアントで実行されるため、この操作はオブジェクトをマップする効率的な方法にはなりません。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAll - パラメーター:
entityClass- 返されるFluxのパラメーター化された型。collectionName- オブジェクトを取得するコレクションの名前。- 戻り値:
- 変換されたコレクション。
findAllAndRemove
インターフェースからコピーされた説明:ReactiveMongoOperations指定されたコレクションから、指定されたクエリに一致するすべてのドキュメントを返して削除します。
注 : ドメイン型情報が不足しているため、フィールドマッピングの追加サポートは利用できません。完全な型固有のサポートを得るには、ReactiveMongoOperations.findAllAndRemove(Query, Class, String)を使用してください。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAllAndRemove - パラメーター:
query- ドキュメントの検索と削除に使用する条件を指定するクエリドキュメント。collectionName- ドキュメントが削除されるコレクションの名前。null または空であってはなりません。- 戻り値:
- この操作によって削除された
Flux変換オブジェクト。
findAllAndRemove
インターフェースからコピーされた説明:ReactiveMongoOperationsentityClass を格納するために使用されたコレクションから、指定されたクエリに一致するすべてのドキュメントを返して削除します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAllAndRemove - パラメーター:
query- ドキュメントの検索と削除に使用する条件を指定するクエリドキュメント。entityClass- 操作対象となる pojo のクラス。- 戻り値:
- この操作によって削除された
Flux変換オブジェクト。
findAllAndRemove
インターフェースからコピーされた説明:ReactiveMongoOperationsentityClass の保存に使用されるコレクションから、指定されたクエリドキュメント条件に一致するすべてのドキュメントを返して削除します。Class パラメーターは、クエリ内に存在する場合、オブジェクトの ID を変換するのにも使用されます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのfindAllAndRemove - パラメーター:
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- 次で指定:
- インターフェース
ReactiveMongoOperationsのreplace - パラメーター:
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
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトのストリームにマッピングします。ストリームはtailableカーソルを使用しますが、これは無限ストリームになる場合があります。Subscriptionがcanceledでない限り、ストリームは完了しません。
オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、これはBasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのtail - パラメーター:
query- ドキュメントの検索に使用される条件と、オプションのフィールド仕様を指定するクエリクラス。entityClass- 返されるFluxのパラメーター化された型。- 戻り値:
- 変換されたオブジェクトの
Flux。
tail
インターフェースからコピーされた説明:ReactiveMongoOperationsエンティティクラスのコレクションに対するアドホッククエリの結果を、指定された型のオブジェクトのストリームにマッピングします。ストリームはtailableカーソルを使用しますが、これは無限ストリームになる場合があります。Subscriptionがcanceledでない限り、ストリームは完了しません。
オブジェクトは、MongoDB のネイティブ表現から のインスタンスを使用して変換されます。特に設定がない限り、MappingMongoConverterのインスタンスが使用されます。
クエリはQueryとして指定され、これはBasicQueryまたはより機能が豊富なQueryを使用して作成できます。- 次で指定:
- インターフェース
ReactiveMongoOperationsのtail - パラメーター:
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を使用します。Subscriptionがcanceledでない限り、ストリームは完了しません。
ChangeStreamEvent.getBody()は resultType にマップされ、ChangeStreamEvent.getRaw()には変更されていないペイロードが含まれます。
変更ストリームを再開するためのthe resumseTokenのような引数を設定するには、ChangeStreamOptionsを使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのchangeStream - 型パラメーター:
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を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのmapReduce - パラメーター:
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を使用します。- 次で指定:
- インターフェース
ReactiveMongoOperationsのmapReduce - パラメーター:
filterQuery- マップ関数に入力されるドキュメントの選択条件。null にすることはできません。domainType- フィルターQueryをマップするために使用されるソース型。null にすることはできません。inputCollectionName- 入力コレクション。resultType- 操作結果ドキュメントのマッピングターゲット。null にすることはできません。mapFunction- JavaScript マップ関数。null にすることはできません。reduceFunction- JavaScript 削減関数。null であってはなりません。options- 出力コレクションなどの追加オプション。null にすることはできません。- 戻り値:
- 結果ドキュメントシーケンスを出力する
Flux。null にはなりません。
query
インターフェースからコピーされた説明:ReactiveFindOperation指定された domainType の検索操作の作成を開始します。- 次で指定:
- インターフェース
ReactiveFindOperationのquery - パラメーター:
domainType- null であってはなりません。- 戻り値:
ReactiveFindOperation.ReactiveFindの新しいインスタンス。null になることはありません。
update
インターフェースからコピーされた説明:ReactiveUpdateOperation指定された domainType の更新操作の作成を開始します。- 次で指定:
- インターフェース
ReactiveUpdateOperationのupdate - パラメーター:
domainType- null であってはなりません。- 戻り値:
ReactiveUpdateOperation.ReactiveUpdateの新しいインスタンス。null になることはありません。
remove
インターフェースからコピーされた説明:ReactiveRemoveOperation指定された domainType の削除操作の作成を開始します。- 次で指定:
- インターフェース
ReactiveRemoveOperationのremove - パラメーター:
domainType- null であってはなりません。- 戻り値:
ReactiveRemoveOperation.ReactiveRemoveの新しいインスタンス。null になることはありません。
insert
インターフェースからコピーされた説明:ReactiveInsertOperation指定された domainType の挿入操作の作成を開始します。- 次で指定:
- インターフェース
ReactiveInsertOperationのinsert - パラメーター:
domainType- null であってはなりません。- 戻り値:
ReactiveInsertOperation.ReactiveInsertの新しいインスタンス。null になることはありません。
aggregateAndReturn
public <T> ReactiveAggregationOperation.ReactiveAggregation<T> aggregateAndReturn(ClassSE<T> domainType) インターフェースからコピーされた説明:ReactiveAggregationOperation指定されたドメイン型にマップされた結果を返す集計操作の作成を開始します。
集計の潜在的に異なる入力型を指定するには、TypedAggregationを使用します。- 次で指定:
- インターフェース
ReactiveAggregationOperationのaggregateAndReturn - パラメーター:
domainType- null であってはなりません。- 戻り値:
ReactiveAggregationOperation.ReactiveAggregationの新しいインスタンス。null になることはありません。
mapReduce
インターフェースからコピーされた説明:ReactiveMapReduceOperation指定された domainType の mapReduce 操作の作成を開始します。- 次で指定:
- インターフェース
ReactiveMapReduceOperationのmapReduce - パラメーター:
domainType- null であってはなりません。- 戻り値:
ExecutableFindOperation.ExecutableFindの新しいインスタンス。
changeStream
public <T> ReactiveChangeStreamOperation.ReactiveChangeStream<T> changeStream(ClassSE<T> domainType) インターフェースからコピーされた説明:ReactiveChangeStreamOperationデータベース内のすべてのコレクションを監視しながら、指定された domainType の変更ストリーム操作の作成を開始します。
collectionおよび / またはfilterを定義してイベントを制限することを検討してください。- 次で指定:
- インターフェース
ReactiveChangeStreamOperationのchangeStream - パラメーター:
domainType- null であってはなりません。生の要素を取得するにはDocumentを使用します。- 戻り値:
ReactiveChangeStreamOperation.ReactiveChangeStreamの新しいインスタンス。null になることはありません。
doFindAndDelete
find(Query, Class, String)およびremove(Query, Class, String)を呼び出して、指定されたqueryに一致するすべてのドキュメントを取得および削除します。一方、remove(Query, Class, String)のQueryは検索結果から構築されます。- パラメーター:
collectionName-query-entityClass-- 戻り値:
doCreateCollection
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
maybeCallBeforeConvert
maybeCallBeforeSave
maybeCallAfterSave
maybeCallAfterConvert
ensureNotCollectionLike
- パラメーター:
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
WriteConcern を用いて処理を行う前に、これを準備しておきます。これにより、サブクラスでカスタム設定を簡単に適用できるようになります。返されるWriteConcernは、WriteResultCheckingがWriteResultChecking.EXCEPTIONに設定されている場合、デフォルトでWriteConcern.ACKNOWLEDGEDになります。- パラメーター:
mongoAction- すでに構成されている WriteConcern または null。- 戻り値:
- 準備された WriteConcern または null。
- 関連事項:
getMongoDatabaseFactory
- 戻り値:
- 使用中の
MongoDatabaseFactory。 - 導入:
- 3.1.4