Posted on 2012-04-15 16:27
zljpp 閱讀(172)
評論(0) 編輯 收藏
spring事務管理全解析
文章出處：DIY部落(http://www.diybl.com/course/3_program/java/javajs/2007923/73069.html#)
了解事務：
事務是一組原子（Atomic）操作的工作單元，以數據庫存取的實例來說，就是一組SQL指令，這一組SQL指令必須全部執行成功，若因為某個原因未全部執行成功（例如其中一行SQL有錯誤），則先前所有執行過的SQL指令都會被撤消。
JDBC是如何控制事務的
try ...{
.....
connection.setAutoCommit(false);
.....
// 一連串SQL操作
connection.commit();
} catch(SQLException) ...{
// 發生錯誤，撤消所有變更
connection.rollback();
}
Spring是把JDBC事務管理進來了封裝，Spring事務管理的抽象關鍵在于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接口的實例定義了
事務的隔離程度（Isolation level）
傳播行為（Propagation behavior）
超時（Timeout）
只讀（Read-only）等
DataSourceTransactionManager、HibernateTransactionManager、JdoTransaction- Manager、JtaTransactionManager等是實現了該接口
Spring提供編程式的事務管理（Programmatic transaction management）與聲明式的事務管理（Declarative transaction management）：
1、編程式的事務管理可以清楚地控制事務的邊界，也就是讓您自行實現事務開始時間、撤消操作的時機、結束時間等，可以實現細粒度的事務控制。
2、然而多數的情況下，事務并不需要細粒度的控制，而是采用聲明式的事務管理，好處是Spring事務管理的相關API可以不用介入程序之中，從對象的角度來看，它并不知道自己正被納入事務管理之中，在不需要事務管理的時候，只要在設置文件上修改一下設置，即可移去事務管理服務。
聲明式的事務管理舉例 以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需要一個TransactionManager，由于這里使用的是JDBC，所以使用DataSourceTransactionManager，TransactionProxyFactoryBean是個代理對象，"target" 屬性指定要代理的對象，事務管理會自動介入指定的方法前后，這里使用 "transactionAttributes" 屬性指定，"insert*" 表示指定方法名稱以insert開頭的都要納入事務管理，您也可以指定方法全名，如果在方法執行過程中發生錯誤，則所有先前的操作自動撤回，否則正常提交。
在"insert*" 等方法上指定了 "PROPAGATION_REQUIRED"，表示在目前的事務中執行操作，如果事務不存在就建立一個新的，相關的常數意義都可以在API文件的TransactionDefinition接口中找到。您可以加上多個事務定義，中間使用逗號 "," 區隔，例如可以加上只讀，或者是指定某個異常發生時撤回操作：
PROPAGATION_REQUIRED,readOnly,-MyCheckedException
MyCheckedException前面加上 "-" 時，表示發生指定異常時撤消操作，如果前面加上 "+"，表示發生異常時立即提交。
由于"userDAO"被"userDAOProxy"代理了，所以要做的是取得"userDAOProxy"，而不是"userDAO"，
IUserDAO userDAO =
(IUserDAO) context.getBean("userDAOProxy");
userDAO.insert(user);
申明式事務管理一般都是粗粒度的，這里可以看到，整個方法都被納入事務管理，其實在大部分的業務處理中，這樣做是沒有什么不好的。
事務的屬性介紹
傳播行為
說明
PROPAGATION_MANDATORY
方法必須在一個現存的事務中進行，否則丟出異常
PROPAGATION_NESTED
在一個嵌入的事務中進行，如果不是，則同PROPAGATION_REQUIRED
PROPAGATION_NEVER
指出不應在事務中進行，如果有就丟出異常
PROPAGATION_NOT_SUPPORTED
指出不應在事務中進行，如果有就暫停現存的事務
PROPAGATION_REQUIRED
支持現在的事務，如果沒有就建立一個新的事務
PROPAGATION_REQUIRES_NEW
建立一個新的事務，如果現存一個事務就暫停它
PROPAGATION_SUPPORTS
支持現在的事務，如果沒有就以非事務的方式執行
隔離層級
說明
ISOLATION_DEFAULT
使用底層數據庫預設的隔離層級
ISOLATION_READ_COMMITTED
允許事務讀取其他并行的事務已經送出（Commit）的數據字段，可以防止Dirty read問題
ISOLATION_READ_UNCOMMITTED
允許事務讀取其他并行的事務還沒送出的數據，會發生Dirty、Nonrepeatable、Phantom read等問題
續表
隔離層級
說明
ISOLATION_REPEATABLE_READ
要求多次讀取的數據必須相同，除非事務本身更新數據，可防止Dirty、Nonrepeatable read問題
ISOLATION_SERIALIZABLE
完整的隔離層級，可防止Dirty、Nonrepeatable、Phantom read等問題，會鎖定對應的數據表格，因而有效率問題
只讀提示（Read-only hints）
如果事務只進行讀取的動作，則可以利用底層數據庫在只讀操作時發生的一些最佳化動作，由于這個動作利用到數據庫在只讀的事務操作最佳化，因而必須在事務中才有效，也就是說要搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設置。
事務超時期間（The transaction timeout period）
有的事務操作可能延續很長一段的時間，事務本身可能關聯到數據表格的鎖定，因而長時間的事務操作會有效率上的問題，對于過長的事務操作，您要考慮Roll back事務并要求重新操作，而不是無限時的等待事務完成。
您可以設置事務超時期間，計時是從事務開始時，所以這個設置必須搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設置。
（上面是從《spring2.0技術開發》摘抄的，里面有些概念還含糊不清，有待實驗考證下）
這里我來介紹一種新的模式，不知道大家有沒有用到過，在文檔中沒有發現
<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>
這里的意圖，大家只有非常了解代理模式才會明白其中的道理。那么分開設置有什么好處呢？模塊化，大家可以公用這個代理模式，而且可以定義自己的聲明，和其他人的聲明無關。
TransactionProxyFactoryBean
配置這個類，是為了現寬廣地實現事務的管理，也可以說是為了要和hibenate結合起來，TransactionProxyFactoryBean這個類一般有三個構造參數要注入，一個是hibernate的sessionFactory,這是為了spring可以和hibernate結合，第二個是用戶的DAO類，而這個DAO類本身也需要把hibernate的sessionFactory作為構造參數注入到它的父類的構造函數中。第三個注入的，其實是事務管理的策略，通過AOP的方式實現的，例如DAO類中有有insert(String sql);update(String sql);delelte(String sql);三個方法，我們可以設定當insert執行時如果拋出異常，就執行rollback等操作。Select不存在異常，這里就一般 不寫了。
下面給出聲明式的事務管理的另外一個舉例（使用HibernateTransactionManager實現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模塊。通過這個模塊Spring提供了對Hibernate、JDO、OJB和iBatis的集成。
在與Hibernate集成時我們需要用到Spring的LocalSessionFactoryBean類，這個類可以看作是連接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，具體實現位于DAOImpl類中，Spring提供SqlMapClientDaoSupport這個抽象類的目的就是為了獲取其SqlMapClientTemplate對象，并通過SqlMapClientTemplate對象直接訪問數據庫，如下：
public class CommonDaoImpl extends SqlMapClientDaoSupport implements CommonDao
{
public List getInputData(String sqlID, Object entity) throws ServiceException
{
return this.getSqlMapClientTemplate().queryForList(sqlID, entity);
}
。。。
}
相應的Spring也提供了類似的HibernateDaoSupport，然后通過HibernateTemplate直接訪問數據庫。
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());
}
}
。。。
}
從整體上來看整個過程是分多步細化的，也就是面向接口的編程吧：首先了解服務Service，這個服務還有一個實現類ServiceImpl，這個實現類中組合IDao，當然IDao也有一個實現類IDaoImpl，具體實現持久層數據的訪問；然后就是裝配ServiceImpl，即需要實例userDAO，裝配的時候通過代理實現即userDAOProxy；裝配userDAOProxy，這個時候需要屬性注入transactionManager，target和transactionAttributes，其中target就是userDao。
注意：find()方法是hibernate2中的方法，hibernate3中一般使用get()和load()
?