Class DefaultReactiveCosmosRepositoryOperations

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
@NullUnmarked
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 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 a 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 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 ReactorReactiveRepositoryOperations

execute

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

public <T> @NonNull reactor.core.publisher.Mono<T> findOne(@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 PreparedQuery<T,Boolean> pq)

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:

pq - The query

Returns:

True if it exists

findOne

public <T,R>
@NonNull reactor.core.publisher.Mono<R> findOne(@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

public <T> @NonNull reactor.core.publisher.Mono<T> findOptional(@NonNull Class<T> type,
 @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

public <T,R>
@NonNull reactor.core.publisher.Mono<R> findOptional(@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

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

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

public <T,R>
@NonNull reactor.core.publisher.Flux<R> findAll(@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

public <T> @NonNull reactor.core.publisher.Mono<T> persist(@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

public <T> @NonNull reactor.core.publisher.Mono<T> update(@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

public <T> @NonNull reactor.core.publisher.Flux<T> updateAll(@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

public <T> @NonNull reactor.core.publisher.Flux<T> persistAll(@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

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

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

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

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

public <R>
@NonNull reactor.core.publisher.Mono<Page<R>> findPage(@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