Thinking in sky

          --老賀的BLOG

            BlogJava :: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理 ::
            21 隨筆 :: 0 文章 :: 35 評(píng)論 :: 0 Trackbacks
          先看一段代碼:
          1Connection conn = Conn.getConnection();
          2    conn.setAutoCommit(false);
          3    ……..
          4    ……
          5    conn.rollback();
          6    conn.commit(); 
          7
          數(shù)據(jù)庫(kù)的事務(wù)是針對(duì) Connection 的。

             
          接著再看一段代碼:( spring 中事務(wù)的一段學(xué)習(xí)代碼,這段代碼是把 spring hibernate 結(jié)合在一起的,增加了理解上的難度,因?yàn)槲业某霭l(fā)點(diǎn)一開(kāi)始不要 hibernate ,就光用 jdbc 來(lái)進(jìn)行數(shù)據(jù)庫(kù)事務(wù),但是沒(méi)有其他好的代碼,就這樣吧)
           1public Long addLineItem(Long orderId, LineItem lineItem)
           2
           3       log("OrderListDAOHibernate.addLineItem : Start"); 
           4
           5       OrderList orderList = (OrderList) getHibernateTemplate().load(OrderList.class, orderId); 
           6
           7       lineItem.setOrderList(orderList); 
           8
           9       getHibernateTemplate().saveOrUpdate(lineItem); 
          10
          11       getHibernateTemplate().saveOrUpdate(orderList); 
          12
          13       log("OrderListDAOHibernate.addLineItem : Ending"); 
          14
          15       return lineItem.getId(); 
          16
          17    }

          18
          19

          在這個(gè)代碼的配置文件中,把 addLineItem 做為一個(gè)切入點(diǎn),進(jìn)行事務(wù),也就是說(shuō),在 addLineItem 的外面,再包上一層事務(wù)的外殼。

             
          但是這個(gè)時(shí)候,問(wèn)題出來(lái)了,事務(wù)是針對(duì) Connection 的,而上面的兩個(gè)連續(xù)的 HibernateTemplate 執(zhí)行的 saveOrUpdate 中的 Connection 必須是一致才能用事務(wù), spring 怎么做到這一點(diǎn)的呢?(這個(gè)問(wèn)題也就是在找 spring 的事務(wù)例子前,我想的 spring 中用 jdbc 來(lái)進(jìn)行事務(wù),怎么樣讓 Connection 保持一致呢?但是沒(méi)有 jdbc 的例子,只有整合 hibernate 或者 ibatis 的例子,但是,我想,原理是一樣的吧。)

           

              解決問(wèn)題的思路: HibernateTemplate 中的 Connection 必定一致。那么就從 HibernateTemplate 入手。

              spring 的源代碼,既然是 Hibernate ,那么,就沒(méi)有 Connection 給你看,只有 Session ,由 Session 來(lái)管理 Connection ,那么用事務(wù)來(lái)控制的話(huà),這個(gè) Session 必定在所有該事務(wù)中是一致的。于是在 HibernateTemplate 中找到:

           1protected Session getSession() 
           2
           3       if (isAlwaysUseNewSession()) 
           4
           5return SessionFactoryUtils.getNewSession(getSessionFactory(), getEntityInterceptor()); 
           6
           7       }
           
           8
           9       else if (!isAllowCreate()) 
          10
          11return SessionFactoryUtils.getSession(getSessionFactory(), false); 
          12
          13       }
           
          14
          15       else 
          16
          17return SessionFactoryUtils.getSession( 
          18
          19                  getSessionFactory(), getEntityInterceptor(), getJdbcExceptionTranslator()); 
          20
          21       }
           
          22
          23    }
           
          24
          25

          看來(lái)在 SessionFactoryUtils 里面,接著在 SessionFactoryUtils.getSession 中找:

           

          這個(gè)方法太長(zhǎng)了,太復(fù)雜了,從簡(jiǎn),發(fā)現(xiàn)了非常關(guān)鍵的一點(diǎn):

          1SessionHolder sessionHolder = (SessionHolder) TransactionSynchronizationManager.getResource(sessionFactory); 
          2
          3

          假如 sessionHolder 不等于空,說(shuō)明,在事務(wù)中有這樣一個(gè)還沒(méi)有 commit session ,那么就返回這個(gè) session ,假如等于空,新建一個(gè) session ,并且在事務(wù)里加入這個(gè) session 。這段代碼的意思大概是這樣,太繁雜了,只能猜,也肯定是如此。

           

          再看 getHibernateTemplate() 方法來(lái)自繼承 HibernateDaoSupport ,看了電子書(shū)《 spring-reference 》的第九章“ Dao 支持”, Dao 的支持類(lèi)可以有好多,如: JdbcDaoSupport HibernateDaoSupport JdoDaoSupport 等等。

           

          既然前面一開(kāi)始就是從 jdbc spring 事務(wù)控制引起的,那么看到了同樣的 HibernateDaoSupport---JdbcDaoSupport ,那么 JdbcDaoSupport 也應(yīng)該有 getJdbcTemplate() 這個(gè)方法,并且返回 JdbcTemplate 這個(gè)類(lèi)。

           

          果然如此。

           

          于是剖析 JdbcTemplate 是不是和 HibernateTemplate 一樣。果然一樣。

           

          注意到:

          Connection con = DataSourceUtils.getConnection(getDataSource()); 

          Connection 是從 DataSourceUtils.getConnection() 來(lái)的,繼續(xù)跟蹤 DataSourceUtils.getConnection()

           

          找到:

          ConnectionHolder conHolder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource);

           

          Hibernate 中的一模一樣,因?yàn)闆](méi)有了 session 的封裝,條理在 jdbc 中更加清晰了。

           

          至此, spring 的事務(wù)控制 已經(jīng)全部搞定。

          posted on 2007-05-11 17:42 老賀 閱讀(402) 評(píng)論(0)  編輯  收藏

          只有注冊(cè)用戶(hù)登錄后才能發(fā)表評(píng)論。


          網(wǎng)站導(dǎo)航:
           
          主站蜘蛛池模板: 托克逊县| 大荔县| 介休市| 伊宁市| 贵州省| 青海省| 凌源市| 依兰县| 鸡西市| 阳信县| 锡林郭勒盟| 邛崃市| 南岸区| 莱芜市| 奎屯市| 连州市| 长春市| 乳源| 玉溪市| 郓城县| 周至县| 吉安市| 抚州市| 东乡族自治县| 湘潭县| 资阳市| 松原市| 宁都县| 那坡县| 津南区| 桐庐县| 双柏县| 贞丰县| 保定市| 永年县| 阿合奇县| 耿马| 梧州市| 三门县| 健康| 上思县|