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

Class AbstractSyncEntityOperations<Ctx extends OperationContext,​T,​Exc extends java.lang.Exception>

  • Type Parameters:
    Ctx - The operation context
    T - The entity type
    Exc - The exception
    @Internal
public abstract class AbstractSyncEntityOperations<Ctx extends OperationContext,​T,​Exc extends java.lang.Exception>
extends SyncEntityOperations<T,​Exc>
    Abstract synchronous entity operations.
    Since:
    3.3
    Author:
    Denis Stepanov

    • Field Detail

      • insert

        protected final boolean insert

      • hasGeneratedId

        protected final boolean hasGeneratedId

      • entity

        protected T entity

      • entityEventListener

        protected final EntityEventListener<java.lang.Object> entityEventListener

      • conversionService

        protected final io.micronaut.core.convert.ConversionService<?> conversionService

    • Constructor Detail

      • AbstractSyncEntityOperations

        protected AbstractSyncEntityOperations​(Ctx ctx,
                                       SyncCascadeOperations<Ctx> cascadeOperations,
                                       EntityEventListener<java.lang.Object> entityEventListener,
                                       RuntimePersistentEntity<T> persistentEntity,
                                       io.micronaut.core.convert.ConversionService<?> conversionService,
                                       T entity,
                                       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
        entity - The entity
        insert - The insert

    • Method Detail

      • 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

      • collectAutoPopulatedPreviousValues

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

      • triggerPre

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

      • triggerPost

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

      • veto

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

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

      • execute

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

      • updateEntityId

        protected T updateEntityId​(io.micronaut.core.beans.BeanProperty<T,​java.lang.Object> identity,
                           T entity,
                           java.lang.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.