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

Interface ReactiveStreamsJpaSpecificationExecutor<T>

Type Parameters:
T - The entity type
All Known Subinterfaces:
ReactorJpaSpecificationExecutor<T>
public interface ReactiveStreamsJpaSpecificationExecutor<T>
Interface representing reactive streams version of JpaSpecificationExecutor.
Since:
3.2
Author:
Denis Stepanov

  • Method Details

    • findOne

      @NonNull @NonNull org.reactivestreams.Publisher<T> findOne(@Nullable @Nullable QuerySpecification<T> spec)
      Returns a single entity matching the given QuerySpecification.
      Parameters:
      spec - The query specification
      Returns:
      optional found result

    • findOne

      @NonNull @NonNull org.reactivestreams.Publisher<T> findOne(@Nullable @Nullable PredicateSpecification<T> spec)
      Returns a single entity matching the given PredicateSpecification.
      Parameters:
      spec - The query specification
      Returns:
      optional found result

    • findAll

      @NonNull @NonNull org.reactivestreams.Publisher<T> findAll(@Nullable @Nullable QuerySpecification<T> spec)
      Returns all entities matching the given QuerySpecification.
      Parameters:
      spec - The query specification
      Returns:
      found results

    • findAll

      @NonNull @NonNull org.reactivestreams.Publisher<T> findAll(@Nullable @Nullable PredicateSpecification<T> spec)
      Returns all entities matching the given PredicateSpecification.
      Parameters:
      spec - The query specification
      Returns:
      found results

    • findAll

      @NonNull @NonNull org.reactivestreams.Publisher<Page<T>> findAll(@Nullable @Nullable QuerySpecification<T> spec, Pageable pageable)
      Returns a Page of entities matching the given QuerySpecification.
      Parameters:
      spec - The query specification
      pageable - The pageable object
      Returns:
      a page

    • findAll

      @NonNull @NonNull org.reactivestreams.Publisher<Page<T>> findAll(@Nullable @Nullable PredicateSpecification<T> spec, Pageable pageable)
      Returns a Page of entities matching the given PredicateSpecification.
      Parameters:
      spec - The query specification
      pageable - The pageable object
      Returns:
      a page

    • findAll

      @NonNull @NonNull org.reactivestreams.Publisher<T> findAll(@Nullable @Nullable QuerySpecification<T> spec, Sort sort)
      Returns all entities matching the given QuerySpecification and Sort.
      Parameters:
      spec - The query specification
      sort - The sort object
      Returns:
      found results

    • findAll

      @NonNull @NonNull org.reactivestreams.Publisher<T> findAll(@Nullable @Nullable PredicateSpecification<T> spec, Sort sort)
      Returns all entities matching the given QuerySpecification and Sort.
      Parameters:
      spec - The query specification
      sort - The sort object
      Returns:
      found results

    • count

      @NonNull @NonNull org.reactivestreams.Publisher<Long> count(@Nullable @Nullable QuerySpecification<T> spec)
      Returns the number of instances that the given QuerySpecification will return.
      Parameters:
      spec - The query specification
      Returns:
      the number of instances.

    • count

      @NonNull @NonNull org.reactivestreams.Publisher<Long> count(@Nullable @Nullable PredicateSpecification<T> spec)
      Returns the number of instances that the given QuerySpecification will return.
      Parameters:
      spec - The query specification
      Returns:
      the number of instances.

    • exists

      @NonNull @NonNull org.reactivestreams.Publisher<Boolean> exists(@Nullable @Nullable QuerySpecification<T> spec)
      Returns whether an instance was found for the given QuerySpecification.
      Parameters:
      spec - The query specification
      Returns:
      the number of instances.
      Since:
      3.8

    • exists

      @NonNull @NonNull org.reactivestreams.Publisher<Boolean> exists(@Nullable @Nullable PredicateSpecification<T> spec)
      Returns whether an instance was found for the given PredicateSpecification.
      Parameters:
      spec - The query specification
      Returns:
      the number of instances.
      Since:
      3.8

    • deleteAll

      @NonNull @NonNull org.reactivestreams.Publisher<Long> deleteAll(@Nullable @Nullable DeleteSpecification<T> spec)
      Deletes all entities matching the given DeleteSpecification.
      Parameters:
      spec - The delete specification
      Returns:
      the number records deleted.

    • deleteAll

      @NonNull @NonNull org.reactivestreams.Publisher<Long> deleteAll(@Nullable @Nullable PredicateSpecification<T> spec)
      Deletes all entities matching the given PredicateSpecification.
      Parameters:
      spec - The delete specification
      Returns:
      the number records deleted.

    • updateAll

      @NonNull @NonNull org.reactivestreams.Publisher<Long> updateAll(@Nullable @Nullable UpdateSpecification<T> spec)
      Updates all entities matching the given UpdateSpecification.
      Parameters:
      spec - The update specification
      Returns:
      the number records updated.