根据hibernate拦截器实现可配置日志的记录

对于日志和事件的记录在每个项目中都会用到，如果在每个manager层中触发时间记录的话，会比较难以扩展和维护，所以可配置的日志和事件记录在项目中会用到！

首先在spring的配置文件中加入hibernate拦截器

Java代码

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="entityInterceptor">
<ref bean="myInterceptor"/>
</property>
</bean>
<bean id="myInterceptor" class="com.creawor.cbsms.util.MyInterceptor" />

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"> <property name="entityInterceptor"> <ref bean="myInterceptor"/> </property> </bean> <bean id="myInterceptor" class="com.creawor.cbsms.util.MyInterceptor" />

MyInterceptor拦截器为：

Java代码

package com.creawor.cbsms.util;
import java.io.Serializable;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.Iterator;
import javacommon.util.ApplicationContextHolder;
import org.hibernate.CallbackException;
import org.hibernate.EntityMode;
import org.hibernate.Interceptor;
import org.hibernate.Transaction;
import org.hibernate.type.Type;
import com.creawor.cbsms.event.EventRecord;
import com.creawor.cbsms.model.CbsChannel;
import com.creawor.cbsms.model.CbsMessage;
public class MyInterceptor implements Interceptor{
//删除时记录时间
public void onDelete(Object obj, Serializable arg1, Object[] arg2, String[] arg3, Type[] arg4) throws CallbackException {
// TODO Auto-generated method stub
String[] entitys = EventRecord.getDeleteEntitysFireEvent();
for (String entityName : entitys) {
if (entityName.equals(obj.getClass().getSimpleName())) {
getEventRecordMethod(entityName, obj,EventRecord.getDeleteInfo());
}
}
}
//修改时记录事件
public boolean onFlushDirty(Object obj, Serializable id, Object[] currentState, Object[] previousState , String[] propertyNames, Type[] types){
String[] entitys = EventRecord.getUpdateEntitysFireEvent();
for (String entityName : entitys) {
if (entityName.equals(obj.getClass().getSimpleName())) {
getEventRecordMethod(entityName, obj, EventRecord.getUpdateInfo());
}
}
return false;
}
public String onPrepareStatement(String arg0) {
// TODO Auto-generated method stub
return arg0;
}
//保存时记录事件
public boolean onSave(Object obj, Serializable arg1, Object[] arg2, String[] arg3, Type[] arg4) throws CallbackException {
// TODO Auto-generated method stub
String[] entitys = EventRecord.getSaveEntitysFireEvent();
for (String entityName : entitys) {
if (entityName.equals(obj.getClass().getSimpleName())) {
getEventRecordMethod(entityName, obj,EventRecord.getSaveInfo());
}
}
return false;
}
//根据反射机制执行事件记录类中相应的函数
public void getEventRecordMethod(String entityName,Object obj,String info){
try {
Class[] parameterTypes = {String.class,Class.forName(EventRecord.getPrefixPackageName()+entityName)};
Method method = EventRecord.class.getMethod(EventRecord.getPrefixMethodName()+entityName, parameterTypes);
Object[] objs = {info, Class.forName(EventRecord.getPrefixPackageName()+entityName).cast(obj)};
method.invoke((EventRecord)ApplicationContextHolder.getBean("eventRecord"),objs);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

package com.creawor.cbsms.util; import java.io.Serializable; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.util.Iterator; import javacommon.util.ApplicationContextHolder; import org.hibernate.CallbackException; import org.hibernate.EntityMode; import org.hibernate.Interceptor; import org.hibernate.Transaction; import org.hibernate.type.Type; import com.creawor.cbsms.event.EventRecord; import com.creawor.cbsms.model.CbsChannel; import com.creawor.cbsms.model.CbsMessage; public class MyInterceptor implements Interceptor{ //删除时记录时间 public void onDelete(Object obj, Serializable arg1, Object[] arg2, String[] arg3, Type[] arg4) throws CallbackException { // TODO Auto-generated method stub String[] entitys = EventRecord.getDeleteEntitysFireEvent(); for (String entityName : entitys) { if (entityName.equals(obj.getClass().getSimpleName())) { getEventRecordMethod(entityName, obj,EventRecord.getDeleteInfo()); } } } //修改时记录事件 public boolean onFlushDirty(Object obj, Serializable id, Object[] currentState, Object[] previousState , String[] propertyNames, Type[] types){ String[] entitys = EventRecord.getUpdateEntitysFireEvent(); for (String entityName : entitys) { if (entityName.equals(obj.getClass().getSimpleName())) { getEventRecordMethod(entityName, obj, EventRecord.getUpdateInfo()); } } return false; } public String onPrepareStatement(String arg0) { // TODO Auto-generated method stub return arg0; } //保存时记录事件 public boolean onSave(Object obj, Serializable arg1, Object[] arg2, String[] arg3, Type[] arg4) throws CallbackException { // TODO Auto-generated method stub String[] entitys = EventRecord.getSaveEntitysFireEvent(); for (String entityName : entitys) { if (entityName.equals(obj.getClass().getSimpleName())) { getEventRecordMethod(entityName, obj,EventRecord.getSaveInfo()); } } return false; } //根据反射机制执行事件记录类中相应的函数 public void getEventRecordMethod(String entityName,Object obj,String info){ try { Class[] parameterTypes = {String.class,Class.forName(EventRecord.getPrefixPackageName()+entityName)}; Method method = EventRecord.class.getMethod(EventRecord.getPrefixMethodName()+entityName, parameterTypes); Object[] objs = {info, Class.forName(EventRecord.getPrefixPackageName()+entityName).cast(obj)}; method.invoke((EventRecord)ApplicationContextHolder.getBean("eventRecord"),objs); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } }

事件记录类：

Java代码

package com.creawor.cbsms.event;
import java.sql.Timestamp;
import javacommon.util.ApplicationContextHolder;
import com.creawor.cbsms.dao.CbsEventDao;
import com.creawor.cbsms.model.CbsBsc;
import com.creawor.cbsms.model.CbsBscCells;
import com.creawor.cbsms.model.CbsChannel;
import com.creawor.cbsms.model.CbsEvent;
import com.creawor.cbsms.model.CbsUserRegister;
import com.creawor.cbsms.service.CbsEventManager;
import com.creawor.security.model.PermUser;
public class EventRecord {
// 保存时要记录事件的对象
private static String[] saveEntitysFireEvent = { "CbsBscCells",
"CbsChannel",
"CbsBsc" };
// 删除时要记录事件的对象
private static String[] deleteEntitysFireEvent = { "CbsBscCells",
"CbsChannel",
"CbsBsc" };
// 更新时要记录事件的对象
private static String[] updateEntitysFireEvent = { "CbsBscCells",
"CbsChannel",
"CbsBsc" };
// 包的前缀，反射得到类时使用
private static String prefixPackageName = "com.creawor.cbsms.model.";
// 记录该次操作的登录用户名：EventRecord为session范围
private String userName;
// 调用函数的前缀，反射执行函数时使用
private static String prefixMethodName = "recordFor";
// 执行save时，事件描述
private static String saveInfo = "创建";
// 执行delete时，事件描述
private static String deleteInfo = "删除";
// 执行update时，事件描述
private static String updateInfo = "修改";
private CbsEventManager cbsEventManager;
// spring自动注入
public void setCbsEventManager(CbsEventManager cbsEventManager) {
this.cbsEventManager = cbsEventManager;
}
public void recordForCbsChannel(String desc, CbsChannel channel) {
StringBuffer eventDesc = new StringBuffer(desc);
eventDesc.append("频道" + channel.getChannelName()).append("[").append(
channel.getChannelNum()).append("]");
record(eventDesc.toString(), null);
}
public void recordForCbsBscCells(String desc, CbsBscCells cell) {
StringBuffer eventDesc = new StringBuffer(desc);
eventDesc.append("小区"+cell.getCellName()).append("[").append(
cell.getCellId()).append("]");
record(eventDesc.toString(), null);
}
public void record(String eventDesc, String eventOrigin) {
CbsEvent event = new CbsEvent();
event.setEventDesc(userName + " " + eventDesc);
event.setEventOrigin(eventOrigin);
event.setStartTime(new Timestamp(System.currentTimeMillis()));
cbsEventManager.save(event);
}
public void setUserName(String userName) {
this.userName = userName;
}
public static String[] getDeleteEntitysFireEvent() {
return deleteEntitysFireEvent;
}
public static String[] getSaveEntitysFireEvent() {
return saveEntitysFireEvent;
}
public static String[] getUpdateEntitysFireEvent() {
return updateEntitysFireEvent;
}
public static String getPrefixPackageName() {
return prefixPackageName;
}
public static void setPrefixPackageName(String prefixPackageName) {
EventRecord.prefixPackageName = prefixPackageName;
}
public static String getPrefixMethodName() {
return prefixMethodName;
}
public static String getDeleteInfo() {
return deleteInfo;
}
public static String getSaveInfo() {
return saveInfo;
}
public static String getUpdateInfo() {
return updateInfo;
}
}

package com.creawor.cbsms.event; import java.sql.Timestamp; import javacommon.util.ApplicationContextHolder; import com.creawor.cbsms.dao.CbsEventDao; import com.creawor.cbsms.model.CbsBsc; import com.creawor.cbsms.model.CbsBscCells; import com.creawor.cbsms.model.CbsChannel; import com.creawor.cbsms.model.CbsEvent; import com.creawor.cbsms.model.CbsUserRegister; import com.creawor.cbsms.service.CbsEventManager; import com.creawor.security.model.PermUser; public class EventRecord { // 保存时要记录事件的对象 private static String[] saveEntitysFireEvent = { "CbsBscCells", "CbsChannel", "CbsBsc" }; // 删除时要记录事件的对象 private static String[] deleteEntitysFireEvent = { "CbsBscCells", "CbsChannel", "CbsBsc" }; // 更新时要记录事件的对象 private static String[] updateEntitysFireEvent = { "CbsBscCells", "CbsChannel", "CbsBsc" }; // 包的前缀，反射得到类时使用 private static String prefixPackageName = "com.creawor.cbsms.model."; // 记录该次操作的登录用户名：EventRecord为session范围 private String userName; // 调用函数的前缀，反射执行函数时使用 private static String prefixMethodName = "recordFor"; // 执行save时，事件描述 private static String saveInfo = "创建"; // 执行delete时，事件描述 private static String deleteInfo = "删除"; // 执行update时，事件描述 private static String updateInfo = "修改"; private CbsEventManager cbsEventManager; // spring自动注入 public void setCbsEventManager(CbsEventManager cbsEventManager) { this.cbsEventManager = cbsEventManager; } public void recordForCbsChannel(String desc, CbsChannel channel) { StringBuffer eventDesc = new StringBuffer(desc); eventDesc.append("频道" + channel.getChannelName()).append("[").append( channel.getChannelNum()).append("]"); record(eventDesc.toString(), null); } public void recordForCbsBscCells(String desc, CbsBscCells cell) { StringBuffer eventDesc = new StringBuffer(desc); eventDesc.append("小区"+cell.getCellName()).append("[").append( cell.getCellId()).append("]"); record(eventDesc.toString(), null); }  public void record(String eventDesc, String eventOrigin) {     CbsEvent event = new CbsEvent();     event.setEventDesc(userName + "   " + eventDesc);    event.setEventOrigin(eventOrigin);    event.setStartTime(new Timestamp(System.currentTimeMillis()));    cbsEventManager.save(event);  } public void setUserName(String userName) { this.userName = userName; } public static String[] getDeleteEntitysFireEvent() { return deleteEntitysFireEvent; } public static String[] getSaveEntitysFireEvent() { return saveEntitysFireEvent; } public static String[] getUpdateEntitysFireEvent() { return updateEntitysFireEvent; } public static String getPrefixPackageName() { return prefixPackageName; } public static void setPrefixPackageName(String prefixPackageName) { EventRecord.prefixPackageName = prefixPackageName; } public static String getPrefixMethodName() { return prefixMethodName; } public static String getDeleteInfo() { return deleteInfo; } public static String getSaveInfo() { return saveInfo; } public static String getUpdateInfo() { return updateInfo; } }

其中EventRecord 在spring中的配置为：

Java代码

<bean id="eventRecord" class="com.creawor.cbsms.event.EventRecord" scope="session" autowire="byName"/>

<bean id="eventRecord" class="com.creawor.cbsms.event.EventRecord" scope="session" />

EventRecord 为session范围可以使字段userName记录每次登录人员的姓名

具体在每次登录后从spring容器中得到EventRecord然后set其userName即可！

最后一步要想让session范围生效还要在web.xml中添加配置：

Java代码

<web-app>
...
<listener>
<listener-class>org.springframework.web.context.request.RequestContextListener</listener-class>
</listener>
...
</web-app>

<web-app> ... <listener> <listener-class>org.springframework.web.context.request.RequestContextListener</listener-class> </listener> ... </web-app>

这样如果想要记录一个业务bean增删改的操作只需在EventRecord中设置saveEntitysFireEvent，deleteEntitysFireEvent，updateEntitysFireEvent属性即可，同样也可使用配置文件配置，这样都可以使日志和事件的记录变得很简单！

根据hibernate拦截器实现可配置日志的记录相关推荐

Hibernate 拦截器 Hibernate 监听器
Hibernate拦截器(Interceptor)与事件监听器(Listener) 拦截器(Intercept):与Struts2的拦截器机制基本一样,都是一个操作穿过一层层拦截器,每穿过一个拦截器就 ...
Hibernate 拦截器实例
Hibernate 在操作数据库的时候要执行很多操作,这些动作对用户是透明的.这些操作主要是有拦截器和时间组成 hibernate拦截器可以拦截大多数动作,比如事务开始之后(afterTransact ...
【第六章拦截器，注解配置springMVC，springMVC执行流程】
第六章拦截器,注解配置springMVC,springMVC执行流程 1.拦截器: ①springMVC中的拦截器用于拦截控制器方法的执行. ②springMVC的拦截器需要实现HandlerInt ...
基于struts2拦截器实现用户操作日志记录
2019独角兽企业重金招聘Python工程师标准>>> 这里基于struts2的拦截器来实现. 使用struts2拦截器拦截所有或者指定的请求,对用户操作过程中的:操作用户,操作时间 ...
Hibernate 拦截器的使用--动态表名
2019独角兽企业重金招聘Python工程师标准>>> 摘要: jpa有多种实现的方式,但是最常见的还是采用Hibernate的方式实现,所以为了实现上述的业务,就必须得用到Hibe ...
使用Axios拦截器打印前端请求日志和后端后返回日志
在main.ts引入 import axios from 'axios'; axios.defaults.baseURL = process.env.VUE_APP_SERVER;/*** axios ...
java拦截器和过滤器配置，逆袭面经分享
1. CAP 的由来要理解 CAP,首先我们要清楚,为何会有人提出 CAP?他提出 CAP 是为了解决什么问题? 时间回到 1985 年,彼时,后来证明了 CAP 理论的 Lynch 教授此时给当时 ...
springboot 添加拦截器之后中文乱码_springboot中配置了拦截器后，拦截器无效的解决方案之一...
springboot的启动类xxxApplication不能扫描到拦截器配置类,可加上@ComponentScan(basePackages={"com.maya.common"} ...
Spring MVC拦截器（Interceptor）的配置及使用
在开发一个网站时可能有这样的需求:某些页面只希望几个特定的用户浏览.对于这样的访问权限控制,应该如何实现呢?拦截器就可以实现上述需求.在Struts 2 框架中,拦截器是其重要的组成部分,Spring ...

根据hibernate拦截器实现可配置日志的记录

根据hibernate拦截器实现可配置日志的记录相关推荐

最新文章

热门文章