Package io.micronaut.data.operations.reactive

Interface ReactiveCriteriaRepositoryOperations

All Superinterfaces:
ReactiveCriteriaCapableRepository
All Known Subinterfaces:
ReactorCriteriaRepositoryOperations
All Known Implementing Classes:
ExecutorReactiveOperationsSupportingCriteria
public interface ReactiveCriteriaRepositoryOperations extends ReactiveCriteriaCapableRepository
The repository operations that support executing criteria queries.
Since:
4.5.0
Author:
Denis Stepanov

  • Method Summary

    Modifier and Type
    Method
    Description
    @NonNull org.reactivestreams.Publisher<Number>
    deleteAll(@NonNull jakarta.persistence.criteria.CriteriaDelete<Number> query)
    Executes a delete for the given query and parameter values.
    org.reactivestreams.Publisher<Boolean>
    exists(@NonNull jakarta.persistence.criteria.CriteriaQuery<?> query)
    Exists query.
    <T> @NonNull org.reactivestreams.Publisher<T>
    findAll(@NonNull jakarta.persistence.criteria.CriteriaQuery<T> query)
    Finds all results for the given query.
    <T> @NonNull org.reactivestreams.Publisher<T>
    findAll(@NonNull jakarta.persistence.criteria.CriteriaQuery<T> query, int offset, int limit)
    Finds all results for the given query.
    <R> org.reactivestreams.Publisher<R>
    findOne(@NonNull jakarta.persistence.criteria.CriteriaQuery<R> query)
    Find one by Query.
    jakarta.persistence.criteria.CriteriaBuilder
    getCriteriaBuilder()
     
    default ReactiveCriteriaRepositoryOperations
    reactive()
     
    @NonNull org.reactivestreams.Publisher<Number>
    updateAll(@NonNull jakarta.persistence.criteria.CriteriaUpdate<Number> query)
    Executes an update for the given query and parameter values.

  • Method Details

    • reactive

      default ReactiveCriteriaRepositoryOperations reactive()
      Specified by:
      reactive in interface ReactiveCriteriaCapableRepository
      Returns:
      The reactive operations.

    • getCriteriaBuilder

      jakarta.persistence.criteria.CriteriaBuilder getCriteriaBuilder()
      Returns:
      The criteria builder

    • exists

      org.reactivestreams.Publisher<Boolean> exists(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<?> query)
      Exists query.
      Parameters:
      query - The query
      Returns:
      True if query returns true or any row
      Since:
      4.10

    • findOne

      @SingleResult <R> org.reactivestreams.Publisher<R> findOne(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<R> query)
      Find one by Query.
      Type Parameters:
      R - The result type
      Parameters:
      query - The query
      Returns:
      A single result publisher

    • findAll

      @NonNull <T> @NonNull org.reactivestreams.Publisher<T> findAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<T> query)
      Finds all results for the given query.
      Type Parameters:
      T - The generic type
      Parameters:
      query - The query
      Returns:
      All result publisher

    • findAll

      @NonNull <T> @NonNull org.reactivestreams.Publisher<T> findAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<T> query, int offset, int limit)
      Finds all results for the given query.
      Type Parameters:
      T - The generic type
      Parameters:
      query - The query
      offset - The offset
      limit - The limit
      Returns:
      All result publisher

    • updateAll

      @NonNull @SingleResult @NonNull org.reactivestreams.Publisher<Number> updateAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaUpdate<Number> query)
      Executes an update for the given query and parameter values. If it is possible to return the number of objects updated, then do so.
      Parameters:
      query - The prepared query
      Returns:
      An optional number with the count of the number of records updated

    • deleteAll

      @NonNull @SingleResult @NonNull org.reactivestreams.Publisher<Number> deleteAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaDelete<Number> query)
      Executes a delete for the given query and parameter values. If it is possible to return the number of objects deleted, then do so.
      Parameters:
      query - The query
      Returns:
      An optional number with the count of the number of records updated