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

    • 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