posts - 60,comments - 71,trackbacks - 0


          
	

          


          
	
					


          
	
	
          
        session是hibernate運做的核心，是有SessionFactory所創建，sessionFactory是線程安全的，你可以讓多個線程同時存取SessionFactory,而不會有資源共用的問題，然而session不是設計為線程安全的，所以讓多個線程共用一個session，將發生資料共用而發生混亂的問題．下面是一個標準類．
          

          import java.io.Serializable;
          
          import net.sf.hibernate.HibernateException;
          
          import net.sf.hibernate.Session;
          
          import net.sf.hibernate.SessionFactory;
          
          import net.sf.hibernate.Transaction;
          
          public class HibernateSessionUtil implements Serializable
          
          {
          
   　           //創建線程局部變量　tLocalsess 
          
              public static final ThreadLocal tLocalsess = new ThreadLocal();
          
　　　          //創建線程局部變量　tLocaltx
          
          public static final ThreadLocal tLocaltx = new ThreadLocal();
          
                //取得session
          
              public static Session currentSession(){
          
                   //從線程變量tLocalsess中，取得當前session
          
          Session session = (Session) tLocalsess.get();
          
          //判斷session是否為空，如果為空，將創建一個session,并付給線程變量tLocalsess
          
              try{
          
          if (session == null){
          
session           = openSession();
          
tLocalsess.set(session);
          
}
          
}          catch (HibernateException e){
          
          throw new InfrastructureException(e);
          
}
          
          return session;
          
}
          
          //關閉當前session
          
              public static void closeSession(){
          

          
                   //從線程變量tLocalsess中，取得當前session
          
          Session session = (Session) tLocalsess.get();
          
                   //設置線程變量tLocalsess為空
          
          tLocalsess.set(null);
          
          try{
          
                      //關閉session
          
          if (session != null && session.isOpen()){
          
session.close();
          
}
          
}          catch (HibernateException e){
          
          throw new InfrastructureException(e);
          
}
          
}
          
          //事物處理
          
              public static void beginTransaction(){
          
                //從線程變量tLocaltx中取得事物管理對象Transaction
          
                  Transaction tx = (Transaction) tLocaltx.get();
          
          try{
          
                      //如果為空就從session中創建一個tx
          
          if (tx == null){
          
tx           = currentSession().beginTransaction();
          
tLocaltx.set(tx);
          
}
          
}          catch (HibernateException e){
          
          throw new InfrastructureException(e);
          
}
          
}
          
          //提交事物
          
              public static void commitTransaction(){
          
                //取得事物
          
          Transaction tx = (Transaction) tLocaltx.get();
          
          try{
          
                      //如果不為空就提交
          
          if (tx != null && !tx.wasCommitted() && !tx.wasRolledBack())
          
tx.commit();
          
tLocaltx.set(          null);
          
}          catch (HibernateException e){
          
          throw new InfrastructureException(e);
          
}
          
}
          
              //事物回滾    
          
              public static void rollbackTransaction(){
          
                   //取得tx事物
          
          Transaction tx = (Transaction) tLocaltx.get();
          
          try{
          
                      //將變量清空
          
          tLocaltx.set(null);
          
          if (tx != null && !tx.wasCommitted() && !tx.wasRolledBack()){
          
                          //事物回滾
          
          tx.rollback();
          
}
          
}          catch (HibernateException e){
          
          throw new InfrastructureException(e);
          
}
          
}
          

          
             //取得session
          
          private static Session openSession() throws HibernateException{
          
          return getSessionFactory().openSession();
          
}
          

          
             //取得sessionFactory
          
          private static SessionFactory getSessionFactory() throws HibernateException{
          
          return SingletonSessionFactory.getInstance();
          
}
          
}
          
filter的代碼：
          
          public class HibernateSessionCloser implements Filter{
          
          protected FilterConfig filterConfig = null;
          
          public void init(FilterConfig filterConfig)throws ServletException{
          
          this.filterConfig = filterConfig;
          
}
          
          public void destroy(){
          
          this.filterConfig = null;
          
}
          
          public void doFilter(ServletRequest request, ServletResponse response,
          
FilterChain chain)
          
          throws IOException, ServletException {
          
          try{
          
chain.doFilter(request, response);
          
}
          
          finally{
          
          try{
          
HibernateSessionUtil.commitTransaction();
          
}          catch (InfrastructureException e){
          
HibernateSessionUtil.rollbackTransaction();
          
}          finally{
          
HibernateSessionUtil.closeSession();
          
}
          
}
          
}
          
}
          

          

          
然后在web.xml配置filter就可以使用了.          

	
          posted on 2008-05-18 20:36 henry1451 閱讀(630) 評論(0)  編輯  收藏  所屬分類: Hibernate技術 
          

          







          
	    
    




          








          

				

          



    







          
        
	




主站蜘蛛池模板：
通州区|
博湖县|
竹北市|
蓬安县|
荥经县|
鄯善县|
林芝县|
黑山县|
报价|
栾城县|
大理市|
竹溪县|
临城县|
平昌县|
寿光市|
宁蒗|
九龙县|
集安市|
剑河县|
衢州市|
浪卡子县|
上饶市|
清涧县|
扎鲁特旗|
云浮市|
巴马|
朔州市|
阳城县|
平陆县|
五台县|
伊川县|
广汉市|
新竹县|
玛多县|
峨边|
犍为县|
清新县|
阳新县|
长海县|
和田市|
垦利县|