我的家園

spring事務(wù)管理全解析
文章出處：DIY部落(http://www.diybl.com/course/3_program/java/javajs/2007923/73069.html#)
 
了解事務(wù)：
        事務(wù)是一組原子（Atomic）操作的工作單元，以數(shù)據(jù)庫(kù)存取的實(shí)例來說，就是一組SQL指令，這一組SQL指令必須全部執(zhí)行成功，若因?yàn)槟硞€(gè)原因未全部執(zhí)行成功（例如其中一行SQL有錯(cuò)誤），則先前所有執(zhí)行過的SQL指令都會(huì)被撤消。
 
JDBC是如何控制事務(wù)的
 
 
try ...{
    .....
    connection.setAutoCommit(false);
    .....
    // 一連串SQL操作
    connection.commit();
} catch(SQLException) ...{
    // 發(fā)生錯(cuò)誤，撤消所有變更
    connection.rollback();
}
Spring是把JDBC事務(wù)管理進(jìn)來了封裝，Spring事務(wù)管理的抽象關(guān)鍵在于org.springframework.transaction.PlatformTransactionManager接口，里面有 commit 和 rollback
 
 
public interface PlatformTransactionManager ...{
    TransactionStatus getTransaction(TransactionDefinition
                    definition)  throws TransactionException;
    void commit(TransactionStatus status)
                                   throws TransactionException;
    void rollback(TransactionStatus status)
                                   throws TransactionException;
}
 
 
TransactionDefinition接口的實(shí)例定義了
事務(wù)的隔離程度（Isolation level）
傳播行為（Propagation behavior）
超時(shí)（Timeout）
只讀（Read-only）等
 
DataSourceTransactionManager、HibernateTransactionManager、JdoTransaction- Manager、JtaTransactionManager等是實(shí)現(xiàn)了該接口
 
 
Spring提供編程式的事務(wù)管理（Programmatic transaction management）與聲明式的事務(wù)管理（Declarative transaction management）：
 
1、編程式的事務(wù)管理可以清楚地控制事務(wù)的邊界，也就是讓您自行實(shí)現(xiàn)事務(wù)開始時(shí)間、撤消操作的時(shí)機(jī)、結(jié)束時(shí)間等，可以實(shí)現(xiàn)細(xì)粒度的事務(wù)控制。
 
2、然而多數(shù)的情況下，事務(wù)并不需要細(xì)粒度的控制，而是采用聲明式的事務(wù)管理，好處是Spring事務(wù)管理的相關(guān)API可以不用介入程序之中，從對(duì)象的角度來看，它并不知道自己正被納入事務(wù)管理之中，在不需要事務(wù)管理的時(shí)候，只要在設(shè)置文件上修改一下設(shè)置，即可移去事務(wù)管理服務(wù)。
 
 
聲明式的事務(wù)管理舉例  以DataSource，mysql舉例
        <bean id="dataSource"
                class="org.springframework.jdbc.datasource.DriverManagerDataSource"
                  destroy-method="close"> 
 
            <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
   
            <property name="url" value="jdbc:mysql://localhost:3306/demo"/>
   
            <property name="username" value="caterpillar"/>
   
            <property name="password" value="123456"/>
 
        </bean>
 
   
 
        <bean id="transactionManager"
              class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
             
            <property name="dataSource" ref="dataSource"/>
           
        </bean>
 
   
 
        <bean id="userDAO" class="onlyfun.caterpillar.UserDAO">
   
            <property name="dataSource" ref="dataSource"/>
   
        </bean>
 
   
 
        <bean id="userDAOProxy"
            class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
 
        <property name="proxyInterfaces">
            <list>
                <value>onlyfun.caterpillar.IUserDAO</value>
            </list>
        </property>
 
        <property name="target" ref="userDAO"/>
 
        <property name="transactionManager" ref="transactionManager"/>
 
        <property name="transactionAttributes">
 
            <props>
 
                <prop key="insert*">PROPAGATION_REQUIRED</prop>
 
            </props>
 
        </property>       
 
           </bean>    
 
 
TransactionProxyFactoryBean需要一個(gè)TransactionManager，由于這里使用的是JDBC，所以使用DataSourceTransactionManager，TransactionProxyFactoryBean是個(gè)代理對(duì)象，"target" 屬性指定要代理的對(duì)象，事務(wù)管理會(huì)自動(dòng)介入指定的方法前后，這里使用 "transactionAttributes" 屬性指定，"insert*" 表示指定方法名稱以insert開頭的都要納入事務(wù)管理，您也可以指定方法全名，如果在方法執(zhí)行過程中發(fā)生錯(cuò)誤，則所有先前的操作自動(dòng)撤回，否則正常提交。
 
在"insert*" 等方法上指定了 "PROPAGATION_REQUIRED"，表示在目前的事務(wù)中執(zhí)行操作，如果事務(wù)不存在就建立一個(gè)新的，相關(guān)的常數(shù)意義都可以在API文件的TransactionDefinition接口中找到。您可以加上多個(gè)事務(wù)定義，中間使用逗號(hào) "," 區(qū)隔，例如可以加上只讀，或者是指定某個(gè)異常發(fā)生時(shí)撤回操作：
 
PROPAGATION_REQUIRED,readOnly,-MyCheckedException
 
MyCheckedException前面加上 "-" 時(shí)，表示發(fā)生指定異常時(shí)撤消操作，如果前面加上 "+"，表示發(fā)生異常時(shí)立即提交。
 
由于"userDAO"被"userDAOProxy"代理了，所以要做的是取得"userDAOProxy"，而不是"userDAO"，
        IUserDAO userDAO =
            (IUserDAO) context.getBean("userDAOProxy");
        userDAO.insert(user);
 
 申明式事務(wù)管理一般都是粗粒度的，這里可以看到，整個(gè)方法都被納入事務(wù)管理，其實(shí)在大部分的業(yè)務(wù)處理中，這樣做是沒有什么不好的。
 
 
事務(wù)的屬性介紹
 
傳播行為
  說明
 
PROPAGATION_MANDATORY
 方法必須在一個(gè)現(xiàn)存的事務(wù)中進(jìn)行，否則丟出異常
 
PROPAGATION_NESTED
 在一個(gè)嵌入的事務(wù)中進(jìn)行，如果不是，則同PROPAGATION_REQUIRED
 
PROPAGATION_NEVER
 指出不應(yīng)在事務(wù)中進(jìn)行，如果有就丟出異常
 
PROPAGATION_NOT_SUPPORTED
 指出不應(yīng)在事務(wù)中進(jìn)行，如果有就暫停現(xiàn)存的事務(wù)
 
PROPAGATION_REQUIRED
 支持現(xiàn)在的事務(wù)，如果沒有就建立一個(gè)新的事務(wù)
 
PROPAGATION_REQUIRES_NEW
 建立一個(gè)新的事務(wù)，如果現(xiàn)存一個(gè)事務(wù)就暫停它
 
PROPAGATION_SUPPORTS
 支持現(xiàn)在的事務(wù)，如果沒有就以非事務(wù)的方式執(zhí)行
 
隔離層級(jí)
 說明
 
ISOLATION_DEFAULT
 使用底層數(shù)據(jù)庫(kù)預(yù)設(shè)的隔離層級(jí)
 
ISOLATION_READ_COMMITTED
 允許事務(wù)讀取其他并行的事務(wù)已經(jīng)送出（Commit）的數(shù)據(jù)字段，可以防止Dirty read問題
 
ISOLATION_READ_UNCOMMITTED
 允許事務(wù)讀取其他并行的事務(wù)還沒送出的數(shù)據(jù)，會(huì)發(fā)生Dirty、Nonrepeatable、Phantom read等問題
 
 
續(xù)表
 
隔離層級(jí)
 說明
 
ISOLATION_REPEATABLE_READ
 要求多次讀取的數(shù)據(jù)必須相同，除非事務(wù)本身更新數(shù)據(jù)，可防止Dirty、Nonrepeatable read問題
 
ISOLATION_SERIALIZABLE
 完整的隔離層級(jí)，可防止Dirty、Nonrepeatable、Phantom read等問題，會(huì)鎖定對(duì)應(yīng)的數(shù)據(jù)表格，因而有效率問題
 
 
 只讀提示（Read-only hints）
如果事務(wù)只進(jìn)行讀取的動(dòng)作，則可以利用底層數(shù)據(jù)庫(kù)在只讀操作時(shí)發(fā)生的一些最佳化動(dòng)作，由于這個(gè)動(dòng)作利用到數(shù)據(jù)庫(kù)在只讀的事務(wù)操作最佳化，因而必須在事務(wù)中才有效，也就是說要搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設(shè)置。
 
 
 
 
事務(wù)超時(shí)期間（The transaction timeout period）
有的事務(wù)操作可能延續(xù)很長(zhǎng)一段的時(shí)間，事務(wù)本身可能關(guān)聯(lián)到數(shù)據(jù)表格的鎖定，因而長(zhǎng)時(shí)間的事務(wù)操作會(huì)有效率上的問題，對(duì)于過長(zhǎng)的事務(wù)操作，您要考慮Roll back事務(wù)并要求重新操作，而不是無限時(shí)的等待事務(wù)完成。
 
您可以設(shè)置事務(wù)超時(shí)期間，計(jì)時(shí)是從事務(wù)開始時(shí)，所以這個(gè)設(shè)置必須搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設(shè)置。
 
 
（上面是從《spring2.0技術(shù)開發(fā)》摘抄的，里面有些概念還含糊不清，有待實(shí)驗(yàn)考證下）
 
這里我來介紹一種新的模式，不知道大家有沒有用到過，在文檔中沒有發(fā)現(xiàn)
 
 
 
    <bean id="txProxyTemplate" abstract="true" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
        <property name="transactionManager"><ref local="transactionManager"/></property>
        <property name="transactionAttributes">
            <props>
                <prop key="add*">PROPAGATION_REQUIRED</prop>
                <prop key="create*">PROPAGATION_REQUIRED</prop>
                <prop key="update*">PROPAGATION_REQUIRED</prop>
                <prop key="delete*">PROPAGATION_REQUIRED</prop>
                <prop key="license*">PROPAGATION_REQUIRED</prop>
                <prop key="save*">PROPAGATION_REQUIRED</prop>
                <prop key="increase*">PROPAGATION_REQUIRED</prop>
                <prop key="active*">PROPAGATION_REQUIRED</prop>
                <prop key="modify*">PROPAGATION_REQUIRED</prop>
                <prop key="*">PROPAGATION_REQUIRED,readOnly</prop>
            </props>
        </property>
    </bean>   
我在這里不去指定target  那么去哪里指定呢？
    <bean id="providerServiceTarget" class="cn.com.zjtelecom.mall.service.pojo.ProviderService" />
    <bean id="providerService" parent="txProxyTemplate" >
        <property name="target"><ref local="providerServiceTarget"/></property>   
    </bean>
這里的意圖，大家只有非常了解代理模式才會(huì)明白其中的道理。那么分開設(shè)置有什么好處呢？模塊化，大家可以公用這個(gè)代理模式，而且可以定義自己的聲明，和其他人的聲明無關(guān)。
 
 
TransactionProxyFactoryBean
配置這個(gè)類，是為了現(xiàn)寬廣地實(shí)現(xiàn)事務(wù)的管理，也可以說是為了要和hibenate結(jié)合起來，TransactionProxyFactoryBean這個(gè)類一般有三個(gè)構(gòu)造參數(shù)要注入，一個(gè)是hibernate的sessionFactory,這是為了spring可以和hibernate結(jié)合，第二個(gè)是用戶的DAO類，而這個(gè)DAO類本身也需要把hibernate的sessionFactory作為構(gòu)造參數(shù)注入到它的父類的構(gòu)造函數(shù)中。第三個(gè)注入的，其實(shí)是事務(wù)管理的策略，通過AOP的方式實(shí)現(xiàn)的，例如DAO類中有有insert(String   sql);update(String   sql);delelte(String   sql);三個(gè)方法，我們可以設(shè)定當(dāng)insert執(zhí)行時(shí)如果拋出異常，就執(zhí)行rollback等操作。Select不存在異常，這里就一般 不寫了。
 
下面給出聲明式的事務(wù)管理的另外一個(gè)舉例（使用HibernateTransactionManager實(shí)現(xiàn)PlatformTransactionManager）：
 
 
 
       <bean id="dataSource"
              class="org.apache.commons.dbcp.BasicDataSource">
              <property name="driverClassName">
                     <value>com.mysql.jdbc.Driver</value></property>
              <property name="url">
                     <value>jdbc:mysql://localhost/fancyshop</value></property>
              <property name="username">
                     <value>root</value></property>
              <property name="password">
                     <value></value></property>
       </bean>
 
    <bean id="sessionFactory"
       class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
              <property name="dataSource">
                     <ref bean="dataSource" />
              </property>
              <property name="mappingResources">
                     <list>
                            <value>jack/shop/po/User.hbm.xml</value>
                            <value>jack/shop/po/Product.hbm.xml</value>
                            <value>jack/shop/po/Advertise.hbm.xml</value>
                            <value>jack/shop/po/UserKind.hbm.xml</value>
                     </list>
              </property>
              <property name="hibernateProperties">
                     <props>
                            <prop key="hibernate.dialect">
                                   org.hibernate.dialect.MySQLDialect
                            </prop>
                     </props>
              </property>
       </bean>
 
<!-- 、、、、、、、、、、、、、、、、、、、、、、、、、、 DAO 、、、、、、、、、、、、、、、、、、、、、、、、、、、 -->
<bean id="userDAO" class="jack.shop.dao.impl.UserDAOImpl">
              <property name="sessionFactory">
                     <ref bean="sessionFactory" />
              </property>
       </bean>
<bean id="userDAOProxy"
       class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
              <property name="transactionManager">
                     <ref bean="transactionManager" />
              </property>
              <property name="target">
                     <ref local="userDAO" />
              </property>
              <property name="transactionAttributes">
                     <props>
                            <prop key="insert*">PROPAGATION_REQUIRED</prop>
                            <prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
                     </props>
              </property>
       </bean>
 
<bean id="productDAO" class="jack.shop.dao.impl.ProductDAOImpl">
              <property name="sessionFactory">
                     <ref bean="sessionFactory" />
              </property>
       </bean>
<bean id="productDAOProxy"
       class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
              <property name="transactionManager">
                     <ref bean="transactionManager" />
              </property>
              <property name="target">
                     <ref local="productDAO" />
              </property>
              <property name="transactionAttributes">
                     <props>
                            <prop key="insert*">PROPAGATION_REQUIRED</prop>
                            <prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
                            <prop key="query*">PROPAGATION_REQUIRED,readOnly</prop>
                     </props>
              </property>
       </bean>
 
在Struts2中集成了Spring之后再集成Hibernate就非常容易了，在這里我們需要用到Spring提供的ORM模塊。通過這個(gè)模塊Spring提供了對(duì)Hibernate、JDO、OJB和iBatis的集成。
在與Hibernate集成時(shí)我們需要用到Spring的LocalSessionFactoryBean類，這個(gè)類可以看作是連接Spring與Hibernate的橋梁。
 
 
Spring整合ibatis也是類似的：
<bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
              <property name="configLocation" value="config.xml"/>
              <property name="xxx">
                     <bean class="org.springframework.jdbc.support.lob.OracleLobHandler"/>
              </property>
       </bean>
提供持久層訪問接口DAO，具體實(shí)現(xiàn)位于DAOImpl類中，Spring提供SqlMapClientDaoSupport這個(gè)抽象類的目的就是為了獲取其SqlMapClientTemplate對(duì)象，并通過SqlMapClientTemplate對(duì)象直接訪問數(shù)據(jù)庫(kù)，如下：
public class CommonDaoImpl extends SqlMapClientDaoSupport implements CommonDao
{
public List getInputData(String sqlID, Object entity) throws ServiceException
    {
        return this.getSqlMapClientTemplate().queryForList(sqlID, entity);
}
。。。
}
相應(yīng)的Spring也提供了類似的HibernateDaoSupport，然后通過HibernateTemplate直接訪問數(shù)據(jù)庫(kù)。
public class AdvertiseDAOImpl extends HibernateDaoSupport implements
              IAdvertiseDAO {
public List queryByKind(Integer kind, Integer state)
                     throws AdvertiseException {
              List lst;
              String hql = "from Advertise a where a.kind = " + kind
                            + ((state == 0) ? "" : (" AND a.state=" + state));
 
              try {
                     lst = getHibernateTemplate().find(hql);
                     return lst;
              } catch (Throwable e) {
                     throw new AdvertiseException(
                                   "AdvertiseException at queryByKind() method: "
                                                 + e.getMessage());
              }
       }
。。。
}
 
從整體上來看整個(gè)過程是分多步細(xì)化的，也就是面向接口的編程吧：首先了解服務(wù)Service，這個(gè)服務(wù)還有一個(gè)實(shí)現(xiàn)類ServiceImpl，這個(gè)實(shí)現(xiàn)類中組合IDao，當(dāng)然IDao也有一個(gè)實(shí)現(xiàn)類IDaoImpl，具體實(shí)現(xiàn)持久層數(shù)據(jù)的訪問；然后就是裝配ServiceImpl，即需要實(shí)例userDAO，裝配的時(shí)候通過代理實(shí)現(xiàn)即userDAOProxy；裝配userDAOProxy，這個(gè)時(shí)候需要屬性注入transactionManager，target和transactionAttributes，其中target就是userDao。
 
 
注意：find()方法是hibernate2中的方法，hibernate3中一般使用get()和load()

?