Package io.micronaut.data.repository.jpa.reactive

Interface ReactorJpaSpecificationExecutor<T>

Type Parameters:

T - The entity type

All Superinterfaces:

ReactiveStreamsJpaSpecificationExecutor<T>

All Known Subinterfaces:

BookReactiveRepository, PersonReactiveRepository

public interface ReactorJpaSpecificationExecutor<T>
extends ReactiveStreamsJpaSpecificationExecutor<T>

Interface representing Reactor version of JpaSpecificationExecutor.

Since:

3.2

Author:

Denis Stepanov

Method Summary

Modifier and Type	Method	Description
@NonNull reactor.core.publisher.Mono<Long>	count(@Nullable PredicateSpecification<T> spec)	Returns the number of instances that the given QuerySpecification will return.
@NonNull reactor.core.publisher.Mono<Long>	count(@Nullable QuerySpecification<T> spec)	Returns the number of instances that the given QuerySpecification will return.
@NonNull reactor.core.publisher.Mono<Long>	deleteAll(@Nullable DeleteSpecification<T> spec)	Deletes all entities matching the given DeleteSpecification.
@NonNull reactor.core.publisher.Mono<Long>	deleteAll(@Nullable PredicateSpecification<T> spec)	Deletes all entities matching the given PredicateSpecification.
@NonNull reactor.core.publisher.Mono<Boolean>	exists(@Nullable PredicateSpecification<T> spec)	Returns whether an instance was found for the given PredicateSpecification.
@NonNull reactor.core.publisher.Mono<Boolean>	exists(@Nullable QuerySpecification<T> spec)	Returns whether an instance was found for the given QuerySpecification.
@NonNull reactor.core.publisher.Flux<T>	findAll(@Nullable PredicateSpecification<T> spec)	Returns all entities matching the given PredicateSpecification.
reactor.core.publisher.Mono<Page<T>>	findAll(@Nullable PredicateSpecification<T> spec, Pageable pageable)	Returns a Page of entities matching the given PredicateSpecification.
@NonNull reactor.core.publisher.Flux<T>	findAll(@Nullable PredicateSpecification<T> spec, Sort sort)	Returns all entities matching the given QuerySpecification and Sort.
@NonNull reactor.core.publisher.Flux<T>	findAll(@Nullable QuerySpecification<T> spec)	Returns all entities matching the given QuerySpecification.
reactor.core.publisher.Mono<Page<T>>	findAll(@Nullable QuerySpecification<T> spec, Pageable pageable)	Returns a Page of entities matching the given QuerySpecification.
@NonNull reactor.core.publisher.Flux<T>	findAll(@Nullable QuerySpecification<T> spec, Sort sort)	Returns all entities matching the given QuerySpecification and Sort.
@NonNull reactor.core.publisher.Mono<T>	findOne(@Nullable PredicateSpecification<T> spec)	Returns a single entity matching the given PredicateSpecification.
@NonNull reactor.core.publisher.Mono<T>	findOne(@Nullable QuerySpecification<T> spec)	Returns a single entity matching the given QuerySpecification.
@NonNull reactor.core.publisher.Mono<Long>	updateAll(@Nullable UpdateSpecification<T> spec)	Updates all entities matching the given UpdateSpecification.

Method Details

findOne

@NonNull
@NonNull reactor.core.publisher.Mono<T> findOne(@Nullable
 @Nullable QuerySpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns a single entity matching the given QuerySpecification.

Specified by:

findOne in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

optional found result

findOne

@NonNull
@NonNull reactor.core.publisher.Mono<T> findOne(@Nullable
 @Nullable PredicateSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns a single entity matching the given PredicateSpecification.

Specified by:

findOne in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

optional found result

findAll

@NonNull
@NonNull reactor.core.publisher.Flux<T> findAll(@Nullable
 @Nullable QuerySpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns all entities matching the given QuerySpecification.

Specified by:

findAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

found results

findAll

@NonNull
@NonNull reactor.core.publisher.Flux<T> findAll(@Nullable
 @Nullable PredicateSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns all entities matching the given PredicateSpecification.

Specified by:

findAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

found results

findAll

reactor.core.publisher.Mono<Page<T>> findAll(@Nullable
 @Nullable QuerySpecification<T> spec,
 Pageable pageable)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns a Page of entities matching the given QuerySpecification.

Specified by:

findAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

pageable - The pageable object

Returns:

a page

findAll

reactor.core.publisher.Mono<Page<T>> findAll(@Nullable
 @Nullable PredicateSpecification<T> spec,
 Pageable pageable)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns a Page of entities matching the given PredicateSpecification.

Specified by:

findAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

pageable - The pageable object

Returns:

a page

findAll

@NonNull
@NonNull reactor.core.publisher.Flux<T> findAll(@Nullable
 @Nullable QuerySpecification<T> spec,
 Sort sort)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns all entities matching the given QuerySpecification and Sort.

Specified by:

findAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

sort - The sort object

Returns:

found results

findAll

@NonNull
@NonNull reactor.core.publisher.Flux<T> findAll(@Nullable
 @Nullable PredicateSpecification<T> spec,
 Sort sort)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns all entities matching the given QuerySpecification and Sort.

Specified by:

findAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

sort - The sort object

Returns:

found results

count

@NonNull
@NonNull reactor.core.publisher.Mono<Long> count(@Nullable
 @Nullable QuerySpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns the number of instances that the given QuerySpecification will return.

Specified by:

count in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

the number of instances.

count

@NonNull
@NonNull reactor.core.publisher.Mono<Long> count(@Nullable
 @Nullable PredicateSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns the number of instances that the given QuerySpecification will return.

Specified by:

count in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

the number of instances.

exists

@NonNull
@NonNull reactor.core.publisher.Mono<Boolean> exists(@Nullable
 @Nullable QuerySpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns whether an instance was found for the given QuerySpecification.

Specified by:

exists in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

the number of instances.

exists

@NonNull
@NonNull reactor.core.publisher.Mono<Boolean> exists(@Nullable
 @Nullable PredicateSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Returns whether an instance was found for the given PredicateSpecification.

Specified by:

exists in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The query specification

Returns:

the number of instances.

deleteAll

@NonNull
@NonNull reactor.core.publisher.Mono<Long> deleteAll(@Nullable
 @Nullable DeleteSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Deletes all entities matching the given DeleteSpecification.

Specified by:

deleteAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The delete specification

Returns:

the number records deleted.

deleteAll

@NonNull
@NonNull reactor.core.publisher.Mono<Long> deleteAll(@Nullable
 @Nullable PredicateSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Deletes all entities matching the given PredicateSpecification.

Specified by:

deleteAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The delete specification

Returns:

the number records deleted.

updateAll

@NonNull
@NonNull reactor.core.publisher.Mono<Long> updateAll(@Nullable
 @Nullable UpdateSpecification<T> spec)

Description copied from interface: ReactiveStreamsJpaSpecificationExecutor

Updates all entities matching the given UpdateSpecification.

Specified by:

updateAll in interface ReactiveStreamsJpaSpecificationExecutor<T>

Parameters:

spec - The update specification

Returns:

the number records updated.