仅为一组实体配置休眠实体侦听器

问题描述 投票:0回答:1

根据https://vladmihalcea.com/hibernate-event-listeners/,我想为实体组的发布后插入/更新/删除事件配置实体侦听器。我不希望应用程序中的所有实体都具有这些侦听器。因此,我为实体组创建了一个抽象类,并实现了onPostUpdate / onPostInsert方法。但是我将无法为集成器部分配置此抽象侦听器类,因为它将仅需要具体的侦听器。对解决方案有何建议?

ConfigHibernateEntity

import org.hibernate.event.spi.PostDeleteEvent;
import org.hibernate.event.spi.PostDeleteEventListener;
import org.hibernate.event.spi.PostInsertEvent;
import org.hibernate.event.spi.PostInsertEventListener;
import org.hibernate.event.spi.PostUpdateEvent;
import org.hibernate.event.spi.PostUpdateEventListener;
import org.hibernate.persister.entity.EntityPersister;


public abstract class ConfigHibernateEntity  extends HibernateEntity implements PostUpdateEventListener, PostInsertEventListener, PostDeleteEventListener{


    // public static final ConfigHibernateEntity INSTANCE =  new ConfigHibernateEntity();

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    @Override
    public void onPostUpdate(PostUpdateEvent event) {

        final Object entity = event.getEntity();

        System.out.println("On post update method");

    }

    @Override
    public void onPostInsert(PostInsertEvent event) {

        final Object entity = event.getEntity();

        System.out.println("On post insert method");

    }

    @Override
    public boolean requiresPostCommitHanding(EntityPersister persister) {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void onPostDelete(PostDeleteEvent event) {

        final Object entity = event.getEntity();

        System.out.println("On post delete method");

    }
}

EventListenerIntegrator:

import org.hibernate.boot.Metadata;
import org.hibernate.engine.spi.SessionFactoryImplementor;
import org.hibernate.event.service.spi.EventListenerRegistry;
import org.hibernate.event.spi.EventType;
import org.hibernate.integrator.spi.Integrator;
import org.hibernate.service.spi.SessionFactoryServiceRegistry;


public class EventListenerIntegrator implements Integrator {

   @Override
   public void integrate(Metadata metadata, SessionFactoryImplementor 
         sessionFactory, SessionFactoryServiceRegistry serviceRegistry) {

      EventListenerRegistry eventListenerRegistry = 
            serviceRegistry.getService(EventListenerRegistry.class);

      eventListenerRegistry.getEventListenerGroup(EventType.POST_INSERT)
                     .appendListener(new ConfigHibernateEntity());

      eventListenerRegistry.getEventListenerGroup(EventType.POST_UPDATE)
      .appendListener(new ConfigHibernateEntity());


      eventListenerRegistry.getEventListenerGroup(EventType.POST_DELETE)
      .appendListener(new ConfigHibernateEntity());


   }

   @Override
   public void disintegrate(SessionFactoryImplementor sessionFactory,
         SessionFactoryServiceRegistry serviceRegistry) {

   }
}

CustomEntity1类:

public class CustomEntity1 extends ConfigHibernateEntity  {

//

}

CustomEntity2类:

public class CustomEntity2 extends HibernateEntity  {

//

}
java hibernate hibernate-5.x
1个回答
0
投票

不是在ConfigHibernateEntity本身中实现侦听器,而是创建单独的侦听器类,并检查该实体是否为ConfigHibernateEntity的实例,

public class ConfigHibernateEntityListener implements PostUpdateEventListener,
PostInsertEventListener, PostDeleteEventListener {

private static final long serialVersionUID = -2607908089881583295L;

private final Predicate<Object> checkInstanceOfConfigHibernateEntity =
    event -> event instanceof ConfigHibernateEntity;

@Override
public void onPostUpdate(final PostUpdateEvent event) {

    final Object entity = event.getEntity();
    if (checkInstanceOfConfigHibernateEntity.test(entity)) {
        System.out.println("On post update method");
    }

}

@Override
public void onPostInsert(final PostInsertEvent event) {

    final Object entity = event.getEntity();
    if (checkInstanceOfConfigHibernateEntity.test(entity)) {
        System.out.println("On post insert method");
    }

}

@Override
public boolean requiresPostCommitHanding(final EntityPersister persister) {
    // TODO Auto-generated method stub
    return false;
}

@Override
public void onPostDelete(final PostDeleteEvent event) {

    final Object entity = event.getEntity();
    if (checkInstanceOfConfigHibernateEntity.test(entity)) {
        System.out.println("On post delete method");
    }

}

[ConfigHibernateEntity可以如下所示,

/**
 * Marker class for adding configure entity listeners for 
 * post/insert/update/delete
 */
 public class ConfigHibernateEntity {
 }
© www.soinside.com 2019 - 2024. All rights reserved.