Package io.micronaut.data.operations.reactive

Interface ReactorReactiveRepositoryOperations

All Superinterfaces:

ReactiveRepositoryOperations

All Known Subinterfaces:

HibernateReactorRepositoryOperations, ReactorReactiveRepositoryOperations

All Known Implementing Classes:

DefaultReactiveMongoRepositoryOperations

public interface ReactorReactiveRepositoryOperations
extends ReactiveRepositoryOperations

The version of ReactiveRepositoryOperations which exposes reactor publisher types.

Since:

3.3.0

Author:

Denis Stepanov

Method Summary

Modifier and Type	Method	Description
<T> reactor.core.publisher.Mono<java.lang.Long>	count(PagedQuery<T> pagedQuery)	Counts all results for the given query.
<T> reactor.core.publisher.Mono<java.lang.Number>	delete(DeleteOperation<T> operation)	Deletes the entity.
<T> reactor.core.publisher.Mono<java.lang.Number>	deleteAll(DeleteBatchOperation<T> operation)	Deletes all the entities of the given type.
reactor.core.publisher.Mono<java.lang.Number>	executeDelete(PreparedQuery<?,java.lang.Number> preparedQuery)	Executes a batch delete for the given query and parameter values.
reactor.core.publisher.Mono<java.lang.Number>	executeUpdate(PreparedQuery<?,java.lang.Number> preparedQuery)	Executes an update for the given query and parameter values.
<T> reactor.core.publisher.Mono<java.lang.Boolean>	exists(PreparedQuery<T,java.lang.Boolean> preparedQuery)	Check with an record exists for the given query.
<T> reactor.core.publisher.Flux<T>	findAll(PagedQuery<T> pagedQuery)	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(java.lang.Class<T> type, java.io.Serializable 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(java.lang.Class<T> type, java.io.Serializable 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.
<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.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.

Method Detail

findOne

@NonNull
@SingleResult
<T> reactor.core.publisher.Mono<T> findOne(@NonNull
                                           java.lang.Class<T> type,
                                           @NonNull
                                           java.io.Serializable id)

Description copied from interface: ReactiveRepositoryOperations

Find one by ID.

Specified by:

findOne in interface ReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A publisher that emits the result

exists

<T> reactor.core.publisher.Mono<java.lang.Boolean> exists(@NonNull
                                                          PreparedQuery<T,java.lang.Boolean> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Check with an record exists for the given query.

Specified by:

exists in interface ReactiveRepositoryOperations

Type Parameters:

T - The declaring type

Parameters:

preparedQuery - The query

Returns:

True if it exists

findOne

@SingleResult
@NonNull
<T,R> reactor.core.publisher.Mono<R> findOne(@NonNull
                                                   PreparedQuery<T,R> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Find one by Query.

Specified by:

findOne in interface ReactiveRepositoryOperations

Type Parameters:

T - The generic resultType

R - The result type

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits the result

findOptional

@NonNull
@SingleResult
<T> reactor.core.publisher.Mono<T> findOptional(@NonNull
                                                java.lang.Class<T> type,
                                                @NonNull
                                                java.io.Serializable id)

Description copied from interface: ReactiveRepositoryOperations

Find one by ID.

Specified by:

findOptional in interface ReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

type - The type

id - The id

Returns:

A publisher that emits zero or one result

findOptional

@SingleResult
@NonNull
<T,R> 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

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

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The paged query

Returns:

A publisher that emits the results

count

@SingleResult
@NonNull
<T> reactor.core.publisher.Mono<java.lang.Long> count(PagedQuery<T> pagedQuery)

Description copied from interface: ReactiveRepositoryOperations

Counts all results for the given query.

Specified by:

count in interface ReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

pagedQuery - The paged query

Returns:

A publisher that emits the count as a long

findAll

@NonNull
<T,R> reactor.core.publisher.Flux<R> findAll(@NonNull
                                                   PreparedQuery<T,R> preparedQuery)

Description copied from interface: ReactiveRepositoryOperations

Finds all results for the given query.

Specified by:

findAll in interface ReactiveRepositoryOperations

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

persist

@SingleResult
@NonNull
<T> 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

Type Parameters:

T - The generic type

Parameters:

operation - The entity operation

Returns:

A publisher that emits the entity

update

@SingleResult
@NonNull
<T> 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

Type Parameters:

T - The generic type

Parameters:

operation - The entity operation

Returns:

A publisher that emits the entity

updateAll

@NonNull
<T> 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

Type Parameters:

T - The generic type

Parameters:

operation - The operation

Returns:

The updated entities

persistAll

@NonNull
<T> 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

Type Parameters:

T - The generic type

Parameters:

operation - The batch operation

Returns:

The entities, possibly mutated

executeUpdate

@NonNull
@SingleResult
reactor.core.publisher.Mono<java.lang.Number> executeUpdate(@NonNull
                                                            PreparedQuery<?,java.lang.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

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits a boolean true if the update was successful

executeDelete

@NonNull
@SingleResult
reactor.core.publisher.Mono<java.lang.Number> executeDelete(@NonNull
                                                            PreparedQuery<?,java.lang.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

Parameters:

preparedQuery - The prepared query

Returns:

A publisher that emits a boolean true if the update was successful

delete

@SingleResult
@NonNull
<T> reactor.core.publisher.Mono<java.lang.Number> delete(@NonNull
                                                         DeleteOperation<T> operation)

Description copied from interface: ReactiveRepositoryOperations

Deletes the entity.

Specified by:

delete in interface ReactiveRepositoryOperations

Type Parameters:

T - The generic type

Parameters:

operation - The batch operation

Returns:

A publisher that emits the number of entities deleted

deleteAll

@SingleResult
@NonNull
<T> reactor.core.publisher.Mono<java.lang.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

Type Parameters:

T - The generic type

Parameters:

operation - The batch operation

Returns:

A publisher that emits the number of entities deleted

findPage

@SingleResult
@NonNull
<R> 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

Type Parameters:

R - The entity generic type

Parameters:

pagedQuery - The paged query

Returns:

The page type