Spring 事務全解析
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()</pre>
pythonopen 
openkk 
碼頭工人