Package org.hibernate.reactive.event.impl

Class DefaultReactivePersistEventListener

java.lang.Object
org.hibernate.reactive.event.impl.DefaultReactivePersistEventListener
All Implemented Interfaces:
org.hibernate.event.spi.PersistEventListener, org.hibernate.jpa.event.spi.CallbackRegistryConsumer, ReactivePersistEventListener
Direct Known Subclasses:
DefaultReactivePersistOnFlushEventListener
public class DefaultReactivePersistEventListener extends Object implements org.hibernate.event.spi.PersistEventListener, ReactivePersistEventListener, org.hibernate.jpa.event.spi.CallbackRegistryConsumer
A reactific DefaultPersistEventListener.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultReactivePersistEventListener()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected CompletionStage<Void>
    cascadeAfterSave(org.hibernate.event.spi.EventSource source, org.hibernate.persister.entity.EntityPersister persister, Object entity, org.hibernate.event.spi.PersistContext context)
    Handles to calls needed to perform post-save cascades.
    protected CompletionStage<Void>
    cascadeBeforeSave(org.hibernate.event.spi.EventSource source, org.hibernate.persister.entity.EntityPersister persister, Object entity, org.hibernate.event.spi.PersistContext context)
    Handles the calls needed to perform pre-save cascades for the given entity.
    protected CompletionStage<Void>
    entityIsPersistent(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createCache)
     
    protected CompletionStage<Void>
    entityIsTransient(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createCache)
    Handle the given create event.
    protected CascadingAction<org.hibernate.event.spi.PersistContext>
    getCascadeReactiveAction()
     
    protected Map<Object,Object>
    getMergeMap(org.hibernate.event.spi.PersistContext anything)
     
    void
    injectCallbackRegistry(org.hibernate.jpa.event.spi.CallbackRegistry callbackRegistry)
     
    void
    onPersist(org.hibernate.event.spi.PersistEvent event)
     
    void
    onPersist(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createdAlready)
     
    CompletionStage<Void>
    reactiveOnPersist(org.hibernate.event.spi.PersistEvent event)
    Handle the given create event.
    CompletionStage<Void>
    reactiveOnPersist(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createCache)
    Handle the given create event.
    protected CompletionStage<Void>
    reactivePerformSave(Object entity, Object id, org.hibernate.persister.entity.EntityPersister persister, boolean useIdentityColumn, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source, boolean requiresImmediateIdAccess)
    Prepares the save call by checking the session caches for a pre-existing entity and performing any lifecycle callbacks.
    protected CompletionStage<Void>
    reactivePerformSaveOrReplicate(Object entity, org.hibernate.engine.spi.EntityKey key, org.hibernate.persister.entity.EntityPersister persister, boolean useIdentityColumn, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source, boolean requiresImmediateIdAccess)
    Performs all the actual work needed to save an entity (well to get the save moved to the execution queue).
    protected CompletionStage<Void>
    reactiveSaveWithGeneratedId(Object entity, String entityName, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source, boolean requiresImmediateIdAccess)
    Prepares the save call using a newly generated id.
    protected CompletionStage<Void>
    reactiveSaveWithRequestedId(Object entity, Object requestedId, String entityName, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source)
    Prepares the save call using the given requested id.
    protected boolean
    substituteValuesIfNecessary(Object entity, Object id, Object[] values, org.hibernate.persister.entity.EntityPersister persister, org.hibernate.engine.spi.SessionImplementor source)
    Perform any property value substitution that is necessary (interceptor callback, version initialization...)
    protected boolean
    visitCollectionsBeforeSave(Object entity, Object id, Object[] values, org.hibernate.type.Type[] types, org.hibernate.event.spi.EventSource source)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.hibernate.jpa.event.spi.CallbackRegistryConsumer

    injectCallbackRegistry

  • Constructor Details

    • DefaultReactivePersistEventListener

      public DefaultReactivePersistEventListener()

  • Method Details

    • getCascadeReactiveAction

      protected CascadingAction<org.hibernate.event.spi.PersistContext> getCascadeReactiveAction()

    • onPersist

      public void onPersist(org.hibernate.event.spi.PersistEvent event) throws org.hibernate.HibernateException
      Specified by:
      onPersist in interface org.hibernate.event.spi.PersistEventListener
      Throws:
      org.hibernate.HibernateException

    • reactiveOnPersist

      public CompletionStage<Void> reactiveOnPersist(org.hibernate.event.spi.PersistEvent event)
      Handle the given create event.
      Specified by:
      reactiveOnPersist in interface ReactivePersistEventListener
      Parameters:
      event - The create event to be handled.

    • onPersist

      public void onPersist(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createdAlready) throws org.hibernate.HibernateException
      Specified by:
      onPersist in interface org.hibernate.event.spi.PersistEventListener
      Throws:
      org.hibernate.HibernateException

    • reactiveOnPersist

      public CompletionStage<Void> reactiveOnPersist(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createCache)
      Handle the given create event.
      Specified by:
      reactiveOnPersist in interface ReactivePersistEventListener
      Parameters:
      event - The create event to be handled.

    • entityIsPersistent

      protected CompletionStage<Void> entityIsPersistent(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createCache)

    • entityIsTransient

      protected CompletionStage<Void> entityIsTransient(org.hibernate.event.spi.PersistEvent event, org.hibernate.event.spi.PersistContext createCache)
      Handle the given create event.
      Parameters:
      event - The save event to be handled.
      createCache - The copy cache of entity instance to merge/copy instance.

    • injectCallbackRegistry

      public void injectCallbackRegistry(org.hibernate.jpa.event.spi.CallbackRegistry callbackRegistry)
      Specified by:
      injectCallbackRegistry in interface org.hibernate.jpa.event.spi.CallbackRegistryConsumer

    • reactiveSaveWithRequestedId

      protected CompletionStage<Void> reactiveSaveWithRequestedId(Object entity, Object requestedId, String entityName, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source)
      Prepares the save call using the given requested id.
      Parameters:
      entity - The entity to be saved.
      requestedId - The id to which to associate the entity.
      entityName - The name of the entity being saved.
      context - Generally cascade-specific information.
      source - The session which is the source of this save event.
      Returns:
      The id used to save the entity.

    • reactiveSaveWithGeneratedId

      protected CompletionStage<Void> reactiveSaveWithGeneratedId(Object entity, String entityName, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source, boolean requiresImmediateIdAccess)
      Prepares the save call using a newly generated id.
      Parameters:
      entity - The entity to be saved
      entityName - The entity-name for the entity to be saved
      context - Generally cascade-specific information.
      source - The session which is the source of this save event.
      requiresImmediateIdAccess - does the event context require access to the identifier immediately after execution of this method (if not, post-insert style id generators may be postponed if we are outside a transaction).
      Returns:
      The id used to save the entity; may be null depending on the type of id generator used and the requiresImmediateIdAccess value

    • reactivePerformSave

      protected CompletionStage<Void> reactivePerformSave(Object entity, Object id, org.hibernate.persister.entity.EntityPersister persister, boolean useIdentityColumn, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source, boolean requiresImmediateIdAccess)
      Prepares the save call by checking the session caches for a pre-existing entity and performing any lifecycle callbacks.
      Parameters:
      entity - The entity to be saved.
      id - The id by which to save the entity.
      persister - The entity's persister instance.
      useIdentityColumn - Is an identity column being used?
      context - Generally cascade-specific information.
      source - The session from which the event originated.
      requiresImmediateIdAccess - does the event context require access to the identifier immediately after execution of this method (if not, post-insert style id generators may be postponed if we are outside a transaction).
      Returns:
      The id used to save the entity; may be null depending on the type of id generator used and the requiresImmediateIdAccess value

    • reactivePerformSaveOrReplicate

      protected CompletionStage<Void> reactivePerformSaveOrReplicate(Object entity, org.hibernate.engine.spi.EntityKey key, org.hibernate.persister.entity.EntityPersister persister, boolean useIdentityColumn, org.hibernate.event.spi.PersistContext context, org.hibernate.event.spi.EventSource source, boolean requiresImmediateIdAccess)
      Performs all the actual work needed to save an entity (well to get the save moved to the execution queue).
      Parameters:
      entity - The entity to be saved
      key - The id to be used for saving the entity (or null, in the case of identity columns)
      persister - The entity's persister instance.
      useIdentityColumn - Should an identity column be used for id generation?
      context - Generally cascade-specific information.
      source - The session which is the source of the current event.
      requiresImmediateIdAccess - Is access to the identifier required immediately after the completion of the save? persist(), for example, does not require this...
      Returns:
      The id used to save the entity; may be null depending on the type of id generator used and the requiresImmediateIdAccess value

    • getMergeMap

      protected Map<Object,Object> getMergeMap(org.hibernate.event.spi.PersistContext anything)

    • cascadeBeforeSave

      protected CompletionStage<Void> cascadeBeforeSave(org.hibernate.event.spi.EventSource source, org.hibernate.persister.entity.EntityPersister persister, Object entity, org.hibernate.event.spi.PersistContext context)
      Handles the calls needed to perform pre-save cascades for the given entity.
      Parameters:
      source - The session from which the save event originated.
      persister - The entity's persister instance.
      entity - The entity to be saved.
      context - Generally cascade-specific data

    • cascadeAfterSave

      protected CompletionStage<Void> cascadeAfterSave(org.hibernate.event.spi.EventSource source, org.hibernate.persister.entity.EntityPersister persister, Object entity, org.hibernate.event.spi.PersistContext context)
      Handles to calls needed to perform post-save cascades.
      Parameters:
      source - The session from which the event originated.
      persister - The entity's persister instance.
      entity - The entity beng saved.
      context - Generally cascade-specific data

    • substituteValuesIfNecessary

      protected boolean substituteValuesIfNecessary(Object entity, Object id, Object[] values, org.hibernate.persister.entity.EntityPersister persister, org.hibernate.engine.spi.SessionImplementor source)
      Perform any property value substitution that is necessary (interceptor callback, version initialization...)
      Parameters:
      entity - The entity
      id - The entity identifier
      values - The snapshot entity state
      persister - The entity persister
      source - The originating session
      Returns:
      True if the snapshot state changed such that reinjection of the values into the entity is required.

    • visitCollectionsBeforeSave

      protected boolean visitCollectionsBeforeSave(Object entity, Object id, Object[] values, org.hibernate.type.Type[] types, org.hibernate.event.spi.EventSource source)