Package io.micronaut.data.operations.reactive

Interface BlockingReactorCriteriaRepositoryOperations

All Superinterfaces:
BlockingCriteriaCapableRepository, CriteriaRepositoryOperations, ReactiveCriteriaCapableRepository, ReactorCriteriaCapableRepository
public interface BlockingReactorCriteriaRepositoryOperations extends CriteriaRepositoryOperations, BlockingCriteriaCapableRepository, ReactorCriteriaCapableRepository
Implementation of CriteriaRepositoryOperations that blocks every call from ReactorCriteriaCapableRepository.
Since:
4.5.0
Author:
Denis Stepanov

  • Method Summary

    Modifier and Type
    Method
    Description
    default CriteriaRepositoryOperations
    blocking()
     
    default Optional<Number>
    deleteAll(@NonNull jakarta.persistence.criteria.CriteriaDelete<Number> query)
    Executes delete for the given query and parameter values.
    default <T> List<T>
    findAll(@NonNull jakarta.persistence.criteria.CriteriaQuery<T> query)
    Finds all results for the given query.
    default <T> List<T>
    findAll(@NonNull jakarta.persistence.criteria.CriteriaQuery<T> query, int limit, int offset)
    Finds all results for the given query.
    default <R> R
    findOne(@NonNull jakarta.persistence.criteria.CriteriaQuery<R> query)
    Find one by Query.
    default Optional<Number>
    updateAll(@NonNull jakarta.persistence.criteria.CriteriaUpdate<Number> query)
    Executes an update for the given query and parameter values.

    Methods inherited from interface io.micronaut.data.operations.CriteriaRepositoryOperations

    exists, getCriteriaBuilder

    Methods inherited from interface io.micronaut.data.operations.reactive.ReactorCriteriaCapableRepository

    reactive

  • Method Details

    • blocking

      default CriteriaRepositoryOperations blocking()
      Specified by:
      blocking in interface BlockingCriteriaCapableRepository
      Returns:
      The blocking operations.

    • findOne

      @Nullable default <R> R findOne(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<R> query)
      Description copied from interface: CriteriaRepositoryOperations
      Find one by Query.
      Specified by:
      findOne in interface CriteriaRepositoryOperations
      Type Parameters:
      R - The result type
      Parameters:
      query - The query
      Returns:
      A result or null

    • findAll

      default <T> List<T> findAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<T> query)
      Description copied from interface: CriteriaRepositoryOperations
      Finds all results for the given query.
      Specified by:
      findAll in interface CriteriaRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      query - The query
      Returns:
      An iterable result

    • findAll

      default <T> List<T> findAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaQuery<T> query, int limit, int offset)
      Description copied from interface: CriteriaRepositoryOperations
      Finds all results for the given query.
      Specified by:
      findAll in interface CriteriaRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      query - The query
      limit - The offset
      offset - The limit
      Returns:
      An iterable result

    • updateAll

      default Optional<Number> updateAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaUpdate<Number> query)
      Description copied from interface: CriteriaRepositoryOperations
      Executes an update for the given query and parameter values. If it is possible to return the number of objects updated, then do so.
      Specified by:
      updateAll in interface CriteriaRepositoryOperations
      Parameters:
      query - The prepared query
      Returns:
      An optional number with the count of the number of records updated

    • deleteAll

      default Optional<Number> deleteAll(@NonNull @NonNull jakarta.persistence.criteria.CriteriaDelete<Number> query)
      Description copied from interface: CriteriaRepositoryOperations
      Executes delete for the given query and parameter values. If it is possible to return the number of objects deleted, then do so.
      Specified by:
      deleteAll in interface CriteriaRepositoryOperations
      Parameters:
      query - The query
      Returns:
      An optional number with the count of the number of records updated