Package io.micronaut.data.runtime.operations.internal

Class AbstractReactiveEntitiesOperations<Ctx extends OperationContext,T,Exc extends Exception>

java.lang.Object
io.micronaut.data.runtime.operations.internal.ReactiveEntitiesOperations<T,Exc>
io.micronaut.data.runtime.operations.internal.AbstractReactiveEntitiesOperations<Ctx,T,Exc>
Type Parameters:
Ctx - The operation context
T - The entity type
Exc - The exception
@Internal public abstract class AbstractReactiveEntitiesOperations<Ctx extends OperationContext,T,Exc extends Exception> extends ReactiveEntitiesOperations<T,Exc>
Abstract reactive entities operations.
Since:
3.3
Author:
Denis Stepanov

  • Field Details

  • Constructor Details

    • AbstractReactiveEntitiesOperations

      protected AbstractReactiveEntitiesOperations(Ctx ctx, ReactiveCascadeOperations<Ctx> cascadeOperations, io.micronaut.core.convert.ConversionService conversionService, EntityEventListener<Object> entityEventListener, RuntimePersistentEntity<T> persistentEntity, Iterable<T> entities, boolean insert)
      Default constructor.
      Parameters:
      ctx - The context
      cascadeOperations - The cascade operations
      conversionService - The conversion service
      entityEventListener - The entity event listener
      persistentEntity - The persistent entity
      entities - The entities
      insert - The insert

  • Method Details

    • cascadePre

      protected void cascadePre(Relation.Cascade cascadeType)
      Cascade pre operation.
      Parameters:
      cascadeType - The cascade type

    • cascadePost

      protected void cascadePost(Relation.Cascade cascadeType)
      Cascade post operation.
      Parameters:
      cascadeType - The cascade type

    • veto

      public void veto(Predicate<T> predicate)
      Veto an entity.
      Parameters:
      predicate - The veto predicate

    • triggerPre

      protected boolean triggerPre(Function<EntityEventContext<Object>,Boolean> fn)
      Trigger pre-actions on EntityEventContext.
      Parameters:
      fn - The entity context function
      Returns:
      true if operation was vetoed

    • triggerPost

      protected void triggerPost(Consumer<EntityEventContext<Object>> fn)
      Trigger post-actions on EntityEventContext.
      Parameters:
      fn - The entity context function

    • notVetoed

      protected boolean notVetoed(AbstractReactiveEntitiesOperations<Ctx,T,Exc>.Data data)
      Check if data not vetoed.
      Parameters:
      data - The data
      Returns:
      true if data is not vetoed

    • getEntities

      public reactor.core.publisher.Flux<T> getEntities()
      Specified by:
      getEntities in class ReactiveEntitiesOperations<T,Exc extends Exception>
      Returns:
      The entities

    • getRowsUpdated

      public reactor.core.publisher.Mono<Number> getRowsUpdated()
      Returns:
      Rows updated.

    • checkOptimisticLocking

      protected void checkOptimisticLocking(long expected, long received)
      Compare the expected modifications and the received rows count. If not equals throw OptimisticLockException.
      Parameters:
      expected - The expected value
      received - THe received value

    • persist

      public void persist()
      Persist one operation.

    • delete

      public void delete()
      Delete one operation.

    • update

      public void update()
      Update one operation.

    • failed

      protected void failed(Exception e, String operation) throws DataAccessException
      Throws:
      DataAccessException

    • collectAutoPopulatedPreviousValues

      protected abstract void collectAutoPopulatedPreviousValues()
      Collect auto-populated values before pre-triggers modifies them.

    • execute

      protected abstract void execute() throws Exc
      Execute update.
      Throws:
      Exc extends Exception - The exception

    • updateEntityId

      protected T updateEntityId(io.micronaut.core.beans.BeanProperty<T,Object> identity, T entity, Object id)
      Update entity id.
      Parameters:
      identity - The identity property.
      entity - The entity instance
      id - The id instance
      Returns:
      The entity instance

    • triggerPrePersist

      protected boolean triggerPrePersist()
      Trigger the pre persist event.
      Returns:
      true if operation was vetoed

    • triggerPreUpdate

      protected boolean triggerPreUpdate()
      Trigger the pre update event.
      Returns:
      true if operation was vetoed

    • triggerPreRemove

      protected boolean triggerPreRemove()
      Trigger the pre remove event.
      Returns:
      true if operation was vetoed

    • triggerPostUpdate

      protected void triggerPostUpdate()
      Trigger the post update event.

    • triggerPostRemove

      protected void triggerPostRemove()
      Trigger the post remove event.

    • triggerPostPersist

      protected void triggerPostPersist()
      Trigger the post persist event.