Package io.micronaut.data.runtime.operations

Class ExecutorReactiveOperations

java.lang.Object
io.micronaut.data.runtime.operations.ExecutorReactiveOperations
All Implemented Interfaces:
io.micronaut.core.convert.ConversionServiceProvider, ReactiveRepositoryOperations
public class ExecutorReactiveOperations extends Object implements ReactiveRepositoryOperations
An implementation of ReactiveRepositoryOperations that delegates to a blocking operations and specified Executor. This can be used in absence of true reactive support at the driver level an allows composing blocking operations within reactive flows.

If a backing implementation provides a reactive API then the backing implementation should not use this class and instead directly implement the ReactiveRepositoryOperations interface.

Since:
1.0.0
Author:
graemerocher
See Also:

  • Constructor Details

    • ExecutorReactiveOperations

      public ExecutorReactiveOperations(@NonNull @NonNull RepositoryOperations datastore, @NonNull @NonNull Executor executor, DataConversionService dataConversionService)
      Default constructor.
      Parameters:
      datastore - The target operations
      executor - The executor to use.
      dataConversionService - The data conversion service

    • ExecutorReactiveOperations

      public ExecutorReactiveOperations(@NonNull @NonNull ExecutorAsyncOperations asyncOperations, DataConversionService dataConversionService)
      Default constructor.
      Parameters:
      asyncOperations - The instance operations instance
      dataConversionService - The data conversion service

  • Method Details

    • findOne

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> findOne(@NonNull @NonNull Class<T> type, @NonNull @NonNull Object id)
      Description copied from interface: ReactiveRepositoryOperations
      Find one by ID.
      Specified by:
      findOne in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      type - The type
      id - The id
      Returns:
      A publisher that emits the result

    • exists

      public <T> org.reactivestreams.Publisher<Boolean> exists(@NonNull @NonNull PreparedQuery<T,Boolean> preparedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Check with an record exists for the given query.
      Specified by:
      exists in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The declaring type
      Parameters:
      preparedQuery - The query
      Returns:
      True if it exists

    • findOne

      @NonNull public <T, R> @NonNull org.reactivestreams.Publisher<R> findOne(@NonNull @NonNull PreparedQuery<T,R> preparedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Find one by Query.
      Specified by:
      findOne in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic resultType
      R - The result type
      Parameters:
      preparedQuery - The prepared query
      Returns:
      A publisher that emits the result

    • findOptional

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> findOptional(@NonNull @NonNull Class<T> type, @NonNull @NonNull Object id)
      Description copied from interface: ReactiveRepositoryOperations
      Find one by ID.
      Specified by:
      findOptional in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      type - The type
      id - The id
      Returns:
      A publisher that emits zero or one result

    • findOptional

      @NonNull public <T, R> @NonNull org.reactivestreams.Publisher<R> findOptional(@NonNull @NonNull PreparedQuery<T,R> preparedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Find one by Query.
      Specified by:
      findOptional in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic resultType
      R - The result type
      Parameters:
      preparedQuery - The prepared query
      Returns:
      A publisher that emits the zero or one result

    • findAll

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> findAll(PagedQuery<T> pagedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Finds all results for the given query.
      Specified by:
      findAll in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      pagedQuery - The paged query
      Returns:
      A publisher that emits the results

    • count

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<Long> count(PagedQuery<T> pagedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Counts all results for the given query.
      Specified by:
      count in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      pagedQuery - The paged query
      Returns:
      A publisher that emits the count as a long

    • findPage

      @NonNull public <R> @NonNull org.reactivestreams.Publisher<Page<R>> findPage(@NonNull @NonNull PagedQuery<R> pagedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Find a page for the given entity and pageable.
      Specified by:
      findPage in interface ReactiveRepositoryOperations
      Type Parameters:
      R - The entity generic type
      Parameters:
      pagedQuery - The paged query
      Returns:
      The page type

    • findAll

      @NonNull public <T, R> @NonNull org.reactivestreams.Publisher<R> findAll(@NonNull @NonNull PreparedQuery<T,R> preparedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      Finds all results for the given query.
      Specified by:
      findAll in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The entity type
      R - The result type
      Parameters:
      preparedQuery - The prepared query
      Returns:
      A publisher that emits an iterable with all results

    • persist

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> persist(@NonNull @NonNull InsertOperation<T> entity)
      Description copied from interface: ReactiveRepositoryOperations
      Persist the entity returning a possibly new entity.
      Specified by:
      persist in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      entity - The entity operation
      Returns:
      A publisher that emits the entity

    • update

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> update(@NonNull @NonNull UpdateOperation<T> operation)
      Description copied from interface: ReactiveRepositoryOperations
      Updates the entity returning a possibly new entity.
      Specified by:
      update in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      operation - The entity operation
      Returns:
      A publisher that emits the entity

    • updateAll

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> updateAll(@NonNull @NonNull UpdateBatchOperation<T> operation)
      Description copied from interface: ReactiveRepositoryOperations
      Updates the entities for the given operation.
      Specified by:
      updateAll in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      operation - The operation
      Returns:
      The updated entities

    • persistAll

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<T> persistAll(@NonNull @NonNull InsertBatchOperation<T> operation)
      Description copied from interface: ReactiveRepositoryOperations
      Persist all the given entities.
      Specified by:
      persistAll in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      operation - The batch operation
      Returns:
      The entities, possibly mutated

    • executeUpdate

      @NonNull public @NonNull org.reactivestreams.Publisher<Number> executeUpdate(@NonNull @NonNull PreparedQuery<?,Number> preparedQuery)
      Description copied from interface: ReactiveRepositoryOperations
      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:
      executeUpdate in interface ReactiveRepositoryOperations
      Parameters:
      preparedQuery - The prepared query
      Returns:
      A publisher that emits a boolean true if the update was successful

    • delete

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<Number> delete(@NonNull @NonNull DeleteOperation<T> operation)
      Description copied from interface: ReactiveRepositoryOperations
      Deletes the entity.
      Specified by:
      delete in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      operation - The batch operation
      Returns:
      A publisher that emits the number of entities deleted

    • deleteAll

      @NonNull public <T> @NonNull org.reactivestreams.Publisher<Number> deleteAll(@NonNull @NonNull DeleteBatchOperation<T> operation)
      Description copied from interface: ReactiveRepositoryOperations
      Deletes all the entities of the given type.
      Specified by:
      deleteAll in interface ReactiveRepositoryOperations
      Type Parameters:
      T - The generic type
      Parameters:
      operation - The batch operation
      Returns:
      A publisher that emits the number of entities deleted

    • getConversionService

      public io.micronaut.core.convert.ConversionService getConversionService()
      Specified by:
      getConversionService in interface io.micronaut.core.convert.ConversionServiceProvider