spring和hibernate整合后手动管理事务工具类

忘是亡心i 2022-07-15 15:59 151阅读 0赞

import org.apache.log4j.Logger;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
 import org.hibernate.Transaction;
 import org.springframework.orm.hibernate3.SessionFactoryUtils;
 import org.springframework.orm.hibernate3.SessionHolder;
 import org.springframework.transaction.support.TransactionSynchronizationManager;
 
 
 import com.isoftstone.fwk.dao.DaoFactory;
 import com.isoftstone.fwk.util.SpringUtils;
 
 
 public class DaoFactoryMod {
 	public static Logger logger = Logger.getLogger(DaoFactoryMod.class);
 	
 	
 	
 	//**************************************************************************
 	/**
 	 * 提交当前事务 
 	 * 重写DaoFactory的同名方法，其方法在提交事务后结束了session
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void commitTransaction(SessionFactory sessionfactory, boolean flag)
 throws Exception
 	{
 	 Transaction transaction;
 	 Session session;
 	 transaction = null;
 	 session = null;
 	 try
 	 {
 	 SessionHolder sessionholder = (SessionHolder)TransactionSynchronizationManager.getResource(sessionfactory);
 	 logger.debug("◆◆◆提交事务时sessionholder:"+sessionholder);
 	 logger.debug("\u4E8B\u52A1\u63D0\u4EA4\u5F00\u59CB============");
 	 if(sessionholder != null)
 	 {
 	 session = sessionholder.getSession();
 	 logger.debug("◆◆◆提交事务时session:"+session);
 	 transaction = session.getTransaction();
 	 if(transaction != null && transaction.isActive())
 	 {
 	 transaction.commit();
 	 logger.debug("◆◆◆提交事务时transaction:"+transaction);
 	 transaction = null;
 	 }
 	 }
 	 logger.debug("\u4E8B\u52A1\u63D0\u4EA4\u7ED3\u675F============");
 	 }
 	 catch(Exception exception)
 	 {
 	 if(flag)
 	 {
 	 session.clear();//回滚事务前一定要先清空session，否则rollback无效
 	 logger.debug("◆◆◆回滚事务前清空session:"+session);
 	 transaction.rollback();
 	 logger.debug("◆◆◆提交事务时回滚transaction:"+transaction);
 	 }
 	 exception.printStackTrace();
 	 throw exception;
 	 }
 	 return;
 	}
 
 
 		
 	//**************************************************************************
 	/**
 	 * 回滚当前事务 
 	 * 重写DaoFactory的同名方法，其方法在回滚事务后结束了session
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void rollbackTransaction(SessionFactory sessionfactory)
 	 throws Exception
 	{
 	 Session session;
 	 Object obj = null;
 	 session = null;
 	 try
 	 {
 	 SessionHolder sessionholder = (SessionHolder)TransactionSynchronizationManager.getResource(sessionfactory);
 	 logger.debug("◆◆◆回滚事务时sessionholder:"+sessionholder);
 	 if(sessionholder != null)
 	 {
 	 session = sessionholder.getSession();
 	 logger.debug("◆◆◆回滚事务时session:"+session);
 	 Transaction transaction = session.getTransaction();
 	 session.clear();//回滚事务前一定要先清空session，否则rollback无效
 	 logger.debug("◆◆◆回滚事务前清空session:"+session);
 	 transaction.rollback();
 	 logger.debug("◆◆◆回滚事务时回滚transaction:"+transaction);
 	 }
 	 }
 	 catch(Exception exception)
 	 {
 	 exception.printStackTrace();
 	 throw exception;
 	 }
 	 return;
 	}
 	
 	
 	
 	
 	//**************************************************************************
 	/**
 	 * 获取或创建hibernate session绑定到当前线程 
 	 * 为后台定时任务线程创建session
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void bindSession(){
 		logger.debug("\n\n");
 		logger.debug("〓〓〓〓〓〓〓〓〓〓〓 开始获得或者创建hibernate session绑定到当前线程！ 〓〓〓〓〓〓〓〓〓〓〓");
 		logger.debug("-----------------------------------------------------------------");
 		SessionFactory sf = (SessionFactory) SpringUtils.getSpringBean("sessionFactory");//从spring中获取sessionFactory
 		logger.debug("◆◆◆绑定session时sessionfactory:"+sf);
 		Session session = SessionFactoryUtils.getSession(sf, true);
 		logger.debug("◆◆◆绑定session时session:"+session);
 		//session.beginTransaction();
 		SessionHolder sessionholder = new SessionHolder(session);
 		logger.debug("◆◆◆绑定session时sessionholder:"+sessionholder);
 		TransactionSynchronizationManager.bindResource(sf,sessionholder);
 		logger.debug("▲▲▲▲▲▲▲▲▲▲ 获得或者创建hibernate session绑定到当前线程成功！ ▲▲▲▲▲▲▲▲▲▲");
 	}
 	
 	//**************************************************************************
 	/**
 	 * 开始绑定到当前线程的session的事务 
 	 * 为后台定时任务线程开启事务
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void beginTransaction(){
 		SessionFactory sf = (SessionFactory) SpringUtils.getSpringBean("sessionFactory");
 		logger.debug("◆◆◆开始事务时sessionfactory:"+sf);
 		Session session = SessionFactoryUtils.getSession(sf, true);
 		logger.debug("◆◆◆开始事务时session:"+session);
 		Transaction transaction=session.beginTransaction();
 		logger.debug("◆◆◆开始事务时transaction:"+transaction);
 		logger.debug("▲▲▲▲▲▲▲▲▲▲ 开始绑定到当前线程的session的事务！ ▲▲▲▲▲▲▲▲▲▲");
 	}
 	
 	
 	//**************************************************************************
 	/**
 	 * 提交绑定到当前线程的session的事务，提交失败后会自动回滚 
 	 * 为后台定时任务线程提交事务
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void commitTransaction(){
 		SessionFactory sf = (SessionFactory) SpringUtils.getSpringBean("sessionFactory");
 		logger.debug("◆◆◆提交事务时sessionfactory:"+sf);
 		try {
 			DaoFactoryMod.commitTransaction(sf,true);
 			//DaoFactory.commitTransaction(sf);
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 		logger.debug("▲▲▲▲▲▲▲▲▲▲ 提交绑定到当前线程的session的事务！ ▲▲▲▲▲▲▲▲▲▲");
 	}
 	
 	//**************************************************************************
 	/**
 	 * 回滚绑定到当前线程的session的事务 
 	 * 为后台定时任务线程回滚事务
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void rollbackTransaction(){
 		SessionFactory sf = (SessionFactory) SpringUtils.getSpringBean("sessionFactory");
 		logger.debug("◆◆◆回滚事务时sessionfactory:"+sf);
 		try {
 			DaoFactoryMod.rollbackTransaction(sf);
 			//DaoFactory.rollbackTransaction(sf);
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
 		logger.debug("▲▲▲▲▲▲▲▲▲▲ 回滚绑定到当前线程的session的事务！ ▲▲▲▲▲▲▲▲▲▲");
 	}
 	
 	
 	//**************************************************************************
 	/**
 	 * 解除当前线程的session绑定并关闭session 
 	 * 为后台定时任务线程关闭session
 	 * @param 参数 说明
 	 * @return void 返回值 说明
 	 * @throws 异常 说明
 	 */
 	//**************************************************************************
 	public static void unbindSession(){
 		SessionFactory sf = (SessionFactory) SpringUtils.getSpringBean("sessionFactory");
 		logger.debug("◆◆◆解除绑定session时sessionfactory:"+sf);
 		try {
 				Session session = SessionFactoryUtils.getSession(sf, true);
 				logger.debug("◆◆◆解除绑定session时session:"+session);
 				DaoFactory.unbindTransaction(sf);
 				session.close();
 				logger.debug("◆◆◆解除绑定session时关闭session:"+session);
 			} catch (Exception e) {
 				e.printStackTrace();
 			}
 			logger.debug("---------------------------------------------");
 			logger.debug("〓〓〓〓〓〓〓〓〓〓〓 解除当前线程的session绑定！ 〓〓〓〓〓〓〓〓〓〓〓");
 			logger.debug("=============================================");
 			logger.debug("\n\n");
 		}
 	
 	
 	}