Package com.alpha.mongodb.sharding.core.template

Class DatabaseShardedReactiveMongoTemplate

java.lang.Object

org.springframework.data.mongodb.core.ReactiveMongoTemplate

com.alpha.mongodb.sharding.core.template.ShardedReactiveMongoTemplate

com.alpha.mongodb.sharding.core.template.DatabaseShardedReactiveMongoTemplate

All Implemented Interfaces:

DatabaseShardingAssistant<org.springframework.data.mongodb.core.ReactiveMongoTemplate>, ShardingAssistant, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.data.mongodb.core.ReactiveAggregationOperation, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation, org.springframework.data.mongodb.core.ReactiveFindOperation, org.springframework.data.mongodb.core.ReactiveFluentMongoOperations, org.springframework.data.mongodb.core.ReactiveInsertOperation, org.springframework.data.mongodb.core.ReactiveMapReduceOperation, org.springframework.data.mongodb.core.ReactiveMongoOperations, org.springframework.data.mongodb.core.ReactiveRemoveOperation, org.springframework.data.mongodb.core.ReactiveUpdateOperation

Direct Known Subclasses:

CompositeShardedReactiveMongoTemplate

public class DatabaseShardedReactiveMongoTemplate
extends ShardedReactiveMongoTemplate
implements DatabaseShardingAssistant<org.springframework.data.mongodb.core.ReactiveMongoTemplate>

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveAggregationOperation

org.springframework.data.mongodb.core.ReactiveAggregationOperation.AggregationOperationWithAggregation<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.AggregationOperationWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.ReactiveAggregation<T extends Object>, org.springframework.data.mongodb.core.ReactiveAggregationOperation.TerminatingAggregationOperation<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveChangeStreamOperation

org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithFilterAndProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ChangeStreamWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ReactiveChangeStream<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.ResumingChangeStream<T extends Object>, org.springframework.data.mongodb.core.ReactiveChangeStreamOperation.TerminatingChangeStream<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveFindOperation

org.springframework.data.mongodb.core.ReactiveFindOperation.DistinctWithProjection, org.springframework.data.mongodb.core.ReactiveFindOperation.DistinctWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindDistinct, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.FindWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.ReactiveFind<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingDistinct<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingFind<T extends Object>, org.springframework.data.mongodb.core.ReactiveFindOperation.TerminatingFindNear<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveInsertOperation

org.springframework.data.mongodb.core.ReactiveInsertOperation.InsertWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveInsertOperation.ReactiveInsert<T extends Object>, org.springframework.data.mongodb.core.ReactiveInsertOperation.TerminatingInsert<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveMapReduceOperation

org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithMapFunction<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.MapReduceWithReduceFunction<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.ReactiveMapReduce<T extends Object>, org.springframework.data.mongodb.core.ReactiveMapReduceOperation.TerminatingMapReduce<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveRemoveOperation

org.springframework.data.mongodb.core.ReactiveRemoveOperation.ReactiveRemove<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.RemoveWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.RemoveWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveRemoveOperation.TerminatingRemove<T extends Object>

Nested classes/interfaces inherited from interface org.springframework.data.mongodb.core.ReactiveUpdateOperation

org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndModifyWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndReplaceWithOptions<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.FindAndReplaceWithProjection<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.ReactiveUpdate<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingFindAndModify<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingFindAndReplace<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.TerminatingUpdate<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithCollection<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithQuery<T extends Object>, org.springframework.data.mongodb.core.ReactiveUpdateOperation.UpdateWithUpdate<T extends Object>

Field Summary

Fields inherited from class org.springframework.data.mongodb.core.ReactiveMongoTemplate

NO_OP_REF_RESOLVER

Constructor Summary

Constructors

Constructor	Description
DatabaseShardedReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient delegatedMongoClient, String databaseName, DatabaseShardingOptions shardingOptions)
DatabaseShardedReactiveMongoTemplate(Map<String,com.mongodb.reactivestreams.client.MongoClient> delegatedMongoClient, String databaseName, DatabaseShardingOptions shardingOptions)
DatabaseShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory, DatabaseShardingOptions shardingOptions)
DatabaseShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory, org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter, DatabaseShardingOptions shardingOptions)
DatabaseShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory, org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter, Consumer<Throwable> subscriptionExceptionHandler, DatabaseShardingOptions shardingOptions)

Method Summary

Modifier and Type	Method	Description
<T> reactor.core.publisher.Flux<T>	find(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass)
<T> reactor.core.publisher.Flux<T>	find(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass, String collectionName)
<T> reactor.core.publisher.Flux<T>	findAll(Class<T> entityClass)
<T> reactor.core.publisher.Flux<T>	findAll(Class<T> entityClass, String collectionName)
<T> reactor.core.publisher.Flux<T>	findAllAndRemove(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass)
<T> reactor.core.publisher.Flux<T>	findAllAndRemove(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass, String collectionName)
<T> reactor.core.publisher.Flux<T>	findAllAndRemove(org.springframework.data.mongodb.core.query.Query query, String collectionName)
<T> reactor.core.publisher.Mono<T>	findAndModify(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<T> entityClass)
<T> reactor.core.publisher.Mono<T>	findAndModify(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<T> entityClass, String collectionName)
<T> reactor.core.publisher.Mono<T>	findAndModify(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, org.springframework.data.mongodb.core.FindAndModifyOptions options, Class<T> entityClass)
<T> reactor.core.publisher.Mono<T>	findAndModify(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, org.springframework.data.mongodb.core.FindAndModifyOptions options, Class<T> entityClass, String collectionName)
<T> reactor.core.publisher.Mono<T>	findAndRemove(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass)
<T> reactor.core.publisher.Mono<T>	findAndRemove(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass, String collectionName)
<S,T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, S replacement, org.springframework.data.mongodb.core.FindAndReplaceOptions options, Class<S> entityType, Class<T> resultType)
<S,T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, S replacement, org.springframework.data.mongodb.core.FindAndReplaceOptions options, Class<S> entityType, String collectionName, Class<T> resultType)
<T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, T replacement)
<T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, T replacement, String collectionName)
<T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, T replacement, org.springframework.data.mongodb.core.FindAndReplaceOptions options)
<T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, T replacement, org.springframework.data.mongodb.core.FindAndReplaceOptions options, Class<T> entityType, String collectionName)
<T> reactor.core.publisher.Mono<T>	findAndReplace(org.springframework.data.mongodb.core.query.Query query, T replacement, org.springframework.data.mongodb.core.FindAndReplaceOptions options, String collectionName)
<T> reactor.core.publisher.Mono<T>	findById(Object id, Class<T> entityClass)
<T> reactor.core.publisher.Mono<T>	findById(Object id, Class<T> entityClass, String collectionName)
<T> reactor.core.publisher.Flux<T>	findDistinct(String field, Class<?> entityClass, Class<T> resultClass)
<T> reactor.core.publisher.Flux<T>	findDistinct(org.springframework.data.mongodb.core.query.Query query, String field, Class<?> entityClass, Class<T> resultClass)
<T> reactor.core.publisher.Flux<T>	findDistinct(org.springframework.data.mongodb.core.query.Query query, String field, String collectionName, Class<?> entityClass, Class<T> resultClass)
<T> reactor.core.publisher.Flux<T>	findDistinct(org.springframework.data.mongodb.core.query.Query query, String field, String collection, Class<T> resultClass)
<T> reactor.core.publisher.Mono<T>	findOne(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass)
<T> reactor.core.publisher.Mono<T>	findOne(org.springframework.data.mongodb.core.query.Query query, Class<T> entityClass, String collectionName)
<T> org.springframework.data.mongodb.core.ReactiveInsertOperation.ReactiveInsert<T>	insert(Class<T> domainType)
<T> reactor.core.publisher.Flux<T>	insert(Collection<? extends T> batchToSave, Class<?> entityClass)
<T> reactor.core.publisher.Flux<T>	insert(Collection<? extends T> batchToSave, String collectionName)
<T> reactor.core.publisher.Mono<T>	insert(T objectToSave)
<T> reactor.core.publisher.Mono<T>	insert(T objectToSave, String collectionName)
<T> reactor.core.publisher.Flux<T>	insertAll(Collection<? extends T> objectsToSave)
<T> org.springframework.data.mongodb.core.ReactiveFindOperation.ReactiveFind<T>	query(Class<T> domainType)
<T> org.springframework.data.mongodb.core.ReactiveRemoveOperation.ReactiveRemove<T>	remove(Class<T> domainType)
reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult>	remove(Object object)
reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult>	remove(Object object, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult>	remove(org.springframework.data.mongodb.core.query.Query query, Class<?> entityClass)
reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult>	remove(org.springframework.data.mongodb.core.query.Query query, Class<?> entityClass, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult>	remove(org.springframework.data.mongodb.core.query.Query query, String collectionName)
<T> reactor.core.publisher.Mono<T>	save(T objectToSave)
<T> reactor.core.publisher.Mono<T>	save(T objectToSave, String collectionName)
<T> org.springframework.data.mongodb.core.ReactiveUpdateOperation.ReactiveUpdate<T>	update(Class<T> domainType)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	updateFirst(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<?> entityClass)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	updateFirst(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<?> entityClass, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	updateFirst(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	updateMulti(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<?> entityClass)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	updateMulti(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<?> entityClass, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	updateMulti(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	upsert(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<?> entityClass)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	upsert(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, Class<?> entityClass, String collectionName)
reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult>	upsert(org.springframework.data.mongodb.core.query.Query query, org.springframework.data.mongodb.core.query.UpdateDefinition update, String collectionName)

Methods inherited from class com.alpha.mongodb.sharding.core.template.ShardedReactiveMongoTemplate

setApplicationContext

Methods inherited from class org.springframework.data.mongodb.core.ReactiveMongoTemplate

aggregate, aggregate, aggregate, aggregate, aggregateAndReturn, changeStream, changeStream, collectionExists, collectionExists, convertToCreateCollectionOptions, convertToCreateCollectionOptions, count, count, count, countCanBeEstimated, createCollection, createCollection, createCollection, createCollection, createFlux, createFlux, createMono, createMono, doAggregate, doCount, doCreateCollection, doEstimatedCount, doExactCount, doFind, doFind, doFind, doFindAndDelete, doFindAndModify, doFindAndRemove, doFindAndReplace, doFindOne, doFindOne, doGetDatabase, doInsert, doInsertAll, doInsertBatch, doRemove, doSave, doUpdate, dropCollection, dropCollection, ensureNotCollectionLike, ensureNotIterable, estimatedCount, exactCount, execute, execute, execute, executeCommand, executeCommand, executeCommand, exists, exists, exists, geoNear, geoNear, geoNear, getCollection, getCollectionName, getCollectionNames, getConverter, getMongoDatabase, getMongoDatabaseFactory, indexOps, indexOps, insert, insertAll, insertAll, insertAll, insertDocument, insertDocumentList, inTransaction, inTransaction, mapReduce, mapReduce, mapReduce, maybeCallAfterConvert, maybeCallAfterSave, maybeCallBeforeConvert, maybeCallBeforeSave, maybeEmitEvent, prepareCollection, prepareDatabase, prepareWriteConcern, remove, remove, save, save, saveDocument, setEntityCallbacks, setReadPreference, setSessionSynchronization, setWriteConcern, setWriteConcernResolver, setWriteResultChecking, tail, tail, useEstimatedCount, withSession, withSession, withSession

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.alpha.mongodb.sharding.core.assitant.DatabaseShardingAssistant

getDelegatedShardedMongoTemplateMap, getDelegatedTemplateForDeleteContext, getDelegatedTemplateForDeleteContext, getDelegatedTemplateForDeleteContext, getDelegatedTemplateForFindContext, getDelegatedTemplateForFindContext, getDelegatedTemplateForSaveContext, getDelegatedTemplateForUpdateContext, getDelegatedTemplateForUpdateContext, getDelegatedTemplateWithEntityContext, getDelegatedTemplateWithoutEntityContext, resolveDatabaseHintWithEntityContext

Methods inherited from interface org.springframework.data.mongodb.core.ReactiveMongoOperations

changeStream, changeStream, estimatedCount, exactCount, exactCount, withSession

Methods inherited from interface com.alpha.mongodb.sharding.core.assitant.ShardingAssistant

getHintResolutionCallbacks, getShardingOptions, resolveCollectionHintWithoutEntityContext, resolveCollectionNameWithoutEntityContext, resolveDatabaseHintWithoutEntityContext, resolveDatabaseNameWithoutEntityContext

Constructor Detail

DatabaseShardedReactiveMongoTemplate

public DatabaseShardedReactiveMongoTemplate(Map<String,com.mongodb.reactivestreams.client.MongoClient> delegatedMongoClient,
                                            String databaseName,
                                            DatabaseShardingOptions shardingOptions)

DatabaseShardedReactiveMongoTemplate

public DatabaseShardedReactiveMongoTemplate(com.mongodb.reactivestreams.client.MongoClient delegatedMongoClient,
                                            String databaseName,
                                            DatabaseShardingOptions shardingOptions)

DatabaseShardedReactiveMongoTemplate

public DatabaseShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory,
                                            DatabaseShardingOptions shardingOptions)

DatabaseShardedReactiveMongoTemplate

public DatabaseShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory,
                                            org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter,
                                            DatabaseShardingOptions shardingOptions)

DatabaseShardedReactiveMongoTemplate

public DatabaseShardedReactiveMongoTemplate(Map<String,org.springframework.data.mongodb.ReactiveMongoDatabaseFactory> delegatedDatabaseFactory,
                                            org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter,
                                            Consumer<Throwable> subscriptionExceptionHandler,
                                            DatabaseShardingOptions shardingOptions)

Method Detail

find

public <T> reactor.core.publisher.Flux<T> find(org.springframework.data.mongodb.core.query.Query query,
                                               Class<T> entityClass,
                                               String collectionName)

Specified by:

find in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

find in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

find

public <T> reactor.core.publisher.Flux<T> find(org.springframework.data.mongodb.core.query.Query query,
                                               Class<T> entityClass)

Specified by:

find in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

find in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAll

public <T> reactor.core.publisher.Flux<T> findAll(Class<T> entityClass,
                                                  String collectionName)

Specified by:

findAll in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAll in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAll

public <T> reactor.core.publisher.Flux<T> findAll(Class<T> entityClass)

Specified by:

findAll in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAll in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAllAndRemove

public <T> reactor.core.publisher.Flux<T> findAllAndRemove(org.springframework.data.mongodb.core.query.Query query,
                                                           Class<T> entityClass)

Specified by:

findAllAndRemove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAllAndRemove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAllAndRemove

public <T> reactor.core.publisher.Flux<T> findAllAndRemove(org.springframework.data.mongodb.core.query.Query query,
                                                           String collectionName)

Specified by:

findAllAndRemove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAllAndRemove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAllAndRemove

public <T> reactor.core.publisher.Flux<T> findAllAndRemove(org.springframework.data.mongodb.core.query.Query query,
                                                           Class<T> entityClass,
                                                           String collectionName)

Specified by:

findAllAndRemove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAllAndRemove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndModify

public <T> reactor.core.publisher.Mono<T> findAndModify(org.springframework.data.mongodb.core.query.Query query,
                                                        org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                        Class<T> entityClass)

Specified by:

findAndModify in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndModify in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndModify

public <T> reactor.core.publisher.Mono<T> findAndModify(org.springframework.data.mongodb.core.query.Query query,
                                                        org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                        Class<T> entityClass,
                                                        String collectionName)

Specified by:

findAndModify in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndModify in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndModify

public <T> reactor.core.publisher.Mono<T> findAndModify(org.springframework.data.mongodb.core.query.Query query,
                                                        org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                        org.springframework.data.mongodb.core.FindAndModifyOptions options,
                                                        Class<T> entityClass)

Specified by:

findAndModify in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndModify in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndModify

public <T> reactor.core.publisher.Mono<T> findAndModify(org.springframework.data.mongodb.core.query.Query query,
                                                        org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                        org.springframework.data.mongodb.core.FindAndModifyOptions options,
                                                        Class<T> entityClass,
                                                        String collectionName)

Specified by:

findAndModify in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndModify in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndRemove

public <T> reactor.core.publisher.Mono<T> findAndRemove(org.springframework.data.mongodb.core.query.Query query,
                                                        Class<T> entityClass)

Specified by:

findAndRemove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndRemove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndRemove

public <T> reactor.core.publisher.Mono<T> findAndRemove(org.springframework.data.mongodb.core.query.Query query,
                                                        Class<T> entityClass,
                                                        String collectionName)

Specified by:

findAndRemove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndRemove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findAndReplace

public <T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                         T replacement)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findAndReplace

public <T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                         T replacement,
                                                         String collectionName)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findAndReplace

public <T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                         T replacement,
                                                         org.springframework.data.mongodb.core.FindAndReplaceOptions options)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findAndReplace

public <T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                         T replacement,
                                                         org.springframework.data.mongodb.core.FindAndReplaceOptions options,
                                                         String collectionName)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findAndReplace

public <S,T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                                 S replacement,
                                                                 org.springframework.data.mongodb.core.FindAndReplaceOptions options,
                                                                 Class<S> entityType,
                                                                 Class<T> resultType)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findAndReplace

public <T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                         T replacement,
                                                         org.springframework.data.mongodb.core.FindAndReplaceOptions options,
                                                         Class<T> entityType,
                                                         String collectionName)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findAndReplace

public <S,T> reactor.core.publisher.Mono<T> findAndReplace(org.springframework.data.mongodb.core.query.Query query,
                                                                 S replacement,
                                                                 org.springframework.data.mongodb.core.FindAndReplaceOptions options,
                                                                 Class<S> entityType,
                                                                 String collectionName,
                                                                 Class<T> resultType)

Specified by:

findAndReplace in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findAndReplace in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findOne

public <T> reactor.core.publisher.Mono<T> findOne(org.springframework.data.mongodb.core.query.Query query,
                                                  Class<T> entityClass)

Specified by:

findOne in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findOne in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findOne

public <T> reactor.core.publisher.Mono<T> findOne(org.springframework.data.mongodb.core.query.Query query,
                                                  Class<T> entityClass,
                                                  String collectionName)

Specified by:

findOne in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findOne in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

query

public <T> org.springframework.data.mongodb.core.ReactiveFindOperation.ReactiveFind<T> query(Class<T> domainType)

Specified by:

query in interface org.springframework.data.mongodb.core.ReactiveFindOperation

Overrides:

query in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

insert

public <T> reactor.core.publisher.Mono<T> insert(T objectToSave)

Specified by:

insert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

insert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

insert

public <T> org.springframework.data.mongodb.core.ReactiveInsertOperation.ReactiveInsert<T> insert(Class<T> domainType)

Specified by:

insert in interface org.springframework.data.mongodb.core.ReactiveInsertOperation

Overrides:

insert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

insert

public <T> reactor.core.publisher.Mono<T> insert(T objectToSave,
                                                 String collectionName)

Specified by:

insert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

insert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

insert

public <T> reactor.core.publisher.Flux<T> insert(Collection<? extends T> batchToSave,
                                                 Class<?> entityClass)

Specified by:

insert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

insert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

insert

public <T> reactor.core.publisher.Flux<T> insert(Collection<? extends T> batchToSave,
                                                 String collectionName)

Specified by:

insert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

insert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

insertAll

public <T> reactor.core.publisher.Flux<T> insertAll(Collection<? extends T> objectsToSave)

Specified by:

insertAll in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

insertAll in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

update

public <T> org.springframework.data.mongodb.core.ReactiveUpdateOperation.ReactiveUpdate<T> update(Class<T> domainType)

Specified by:

update in interface org.springframework.data.mongodb.core.ReactiveUpdateOperation

Overrides:

update in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

updateFirst

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> updateFirst(org.springframework.data.mongodb.core.query.Query query,
                                                                                       org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                       Class<?> entityClass)

Specified by:

updateFirst in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

updateFirst in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

updateFirst

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> updateFirst(org.springframework.data.mongodb.core.query.Query query,
                                                                                       org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                       String collectionName)

Specified by:

updateFirst in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

updateFirst in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

updateFirst

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> updateFirst(org.springframework.data.mongodb.core.query.Query query,
                                                                                       org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                       Class<?> entityClass,
                                                                                       String collectionName)

Specified by:

updateFirst in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

updateFirst in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

updateMulti

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> updateMulti(org.springframework.data.mongodb.core.query.Query query,
                                                                                       org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                       Class<?> entityClass)

Specified by:

updateMulti in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

updateMulti in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

updateMulti

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> updateMulti(org.springframework.data.mongodb.core.query.Query query,
                                                                                       org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                       String collectionName)

Specified by:

updateMulti in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

updateMulti in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

updateMulti

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> updateMulti(org.springframework.data.mongodb.core.query.Query query,
                                                                                       org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                       Class<?> entityClass,
                                                                                       String collectionName)

Specified by:

updateMulti in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

updateMulti in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

upsert

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> upsert(org.springframework.data.mongodb.core.query.Query query,
                                                                                  org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                  Class<?> entityClass)

Specified by:

upsert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

upsert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

upsert

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> upsert(org.springframework.data.mongodb.core.query.Query query,
                                                                                  org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                  String collectionName)

Specified by:

upsert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

upsert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

upsert

public reactor.core.publisher.Mono<com.mongodb.client.result.UpdateResult> upsert(org.springframework.data.mongodb.core.query.Query query,
                                                                                  org.springframework.data.mongodb.core.query.UpdateDefinition update,
                                                                                  Class<?> entityClass,
                                                                                  String collectionName)

Specified by:

upsert in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

upsert in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

remove

public reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> remove(Object object)

Specified by:

remove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

remove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

remove

public reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> remove(Object object,
                                                                                  String collectionName)

Specified by:

remove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

remove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

remove

public reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> remove(org.springframework.data.mongodb.core.query.Query query,
                                                                                  Class<?> entityClass)

Specified by:

remove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

remove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

remove

public reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> remove(org.springframework.data.mongodb.core.query.Query query,
                                                                                  String collectionName)

Specified by:

remove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

remove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

remove

public reactor.core.publisher.Mono<com.mongodb.client.result.DeleteResult> remove(org.springframework.data.mongodb.core.query.Query query,
                                                                                  Class<?> entityClass,
                                                                                  String collectionName)

Specified by:

remove in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

remove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

remove

public <T> org.springframework.data.mongodb.core.ReactiveRemoveOperation.ReactiveRemove<T> remove(Class<T> domainType)

Specified by:

remove in interface org.springframework.data.mongodb.core.ReactiveRemoveOperation

Overrides:

remove in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

save

public <T> reactor.core.publisher.Mono<T> save(T objectToSave)

Specified by:

save in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

save in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

save

public <T> reactor.core.publisher.Mono<T> save(T objectToSave,
                                               String collectionName)

Specified by:

save in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

save in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findById

public <T> reactor.core.publisher.Mono<T> findById(Object id,
                                                   Class<T> entityClass)

Specified by:

findById in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findById in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findById

public <T> reactor.core.publisher.Mono<T> findById(Object id,
                                                   Class<T> entityClass,
                                                   String collectionName)

Specified by:

findById in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findById in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findDistinct

public <T> reactor.core.publisher.Flux<T> findDistinct(String field,
                                                       Class<?> entityClass,
                                                       Class<T> resultClass)

Specified by:

findDistinct in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findDistinct

public <T> reactor.core.publisher.Flux<T> findDistinct(org.springframework.data.mongodb.core.query.Query query,
                                                       String field,
                                                       Class<?> entityClass,
                                                       Class<T> resultClass)

Specified by:

findDistinct in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findDistinct in class org.springframework.data.mongodb.core.ReactiveMongoTemplate

findDistinct

public <T> reactor.core.publisher.Flux<T> findDistinct(org.springframework.data.mongodb.core.query.Query query,
                                                       String field,
                                                       String collection,
                                                       Class<T> resultClass)

Specified by:

findDistinct in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

findDistinct

public <T> reactor.core.publisher.Flux<T> findDistinct(org.springframework.data.mongodb.core.query.Query query,
                                                       String field,
                                                       String collectionName,
                                                       Class<?> entityClass,
                                                       Class<T> resultClass)

Specified by:

findDistinct in interface org.springframework.data.mongodb.core.ReactiveMongoOperations

Overrides:

findDistinct in class org.springframework.data.mongodb.core.ReactiveMongoTemplate