io.micronaut.data.mongodb.operations

Class DefaultMongoRepositoryOperations

java.lang.Object

io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations<com.mongodb.client.ClientSession,java.lang.Object>

io.micronaut.data.mongodb.operations.DefaultMongoRepositoryOperations

All Implemented Interfaces:

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

@EachBean(value=com.mongodb.client.MongoClient.class)
 @Internal
public final class DefaultMongoRepositoryOperations
extends AbstractRepositoryOperations<com.mongodb.client.ClientSession,java.lang.Object>
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 inherited from class io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations

attributeConverterRegistry, conversionService, dateTimeProvider, entityEventRegistry, jsonCodec, runtimeEntityRegistry

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

DefaultMongoRepositoryOperations(java.lang.String serverName, io.micronaut.context.BeanContext beanContext, java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs, DateTimeProvider<java.lang.Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, DataConversionService<?> conversionService, AttributeConverterRegistry attributeConverterRegistry, com.mongodb.client.MongoClient mongoClient, java.util.concurrent.ExecutorService executorService) Default constructor.

Method Summary

Modifier and Type	Method and Description
ExecutorAsyncOperations	async()
<T> long	count(PagedQuery<T> pagedQuery) Counts all results for the given query.
protected io.micronaut.core.convert.ConversionContext	createTypeConversionContext(com.mongodb.client.ClientSession 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.
<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()
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, 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, 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

Constructor Detail

DefaultMongoRepositoryOperations

protected DefaultMongoRepositoryOperations(@Parameter
                                           java.lang.String serverName,
                                           io.micronaut.context.BeanContext beanContext,
                                           java.util.List<io.micronaut.http.codec.MediaTypeCodec> codecs,
                                           DateTimeProvider<java.lang.Object> dateTimeProvider,
                                           RuntimeEntityRegistry runtimeEntityRegistry,
                                           DataConversionService<?> conversionService,
                                           AttributeConverterRegistry attributeConverterRegistry,
                                           com.mongodb.client.MongoClient mongoClient,
                                           @Named(value="io") @Nullable
                                           java.util.concurrent.ExecutorService executorService)

Default constructor.

Parameters:

serverName - The server name

beanContext - The bean context

codecs - The media type codecs

dateTimeProvider - The date time provider

runtimeEntityRegistry - The entity registry

conversionService - The conversion service

attributeConverterRegistry - The attribute converter registry

mongoClient - The Mongo client

executorService - The executor service

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

createTypeConversionContext

protected io.micronaut.core.convert.ConversionContext createTypeConversionContext(com.mongodb.client.ClientSession 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<com.mongodb.client.ClientSession,java.lang.Object>

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