Class DefaultReactiveMongoRepositoryOperations

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations

io.micronaut.data.mongodb.operations.DefaultReactiveMongoRepositoryOperations

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider, io.micronaut.core.convert.ConversionServiceProvider, MongoReactiveRepositoryOperations, MongoReactorRepositoryOperations, HintsCapableRepository, ReactiveRepositoryOperations, ReactorReactiveRepositoryOperations, ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>, MethodContextAwareStoredQueryDecorator, PreparedQueryDecorator

@RequiresReactiveMongo
@EachBean(com.mongodb.reactivestreams.client.MongoClient.class)
@Internal
public final class DefaultReactiveMongoRepositoryOperations
extends AbstractRepositoryOperations
implements MongoReactorRepositoryOperations, ReactorReactiveRepositoryOperations, ReactiveCascadeOperations.ReactiveCascadeOperationsHelper<DefaultReactiveMongoRepositoryOperations.MongoOperationContext>

The reactive MongoDB repository operations implementation.

Since:

3.3

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final MongoCollectionNameProvider	collectionNameProvider
protected final MongoDatabaseNameProvider	databaseNameProvider
protected static final org.bson.BsonDocument	EMPTY

Fields inherited from class AbstractRepositoryOperations

attributeConverterRegistry, conversionService, dateTimeProvider, entityEventRegistry, runtimeEntityRegistry

Method Summary

Modifier and Type	Method	Description
protected org.bson.BsonDocument	association(org.bson.codecs.configuration.CodecRegistry codecRegistry, Object value, RuntimePersistentEntity<Object> persistentEntity, Object child, RuntimePersistentEntity<Object> childPersistentEntity)
protected <R> R	convertResult(PreparedQuery<?,?> preparedQuery, org.bson.codecs.configuration.CodecRegistry codecRegistry, Class<R> resultType, org.bson.BsonDocument result, boolean isDtoProjection)
protected <R> Optional<R>	convertUsingIntrospected(PreparedQuery<?,?> preparedQuery, org.bson.BsonDocument result, Class<R> resultType)	Attempts to convert a BSON document into an instance of the specified result type using introspection.
<T> reactor.core.publisher.Mono<Long>	count(PagedQuery<T> pagedQuery)	Counts all results for the given query.
protected final <T> org.bson.conversions.Bson	createFilterIdAndVersion(RuntimePersistentEntity<T> persistentEntity, T entity, org.bson.codecs.configuration.CodecRegistry codecRegistry)
<E,R> StoredQuery<E,R>	decorate(io.micronaut.aop.MethodInvocationContext<?,?> context, StoredQuery<E,R> storedQuery)	Decorate stored query.
<E,R> PreparedQuery<E,R>	decorate(PreparedQuery<E,R> preparedQuery)	Decorate prepared query.
<T> reactor.core.publisher.Mono<Number>	delete(DeleteOperation<T> operation)	Deletes the entity.
<T> reactor.core.publisher.Mono<Number>	deleteAll(DeleteBatchOperation<T> operation)	Deletes all the entities of the given type.
reactor.core.publisher.Mono<Number>	executeDelete(PreparedQuery<?,Number> preparedQuery)	Executes a batch delete for the given query and parameter values.
reactor.core.publisher.Mono<Number>	executeUpdate(PreparedQuery<?,Number> preparedQuery)	Executes an update for the given query and parameter values.
<T> reactor.core.publisher.Mono<Boolean>	exists(PreparedQuery<T,Boolean> preparedQuery)	Check with a 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,R> reactor.core.publisher.Mono<R>	findOne(PreparedQuery<T,R> preparedQuery)	Find one by Query.
<T> reactor.core.publisher.Mono<T>	findOne(Class<T> type, Object id)	Find one by ID.
<T,R> reactor.core.publisher.Mono<R>	findOptional(PreparedQuery<T,R> preparedQuery)	Find one by Query.
<T> reactor.core.publisher.Mono<T>	findOptional(Class<T> type, Object id)	Find one by ID.
<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(PersistentEntity persistentEntity, @Nullable Class<?> repository)
protected final com.mongodb.client.model.DeleteOptions	getDeleteOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)
protected final com.mongodb.client.model.InsertManyOptions	getInsertManyOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)
protected final com.mongodb.client.model.InsertOneOptions	getInsertOneOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)
protected <E,R> MongoPreparedQuery<E,R>	getMongoPreparedQuery(PreparedQuery<E,R> preparedQuery)
protected <E,R> MongoStoredQuery<E,R>	getMongoStoredQuery(StoredQuery<E,R> storedQuery)
protected final com.mongodb.client.model.ReplaceOptions	getReplaceOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)
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, Iterable<T> values, RuntimePersistentEntity<T> persistentEntity, @Nullable Predicate<T> predicate)	Persist multiple entities in batch during cascade.
reactor.core.publisher.Mono<Void>	persistManyAssociation(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, RuntimeAssociation runtimeAssociation, Object value, RuntimePersistentEntity<Object> persistentEntity, Object child, RuntimePersistentEntity<Object> childPersistentEntity)	Persist JOIN table relationship.
reactor.core.publisher.Mono<Void>	persistManyAssociationBatch(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx, RuntimeAssociation runtimeAssociation, Object value, RuntimePersistentEntity<Object> persistentEntity, Iterable<Object> child, RuntimePersistentEntity<Object> childPersistentEntity, Predicate<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.
<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(Function<com.mongodb.reactivestreams.client.ClientSession, reactor.core.publisher.Mono<T>> function)	Starts a new session or reuses one from the context.
<T> reactor.core.publisher.Flux<T>	withClientSessionMany(Function<com.mongodb.reactivestreams.client.ClientSession, reactor.core.publisher.Flux<T>> function)	Starts a new session or reuses one from the context.

Methods inherited from class AbstractRepositoryOperations

checkOptimisticLocking, getApplicationContext, getConversionService, getEntity, getIdReader, isOnlySingleEndedJoins, triggerPostLoad

Methods inherited from class Object

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

Methods inherited from interface io.micronaut.core.convert.ConversionServiceProvider

getConversionService

Methods inherited from interface HintsCapableRepository

getQueryHints

Methods inherited from interface ReactiveCascadeOperations.ReactiveCascadeOperationsHelper

isSupportsBatchDelete, isSupportsBatchInsert, isSupportsBatchUpdate

Methods inherited from interface ReactorReactiveRepositoryOperations

execute

Field Details

EMPTY

protected static final org.bson.BsonDocument EMPTY

collectionNameProvider

protected final MongoCollectionNameProvider collectionNameProvider

databaseNameProvider

protected final MongoDatabaseNameProvider databaseNameProvider

Method Details

findOne

public <T> reactor.core.publisher.Mono<T> findOne(Class<T> type,
 Object 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<Boolean> exists(PreparedQuery<T,Boolean> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Check with a 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<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(Class<T> type,
 Object 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<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<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<Number> executeUpdate(PreparedQuery<?,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<Number> executeDelete(PreparedQuery<?,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

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,
 Iterable<T> values,
 RuntimePersistentEntity<T> persistentEntity,
 @Nullable 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(PersistentEntity persistentEntity,
 @Nullable Class<?> repository)

getCodecRegistry

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

persistManyAssociation

public reactor.core.publisher.Mono<Void> persistManyAssociation(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
 RuntimeAssociation runtimeAssociation,
 Object value,
 RuntimePersistentEntity<Object> persistentEntity,
 Object child,
 RuntimePersistentEntity<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<Void> persistManyAssociationBatch(DefaultReactiveMongoRepositoryOperations.MongoOperationContext ctx,
 RuntimeAssociation runtimeAssociation,
 Object value,
 RuntimePersistentEntity<Object> persistentEntity,
 Iterable<Object> child,
 RuntimePersistentEntity<Object> childPersistentEntity,
 Predicate<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(Function<com.mongodb.reactivestreams.client.ClientSession, reactor.core.publisher.Mono<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(Function<com.mongodb.reactivestreams.client.ClientSession, reactor.core.publisher.Flux<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

getReplaceOptions

protected final com.mongodb.client.model.ReplaceOptions getReplaceOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)

getInsertOneOptions

protected final com.mongodb.client.model.InsertOneOptions getInsertOneOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)

getInsertManyOptions

protected final com.mongodb.client.model.InsertManyOptions getInsertManyOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)

getDeleteOptions

protected final com.mongodb.client.model.DeleteOptions getDeleteOptions(io.micronaut.core.annotation.AnnotationMetadata annotationMetadata)

getMongoStoredQuery

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

getMongoPreparedQuery

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

decorate

public <E,R> PreparedQuery<E,R> decorate(PreparedQuery<E,R> preparedQuery)

Description copied from interface: PreparedQueryDecorator

Decorate prepared query.

Specified by:

decorate in interface PreparedQueryDecorator

Type Parameters:

E - The entity type

R - The result type

Parameters:

preparedQuery - The query to be decorated

Returns:

decorated prepared query

decorate

public <E,R> StoredQuery<E,R> decorate(io.micronaut.aop.MethodInvocationContext<?,?> context,
 StoredQuery<E,R> storedQuery)

Description copied from interface: MethodContextAwareStoredQueryDecorator

Decorate stored query.

Specified by:

decorate in interface MethodContextAwareStoredQueryDecorator

Type Parameters:

E - The entity type

R - The result type

Parameters:

context - The context

storedQuery - The query to be decorated

Returns:

decorated stored query

convertResult

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

convertUsingIntrospected

protected <R> Optional<R> convertUsingIntrospected(PreparedQuery<?,?> preparedQuery,
 org.bson.BsonDocument result,
 Class<R> resultType)

Attempts to convert a BSON document into an instance of the specified result type using introspection.

If the result type has been annotated with `@Introspection`, this method will attempt to use the provided `BeanIntrospection` to map the BSON document onto an instance of the result type.

If the mapping fails or if no `BeanIntrospection` is found for the result type, an empty `Optional` is returned.

Type Parameters:

R - The type parameter representing the result type

Parameters:

preparedQuery - The preparedQuery

result - The BSON document containing the data to be mapped

resultType - The type of the object being mapped

Returns:

An `Optional` containing the mapped object, or an empty `Optional` if mapping failed or no `BeanIntrospection` was found

association

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

createFilterIdAndVersion

protected final <T> org.bson.conversions.Bson createFilterIdAndVersion(RuntimePersistentEntity<T> persistentEntity,
 T entity,
 org.bson.codecs.configuration.CodecRegistry codecRegistry)

logFind

protected void logFind(MongoFind find)

logAggregate

protected void logAggregate(MongoAggregation aggregation)