java.lang.Object

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

io.micronaut.data.cosmos.operations.DefaultReactiveCosmosRepositoryOperations

All Implemented Interfaces:: io.micronaut.context.ApplicationContextProvider, io.micronaut.core.convert.ConversionServiceProvider, ReactiveRepositoryOperations, ReactorReactiveRepositoryOperations, MethodContextAwareStoredQueryDecorator, PreparedQueryDecorator

@Singleton @Internal public final class DefaultReactiveCosmosRepositoryOperations extends AbstractRepositoryOperations implements ReactorReactiveRepositoryOperations, ReactiveRepositoryOperations, MethodContextAwareStoredQueryDecorator, PreparedQueryDecorator

The reactive Cosmos DB repository operations implementation.

Since:: 3.9.0
Author:: radovanradic

Field Summary

Fields inherited from class io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations
attributeConverterRegistry, conversionService, dateTimeProvider, entityEventRegistry, runtimeEntityRegistry
Constructor Summary

Constructors

Constructor

Description

DefaultReactiveCosmosRepositoryOperations(DateTimeProvider<Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, DataConversionService conversionService, AttributeConverterRegistry attributeConverterRegistry, com.azure.cosmos.CosmosAsyncClient cosmosAsyncClient, io.micronaut.data.cosmos.operations.CosmosSerde cosmosSerde, @Nullable CosmosDiagnosticsProcessor cosmosDiagnosticsProcessor, CosmosDatabaseConfiguration configuration)

Default constructor.
Method Summary

Modifier and Type

Method

Description

<T> @NonNull reactor.core.publisher.Mono<Long>

count(PagedQuery<T> pagedQuery)

Counts all results for the given query.

<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> @NonNull reactor.core.publisher.Mono<Number>

delete(@NonNull DeleteOperation<T> operation)

Deletes the entity.

<T> @NonNull reactor.core.publisher.Mono<Number>

deleteAll(@NonNull DeleteBatchOperation<T> operation)

Deletes all the entities of the given type.

@NonNull reactor.core.publisher.Mono<Number>

executeDelete(@NonNull PreparedQuery<?,Number> pq)

Executes a batch delete for the given query and parameter values.

@NonNull reactor.core.publisher.Mono<Number>

executeUpdate(@NonNull PreparedQuery<?,Number> pq)

Executes an update for the given query and parameter values.

<T> reactor.core.publisher.Mono<Boolean>

exists(@NonNull PreparedQuery<T,Boolean> pq)

Check with an record exists for the given query.

<T, R> @NonNull reactor.core.publisher.Flux<R>

findAll(@NonNull PreparedQuery<T,R> pq)

Finds all results for the given query.

<T> @NonNull reactor.core.publisher.Flux<T>

findAll(PagedQuery<T> pagedQuery)

Finds all results for the given query.

<T, R> @NonNull reactor.core.publisher.Mono<R>

findOne(@NonNull PreparedQuery<T,R> pq)

Find one by Query.

<T> @NonNull reactor.core.publisher.Mono<T>

findOne(@NonNull Class<T> type, Object id)

Find one by ID.

<T, R> @NonNull reactor.core.publisher.Mono<R>

findOptional(@NonNull PreparedQuery<T,R> preparedQuery)

Find one by Query.

<T> @NonNull reactor.core.publisher.Mono<T>

findOptional(@NonNull Class<T> type, @NonNull Object id)

Find one by ID.

<R> @NonNull reactor.core.publisher.Mono<Page<R>>

findPage(@NonNull PagedQuery<R> pagedQuery)

Find a page for the given entity and pageable.

<T> @NonNull reactor.core.publisher.Mono<T>

persist(@NonNull InsertOperation<T> operation)

Persist the entity returning a possibly new entity.

<T> @NonNull reactor.core.publisher.Flux<T>

persistAll(@NonNull InsertBatchOperation<T> operation)

Persist all the given entities.

<T> @NonNull reactor.core.publisher.Mono<T>

update(@NonNull UpdateOperation<T> operation)

Updates the entity returning a possibly new entity.

<T> @NonNull reactor.core.publisher.Flux<T>

updateAll(@NonNull UpdateBatchOperation<T> operation)

Updates the entities for the given operation.

Methods inherited from class io.micronaut.data.runtime.operations.internal.AbstractRepositoryOperations
checkOptimisticLocking, getApplicationContext, getConversionService, getEntity, getIdReader, isOnlySingleEndedJoins, 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.core.convert.ConversionServiceProvider
getConversionService

Constructor Details
- DefaultReactiveCosmosRepositoryOperations
  
  public DefaultReactiveCosmosRepositoryOperations(DateTimeProvider<Object> dateTimeProvider, RuntimeEntityRegistry runtimeEntityRegistry, DataConversionService conversionService, AttributeConverterRegistry attributeConverterRegistry, com.azure.cosmos.CosmosAsyncClient cosmosAsyncClient, io.micronaut.data.cosmos.operations.CosmosSerde cosmosSerde, @Nullable @Nullable CosmosDiagnosticsProcessor cosmosDiagnosticsProcessor, CosmosDatabaseConfiguration configuration)
  
  Default constructor.
  
  Parameters:
  
  dateTimeProvider - The date time provider
  
  runtimeEntityRegistry - The entity registry
  
  conversionService - The conversion service
  
  attributeConverterRegistry - The attribute converter registry
  
  cosmosAsyncClient - The Cosmos async client
  
  cosmosSerde - The Cosmos de/serialization helper
  
  cosmosDiagnosticsProcessor - The Cosmos diagnostics processor, can be null
  
  configuration - The Cosmos database configuration
Method Details
- 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
- findOne
  
  @NonNull public <T> @NonNull reactor.core.publisher.Mono<T> findOne(@NonNull @NonNull 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
- exists
  
  public <T> reactor.core.publisher.Mono<Boolean> exists(@NonNull @NonNull PreparedQuery<T,Boolean> pq)
  
  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:
  
  pq - The query
  
  Returns:
  
  True if it exists
- findOne
  
  @NonNull public <T, R> @NonNull reactor.core.publisher.Mono<R> findOne(@NonNull @NonNull PreparedQuery<T,R> pq)
  
  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:
  
  pq - The prepared query
  
  Returns:
  
  A publisher that emits the result
- findOptional
  
  @NonNull public <T> @NonNull reactor.core.publisher.Mono<T> findOptional(@NonNull @NonNull Class<T> type, @NonNull @NonNull 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
  
  @NonNull public <T, R> @NonNull reactor.core.publisher.Mono<R> findOptional(@NonNull @NonNull 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
- findAll
  
  @NonNull public <T> @NonNull reactor.core.publisher.Flux<T> findAll(PagedQuery<T> pagedQuery)
  
  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:
  
  pagedQuery - The paged query
  
  Returns:
  
  A publisher that emits the results
- count
  
  @NonNull public <T> @NonNull 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
  
  @NonNull public <T, R> @NonNull reactor.core.publisher.Flux<R> findAll(@NonNull @NonNull PreparedQuery<T,R> pq)
  
  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:
  
  pq - The prepared query
  
  Returns:
  
  A publisher that emits an iterable with all results
- persist
  
  @NonNull public <T> @NonNull reactor.core.publisher.Mono<T> persist(@NonNull @NonNull 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
- update
  
  @NonNull public <T> @NonNull reactor.core.publisher.Mono<T> update(@NonNull @NonNull 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
  
  @NonNull public <T> @NonNull reactor.core.publisher.Flux<T> updateAll(@NonNull @NonNull 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
- persistAll
  
  @NonNull public <T> @NonNull reactor.core.publisher.Flux<T> persistAll(@NonNull @NonNull 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
- executeUpdate
  
  @NonNull public @NonNull reactor.core.publisher.Mono<Number> executeUpdate(@NonNull @NonNull PreparedQuery<?,Number> pq)
  
  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:
  
  pq - The prepared query
  
  Returns:
  
  A publisher that emits a boolean true if the update was successful
- executeDelete
  
  @NonNull public @NonNull reactor.core.publisher.Mono<Number> executeDelete(@NonNull @NonNull PreparedQuery<?,Number> pq)
  
  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:
  
  pq - The prepared query
  
  Returns:
  
  A publisher that emits a boolean true if the update was successful
- delete
  
  @NonNull public <T> @NonNull reactor.core.publisher.Mono<Number> delete(@NonNull @NonNull 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
  
  @NonNull public <T> @NonNull reactor.core.publisher.Mono<Number> deleteAll(@NonNull @NonNull 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
- findPage
  
  @NonNull public <R> @NonNull reactor.core.publisher.Mono<Page<R>> findPage(@NonNull @NonNull 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

Class DefaultReactiveCosmosRepositoryOperations

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultReactiveCosmosRepositoryOperations

Method Details

decorate

decorate

findOne

exists

findOne

findOptional

findOptional

findAll

count

findAll

persist

update

updateAll

persistAll

executeUpdate

executeDelete

delete

deleteAll

findPage