io.micronaut.data.mongodb.operations

Class DefaultReactiveMongoRepositoryOperations

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations<Cnt,PS>

io.micronaut.data.mongodb.operations.DefaultReactiveMongoRepositoryOperations

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider, MongoReactiveRepositoryOperations, MongoReactorRepositoryOperations, HintsCapableRepository, ReactiveRepositoryOperations, ReactorReactiveRepositoryOperations, OpContext<com.mongodb.reactivestreams.client.ClientSession,java.lang.Object>, ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>, PreparedQueryResolver, StoredQueryResolver, ReactiveTransactionOperations<com.mongodb.reactivestreams.client.ClientSession>

@RequiresReactiveMongo
 @EachBean(value=com.mongodb.reactivestreams.client.MongoClient.class)
 @Internal
public class DefaultReactiveMongoRepositoryOperations
extends AbstractRepositoryOperations<Cnt,PS>
implements MongoReactorRepositoryOperations, ReactorReactiveRepositoryOperations, ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>, ReactiveTransactionOperations<com.mongodb.reactivestreams.client.ClientSession>

The reactive MongoDB repository operations implementation.

Since:

3.3

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	DefaultReactiveMongoRepositoryOperations.MongoOperationContext

Nested classes/interfaces inherited from interface io.micronaut.transaction.reactive.ReactiveTransactionOperations

ReactiveTransactionOperations.TransactionalCallback<C,T>

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.bson.BsonDocument	EMPTY
protected java.util.Map<java.lang.Class,java.lang.String>	repoDatabaseConfig

Fields inherited from class io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations

attributeConverterRegistry, conversionService, dateTimeProvider, entityEventRegistry, jsonCodec, runtimeEntityRegistry

Fields inherited from interface io.micronaut.data.mongodb.operations.MongoReactorRepositoryOperations

CLIENT_SESSION_CONTEXT_KEY

Method Summary

Modifier and Type	Method and Description
protected org.bson.BsonDocument	association(org.bson.codecs.configuration.CodecRegistry codecRegistry, java.lang.Object value, RuntimePersistentEntity<java.lang.Object> persistentEntity, java.lang.Object child, RuntimePersistentEntity<java.lang.Object> childPersistentEntity)
protected <R> R	convertResult(org.bson.codecs.configuration.CodecRegistry codecRegistry, java.lang.Class<R> resultType, org.bson.BsonDocument result, boolean isDtoProjection)
<T> reactor.core.publisher.Mono<java.lang.Long>	count(PagedQuery<T> pagedQuery) Counts all results for the given query.
StoredQuery<java.lang.Object,java.lang.Long>	createCountStoredQuery(io.micronaut.inject.ExecutableMethod<?,?> executableMethod, DataMethod.OperationType operationType, java.lang.String name, io.micronaut.core.annotation.AnnotationMetadata annotationMetadata, java.lang.Class<java.lang.Object> rootEntity, java.lang.String query, java.lang.String[] queryParts, java.util.List<QueryParameterBinding> queryParameters) Create count stored query from provided values.
<E,QR> StoredQuery<E,QR>	createStoredQuery(io.micronaut.inject.ExecutableMethod<?,?> executableMethod, DataMethod.OperationType operationType, java.lang.String name, io.micronaut.core.annotation.AnnotationMetadata annotationMetadata, java.lang.Class<java.lang.Object> rootEntity, java.lang.String query, java.lang.String update, java.lang.String[] queryParts, java.util.List<QueryParameterBinding> queryParameters, boolean hasPageable, boolean isSingleResult) Create stored query from provided values.
protected io.micronaut.core.convert.ConversionContext	createTypeConversionContext(com.mongodb.reactivestreams.client.ClientSession connection, RuntimePersistentProperty<?> property, io.micronaut.core.type.Argument<?> argument) Creates implementation specific conversion context.
<T> reactor.core.publisher.Mono<java.lang.Number>	delete(DeleteOperation<T> operation) Deletes the entity.
<T> reactor.core.publisher.Mono<java.lang.Number>	deleteAll(DeleteBatchOperation<T> operation) Deletes all the entities of the given type.
reactor.core.publisher.Mono<java.lang.Number>	executeDelete(PreparedQuery<?,java.lang.Number> preparedQuery) Executes a batch delete for the given query and parameter values.
reactor.core.publisher.Mono<java.lang.Number>	executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery) Executes an update for the given query and parameter values.
<T> reactor.core.publisher.Mono<java.lang.Boolean>	exists(PreparedQuery<T,java.lang.Boolean> preparedQuery) Check with an record exists for the given query.
<T> reactor.core.publisher.Flux<T>	findAll(PagedQuery<T> query) Finds all results for the given query.
<T,R> reactor.core.publisher.Flux<R>	findAll(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
<T> reactor.core.publisher.Mono<T>	findOne(java.lang.Class<T> type, java.io.Serializable id) Find one by ID.
<T,R> reactor.core.publisher.Mono<R>	findOne(PreparedQuery<T,R> preparedQuery) Find one by Query.
<T> reactor.core.publisher.Mono<T>	findOptional(java.lang.Class<T> type, java.io.Serializable id) Find one by ID.
<T,R> reactor.core.publisher.Mono<R>	findOptional(PreparedQuery<T,R> preparedQuery) Find one by Query.
<R> reactor.core.publisher.Mono<Page<R>>	findPage(PagedQuery<R> pagedQuery) Find a page for the given entity and pageable.
protected org.bson.codecs.configuration.CodecRegistry	getCodecRegistry(com.mongodb.reactivestreams.client.MongoDatabase mongoDatabase)
protected com.mongodb.reactivestreams.client.MongoDatabase	getDatabase(RuntimePersistentEntity<?> persistentEntity, java.lang.Class<?> repositoryClass)
protected <E,R> MongoPreparedQuery<E,R,Dtb>	getMongoPreparedQuery(PreparedQuery<E,R> preparedQuery)
protected <E,R> MongoStoredQuery<E,R,Dtb>	getMongoStoredQuery(StoredQuery<E,R> storedQuery)
protected void	logAggregate(MongoAggregation aggregation)
protected void	logFind(MongoFind find)
<T> reactor.core.publisher.Mono<T>	persist(InsertOperation<T> operation) Persist the entity returning a possibly new entity.
<T> reactor.core.publisher.Flux<T>	persistAll(InsertBatchOperation<T> operation) Persist all the given entities.
<T> reactor.core.publisher.Flux<T>	persistBatch(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, java.lang.Iterable<T> values, RuntimePersistentEntity<T> persistentEntity, java.util.function.Predicate<T> predicate) Persist multiple entities in batch during cascade.
reactor.core.publisher.Mono<java.lang.Void>	persistManyAssociation(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, RuntimeAssociation runtimeAssociation, java.lang.Object value, RuntimePersistentEntity<java.lang.Object> persistentEntity, java.lang.Object child, RuntimePersistentEntity<java.lang.Object> childPersistentEntity) Persist JOIN table relationship.
reactor.core.publisher.Mono<java.lang.Void>	persistManyAssociationBatch(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, RuntimeAssociation runtimeAssociation, java.lang.Object value, RuntimePersistentEntity<java.lang.Object> persistentEntity, java.lang.Iterable<java.lang.Object> child, RuntimePersistentEntity<java.lang.Object> childPersistentEntity, java.util.function.Predicate<java.lang.Object> veto) Persist JOIN table relationships in batch.
<T> reactor.core.publisher.Mono<T>	persistOne(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, T value, RuntimePersistentEntity<T> persistentEntity) Persist one entity during cascade.
<E,R> StoredQuery<E,R>	resolveCountQuery(io.micronaut.aop.MethodInvocationContext<?,?> context, java.lang.Class<E> entityClass, java.lang.Class<R> resultType) Stored count query resolved from the method context.
<E,R> PreparedQuery<E,R>	resolveCountQuery(io.micronaut.aop.MethodInvocationContext<?,?> context, StoredQuery<E,R> storedQuery, Pageable pageable) Prepared count query resolved from the method context.
<E,R> StoredQuery<E,R>	resolveQuery(io.micronaut.aop.MethodInvocationContext<?,?> context, java.lang.Class<E> entityClass, java.lang.Class<R> resultType) Stored query resolved from the method context.
<E,R> PreparedQuery<E,R>	resolveQuery(io.micronaut.aop.MethodInvocationContext<?,?> context, StoredQuery<E,R> storedQuery, Pageable pageable) Prepared query resolved from the method context.
void	setStatementParameter(java.lang.Object preparedStatement, int index, DataType dataType, java.lang.Object value, Dialect dialect) Set the parameter value on the given statement.
<T> reactor.core.publisher.Mono<T>	update(UpdateOperation<T> operation) Updates the entity returning a possibly new entity.
<T> reactor.core.publisher.Flux<T>	updateAll(UpdateBatchOperation<T> operation) Updates the entities for the given operation.
<T> reactor.core.publisher.Mono<T>	updateOne(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, T value, RuntimePersistentEntity<T> persistentEntity) Update one entity during cascade.
<T> reactor.core.publisher.Mono<T>	withClientSession(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Mono<? extends T>> function) Starts a new session or reuses one from the context.
<T> reactor.core.publisher.Flux<T>	withClientSessionMany(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Flux<? extends T>> function) Starts a new session or reuses one from the context.
<T> org.reactivestreams.Publisher<T>	withTransaction(ReactiveTransactionStatus<com.mongodb.reactivestreams.client.ClientSession> status, ReactiveTransactionOperations.TransactionalCallback<com.mongodb.reactivestreams.client.ClientSession,T> handler) Execute the given handler with a new transaction.
<T> reactor.core.publisher.Flux<T>	withTransaction(TransactionDefinition definition, ReactiveTransactionOperations.TransactionalCallback<com.mongodb.reactivestreams.client.ClientSession,T> handler) Execute the given handler with a new transaction.

Methods inherited from class io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations

checkOptimisticLocking, convert, convert, getApplicationContext, getConversionService, getEntity, getIdReader, getRuntimeEntityRegistry, isOnlySingleEndedJoins, shiftIndex, triggerPostLoad

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.data.runtime.operations.internal.ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

isSupportsBatchDelete, isSupportsBatchInsert, isSupportsBatchUpdate

Methods inherited from interface io.micronaut.transaction.reactive.ReactiveTransactionOperations

withTransaction

Methods inherited from interface io.micronaut.data.operations.HintsCapableRepository

getQueryHints

Field Detail

EMPTY

protected static final org.bson.BsonDocument EMPTY

repoDatabaseConfig

protected final java.util.Map<java.lang.Class,java.lang.String> repoDatabaseConfig

Method Detail

findOne

public <T> reactor.core.publisher.Mono<T> findOne(java.lang.Class<T> type,
                                                  java.io.Serializable id)

Description copied from interface: ReactiveRepositoryOperations

Find one by ID.

Specified by:

findOne in interface ReactiveRepositoryOperations

Specified by:

findOne in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A publisher that emits the result

findOne

public <T,R> reactor.core.publisher.Mono<R> findOne(PreparedQuery<T,R> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Find one by Query.

Specified by:

findOne in interface ReactiveRepositoryOperations

Specified by:

findOne in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic resultType

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits the result

exists

public <T> reactor.core.publisher.Mono<java.lang.Boolean> exists(PreparedQuery<T,java.lang.Boolean> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Check with an record exists for the given query.

Specified by:

exists in interface ReactiveRepositoryOperations

Specified by:

exists in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The declaring type

Parameters:

preparedQuery - The query

Returns:

True if it exists

findAll

public <T> reactor.core.publisher.Flux<T> findAll(PagedQuery<T> query)

Description copied from interface: ReactiveRepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface ReactiveRepositoryOperations

Specified by:

findAll in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The paged query

Returns:

A publisher that emits the results

count

public <T> reactor.core.publisher.Mono<java.lang.Long> count(PagedQuery<T> pagedQuery)

Description copied from interface: ReactiveRepositoryOperations

Counts all results for the given query.

Specified by:

count in interface ReactiveRepositoryOperations

Specified by:

count in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The paged query

Returns:

A publisher that emits the count as a long

findAll

public <T,R> reactor.core.publisher.Flux<R> findAll(PreparedQuery<T,R> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface ReactiveRepositoryOperations

Specified by:

findAll in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits an iterable with all results

findOptional

public <T> reactor.core.publisher.Mono<T> findOptional(java.lang.Class<T> type,
                                                       java.io.Serializable id)

Description copied from interface: ReactiveRepositoryOperations

Find one by ID.

Specified by:

findOptional in interface ReactiveRepositoryOperations

Specified by:

findOptional in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A publisher that emits zero or one result

findOptional

public <T,R> reactor.core.publisher.Mono<R> findOptional(PreparedQuery<T,R> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Find one by Query.

Specified by:

findOptional in interface ReactiveRepositoryOperations

Specified by:

findOptional in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic resultType

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits the zero or one result

findPage

public <R> reactor.core.publisher.Mono<Page<R>> findPage(PagedQuery<R> pagedQuery)

Description copied from interface: ReactiveRepositoryOperations

Find a page for the given entity and pageable.

Specified by:

findPage in interface ReactiveRepositoryOperations

Specified by:

findPage in interface ReactorReactiveRepositoryOperations

Type Parameters:

R - The entity generic type

Parameters:

pagedQuery - The paged query

Returns:

The page type

persist

public <T> reactor.core.publisher.Mono<T> persist(InsertOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Persist the entity returning a possibly new entity.

Specified by:

persist in interface ReactiveRepositoryOperations

Specified by:

persist in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The entity operation

Returns:

A publisher that emits the entity

persistAll

public <T> reactor.core.publisher.Flux<T> persistAll(InsertBatchOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Persist all the given entities.

Specified by:

persistAll in interface ReactiveRepositoryOperations

Specified by:

persistAll in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The batch operation

Returns:

The entities, possibly mutated

update

public <T> reactor.core.publisher.Mono<T> update(UpdateOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Updates the entity returning a possibly new entity.

Specified by:

update in interface ReactiveRepositoryOperations

Specified by:

update in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The entity operation

Returns:

A publisher that emits the entity

updateAll

public <T> reactor.core.publisher.Flux<T> updateAll(UpdateBatchOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Updates the entities for the given operation.

Specified by:

updateAll in interface ReactiveRepositoryOperations

Specified by:

updateAll in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The updated entities

delete

public <T> reactor.core.publisher.Mono<java.lang.Number> delete(DeleteOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Deletes the entity.

Specified by:

delete in interface ReactiveRepositoryOperations

Specified by:

delete in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The batch operation

Returns:

A publisher that emits the number of entities deleted

deleteAll

public <T> reactor.core.publisher.Mono<java.lang.Number> deleteAll(DeleteBatchOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Deletes all the entities of the given type.

Specified by:

deleteAll in interface ReactiveRepositoryOperations

Specified by:

deleteAll in interface ReactorReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The batch operation

Returns:

A publisher that emits the number of entities deleted

executeUpdate

public reactor.core.publisher.Mono<java.lang.Number> executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Executes an update for the given query and parameter values. If it is possible to return the number of objects updated, then do so.

Specified by:

executeUpdate in interface ReactiveRepositoryOperations

Specified by:

executeUpdate in interface ReactorReactiveRepositoryOperations

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits a boolean true if the update was successful

executeDelete

public reactor.core.publisher.Mono<java.lang.Number> executeDelete(PreparedQuery<?,java.lang.Number> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Executes a batch delete for the given query and parameter values. If it is possible to return the number of objects updated, then do so.

Specified by:

executeDelete in interface ReactiveRepositoryOperations

Specified by:

executeDelete in interface ReactorReactiveRepositoryOperations

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits a boolean true if the update was successful

createTypeConversionContext

protected io.micronaut.core.convert.ConversionContext createTypeConversionContext(com.mongodb.reactivestreams.client.ClientSession connection,
                                                                                  RuntimePersistentProperty<?> property,
                                                                                  io.micronaut.core.type.Argument<?> argument)

Description copied from class: AbstractRepositoryOperations

Creates implementation specific conversion context.

Parameters:

connection - The connection

property - The property

argument - The argument

Returns:

new ConversionContext

setStatementParameter

public void setStatementParameter(java.lang.Object preparedStatement,
                                  int index,
                                  DataType dataType,
                                  java.lang.Object value,
                                  Dialect dialect)

Description copied from interface: OpContext

Set the parameter value on the given statement.

Specified by:

setStatementParameter in interface OpContext<com.mongodb.reactivestreams.client.ClientSession,java.lang.Object>

Parameters:

preparedStatement - The prepared statement

index - The index

dataType - The data type

value - The value

dialect - The dialect

persistOne

public <T> reactor.core.publisher.Mono<T> persistOne(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
                                                     T value,
                                                     RuntimePersistentEntity<T> persistentEntity)

Description copied from interface: ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

Persist one entity during cascade.

Specified by:

persistOne in interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

value - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

persistBatch

public <T> reactor.core.publisher.Flux<T> persistBatch(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
                                                       java.lang.Iterable<T> values,
                                                       RuntimePersistentEntity<T> persistentEntity,
                                                       java.util.function.Predicate<T> predicate)

Description copied from interface: ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

Persist multiple entities in batch during cascade.

Specified by:

persistBatch in interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

values - The entity values

persistentEntity - The persistent entity

predicate - The veto predicate

Returns:

The entity values

updateOne

public <T> reactor.core.publisher.Mono<T> updateOne(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
                                                    T value,
                                                    RuntimePersistentEntity<T> persistentEntity)

Description copied from interface: ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

Update one entity during cascade.

Specified by:

updateOne in interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

value - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

getDatabase

protected com.mongodb.reactivestreams.client.MongoDatabase getDatabase(RuntimePersistentEntity<?> persistentEntity,
                                                                       java.lang.Class<?> repositoryClass)

getCodecRegistry

protected org.bson.codecs.configuration.CodecRegistry getCodecRegistry(com.mongodb.reactivestreams.client.MongoDatabase mongoDatabase)

persistManyAssociation

public reactor.core.publisher.Mono<java.lang.Void> persistManyAssociation(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
                                                                          RuntimeAssociation runtimeAssociation,
                                                                          java.lang.Object value,
                                                                          RuntimePersistentEntity<java.lang.Object> persistentEntity,
                                                                          java.lang.Object child,
                                                                          RuntimePersistentEntity<java.lang.Object> childPersistentEntity)

Description copied from interface: ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

Persist JOIN table relationship.

Specified by:

persistManyAssociation in interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>

Parameters:

ctx - The context

runtimeAssociation - The association

value - The parent entity value

persistentEntity - The parent persistent entity

child - The child entity value

childPersistentEntity - The child persistent entity

Returns:

The empty mono

persistManyAssociationBatch

public reactor.core.publisher.Mono<java.lang.Void> persistManyAssociationBatch(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
                                                                               RuntimeAssociation runtimeAssociation,
                                                                               java.lang.Object value,
                                                                               RuntimePersistentEntity<java.lang.Object> persistentEntity,
                                                                               java.lang.Iterable<java.lang.Object> child,
                                                                               RuntimePersistentEntity<java.lang.Object> childPersistentEntity,
                                                                               java.util.function.Predicate<java.lang.Object> veto)

Description copied from interface: ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

Persist JOIN table relationships in batch.

Specified by:

persistManyAssociationBatch in interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>

Parameters:

ctx - The context

runtimeAssociation - The association

value - The parent entity value

persistentEntity - The parent persistent entity

child - The child entity values

childPersistentEntity - The child persistent entity

veto - The veto predicate

Returns:

The empty mono

withClientSession

public <T> reactor.core.publisher.Mono<T> withClientSession(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Mono<? extends T>> function)

Description copied from interface: MongoReactorRepositoryOperations

Starts a new session or reuses one from the context.

Specified by:

withClientSession in interface MongoReactorRepositoryOperations

Type Parameters:

T - The emitted type

Parameters:

function - The function

Returns:

The processed publisher

withClientSessionMany

public <T> reactor.core.publisher.Flux<T> withClientSessionMany(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Flux<? extends T>> function)

Description copied from interface: MongoReactorRepositoryOperations

Starts a new session or reuses one from the context.

Specified by:

withClientSessionMany in interface MongoReactorRepositoryOperations

Type Parameters:

T - The emitted type

Parameters:

function - The function

Returns:

The processed publisher

withTransaction

@NonNull
public <T> org.reactivestreams.Publisher<T> withTransaction(@NonNull
                                                                     ReactiveTransactionStatus<com.mongodb.reactivestreams.client.ClientSession> status,
                                                                     @NonNull
                                                                     ReactiveTransactionOperations.TransactionalCallback<com.mongodb.reactivestreams.client.ClientSession,T> handler)

Description copied from interface: MongoReactorRepositoryOperations

Execute the given handler with a new transaction.

Specified by:

withTransaction in interface MongoReactorRepositoryOperations

Type Parameters:

T - The emitted type

Parameters:

status - The tx status

handler - The handler

Returns:

A publisher that emits the result type

withTransaction

@NonNull
public <T> reactor.core.publisher.Flux<T> withTransaction(@NonNull
                                                                   TransactionDefinition definition,
                                                                   @NonNull
                                                                   ReactiveTransactionOperations.TransactionalCallback<com.mongodb.reactivestreams.client.ClientSession,T> handler)

Description copied from interface: ReactiveTransactionOperations

Execute the given handler with a new transaction.

Specified by:

withTransaction in interface ReactiveTransactionOperations<com.mongodb.reactivestreams.client.ClientSession>

Type Parameters:

T - The emitted type

Parameters:

definition - The definition

handler - The handler

Returns:

A publisher that emits the result type

getMongoStoredQuery

protected <E,R> MongoStoredQuery<E,R,Dtb> getMongoStoredQuery(StoredQuery<E,R> storedQuery)

getMongoPreparedQuery

protected <E,R> MongoPreparedQuery<E,R,Dtb> getMongoPreparedQuery(PreparedQuery<E,R> preparedQuery)

resolveQuery

public <E,R> PreparedQuery<E,R> resolveQuery(io.micronaut.aop.MethodInvocationContext<?,?> context,
                                             StoredQuery<E,R> storedQuery,
                                             Pageable pageable)

Description copied from interface: PreparedQueryResolver

Prepared query resolved from the method context.

Specified by:

resolveQuery in interface PreparedQueryResolver

Type Parameters:

E - The entity type

R - The result type

Parameters:

context - The method context

storedQuery - The stored query

pageable - The pageable

Returns:

The prepared query

resolveCountQuery

public <E,R> PreparedQuery<E,R> resolveCountQuery(io.micronaut.aop.MethodInvocationContext<?,?> context,
                                                  StoredQuery<E,R> storedQuery,
                                                  Pageable pageable)

Description copied from interface: PreparedQueryResolver

Prepared count query resolved from the method context.

Specified by:

resolveCountQuery in interface PreparedQueryResolver

Type Parameters:

E - The entity type

R - The result type

Parameters:

context - The method context

storedQuery - The stored query

pageable - The pageable

Returns:

The prepared query

resolveQuery

public <E,R> StoredQuery<E,R> resolveQuery(io.micronaut.aop.MethodInvocationContext<?,?> context,
                                           java.lang.Class<E> entityClass,
                                           java.lang.Class<R> resultType)

Description copied from interface: StoredQueryResolver

Stored query resolved from the method context.

Specified by:

resolveQuery in interface StoredQueryResolver

Type Parameters:

E - The entity type

R - The result type

Parameters:

context - The method context

entityClass - The entity type

resultType - The result type

Returns:

The prepared query

resolveCountQuery

public <E,R> StoredQuery<E,R> resolveCountQuery(io.micronaut.aop.MethodInvocationContext<?,?> context,
                                                java.lang.Class<E> entityClass,
                                                java.lang.Class<R> resultType)

Description copied from interface: StoredQueryResolver

Stored count query resolved from the method context.

Specified by:

resolveCountQuery in interface StoredQueryResolver

Type Parameters:

E - The entity type

R - The result type

Parameters:

context - The method context

entityClass - The entity type

resultType - The result type

Returns:

The prepared query

createStoredQuery

public <E,QR> StoredQuery<E,QR> createStoredQuery(io.micronaut.inject.ExecutableMethod<?,?> executableMethod,
                                                  DataMethod.OperationType operationType,
                                                  java.lang.String name,
                                                  io.micronaut.core.annotation.AnnotationMetadata annotationMetadata,
                                                  java.lang.Class<java.lang.Object> rootEntity,
                                                  java.lang.String query,
                                                  java.lang.String update,
                                                  java.lang.String[] queryParts,
                                                  java.util.List<QueryParameterBinding> queryParameters,
                                                  boolean hasPageable,
                                                  boolean isSingleResult)

Description copied from interface: StoredQueryResolver

Create stored query from provided values. Used for criteria stored query creation.

Specified by:

createStoredQuery in interface StoredQueryResolver

Type Parameters:

E - The entity type

QR - The result type

Parameters:

executableMethod - The executableMethod

operationType - The operationType

name - The name

annotationMetadata - The annotation metadata

rootEntity - The root entity

query - The query

update - The update query

queryParts - The query parts

queryParameters - The query parameters

hasPageable - Has pageable

isSingleResult - Is single result

Returns:

new instance of stored query

createCountStoredQuery

public StoredQuery<java.lang.Object,java.lang.Long> createCountStoredQuery(io.micronaut.inject.ExecutableMethod<?,?> executableMethod,
                                                                           DataMethod.OperationType operationType,
                                                                           java.lang.String name,
                                                                           io.micronaut.core.annotation.AnnotationMetadata annotationMetadata,
                                                                           java.lang.Class<java.lang.Object> rootEntity,
                                                                           java.lang.String query,
                                                                           java.lang.String[] queryParts,
                                                                           java.util.List<QueryParameterBinding> queryParameters)

Description copied from interface: StoredQueryResolver

Create count stored query from provided values. Used for criteria stored query creation.

Specified by:

createCountStoredQuery in interface StoredQueryResolver

Parameters:

executableMethod - The executableMethod

operationType - The operationType

name - The name

annotationMetadata - The annotation metadata

rootEntity - The root entity

query - The query

queryParts - The query parts

queryParameters - The query parameters

Returns:

new instance of stored query

convertResult

protected <R> R convertResult(org.bson.codecs.configuration.CodecRegistry codecRegistry,
                              java.lang.Class<R> resultType,
                              org.bson.BsonDocument result,
                              boolean isDtoProjection)

association

protected org.bson.BsonDocument association(org.bson.codecs.configuration.CodecRegistry codecRegistry,
                                            java.lang.Object value,
                                            RuntimePersistentEntity<java.lang.Object> persistentEntity,
                                            java.lang.Object child,
                                            RuntimePersistentEntity<java.lang.Object> childPersistentEntity)

logFind

protected void logFind(MongoFind find)

logAggregate

protected void logAggregate(MongoAggregation aggregation)