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

Class ReactiveEntitiesOperations<T,Exc extends Exception>

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

  • Field Details

    • entityEventListener

      protected final EntityEventListener<Object> entityEventListener

    • persistentEntity

      protected final RuntimePersistentEntity<T> persistentEntity

    • conversionService

      protected final io.micronaut.core.convert.ConversionService conversionService

  • Constructor Details

  • Method Details

    • getEntities

      public abstract reactor.core.publisher.Flux<T> getEntities()
      Returns:
      The entities

    • 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

    • cascadePre

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

    • cascadePost

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

    • 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

    • veto

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

    • 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.

    • triggerPre

      protected abstract 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 abstract void triggerPost(Consumer<EntityEventContext<Object>> fn)
      Trigger post-actions on EntityEventContext.
      Parameters:
      fn - The entity context function