拦截器(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()
当完成一个事务之后,立刻调用此方法
使用拦截器实现审计日志
审计日志指的是,在应用系统中,对所有的数据库的操作都做记录,记录所操作内容,操作的用户和操作的时间
log4j.properties
log4j.logger.com.rbh.examples=info,appender1 log4j.appender.appender1=org.apache.log4j.FileAppender log4j.appender.appender1.layout=org.apache.log4j.TTCCLayout log4j.appender.appender1.File=ligfile.txt
LogEntityInterceptor
package com.rbh.examples; import java.io.Serializable; import org.apache.log4j.Logger; import org.hibernate.EmptyInterceptor; import org.hibernate.type.Type; public class LogEntityInterceptor extends EmptyInterceptor { private static final long serialVersionUID = 1L; private Logger logger = Logger.getLogger(LogEntityInterceptor.class); public void onDelete(Object entity,Serializable id, Object[] state,String[] propertyNames, Type[] types){ logger.info("删除数据"); } public boolean onFlushDirty(Object entity,Serializable id, Object[] currentState, Object[] preState,String[] propertyNames, Type[] types){ logger.info("修改数据"); return false; } public boolean onSave(Object entity,Serializable id, Object[] State, String[] propertyNames, Type[] types){ logger.info("保存数据"); return false; } }
HibernateTest
package com.rbh.examples; import java.util.Date; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.cfg.Configuration; public class HibernateTest { public static void main(String[] args) { HibernateTest test =new HibernateTest(); test.testInterceptor(); } public void testInterceptor() { LogEntityInterceptor interceptor=new LogEntityInterceptor(); Configuration config=new Configuration(); config.setInterceptor(interceptor); config.configure(); SessionFactory sf=config.buildSessionFactory(); Session session=sf.getCurrentSession(); Guestbook gb= new Guestbook(); gb.setName("Narcissus"); gb.setEmail("javac.q@gmail.com"); gb.setCreatedTime(new Date()); gb.setPhone("11102121"); gb.setTitle("test Interceptor"); gb.setContent("test Interceptor,test Interceptor"); session.beginTransaction(); session.save(gb); session.getTransaction().commit(); session=sf.getCurrentSession(); gb.setName("tom"); session.beginTransaction(); session.update(gb); session.getTransaction().commit(); session=sf.getCurrentSession(); session.beginTransaction(); session.delete(gb); session.getTransaction().commit(); } }
可以通过session方式加载拦截器对象,也可以通过Configuration对象加载拦截器
Configuration:对所有的session都会被拦截
session:只对当前的session进行拦截
原文链接:http://fehly.iteye.com/blog/646383
发表评论(对文章涉及的知识点还有疑问,可以在这里留言,老高看到后会及时回复的。)