`

Hibernate拦截器与事件监听

阅读更多

拦截器(Interceptor)
org.hibernate.Interceptor接口定义了Hibernate中通用拦截机制
创建Session对象的时候,所有的Session对象或者这个Session对象的所有持久化操作的动作都会被指定的拦截器进行拦截.


Interceptor接口的方法

  • afterTransactionBegin()
    当一个事务时候启动时,会立刻调用这个方法,这个方法可以改变这个事务的状态,例如:回滚事务
  • instantiate()
    创建对象,如果返回null,则Hibernate将调用实体类的默认构造方法创建持久化对象
  • getEntity()
    当一个持久化对象,通过标示符属性在Session对象的缓存中进行查找,并且没有找到时,会调用该方法
  • getEntityName()
    当session对象获取持久化对象的名字时,会调用这个方法
  • onLoad()
    该方法在持久化对象初始化之前加载,这个的持久化对象处于刚被创建的状态(对象的属性值都未赋值)
  • findDirty()
    当调用Session对象的flush()方法时,讲调用该方法判断对象是否为脏数据,这是脏数据检查的另外拦截的实现方式
  • isTransient()
    当调用Session对象的saveOrUpdate方法时,会调用该方法判断对象是否尚未保存
  • onSave()
    在对象被保存之前调用,通过这个方法可以对要保持的对象的属性进行修改
  • onDelete()
    该方法在持久化对象被删除之前调用
  • preFlush()
    该方法当调用Session对象的flush()方法之前被调用
  • onFlushDirty()
    当调用Session对象flush()方法进行脏数据检查时,如果发现持久化对象的状态发生了改变,会调用该方法
  • postFlush()
    该方法调用Session对象的flush()方法之后被调用
  • beforeTransactionCompletion()
    在完成一个事务之前,调用此方法,这个方法可以改变事务的状态,例如回滚事务
  • afterTransactionCompletion()
    当完成一个事务之后,立刻调用此方法

1、使用拦截器实现操作日志
在应用系统中,对所有的数据库的操作都做记录,记录所操作内容,操作的用户和操作的时间

 

import org.hibernate.CallbackException;
import org.hibernate.EmptyInterceptor;
import org.hibernate.type.Type;

import java.io.Serializable;
import java.util.Date;


public class DaoLogInterceptor extends EmptyInterceptor {

	private static final long serialVersionUID = 1L;

	@Override
    public void onDelete(Object entity, Serializable id, Object[] state, String[] propertyNames, Type[] types) {
        super.onDelete(entity, id, state, propertyNames, types);
    }

    @Override
    public boolean onSave(Object entity, Serializable id, Object[] state, String[] propertyNames, Type[] types) {
        return super.onSave(entity, id, state, propertyNames, types);
    }

    @Override
    public void onCollectionUpdate(Object collection, Serializable key) throws CallbackException {
        super.onCollectionUpdate(collection, key);
    }

    @Override
    public void onCollectionRemove(Object collection, Serializable key) throws CallbackException {
        super.onCollectionRemove(collection, key);
    }

    @Override
    public boolean onLoad(Object entity, Serializable id, Object[] state, String[] propertyNames, Type[] types) {
        return super.onLoad(entity, id, state, propertyNames, types);
    }

    @Override
    public boolean onFlushDirty(Object entity, Serializable id, Object[] currentState, Object[] previousState, String[] propertyNames, Type[] types) {
    	System.out.println("operateTm:"+entity.getClass().getName()+"--OperateTm:"+new Date()+"--操作用户:当前登录用户");
    	getOperateDetails(previousState, currentState, propertyNames);
        return super.onFlushDirty(entity, id, currentState, previousState, propertyNames, types);
    }


    /**
     * 操作前后的数据差异
     *
     * @param oldState
     * @param state
     * @param operateLog
     * @return
     */
    private void getOperateDetails(Object[] oldState, Object[] state, String[] propertyNames) {
        for (int i = 0; i < propertyNames.length; i++) {
            if (!equalsObject(oldState[i], state[i])) {
                System.out.println("Field:"+propertyNames[i]+"NewValue:"+state[i] +"OldValue:"+oldState[i]);
            }
        }
    }

    private boolean equalsObject(Object o1, Object o2) {
        if (o1 == null && o2 != null) {
            return false;
        }
        if (o2 == null && o1 != null) {
            return false;
        }
        if (o1 == null && o2 == null) {
            return true;
        }
        return o1.equals(o2);
    }
}

 

 

 

<!--hibernate配置-->

    <bean id="myInterceptor" class="com.sf.sfbuy2.context.filter.DaoLogInterceptor"/>
    <bean id="postUpdateListener" class="com.sf.sfbuy2.context.filter.PostUpdateListener"></bean>
    <bean id="sessionFactory"
          class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">

        <property name="dataSource">
            <ref bean="dataSource"/>
        </property>
        <property name="entityInterceptor">
            <ref bean="myInterceptor" />
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.Oracle10gDialect</prop>
                <prop key="hibernate.show_sql">true</prop>
                <prop key="hibernate.format_sql">true</prop>
                <prop key="use_sql_comments">true</prop>
                <prop key="javax.persistence.validation.mode">none</prop>
                <prop key="hibernate.validator.apply_to_ddl">false</prop>
                <prop key="hibernate.validator.autoregister_listeners">false</prop>

            </props>
        </property>
        <property name="packagesToScan">
            <list>
                <value>com.sf.sfbuy2.db.entity</value>
            </list>
        </property>
    </bean>

2、Hibernate的事件监听机制

 

Hibernate中的事件监听机制可以对Session对象的动作进行监听,一旦发生了特殊的事件,Hibernate就会执行监听器中的事件处理方法

在某些功能的设计中,我们即可以使用Hibernate的拦截器实现,也可以使用Hibernate的事件监听来实现

 

Hibernate中事件与对应的监听器接口

                 事件类型                                                       监听器接口

                     auto-flush                                                    AutoFlushEventListener
                        merge                                                       MergeEventListener
                        delete                                                       DeleteEventListener
                        persist                                                      PersistEventListener
                    dirty-check                                                    DirtyCheckEventListener
                         evice                                                        EvictEventListener
                          flush                                                        FlushEventListener
                    flush-entity                                                    FlushEntityEventListener
                          load                                                         LoadEventListener
                 load-collection                                                  InitializeCollectEventListener
                          lock                                                          LockEventListener
                      refresh                                                         RefreshEventListener
                      replicate                                                      ReplicateEventListener
                     save-update                                                 SaveOrUpdateEventListener
                     pre-load                                                        PreLoadEventListener
                     pre-update                                                    PreUpdateEventListener
                     pre-delete                                                     PreDeleteEventListener
                     pre-insert                                                      PreInsertEventListener
                     post-load                                                       PostLoadEventListener
                     post-update                                                   PostUpdateEventListener
                     post-delete                                                    PostDeleteEventListener
                     post-insert                                                     PostInsertEventListener

 


应用Hibernate事件监听器

用户制定的事件监听器首先需要实现与所需要处理的事件对应的接口,或者继承实现这个接口的类

通过使用Hibernate的配置文件(hibernate.cfg.xml)配置事件监听对象,或者使用Configuration对象注册这个定制的事件监听器对象

LogPostLoadEventListener

 

import org.hibernate.event.PostLoadEvent;
import org.hibernate.event.PostLoadEventListener;
public class LogPostLoadEventListener implements PostLoadEventListener {
	private static final long serialVersionUID = 404241098418965422L;
	public void onPostLoad(PostLoadEvent event) {
		System.out.println("Class:" + event.getEntity().getClass().getName() + ",id:"
				+ event.getId());
	}
}

修改Hibernate.cfg.xml文件

<mapping resource="com/rbh/examples/Guestbook.hbm.xml" />
		<listener type="post-load" class="com.rbh.examples.LogPostLoadEventListener" />
	</session-factory>
</hibernate-configuration>

 或者通过Configuration 对象注册这个监听器对象

Configuration config = new Configuration();
config.setListener("post-load", new LogPostLoadEventListener());
config.configure();
Session session = config.buildSessionFactory().getCurrentSession();

 

编写、配置好监听器以后,当通过Session对象的load()、get()方法或者Query对象的list方法加载持久化对象之后,LogPostEventListener对象中的onPostLoad()方法就会被执行.

 

使用监听器实现记录操作日志

利用Hibernate的事件机制,不仅能够精确追踪到持久化对象的字段的修改,持久化对象关联关系的变更,还能记录更新前的数值和更新后的数值

 

监听器与拦截器的比较

监听器可以实现更细化粒度的拦截
通过监听器获取所拦截的持久化对象的修改后喝修改前的状态值
能直接通过Event对象获取Session对象

 

 

 

 

 

 

 

分享到:
评论

相关推荐

    拦截器和控制器的区别

    拦截器和过滤器的区别 1、拦截器基于动态代理 , 过滤器基于函数回调 2、拦截器不依赖于servlet容器,通过动态代理实现,过滤器依赖于servlet容器 3、拦截器在方法前后,异常前后等调用,而过滤器只能在请求前和请求...

    浅析JAVA中过滤器、监听器、拦截器的区别

    与过滤器和监听器不同,拦截器更多地用于框架层面上,如Spring、Hibernate、Struts2等。拦截器的作用是拦截框架中的方法调用或Web请求,并在方法或请求执行前后执行特定的代码逻辑。拦截器可以在配置文件中声明,也...

    hibernate事件 刷新事件.zip

    - **示例代码**:展示如何注册监听器以监听刷新事件,可能包括了自定义的Hibernate事件监听器类,以及如何在配置文件中启用这些监听器。 - **事件处理逻辑**:可能包含在监听器中如何编写代码来响应刷新事件,比如在...

    学习常用知识(java,sql,oracle,ejb,ssh,struts,xml,监听器,拦截器,过滤器)

    在IT领域,掌握Java、SQL、Oracle、EJB、SSH、Struts、XML以及监听器、拦截器和过滤器等技术是至关重要的。这些技术涵盖了Web应用开发的多个层面,对于初学者而言,理解并熟练运用它们能为职业生涯打下坚实的基础。 ...

    ssh最新框架搭建,加入拦截器

    在这个"ssh最新框架搭建,加入拦截器"的主题中,我们将深入探讨SSH框架的搭建过程以及如何添加拦截器来增强功能。 首先,让我们从Spring框架开始。Spring是核心,它提供依赖注入(DI)和面向切面编程(AOP)的功能,...

    hibernate源码分析

    **三、拦截器(Interceptor)与事件监听器(Listener)** Hibernate提供拦截器和事件监听器来扩展其行为。Interceptor是在特定操作(如保存、更新、删除等)执行前后被调用的接口,允许用户自定义行为。Listener则是...

    hibernate 2 升级参考文档

    在进行以上步骤的同时,还需要注意检查任何自定义的Hibernate拦截器、事件监听器或者其他扩展是否兼容Hibernate 3。另外,确保所有使用的API和方法在新版本中仍然可用,因为某些API在不同版本之间可能会被废弃或修改...

    hibernate框架配置源码

    Hibernate提供了一套事件监听系统,可以通过实现特定接口或使用拦截器来监听和干预对象的生命周期事件,如保存、更新、删除等。 通过学习和分析`hibernateDay3`中的源码,你可以更深入地理解这些概念,并且能够...

    Hibernate参考文档(CHM).

    6. **拦截器与事件监听**:通过实现特定接口,可以自定义拦截器或事件监听器,实现对对象生命周期的干预,例如在保存、更新、加载前后执行特定逻辑。 7. **性能优化**:提供了关于批处理、延迟加载、缓存策略、连接...

    Middlegen-Hibernate-r5,hibernate-extensions-2.1.3

    这些扩展可能包括对CGLIB或JPA的支持,也可能包含了一些自定义的拦截器、事件监听器或者更高级的查询构建工具。Hibernate Extensions使开发者能够更好地定制和扩展他们的Hibernate应用,以满足项目特定的需求。 在...

    Hibernate\hibernate3.2官方中文参考手册PDF

    8. **事件监听器和拦截器**:Hibernate允许用户自定义事件监听器或拦截器,以便在特定的生命周期事件(如对象的保存、更新、删除等)发生时执行自定义逻辑。 9. **实体生命周期**:Hibernate定义了几个关键的实体...

    Hibernate 中文参考文档

    事件监听与拦截器 Hibernate允许开发者注册事件监听器或拦截器,以在特定操作前后执行自定义逻辑,如对象的保存、更新和删除。 ### 10. 批量操作与性能优化 为了提高性能,Hibernate提供了批量插入、更新和删除...

    Hibernate实战

    高级特性部分可能包含懒加载、缓存机制、二级缓存、性能优化、事件监听器、拦截器等。懒加载是Hibernate优化性能的一种策略,它延迟加载关联的对象,直到真正需要时才执行数据库查询。缓存机制可以提高数据访问速度...

    Hibernate 中文api 等学习资料

    9. **拦截器和事件监听器**:学习如何自定义行为,比如在对象保存或删除前进行额外操作。 10. **JPA集成**:如果需要,可以了解Hibernate作为Java Persistence API(JPA)提供商的角色。 通过阅读和学习这些资料,...

    孙卫琴精通hibernate part2

    8. **Chapter 12:事件监听与拦截器** - Hibernate允许开发者定义事件监听器和拦截器,以在特定的生命周期阶段执行自定义逻辑。本章将探讨如何实现这些机制,提升业务逻辑的可扩展性。 通过以上章节的学习,读者将...

    hibernate框架基本包

    - **Hibernate拦截器**: 类似于监听器,但更灵活,可以直接修改对象的状态。 总结来说,“hibernate框架基本包”包含的资源旨在帮助开发者理解Hibernate的核心概念、操作和配置,以及如何在实际项目中有效利用它。...

    hibernate5.3.7中文帮助文档 中文PDF版 1.67MB

    9. **事件监听和拦截器**:Hibernate允许用户自定义事件监听器和拦截器,对特定操作如保存、更新、删除等进行扩展和定制。 10. **性能优化**:通过批处理、缓存策略、连接池管理等方式,可以优化Hibernate的性能。...

    hibernate3.zip 包含hibernate3.jar

    11. **事件监听器**:Hibernate允许注册事件监听器,对持久化对象的各种操作(如保存、更新、删除等)进行拦截和自定义处理。 以上就是`hibernate3.jar`中所包含的关键知识点。理解并熟练使用这些概念,可以帮助...

    精通Hibernate源码.rar

    7. **事件监听器与拦截器** Hibernate允许开发者注册事件监听器,如`PreLoadEventListener`、`PostInsertEventListener`等,以在特定操作前后执行自定义逻辑。拦截器(Interceptor)则提供了更灵活的扩展点,可以在...

    hibernate4.3.11

    9. **事件监听器和拦截器**: Hibernate允许开发者定义事件监听器和拦截器,对实体的生命周期事件进行监听和处理,如保存、更新、删除等操作前后的回调。 10. **性能优化**: Hibernate提供了多种性能优化策略,如...

Global site tag (gtag.js) - Google Analytics