Spring的事務

　　今天對 spring 的 AOP 事務有了一個新的認識,所以趕緊把今天的學習記下來,希望在今後的學習中能夠起到一些作用,也能對今天的認識做一次總結.

　　1.spring 分享

　　先看一段代碼：

　　Connection conn = Conn.getConnection();

　　conn.setAutoCommit(false);

　　……..

　　……...

　　conn.rollback();

　　conn.commit();

　　資料庫的事務是針對 Connection 的.

　　接著再看一段代碼：（ spring 中事務的一段學習代碼,這段代碼是把 spring 和 hibernate 結合在一起的,增加了理解上的難度,我的出發點一開始不要 hibernate ,就光用 jdbc 來進行資料庫事務,但是沒有其他好的代碼,就這樣吧）

　　public Long addLineItem(Long orderId, LineItem lineItem){

　　log("OrderListDAOHibernate.addLineItem : Start...");

　　OrderList orderList = (OrderList) getHibernateTemplate().load(OrderList.class, orderId);

　　lineItem.setOrderList(orderList);

　　getHibernateTemplate().saveOrUpdate(lineItem);

　　getHibernateTemplate().saveOrUpdate(orderList);

　　log("OrderListDAOHibernate.addLineItem : Ending...");

　　return lineItem.getId();

　　}

　　在這個代碼的配置文件中,把 addLineItem 做為一個切入點,進行事務,也就是說,在 addLineItem 的外面,再包上一層事務的外殼.

　　但是這個時候,問題出來了,事務是針對 Connection 的,而上面的兩個連續的 HibernateTemplate 執行的 saveOrUpdate 中的 Connection 必須是一致才能用事務, spring 怎麼做到這一點的呢？（這個問題也就是在找 spring 的事務例子前,我想的 spring 中用 jdbc 來進行事務,怎麼樣讓 Connection 保持一致呢？但是沒有 jdbc 的例子,只有整合 hibernate 或者 ibatis 的例子,但是,我想,原理是一樣的吧.）

　　解決問題的思路： HibernateTemplate 中的 Connection 必定一致.那麼就從 HibernateTemplate 入手.

　　看 spring 的源代碼,既然是 Hibernate ,那麼,就沒有 Connection 給你看,只有 Session ,由 Session 來管理 Connection ,那麼用事務來控制的話,這個 Session 必定在所有該事務中是一致的.於是在 HibernateTemplate 中找到：

　　protected Session getSession() {

　　if (isAlwaysUseNewSession()) {

　　return SessionFactoryUtils.getNewSession(getSessionFactory(), getEntityInterceptor());

　　}

　　else if (!isAllowCreate()) {

　　return SessionFactoryUtils.getSession(getSessionFactory(), false);

　　}

　　else {

　　return SessionFactoryUtils.getSession(

　　getSessionFactory(), getEntityInterceptor(), getJdbcExceptionTranslator());

　　}

　　}

　　看來在 SessionFactoryUtils 裡面,接著在 SessionFactoryUtils.getSession 中找：

　　這個方法太長了,太複雜了,從簡,發現了非常關鍵的一點：

　　SessionHolder sessionHolder = (SessionHolder) TransactionSynchronizationManager.getResource(sessionFactory);

　　假如 sessionHolder 不等於空,說明,在事務中有這樣一個還沒有 commit 的 session ,那麼就返回這個 session ,假如等於空,新建一個 session ,並且在事務里加入這個 session .這段代碼的意思大概是這樣,太繁雜了,只能猜,也肯定是如此.

　　再看 getHibernateTemplate() 方法來自繼承 HibernateDaoSupport ,看了電子書《 spring-reference 》的第九章「 Dao 支持」, Dao 的支持類可以有好多,如： JdbcDaoSupport , HibernateDaoSupport , JdoDaoSupport 等等.

　　既然前面一開始就是從 jdbc 的 spring 事務控制引起的,那麼看到了同樣的 HibernateDaoSupport---JdbcDaoSupport ,那麼 JdbcDaoSupport 也應該有 getJdbcTemplate() 這個方法,並且返回 JdbcTemplate 這個類.

　　果然如此.

　　於是剖析 JdbcTemplate 是不是和 HibernateTemplate 一樣.果然一樣.

　　注意到：

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

　　Connection 是從 DataSourceUtils.getConnection() 來的,繼續跟蹤 DataSourceUtils.getConnection() .

　　找到：

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

　　和 Hibernate 中的一模一樣,沒有了 session 的封裝,條理在 jdbc 中更加清晰了.

　　至此, spring 的事務控制 已經全部搞定.

　　2.Spring 事務管理的配置

　　看了上面同事學習 spring 的筆記后自己也覺得有新的理解,從什麼地方說起呢？就從 spring 的事務配置說起吧.那麼我們看看 contextConfig.xml 吧.

　　<bean id="sessionFactory" class="org.springframework.orm.hibernate.LocalSessionFactoryBean">

　　<property name="dataSource">

　　<ref bean="dataSource" />

　　</property>

　　<property name="mappingResources">

　　<list>

　　<value>mf/org/user/User.hbm.xml</value>

　　</list>

　　</property>

　　</bean>

　　<bean id="transactionManager" class="org.springframework.orm.hibernate.HibernateTransactionManager">

　　<property name="sessionFactory">

　　<ref local="sessionFactory" />

　　</property>

　　</bean>

　　<bean id="txProxyTemplate" abstract="true" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">

　　<property name="transactionManager">

　　<ref bean="transactionManager" />

　　</property>

　　<property name="transactionAttributes">

　　<props>

　　<prop key="save*">PROPAGATION_REQUIRED,-Exception</prop>

　　<prop key="remove*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="update*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="incress*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="*">PROPAGATION_REQUIRED,readOnly</prop>

　　</props>

　　</property>

　　</bean>

　　<bean id="userManager" parent="txProxyTemplate">

　　<property name="target" ref="userManagerTarget" />

　　</bean>

　　<bean id="userManagerTarget"

　　class=" mf.org.hb.user.service.impl.UserManagerImpl">

　　<property name="userDAO" ref="userDAO" />

　　</bean>

　　<bean id="userDAO" class="mf.org.hb.user.dao.hibernate.UserDAOHibernate">

　　<property name="sessionFactory" ref="sessionFactory" />

　　</bean>

　　以上就是一個完整的 spring 配置,是不是很熟悉呢,這裡是用的 Appfuse 的框架,呵呵.有那麼點味道吧.

　　我們看看

　　<bean id="transactionManager" class="org.springframework.orm.hibernate.HibernateTransactionManager">

　　<property name="sessionFactory">

　　<ref local="sessionFactory" />

　　</property>

　　</bean>

　　這一個 bean 讓 spring 為我們注入了什麼呢？事務,對！我們把 hibernate 的事務注入到了 spring 的 IOC 容器之中了.然後我們再看看：

　　<bean id="txProxyTemplate" abstract="true" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">

　　<property name="transactionManager">

　　<ref bean="transactionManager" />

　　</property>

　　<property name="transactionAttributes">

　　<props>

　　<prop key="save*">PROPAGATION_REQUIRED,-Exception</prop>

　　<prop key="remove*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="update*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="incress*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="*">PROPAGATION_REQUIRED,readOnly</prop>

　　</props>

　　</property>

　　</bean>

　　這個 bean 又是讓 spring 為我們注入了了什麼呢？事務代理,對了！我們把事務的代理交給一個 txProxyTemplate 的去做了,這樣的好處我待會再說,現在我們看看下面的一些配置信息.

　　<prop key="save*">PROPAGATION_REQUIRED,-Exception</prop>

　　<prop key="remove*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="update*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="incress*">PROPAGATION_REQUIRED,-Exception </prop>

　　<prop key="*">PROPAGATION_REQUIRED,readOnly</prop>

　　這裡就是事務處理時如果遇到異常信息,或者其他的原因時我們要求 spring 把當前的事務回滾了,這樣才能不至於在資料庫中產生垃圾啊.我們規定所有的 save,remove,update,incress 這樣的方法開頭的在出現一些問題后把事務給回滾了,看看我們寫的： PROPAGATION_REQUIRED,-Exception .

　　有人就會說 PROPAGATION_REQUIRED 就可以回滾事務啊,為什麼加上 ,-Exception 呢？其實我以前也時這樣想的,但這是不完全正確的,當然我們在處理一個事務時只要有一個 PROPAGATION_REQUIRED 就可以了,但是當我們的業務邏輯中要求我們在一個事務代理中開啟兩個事務,這兩個事務表面上沒有聯繫,但是實際中又有很多聯繫的,比如我們上傳附件和提交文檔,這樣兩個操作我們可以分開,他們不是往一個表裡插入數據,我們又不希望這兩個操作寫在一個 service 里,這樣我們要是有一個業務只要上傳附件呢？那樣我們是不是又要再寫一個方法啊！所以在開啟兩個事務時如果有一個拋出異常了,我們就要把上一個提交的事務回滾了,這樣做我們就要用的 -Exception 了,這樣就完全滿足我們的要求了,我也試過如果我寫的是 PROPAGATION_REQUIRED,-SQLException 時,這樣我們只會在出現 SQLException 時事務回顧,出現其他的異常事務就不回滾了,好在 spring 可以讓我們寫如異常的基類就可以做到捕獲任何異常,這樣我們就寫 -Exception 好了.特殊情況在特殊處理吧.通用情況下我們還是這樣的.

　　我們再看看：

　　<bean id="userManager" parent="txProxyTemplate">

　　<property name="target" ref="userManagerTarget" />

　　</bean>

　　<bean id="userManagerTarget"

　　class="mf.org.hb.user.service.impl.UserManagerImpl">

　　<property name="userDAO" ref="userDAO" />

　　</bean>

　　<bean id="userDAO" class="mf.org.hb.user.dao.hibernate.UserDAOHibernate">

　　<property name="sessionFactory" ref="sessionFactory" />

　　</bean>

　　當然我們也可以寫成：

　　<bean id="userManager" parent="txProxyTemplate">

　　<property name="target">

　　<bean class="mf.org.hb.user.service.impl.UserManagerImpl">

　　<property name="userDAO">

　　<ref bean="userDao"/>

　　</property>

　　</bean>

　　</property>

　　</bean>

　　<bean id="userDAO" class="mf.org.hb.user.dao.hibernate.UserDAOHibernate">

　　<property name="sessionFactory" ref="sessionFactory" />

　　</bean>

　　這下我們解除以前的疑惑, parent="txProxyTemplate" 知道我們為什麼在上面先寫了 txProxyTemplate 的 bean 了吧,這樣我們就沒有必要再寫一編了.是不是很方便？ spring 的這些技巧還不只這些呢.這樣我們就可以輕鬆利用以上這三個注入的類去做我們的邏輯了.

　　Spring 就是要我們注入實現類,然後使用介面操作,這樣耦合性就不是那麼強了,這也體現了 Spring 的工廠模式.而 AOP 的 manager 又象我們熟知的代理模式吧 !

　　3.注意要點

　　在寫配置的時候注意各個 Manager 和 DAO 之間的關係,以及 <ref= 」」 > 之間的關係,清晰裡面的關係才能更好的配置

Tags: