org.springframework.data.querydsl

Interface ReactiveQuerydslPredicateExecutor<T>

public interface ReactiveQuerydslPredicateExecutor<T>

Interface to issue queries using Querydsl Predicate instances.
Intended for usage along with the ReactiveCrudRepository interface to wire in Querydslsupport.

     

  public interface PersonRepository extends ReactiveCrudRepository<Person, String>, ReactiveQuerydslPredicateExecutor<Person> {

  }

  // ...

  personRepository.findOne(QPerson.person.email.eq("t-800@skynet.io"))
      .flatMap(t800 ->
      //....

     
 

IMPORTANT: Please check the module specific documentation whether or not Querydsl is supported.

Since:

2.2

Author:

Mark Paluch, Christoph Strobl

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<Long>	count(com.querydsl.core.types.Predicate predicate) Returns a Mono emitting the number of instances matching the given Predicate.
reactor.core.publisher.Mono<Boolean>	exists(com.querydsl.core.types.Predicate predicate) Checks whether the data store contains elements that match the given Predicate.
reactor.core.publisher.Flux<T>	findAll(com.querydsl.core.types.OrderSpecifier<?>... orders) Returns a Flux emitting all entities ordered by the given OrderSpecifiers.
reactor.core.publisher.Flux<T>	findAll(com.querydsl.core.types.Predicate predicate) Returns a Flux emitting all entities matching the given Predicate.
reactor.core.publisher.Flux<T>	findAll(com.querydsl.core.types.Predicate predicate, com.querydsl.core.types.OrderSpecifier<?>... orders) Returns a Flux emitting all entities matching the given Predicate applying the given OrderSpecifiers.
reactor.core.publisher.Flux<T>	findAll(com.querydsl.core.types.Predicate predicate, Sort sort) Returns a Flux emitting all entities matching the given Predicate applying the given Sort.
<S extends T,R,P extends org.reactivestreams.Publisher<R>> P	findBy(com.querydsl.core.types.Predicate predicate, Function<FluentQuery.ReactiveFluentQuery<S>,P> queryFunction) Returns entities matching the given Predicate applying the queryFunction that defines the query and its result type.
reactor.core.publisher.Mono<T>	findOne(com.querydsl.core.types.Predicate predicate) Returns a Mono emitting the entity matching the given Predicate or Mono.empty() if none was found.

Method Detail

findOne

reactor.core.publisher.Mono<T> findOne(com.querydsl.core.types.Predicate predicate)

Returns a Mono emitting the entity matching the given Predicate or Mono.empty() if none was found.

Parameters:

predicate - must not be null.

Returns:

a Mono emitting a single entity matching the given Predicate or Mono.empty() if none was found.

Throws:

IllegalArgumentException - if the required parameter is null.

IncorrectResultSizeDataAccessException - if the predicate yields more than one result.

findAll

reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate)

Returns a Flux emitting all entities matching the given Predicate. In case no match could be found, Flux emits no items.

Parameters:

predicate - must not be null.

Returns:

a Flux emitting all entities matching the given Predicate one by one.

Throws:

IllegalArgumentException - if the required parameter is null.

findAll

reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate,
                                       Sort sort)

Returns a Flux emitting all entities matching the given Predicate applying the given Sort. In case no match could be found, Flux emits no items.

Parameters:

predicate - must not be null.

sort - the Sort specification to sort the results by, may be Sort.unsorted(), must not be null.

Returns:

a Flux emitting all entities matching the given Predicate one by one.

Throws:

IllegalArgumentException - if one of the required parameters is null.

findAll

reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate,
                                       com.querydsl.core.types.OrderSpecifier<?>... orders)

Returns a Flux emitting all entities matching the given Predicate applying the given OrderSpecifiers. In case no match could be found, Flux emits no items.

Parameters:

predicate - must not be null.

orders - the OrderSpecifiers to sort the results by.

Returns:

a Flux emitting all entities matching the given Predicate applying the given OrderSpecifiers.

Throws:

IllegalArgumentException - if one of the required parameter is null, or contains a null value.

findAll

reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.OrderSpecifier<?>... orders)

Returns a Flux emitting all entities ordered by the given OrderSpecifiers.

Parameters:

orders - the OrderSpecifiers to sort the results by.

Returns:

a Flux emitting all entities ordered by the given OrderSpecifiers.

Throws:

IllegalArgumentException - one of the OrderSpecifiers is null.

count

reactor.core.publisher.Mono<Long> count(com.querydsl.core.types.Predicate predicate)

Returns a Mono emitting the number of instances matching the given Predicate.

Parameters:

predicate - the Predicate to count instances for, must not be null.

Returns:

a Mono emitting the number of instances matching the Predicate or 0 if none found.

Throws:

IllegalArgumentException - if the required parameter is null.

exists

reactor.core.publisher.Mono<Boolean> exists(com.querydsl.core.types.Predicate predicate)

Checks whether the data store contains elements that match the given Predicate.

Parameters:

predicate - the Predicate to use for the existence check, must not be null.

Returns:

a Mono emitting true if the data store contains elements that match the given Predicate, false otherwise.

Throws:

IllegalArgumentException - if the required parameter is null.

findBy

<S extends T,R,P extends org.reactivestreams.Publisher<R>> P findBy(com.querydsl.core.types.Predicate predicate,
                                                                    Function<FluentQuery.ReactiveFluentQuery<S>,P> queryFunction)

Returns entities matching the given Predicate applying the queryFunction that defines the query and its result type.

Parameters:

predicate - must not be null.

queryFunction - the query function defining projection, sorting, and the result type

Returns:

all entities matching the given Predicate.

Since:

2.6