io.micronaut.data.mongodb.operations

Class DefaultMongoRepositoryOperations

java.lang.Object

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

io.micronaut.data.mongodb.operations.DefaultMongoRepositoryOperations

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider, MongoRepositoryOperations, AsyncCapableRepository, HintsCapableRepository, ReactiveCapableRepository, RepositoryOperations, OpContext<com.mongodb.client.ClientSession,java.lang.Object>, SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.MongoOperationContext>, PreparedQueryResolver, StoredQueryResolver

@RequiresSyncMongo
 @EachBean(value=com.mongodb.client.MongoClient.class)
 @Internal
public final class DefaultMongoRepositoryOperations
extends AbstractRepositoryOperations<Cnt,PS>
implements MongoRepositoryOperations, AsyncCapableRepository, ReactiveCapableRepository, SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.MongoOperationContext>

Default Mongo repository operations.

Since:

3.3

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.bson.BsonDocument	EMPTY
protected static org.slf4j.Logger	QUERY_LOG
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

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)
ExecutorAsyncOperations	async()
protected <R> R	convertResult(org.bson.codecs.configuration.CodecRegistry codecRegistry, java.lang.Class<R> resultType, org.bson.BsonDocument result, boolean isDtoProjection)
<T> 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(Cnt connection, RuntimePersistentProperty<?> property, io.micronaut.core.type.Argument<?> argument) Creates implementation specific conversion context.
<T> int	delete(DeleteOperation<T> operation) Deletes the entity.
<T> java.util.Optional<java.lang.Number>	deleteAll(DeleteBatchOperation<T> operation) Deletes all the entities of the given type.
java.util.Optional<java.lang.Number>	executeDelete(PreparedQuery<?,java.lang.Number> preparedQuery) Executes a delete for the given query and parameter values.
java.util.Optional<java.lang.Number>	executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery) Executes an update for the given query and parameter values.
<T> boolean	exists(PreparedQuery<T,java.lang.Boolean> preparedQuery) Execute a query that checks for existence.
<T> java.lang.Iterable<T>	findAll(PagedQuery<T> query) Finds all results for the given query.
<T,R> java.lang.Iterable<R>	findAll(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
<T> T	findOne(java.lang.Class<T> type, java.io.Serializable id) Find one by ID.
<T,R> R	findOne(PreparedQuery<T,R> preparedQuery) Find one by Query.
<R> Page<R>	findPage(PagedQuery<R> query) Find a page for the given entity and pageable.
<T> java.util.stream.Stream<T>	findStream(PagedQuery<T> query) Finds a stream for the given arguments.
<T,R> java.util.stream.Stream<R>	findStream(PreparedQuery<T,R> preparedQuery) Finds all results for the given query.
protected org.bson.codecs.configuration.CodecRegistry	getCodecRegistry(com.mongodb.client.MongoDatabase mongoDatabase)
protected com.mongodb.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> T	persist(InsertOperation<T> operation) Persist the operation returning a possibly new entity.
<T> java.lang.Iterable<T>	persistAll(InsertBatchOperation<T> operation) Persist all the given entities.
<T> java.util.List<T>	persistBatch(DefaultMongoRepositoryOperations.MongoOperationContext ctx, java.lang.Iterable<T> values, RuntimePersistentEntity<T> persistentEntity, java.util.function.Predicate<T> predicate) Persist multiple entities in batch during cascade.
void	persistManyAssociation(DefaultMongoRepositoryOperations.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.
void	persistManyAssociationBatch(DefaultMongoRepositoryOperations.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) Persist JOIN table relationships in batch.
<T> T	persistOne(DefaultMongoRepositoryOperations.MongoOperationContext ctx, T value, RuntimePersistentEntity<T> persistentEntity) Persist one entity during cascade.
ReactiveRepositoryOperations	reactive()
<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> T	update(UpdateOperation<T> operation) Updates the entity for the given operation.
<T> java.lang.Iterable<T>	updateAll(UpdateBatchOperation<T> operation) Updates the entities for the given operation.
<T> T	updateOne(DefaultMongoRepositoryOperations.MongoOperationContext ctx, T value, RuntimePersistentEntity<T> persistentEntity) Update one entity during cascade.

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.operations.RepositoryOperations

getConversionService, getEntity

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

getQueryHints

Methods inherited from interface io.micronaut.context.ApplicationContextProvider

getApplicationContext

Methods inherited from interface io.micronaut.data.runtime.operations.internal.SyncCascadeOperations.SyncCascadeOperationsHelper

isSupportsBatchDelete, isSupportsBatchInsert, isSupportsBatchUpdate

Field Detail

QUERY_LOG

protected static final org.slf4j.Logger QUERY_LOG

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> T findOne(java.lang.Class<T> type,
                     java.io.Serializable id)

Description copied from interface: RepositoryOperations

Find one by ID.

Specified by:

findOne in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A result or null

findOne

public <T,R> R findOne(PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Find one by Query.

Specified by:

findOne in interface RepositoryOperations

Type Parameters:

T - The generic resultType

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A result or null

exists

public <T> boolean exists(PreparedQuery<T,java.lang.Boolean> preparedQuery)

Description copied from interface: RepositoryOperations

Execute a query that checks for existence.

Specified by:

exists in interface RepositoryOperations

Type Parameters:

T - The generic resultType

Parameters:

preparedQuery - The prepared query

Returns:

A result or null

findAll

public <T> java.lang.Iterable<T> findAll(PagedQuery<T> query)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The root entity

Returns:

An iterable result

count

public <T> long count(PagedQuery<T> pagedQuery)

Description copied from interface: RepositoryOperations

Counts all results for the given query.

Specified by:

count in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The paged query

Returns:

An iterable result

findStream

public <T> java.util.stream.Stream<T> findStream(PagedQuery<T> query)

Description copied from interface: RepositoryOperations

Finds a stream for the given arguments.

Specified by:

findStream in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

query - The query

Returns:

The stream

findPage

public <R> Page<R> findPage(PagedQuery<R> query)

Description copied from interface: RepositoryOperations

Find a page for the given entity and pageable.

Specified by:

findPage in interface RepositoryOperations

Type Parameters:

R - The entity generic type

Parameters:

query - The query

Returns:

The page type

findAll

public <T,R> java.lang.Iterable<R> findAll(PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface RepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

An iterable result

findStream

public <T,R> java.util.stream.Stream<R> findStream(PreparedQuery<T,R> preparedQuery)

Description copied from interface: RepositoryOperations

Finds all results for the given query.

Specified by:

findStream in interface RepositoryOperations

Type Parameters:

T - The entity type

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

An iterable result

persist

public <T> T persist(InsertOperation<T> operation)

Description copied from interface: RepositoryOperations

Persist the operation returning a possibly new entity.

Specified by:

persist in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The operation

persistAll

public <T> java.lang.Iterable<T> persistAll(InsertBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Persist all the given entities.

Specified by:

persistAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The entities, possibly mutated

update

public <T> T update(UpdateOperation<T> operation)

Description copied from interface: RepositoryOperations

Updates the entity for the given operation.

Specified by:

update in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The operation

updateAll

public <T> java.lang.Iterable<T> updateAll(UpdateBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Updates the entities for the given operation.

Specified by:

updateAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The updated entities

delete

public <T> int delete(DeleteOperation<T> operation)

Description copied from interface: RepositoryOperations

Deletes the entity.

Specified by:

delete in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The number of entities deleted

deleteAll

public <T> java.util.Optional<java.lang.Number> deleteAll(DeleteBatchOperation<T> operation)

Description copied from interface: RepositoryOperations

Deletes all the entities of the given type.

Specified by:

deleteAll in interface RepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The number of entities deleted

executeUpdate

public java.util.Optional<java.lang.Number> executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery)

Description copied from interface: RepositoryOperations

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 RepositoryOperations

Parameters:

preparedQuery - The prepared query

Returns:

An optional number with the count of the number of records updated

executeDelete

public java.util.Optional<java.lang.Number> executeDelete(PreparedQuery<?,java.lang.Number> preparedQuery)

Description copied from interface: RepositoryOperations

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

Specified by:

executeDelete in interface RepositoryOperations

Parameters:

preparedQuery - The prepared query

Returns:

An optional number with the count of the number of records updated

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.client.ClientSession,java.lang.Object>

Parameters:

preparedStatement - The prepared statement

index - The index

dataType - The data type

value - The value

dialect - The dialect

getDatabase

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

getCodecRegistry

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

persistOne

public <T> T persistOne(DefaultMongoRepositoryOperations.MongoOperationContext ctx,
                        T value,
                        RuntimePersistentEntity<T> persistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist one entity during cascade.

Specified by:

persistOne in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.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> java.util.List<T> persistBatch(DefaultMongoRepositoryOperations.MongoOperationContext ctx,
                                          java.lang.Iterable<T> values,
                                          RuntimePersistentEntity<T> persistentEntity,
                                          java.util.function.Predicate<T> predicate)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist multiple entities in batch during cascade.

Specified by:

persistBatch in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.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> T updateOne(DefaultMongoRepositoryOperations.MongoOperationContext ctx,
                       T value,
                       RuntimePersistentEntity<T> persistentEntity)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Update one entity during cascade.

Specified by:

updateOne in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.MongoOperationContext>

Type Parameters:

T - The entity type

Parameters:

ctx - The context

value - The entity value

persistentEntity - The persistent entity

Returns:

The entity value

persistManyAssociation

public void persistManyAssociation(DefaultMongoRepositoryOperations.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: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist JOIN table relationship.

Specified by:

persistManyAssociation in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.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

persistManyAssociationBatch

public void persistManyAssociationBatch(DefaultMongoRepositoryOperations.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)

Description copied from interface: SyncCascadeOperations.SyncCascadeOperationsHelper

Persist JOIN table relationships in batch.

Specified by:

persistManyAssociationBatch in interface SyncCascadeOperations.SyncCascadeOperationsHelper<DefaultMongoRepositoryOperations.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

async

@NonNull
public ExecutorAsyncOperations async()

Specified by:

async in interface AsyncCapableRepository

Returns:

The async operations.

reactive

@NonNull
public ReactiveRepositoryOperations reactive()

Specified by:

reactive in interface ReactiveCapableRepository

Returns:

The reactive operations instance.

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)

createTypeConversionContext

protected io.micronaut.core.convert.ConversionContext createTypeConversionContext(Cnt connection,
                                                                                  RuntimePersistentProperty<?> property,
                                                                                  io.micronaut.core.type.Argument<?> argument)

Description copied from class: AbstractRepositoryOperations

Creates implementation specific conversion context.

Specified by:

createTypeConversionContext in class AbstractRepositoryOperations<Cnt,PS>

Parameters:

connection - The connection

property - The property

argument - The argument

Returns:

new ConversionContext

logFind

protected void logFind(MongoFind find)

logAggregate

protected void logAggregate(MongoAggregation aggregation)