Spring事務(wù)管理

點(diǎn)擊上方藍(lán)色字體，選擇“標(biāo)星公眾號(hào)”

優(yōu)質(zhì)文章，第一時(shí)間送達(dá)

? 作者?|? 笑忘書(shū)丶

來(lái)源 |? urlify.cn/vay6fu

76套java從入門(mén)到精通實(shí)戰(zhàn)課程分享

Spring的事務(wù)管理簡(jiǎn)化了傳統(tǒng)的事務(wù)管理流程，提高了開(kāi)發(fā)效率。但是首先先要了解Spring的數(shù)據(jù)庫(kù)編程。

Spring的數(shù)據(jù)庫(kù)編程

數(shù)據(jù)庫(kù)編程是互聯(lián)網(wǎng)編程的基礎(chǔ)，Spring框架為開(kāi)發(fā)者提供了JDBC模板模式，即jdbcTemplate，它可以簡(jiǎn)化許多代碼，但在實(shí)際應(yīng)用中jdbcTemplate使用并不常見(jiàn)，在大多數(shù)時(shí)候都采用Spring結(jié)合MyBatis進(jìn)行開(kāi)發(fā)。在這里，只講述Spring的jdbcTemplate開(kāi)發(fā)。

SpringJDBC的配置

本節(jié)Spring數(shù)據(jù)庫(kù)編程主要使用的是SpringJDBC模塊的core和DataSource包，core是JDBC的核心包，包括常用的JdbcTemplate類(lèi)，DataSource是訪問(wèn)數(shù)據(jù)源的工具類(lèi)包。如果要使用SpringJDBC操作數(shù)據(jù)庫(kù)，需要進(jìn)行配置，配置如下：

"dataSource"?class="org.springframework.jdbc.datasource.DriverManagerDataSource">
????
????"driverClassName"?value="com.mysql.jdbc.Driver"/>
????
????"url"?value="jdbc:mysql://localhost:3306/spring?characterEncoding=utf-8"/>
????
????"username"?value="root"/>
????"password"?value="root"/>


"jdbcTemplate"?class="org.springframework.jdbc.core.JdbcTemplate">
????"dataSource"?ref="dataSource"/>

在上述示例中，配置JDBC模板需要將dataSource注入到j(luò)dbcTemplate，而在數(shù)據(jù)訪問(wèn)層（Dao）中需要使用jdbcTemplate時(shí)也需要將jdbcTemplate注入到對(duì)應(yīng)的bean中。

@Repository("testDao")
public?class?TestDaoImpl?implements?TestDao?{
????@Autowired?//按照類(lèi)型注入
????private?JdbcTemplate?jdbcTemplate;

JDBCTemplate的常用方法

public int update(String sql,Object args[])：該方法可以對(duì)數(shù)據(jù)表進(jìn)行增加、修改、刪除。使用args[]設(shè)置參數(shù)，函數(shù)返回的是更新的行數(shù)。示例如下：

String?insertSQL="insert?into?user?values(NULL,?,?)";
Onject?param[]?=?{"chencheng","m"};
jdbcTemplate.update(insertSQL,param);

public List query(String sql,RowMapper rowmapper,Object args[])：該方法可以對(duì)數(shù)據(jù)表進(jìn)行查詢(xún)操作，rowMapper將結(jié)果集映射到用戶自定義的類(lèi)中（前提是類(lèi)的屬性名與字段名相同）。示例如下：

jdbcTemplate.query(sql,new?BeanPropertyRowMapper(User.class),param);

具體的實(shí)現(xiàn)步驟

1. 創(chuàng)建并編輯配置文件applicationContext.xml

   
   

2. "1.0"?encoding="UTF-8"?>
   "http://www.springframework.org/schema/beans"
   ???????xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   ???????xmlns:aop="http://www.springframework.org/schema/aop"
   ???????xmlns:context="http://www.springframework.org/schema/context"
   ???????xsi:schemaLocation="http://www.springframework.org/schema/beans
   ????????http://www.springframework.org/schema/beans/spring-beans.xsd
   ????????http://www.springframework.org/schema/aop
   ????????http://www.springframework.org/schema/aop/spring-aop.xsd
   ????????http://www.springframework.org/schema/context
   ????????http://www.springframework.org/schema/context/spring-context.xsd">
   ????
   ????"com.ch5"/>
   ????
   ????"dataSource"?class="org.springframework.jdbc.datasource.DriverManagerDataSource">
   ????????
   ????????"driverClassName"?value="com.mysql.jdbc.Driver"/>
   ????????
   ????????"url"?value="jdbc:mysql://localhost:3306/spring?characterEncoding=utf-8"/>
   ????????
   ????????"username"?value="root"/>
   ????????"password"?value="root"/>
   ????
   ????
   ????"jdbcTemplate"?class="org.springframework.jdbc.core.JdbcTemplate">
   ????????"dataSource"?ref="dataSource"/>
   ????
   
   
   

   2.創(chuàng)建映射數(shù)據(jù)庫(kù)的實(shí)體類(lèi)

package?com.ch5;
?
public?class?User?{
????private?Integer?id;
????private?String?name;
????private?double?money;
?
????public?Integer?getId()?{
????????return?id;
????}
?
????public?void?setId(Integer?id)?{
????????this.id?=?id;
????}
?
????public?String?getName()?{
????????return?name;
????}
?
????public?void?setName(String?name)?{
????????this.name?=?name;
????}
?
????public?double?getMoney()?{
????????return?money;
????}
?
????public?void?setMoney(double?money)?{
????????this.money?=?money;
????}
?
????@Override
????public?String?toString()?{
????????return?"User{"?+
????????????????"id="?+?id?+
????????????????",?name='"?+?name?+?'\''?+
????????????????",?money="?+?money?+
????????????????'}';
????}
}

3. 創(chuàng)建數(shù)據(jù)庫(kù)訪問(wèn)層TestDao和TestDaoImpl

package?com.ch5.dao;
import?com.ch5.User;
import?java.util.List;
public?interface?TestDao?{
????public?int?update(String?sql,Object[]?param);
????public?List?query(String?sql,Object[]?param);
}

package?com.ch5.dao.Impl;
import?com.ch5.User;
import?com.ch5.dao.TestDao;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.jdbc.core.BeanPropertyRowMapper;
import?org.springframework.jdbc.core.JdbcTemplate;
import?org.springframework.stereotype.Repository;
import?java.util.List;
@Repository("testDao")
public?class?TestDaoImpl?implements?TestDao?{
????@Autowired?//按照類(lèi)型注入
????private?JdbcTemplate?jdbcTemplate;
????@Override
????public?int?update(String?sql,?Object[]?param)?{
????????return?jdbcTemplate.update(sql,param);
????}
????@Override
????public?List?query(String?sql,?Object[]?param)?{
????????return?jdbcTemplate.query(sql,new?BeanPropertyRowMapper(User.class),param);
????}
}

4. 編寫(xiě)測(cè)試類(lèi)JdbcTemplateTest

package?com.ch5.Test;
?
import?com.ch5.User;
import?com.ch5.dao.TestDao;
import?org.springframework.context.ApplicationContext;
import?org.springframework.context.support.ClassPathXmlApplicationContext;
?
import?java.util.List;
?
public?class?JdbcTemplateTest?{
????public?static?void?main(String[]?args)?{
????????ApplicationContext?appCo?=?new?ClassPathXmlApplicationContext("appliationContext.xml");
????????TestDao?testDao=(TestDao)appCo.getBean("testDao");
????????String?insertSql="insert?into?account?values(null,?,?)";
????????Object?param[]?=?{"chencheng",1050.0};
????????testDao.update(insertSql,param);
????????String?selectSql="select?*?from?account";
????????List?list=testDao.query(selectSql,null);
????????for?(User?user?:?list)?{
????????????System.out.println(user);
????????}
????}
}


編程式事務(wù)管理

在代碼中顯式的調(diào)用beginTransaction、commit、rollback等與事務(wù)處理相關(guān)的方法，這就是編程式事務(wù)管理，當(dāng)只有少數(shù)事務(wù)操作時(shí)，編程式事務(wù)管理才比較適合。

基于XML的AOP實(shí)現(xiàn)事務(wù)控制

1. 編寫(xiě)事務(wù)管理的類(lèi)

package?com.itheima.utils;
/**
?*?和事務(wù)管理相關(guān)的工具類(lèi)，它包含了，開(kāi)啟事務(wù)，提交事務(wù)，回滾事務(wù)和釋放連接
?*/
public?class?TransactionManager?{
????private?ConnectionUtils?connectionUtils;
????public?void?setConnectionUtils(ConnectionUtils?connectionUtils)?{
????????this.connectionUtils?=?connectionUtils;
????}
????/**
?????*?開(kāi)啟事務(wù)
?????*/
????public??void?beginTransaction(){
????????try?{
????????????connectionUtils.getThreadConnection().setAutoCommit(false);
????????}catch?(Exception?e){
????????????e.printStackTrace();
????????}
????}
????/**
?????*?提交事務(wù)
?????*/
????public??void?commit(){
????????try?{
????????????connectionUtils.getThreadConnection().commit();
????????}catch?(Exception?e){
????????????e.printStackTrace();
????????}
????}
????/**
?????*?回滾事務(wù)
?????*/
????public??void?rollback(){
????????try?{
????????????connectionUtils.getThreadConnection().rollback();
????????}catch?(Exception?e){
????????????e.printStackTrace();
????????}
????}
????/**
?????*?釋放連接
?????*/
????public??void?release(){
????????try?{
????????????connectionUtils.getThreadConnection().close();//還回連接池中
????????????connectionUtils.removeConnection();
????????}catch?(Exception?e){
????????????e.printStackTrace();
????????}
????}
}

2. 配置aop

"txManager"?class="com.itheima.utils.TransactionManager">
????
???"connectionUtils"?ref="connectionUtils">


????????"pt1"?expression="execution(*?com.itheima.service.impl.*.*(..)"/>
????????"txAdvice"?ref="txManager">
????????
????????????"beginTransaction"?pointcut-ref="pt1"/>
????????
????????????"commit"?pointcut-ref="pt1"/>
????????
????????????"rollback"?pointcut-ref="pt1"/>
????????
????????????"release"?pointcut-ref="pt1"/>
????????
????

基于底層API的編程式事務(wù)管理

基于底層API的編程式事務(wù)管理就是根據(jù)PlatformTransactionManager，TransactionDefinition和TeansactionStatus等幾個(gè)核心接口，通過(guò)編程的方式進(jìn)行事務(wù)管理，下面通過(guò)一個(gè)實(shí)例描述底層API的事務(wù)管理實(shí)現(xiàn)：

1. 給數(shù)據(jù)源配置事務(wù)管理器

"txManager"?class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
????"dataSource"?ref="dataSource"/>

2. 創(chuàng)建數(shù)據(jù)訪問(wèn)類(lèi)

package?com.ch5.dao.Impl;
?
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.jdbc.core.JdbcTemplate;
import?org.springframework.jdbc.datasource.DataSourceTransactionManager;
import?org.springframework.stereotype.Repository;
import?org.springframework.transaction.TransactionDefinition;
import?org.springframework.transaction.TransactionStatus;
import?org.springframework.transaction.support.DefaultTransactionDefinition;
?
@Repository("codeTransaction")
public?class?CodeTransaction?{
????@Autowired
????private?JdbcTemplate?jdbcTemplate;
????@Autowired
????private?DataSourceTransactionManager?transactionManager;
????public?String?testTransaction(){
????????//默認(rèn)事務(wù)定義
????????TransactionDefinition?definition=new?DefaultTransactionDefinition();
????????//開(kāi)啟事務(wù)
????????TransactionStatus?transactionStatus?=?transactionManager.getTransaction(definition);
????????String?message="執(zhí)行成功，沒(méi)有回滾";
????????try{
????????????String?sql?=?"delete?*?from?account";
????????????String?insertSql?=?"insert?into?account?values(?,?,?)";
????????????Object?param[]?=?{"1","chenheng",2000};
????????????jdbcTemplate.update(sql);
????????????//id重復(fù),因此發(fā)生錯(cuò)誤。
????????????jdbcTemplate.update(insertSql,param);
????????????jdbcTemplate.update(insertSql,param);
????????????//提交事務(wù)
????????????transactionManager.commit(transactionStatus);
????????}catch?(Exception?e){
????????????//出現(xiàn)異常，回滾
????????????transactionManager.rollback(transactionStatus);
????????????message="事務(wù)回滾";
????????????e.printStackTrace();
????????}
????????return?message;
????}
}

3. 定義測(cè)試類(lèi)

package?com.ch5.Test;
?
import?com.ch5.dao.Impl.CodeTransaction;
import?org.springframework.context.ApplicationContext;
import?org.springframework.context.support.ClassPathXmlApplicationContext;
?
public?class?TransactionMangagerTest?{
????public?static?void?main(String[]?args)?{
????????ApplicationContext?appCo=new?ClassPathXmlApplicationContext("appliationContext.xml");
????????CodeTransaction?codeTransaction?=?(CodeTransaction)appCo.getBean("codeTransaction");
????????String?result?=?codeTransaction.testTransaction();
????????System.out.println(result);
????}
}

基于TransactionTemplate的編程式事務(wù)管理

事務(wù)處理的代碼散落在業(yè)務(wù)邏輯代碼中，破壞了原有代碼的條理性，并且每一個(gè)事務(wù)都會(huì)有類(lèi)似的啟動(dòng)事務(wù)，提交以及回滾事務(wù)的代碼。

TransactionTemplate的excute方法有一個(gè)TransactionCallback接口類(lèi)型的參數(shù)，該接口定義了一個(gè)DoInTransaction的方法，通常以匿名內(nèi)部類(lèi)的方式實(shí)現(xiàn)TransactionCallback接口，并在其doInTransaction方法中寫(xiě)業(yè)務(wù)邏輯代碼。在這里可以使用默認(rèn)的事務(wù)提交和回滾規(guī)則，在業(yè)務(wù)代碼中不需要顯式調(diào)用任何事務(wù)處理的API，doInTransaction方法有一個(gè)TransactionStatus類(lèi)型的參數(shù)，可以在方法的任何位置調(diào)用該參數(shù)的setRollbackOnly方法將事務(wù)標(biāo)識(shí)為回滾，以執(zhí)行事務(wù)回滾。

根據(jù)默認(rèn)規(guī)則，如果在執(zhí)行回調(diào)方法的過(guò)程中拋出未檢查異常，或者顯式調(diào)用了setRollbackOnly方法，則回滾事務(wù)；如果事務(wù)執(zhí)行完成或者拋出了checked類(lèi)型的異常，則提交事務(wù)。

基于TransactionTemplate的編程式事務(wù)管理的步驟如下：

1. 為事務(wù)管理添加事務(wù)模板：在基于底層的API開(kāi)發(fā)的applicationContext.xml配置文件上使用springframwork提供的org,springframework,transaction.support.TransactionTemplate類(lèi)為事務(wù)管理器添加事務(wù)模板。完整的配置文件如下：

"1.0"?encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
???????xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
???????xmlns:aop="http://www.springframework.org/schema/aop"
???????xmlns:context="http://www.springframework.org/schema/context"
???????xsi:schemaLocation="http://www.springframework.org/schema/beans
????????http://www.springframework.org/schema/beans/spring-beans.xsd
????????http://www.springframework.org/schema/aop
????????http://www.springframework.org/schema/aop/spring-aop.xsd
????????http://www.springframework.org/schema/context
????????http://www.springframework.org/schema/context/spring-context.xsd">
????
????"com.ch5"/>
????
????"dataSource"?class="org.springframework.jdbc.datasource.DriverManagerDataSource">
????????
????????"driverClassName"?value="com.mysql.jdbc.Driver"/>
????????
????????"url"?value="jdbc:mysql://localhost:3306/spring?characterEncoding=utf-8"/>
????????
????????"username"?value="root"/>
????????"password"?value="root"/>
????
????
????"txManager"?class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
????????"dataSource"?ref="dataSource"/>
????
????
????"transactionTemplate"?class="org.springframework.transaction.support.TransactionTemplate">
????????"transactionManager"?ref="txManager"/>
????
????
????"jdbcTemplate"?class="org.springframework.jdbc.core.JdbcTemplate">
????????"dataSource"?ref="dataSource"/>
????

2. 創(chuàng)建數(shù)據(jù)訪問(wèn)類(lèi)TransactionTemplateDao

package?com.ch5;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.jdbc.core.JdbcTemplate;
import?org.springframework.stereotype.Repository;
import?org.springframework.transaction.TransactionStatus;
import?org.springframework.transaction.support.TransactionCallback;
import?org.springframework.transaction.support.TransactionTemplate;
@Repository("transactionTemplateDao")
public?class?TransactionTemplateDao?{
????@Autowired
????private?JdbcTemplate?jdbcTemplate;
????@Autowired
????private?TransactionTemplate?transactionTemplate;
????String?message?=?"";
????public?String?TransactionTemplateTest(){
????????//以你命好內(nèi)部類(lèi)的方式實(shí)現(xiàn)TransactionCallback接口。使用默認(rèn)的事務(wù)規(guī)則。
????????transactionTemplate.execute(new?TransactionCallback