SpringBoot事物Transaction實戰講解教程
前言
本篇文章主要介紹的是SpringBoot的事物Transaction使用的教程。html
SpringBoot Transaction
說明：若是想直接獲取工程那麼能夠直接跳到底部，經過連接下載工程代碼。java
Transaction
事務管理方式
在Spring中，事務有兩種實現方式，分別是編程式事務管理和聲明式事務管理兩種方式。mysql
- 編程式事務管理： 編程式事務管理使用TransactionTemplate或者直接使用底層的PlatformTransactionManager。對於編程式事務管理，spring推薦使用TransactionTemplate。
- 聲明式事務管理： 創建在AOP之上的。其本質是對方法先後進行攔截，而後在目標方法開始以前建立或者加入一個事務，在執行完目標方法以後根據執行狀況提交或者回滾事務。 聲明式事務管理不須要入侵代碼，經過@Transactional就能夠進行事務操做，更快捷並且簡單，推薦使用。
事務提交方式
默認狀況下，數據庫處於自動提交模式。每一條語句處於一個單獨的事務中，在這條語句執行完畢時，若是執行成功則隱式的提交事務，若是執行失敗則隱式的回滾事務。 對於正常的事務管理，是一組相關的操做處於一個事務之中，所以必須關閉數據庫的自動提交模式。不過，這個咱們不用擔憂，spring會將底層鏈接的自動提交特性設置爲false。也就是在使用spring進行事物管理的時候，spring會將是否自動提交設置爲false，等價於JDBC中的 connection.setAutoCommit(false);，在執行完以後在進行提交，connection.commit(); 。git
事務隔離級別
隔離級別是指若干個併發的事務之間的隔離程度。TransactionDefinition 接口中定義了五個表示隔離級別的常量：github
- TransactionDefinition.ISOLATION_DEFAULT：這是默認值，表示使用底層數據庫的默認隔離級別。對大部分數據庫而言，一般這值就是TransactionDefinition.ISOLATION_READ_COMMITTED。
- TransactionDefinition.ISOLATION_READ_UNCOMMITTED：該隔離級別表示一個事務能夠讀取另外一個事務修改但尚未提交的數據。該級別不能防止髒讀，不可重複讀和幻讀，所以不多使用該隔離級別。好比PostgreSQL實際上並無此級別。
- TransactionDefinition.ISOLATION_READ_COMMITTED：該隔離級別表示一個事務只能讀取另外一個事務已經提交的數據。該級別能夠防止髒讀，這也是大多數狀況下的推薦值。
- TransactionDefinition.ISOLATION_REPEATABLE_READ：該隔離級別表示一個事務在整個過程當中能夠屢次重複執行某個查詢，而且每次返回的記錄都相同。該級別能夠防止髒讀和不可重複讀。
- TransactionDefinition.ISOLATION_SERIALIZABLE：全部的事務依次逐個執行，這樣事務之間就徹底不可能產生干擾，也就是說，該級別能夠防止髒讀、不可重複讀以及幻讀。可是這將嚴重影響程序的性能。一般狀況下也不會用到該級別。
事務傳播行爲
所謂事務的傳播行爲是指，若是在開始當前事務以前，一個事務上下文已經存在，此時有若干選項能夠指定一個事務性方法的執行行爲。在TransactionDefinition定義中包括了以下幾個表示傳播行爲的常量：web
- TransactionDefinition.PROPAGATION_REQUIRED：若是當前存在事務，則加入該事務；若是當前沒有事務，則建立一個新的事務。這是默認值。
- TransactionDefinition.PROPAGATION_REQUIRES_NEW：建立一個新的事務，若是當前存在事務，則把當前事務掛起。
- TransactionDefinition.PROPAGATION_SUPPORTS：若是當前存在事務，則加入該事務；若是當前沒有事務，則以非事務的方式繼續運行。
- TransactionDefinition.PROPAGATION_NOT_SUPPORTED：以非事務方式運行，若是當前存在事務，則把當前事務掛起。
- TransactionDefinition.PROPAGATION_NEVER：以非事務方式運行，若是當前存在事務，則拋出異常。
- TransactionDefinition.PROPAGATION_MANDATORY：若是當前存在事務，則加入該事務；若是當前沒有事務，則拋出異常。
- TransactionDefinition.PROPAGATION_NESTED：若是當前存在事務，則建立一個事務做爲當前事務的嵌套事務來運行；若是當前沒有事務，則該取值等價於TransactionDefinition.PROPAGATION_REQUIRED。
事務回滾規則
指示spring事務管理器回滾一個事務的推薦方法是在當前事務的上下文內拋出異常。spring事務管理器會捕捉任何未處理的異常，而後依據規則決定是否回滾拋出異常的事務。 默認配置下，spring只有在拋出的異常爲運行時unchecked異常時纔回滾該事務，也就是拋出的異常爲RuntimeException的子類(Errors也會致使事務回滾)，而拋出checked異常則不會致使事務回滾。 能夠明確的配置在拋出那些異常時回滾事務，包括checked異常。也能夠明肯定義那些異常拋出時不回滾事務。spring
事務經常使用配置
- readOnly：該屬性用於設置當前事務是否爲只讀事務，設置爲true表示只讀，false則表示可讀寫，默認值爲false。例如：@Transactional(readOnly=true)；
- rollbackFor： 該屬性用於設置須要進行回滾的異常類數組，當方法中拋出指定異常數組中的異常時，則進行事務回滾。例如：指定單一異常類：@Transactional(rollbackFor=RuntimeException.class)指定多個異常類：@Transactional(rollbackFor={RuntimeException.class, Exception.class})；
- rollbackForClassName： 該屬性用於設置須要進行回滾的異常類名稱數組，當方法中拋出指定異常名稱數組中的異常時，則進行事務回滾。例如：指定單一異常類名稱@Transactional(rollbackForClassName=」RuntimeException」)指定多個異常類名稱：@Transactional(rollbackForClassName={「RuntimeException」,」Exception」})。
- noRollbackFor：該屬性用於設置不須要進行回滾的異常類數組，當方法中拋出指定異常數組中的異常時，不進行事務回滾。例如：指定單一異常類：@Transactional(noRollbackFor=RuntimeException.class)指定多個異常類：@Transactional(noRollbackFor={RuntimeException.class, Exception.class})。
- noRollbackForClassName：該屬性用於設置不須要進行回滾的異常類名稱數組，當方法中拋出指定異常名稱數組中的異常時，不進行事務回滾。例如：指定單一異常類名稱：@Transactional(noRollbackForClassName=」RuntimeException」)指定多個異常類名稱：@Transactional(noRollbackForClassName={「RuntimeException」,」Exception」})。
- propagation ： 該屬性用於設置事務的傳播行爲。例如：@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true)。
- isolation：該屬性用於設置底層數據庫的事務隔離級別，事務隔離級別用於處理多事務併發的狀況，一般使用數據庫的默認隔離級別便可，基本不須要進行設置。
- timeout：該屬性用於設置事務的超時秒數，默認值爲-1表示永不超時。
事物注意事項
- 要根據實際的需求來決定是否要使用事物，最好是在編碼以前就考慮好，否則到之後就難以維護；
- 若是使用了事物，請務必進行事物測試，由於不少狀況下覺得事物是生效的，可是實際上可能未生效！
- 事物@Transactional的使用要放再類的公共(public)方法中，須要注意的是在 protected、private 方法上使用 @Transactional 註解，它也不會報錯(IDEA會有提示)，但事務無效。
- 事物@Transactional是不會對該方法裏面的子方法生效！也就是你在公共方法A聲明的事物@Transactional，可是在A方法中有個子方法B和C，其中方法B進行了數據操做，可是該異常被B本身處理了，這樣的話事物是不會生效的！反之B方法聲明的事物@Transactional，可是公共方法A卻未聲明事物的話，也是不會生效的！若是想事物生效，須要將子方法的事務控制交給調用的方法，在子方法中使用
rollbackFor註解指定須要回滾的異常或者將異常拋出交給調用的方法處理。一句話就是在使用事物的時候子方法最好將異常拋出！ - 事物@Transactional由spring控制的時候，它會在拋出異常的時候進行回滾。若是本身使用catch捕獲了處理了，是不生效的，若是想生效能夠進行手動回滾或者在catch裏面將異常拋出，好比
throw new RuntimeException();。
開發準備
環境要求sql
JDK：1.8數據庫
SpringBoot：1.5.17.RELEASE編程
首先仍是Maven的相關依賴:
pom.xml文件以下:
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.17.RELEASE</version>
<relativePath />
</parent>
<dependencies>
<!-- Spring Boot Web 依賴 核心 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Spring Boot Test 依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.2.0</version>
</dependency>
<!-- MySQL 鏈接驅動依賴 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.44</version>
</dependency>
<!-- Druid 數據鏈接池依賴 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.8</version>
</dependency>
</dependencies>
複製代碼
application.properties的文件的配置:
banner.charset=UTF-8
server.tomcat.uri-encoding=UTF-8
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
spring.messages.encoding=UTF-8
spring.application.name=springboot-transactional
server.port=8182
spring.datasource.url=jdbc:mysql://localhost:3306/springBoot?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driverClassName=com.mysql.jdbc.Driver
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
spring.datasource.maxWait=60000
spring.datasource.timeBetweenEvictionRunsMillis=60000
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.filters=stat,wall,log4j
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
logging.level.com.pancm.dao=debug
複製代碼
代碼編寫
SpringBoot在使用事物Transactional的時候，要在main方法上加上 @EnableTransactionManagement 註解開發事物聲明，在使用的service層的公共方法加上 @Transactional (spring)註解。
使用示例一
那麼首先咱們來看下 @Transactional 這個註解的使用方法吧，只須要你在須要添加公共方法上面添加該註解便可。可是這麼使用的話須要你將異常拋出，由spring進行去控制。
代碼示例:
@Transactional
public boolean test1(User user) throws Exception {
long id = user.getId();
System.out.println("查詢的數據1:" + udao.findById(id));
// 新增兩次，會出現主鍵ID衝突，看是否能夠回滾該條數據
udao.insert(user);
System.out.println("查詢的數據2:" + udao.findById(id));
udao.insert(user);
return false;
}
複製代碼
使用示例二
若是咱們在使用事物 @Transactional 的時候，想本身對異常進行處理的話，那麼咱們能夠進行手動回滾事物。在catch中加上 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); 方法進行手動回滾。不過須要注意的是發生異常須要第一時間進行手動回滾事物，也就是要在異常拋出以前！
代碼示例:
@Transactional
public boolean test2(User user) {
long id = user.getId();
try {
System.out.println("查詢的數據1:" + udao.findById(id));
// 新增兩次，會出現主鍵ID衝突，看是否能夠回滾該條數據
udao.insert(user);
System.out.println("查詢的數據2:" + udao.findById(id));
udao.insert(user);
} catch (Exception e) {
System.out.println("發生異常,進行手動回滾！");
// 手動回滾事物
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
e.printStackTrace();
}
return false;
}
複製代碼
使用示例三
若是咱們在使用事物 @Transactional 的時候，調用了其餘的子方法進行了數據庫的操做，可是咱們想使其事物生效的話，咱們可使用rollbackFor註解或者將該子方法的異常拋出由調用的方法進行處理，不過這裏須要注意的是，子方法也必須是公共的方法！
代碼示例:
@Transactional
public boolean test3(User user) {
/*
* 子方法出現異常進行回滾
*/
try {
System.out.println("查詢的數據1:" + udao.findById(user.getId()));
deal1(user);
deal2(user);
deal3(user);
} catch (Exception e) {
System.out.println("發生異常,進行手動回滾！");
// 手動回滾事物
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
e.printStackTrace();
}
return false;
}
public void deal1(User user) throws SQLException {
udao.insert(user);
System.out.println("查詢的數據2:" + udao.findById(user.getId()));
}
public void deal2(User user) throws SQLException{
if(user.getAge()<20){
//SQL異常
udao.insert(user);
}else{
user.setAge(21);
udao.update(user);
System.out.println("查詢的數據3:" + udao.findById(user.getId()));
}
}
@Transactional(rollbackFor = SQLException.class)
public void deal3(User user) {
if(user.getAge()>20){
//SQL異常
udao.insert(user);
}
}
複製代碼
使用示例四
若是咱們不想使用事物 @Transactional 註解，想本身進行事物控制(編程事物管理)，控制某一段的代碼事物生效，可是又不想本身去編寫那麼多的代碼，那麼可使用springboot中的DataSourceTransactionManager和TransactionDefinition這兩個類來結合使用，可以達到手動控制事物的提交回滾。不過在進行使用的時候，須要注意在回滾的時候，要確保開啓了事物可是未提交，若是未開啓或已提交的時候進行回滾是會在catch裏面發生異常的！
代碼示例:
@Autowired
private DataSourceTransactionManager dataSourceTransactionManager;
@Autowired
private TransactionDefinition transactionDefinition;
public boolean test4(User user) {
/*
* 手動進行事物控制
*/
TransactionStatus transactionStatus=null;
boolean isCommit = false;
try {
transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
System.out.println("查詢的數據1:" + udao.findById(user.getId()));
// 進行新增/修改
udao.insert(user);
System.out.println("查詢的數據2:" + udao.findById(user.getId()));
if(user.getAge()<20) {
user.setAge(user.getAge()+2);
udao.update(user);
System.out.println("查詢的數據3:" + udao.findById(user.getId()));
}else {
throw new Exception("模擬一個異常!");
}
//手動提交
dataSourceTransactionManager.commit(transactionStatus);
isCommit= true;
System.out.println("手動提交事物成功!");
throw new Exception("模擬第二個異常!");
} catch (Exception e) {
//若是未提交就進行回滾
if(!isCommit){
System.out.println("發生異常,進行手動回滾！");
//手動回滾事物
dataSourceTransactionManager.rollback(transactionStatus);
}
e.printStackTrace();
}
return false;
}
複製代碼
上述的這幾種示例是比較常見使用的，基本能夠知足平常咱們對事物的使用，spring裏面還有一種事物的控制方法，就是設置斷點進行回滾。可是這種方法我的還沒實際驗證過，可靠性待確認。 使用方法以下:
Object savePoint =null;
try{
//設置回滾點
savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
}catch(Exception e){
//出現異常回滾到savePoint。
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
}
複製代碼
上面的使用示例介紹完畢以後，咱們再來介紹一下幾個主要的類。
首先仍是實體類:
實體類
又是萬能的用戶表
public class User {
private Long id;
private String name;
private Integer age;
//getter 和 setter 略
}
複製代碼
Controller 控制層
而後即是控制層，控制層這塊的我作了下最後的查詢，用於校驗事物是否成功生效！
控制層代碼以下:
@RestController
@RequestMapping(value = "/api/user")
public class UserRestController {
@Autowired
private UserService userService;
@Autowired
private UserDao userDao;
@PostMapping("/test1")
public boolean test1(@RequestBody User user) {
System.out.println("請求參數:" + user);
try {
userService.test1(user);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("最後查詢的數據:" + userDao.findById(user.getId()));
return true;
}
@PostMapping("/test2")
public boolean test2(@RequestBody User user) {
System.out.println("請求參數:" + user);
userService.test2(user);
System.out.println("最後查詢的數據:" + userDao.findById(user.getId()));
return true;
}
@PostMapping("/test3")
public boolean test3(@RequestBody User user) {
System.out.println("請求參數:" + user);
userService.test3(user);
System.out.println("最後查詢的數據:" + userDao.findById(user.getId()));
return true;
}
@PostMapping("/test4")
public boolean test4(@RequestBody User user) {
System.out.println("請求參數:" + user);
userService.test4(user);
System.out.println("最後查詢的數據:" + userDao.findById(user.getId()));
return true;
}
}
複製代碼
App 入口
和普通的SpringBoot項目基本同樣，只不過須要加上 @EnableTransactionManagement 註解！
代碼以下:
@EnableTransactionManagement
@SpringBootApplication
public class TransactionalApp
{
public static void main( String[] args )
{
SpringApplication.run(TransactionalApp.class, args);
System.out.println("Transactional 程序正在運行...");
}
}
複製代碼
功能測試
咱們在啓動程序以後，來進行上述的幾個示例測試，這裏的測試示例分別對應上述的使用示例，有的示例須要測試兩邊以上才能驗證事物是否可以生效！這裏咱們使用Postman進行測試！
測試示例一
兩次測試，第一次不使用@Transactional註解，第二次使用！
第一次測試:
註釋掉@Transactional註解！ 使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":18}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=18]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=18]
Duplicate entry '1' for key 'PRIMARY'
最後查詢的數據:User [id=1, name=xuwujing, age=18]
複製代碼
第二次測試:
解除@Transactional註解註釋！
使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":18}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=18]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=18]
Duplicate entry '1' for key 'PRIMARY'
最後查詢的數據:null
複製代碼
注: 在第二次測試的以前是把第一次測試寫入數據庫的id爲1的數據個刪除了！
第一次測試中因爲沒有添加@Transactional註解，所以發生了異常數據仍是寫入了，可是第二次測試中添加了@Transactional註解，發現即便數據已經寫入了，可是出現了異常以後，數據最終被回滾了，沒有寫入！ 從上述的測試用例中能夠看到測試用例一種的事物已經生效了！
測試示例二
因爲使用示例二中的代碼幾乎和使用示例一種的同樣，不一樣的是異常由咱們本身進行控制！
使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":18}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=18]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=18]
發生異常,進行手動回滾!
Duplicate entry '1' for key 'PRIMARY'
最後查詢的數據:null
複製代碼
能夠看到事物生效了！
測試示例三
因爲使用示例三中進行了子方法調用，這裏咱們進行兩次測試，根據不一樣的請求條件來進行測試！
第一次測試:
使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":18}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=18]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=18]
發生異常,進行手動回滾！
Duplicate entry '1' for key 'PRIMARY'
最後查詢的數據:null
複製代碼
第二次測試:
使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":21}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=21]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=21]
查詢的數據3:User [id=1, name=xuwujing2, age=21]
發生異常,進行手動回滾！
Duplicate entry '1' for key 'PRIMARY'
最後查詢的數據:null
複製代碼
根據上述的兩次測試，能夠得出使用rollbackFor註解或者將該子方法的異常拋出由調用的方法進行處理均可以使事物生效！
測試示例四
因爲使用示例四中進行了手動控制事物，這裏咱們進行兩次測試，根據不一樣的請求條件來進行測試！
第一次測試:
使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":18}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=18]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=18]
查詢的數據3:User [id=1, name=xuwujing2, age=20]
手動提交事物成功!
模擬第二個異常!
最後查詢的數據:User [id=1, name=xuwujing, age=20]
複製代碼
第二次測試:
事先仍是把數據庫id爲1的數據給刪除！
使用進行POST請求
Body參數爲:
{"id":1,"name":"xuwujing","age":21}
控制檯打印的數據:
請求參數:User [id=1, name=xuwujing, age=21]
查詢的數據1:null
查詢的數據2:User [id=1, name=xuwujing, age=21]
發生異常,進行手動回滾！
模擬一個異常!
最後查詢的數據:null
複製代碼
根據上述的兩次測試，咱們能夠得出使用手動控制事物徹底ok，只要提交了事物，即便後面發生了異常也不回影響以前的寫入！若是在控制的範圍之類發生了異常，也能夠進行回滾！
測試示例圖:
其它
參考: www.cnblogs.com/yepei/p/471…
項目地址
SpringBoot 事物Transaction的項目工程地址: github.com/xuwujing/sp…
SpringBoot整個集合的地址: github.com/xuwujing/sp…
SpringBoot整合系列的文章
音樂推薦
原創不易，若是感受不錯，但願給個推薦！您的支持是我寫做的最大動力！ 版權聲明: 做者：虛無境 博客園出處：www.cnblogs.com/xuwujing CSDN出處：blog.csdn.net/qazwsxpcm 我的博客出處：www.panchengming.com
- 1. SpringBoot事物Transaction實戰講解教程
- 2. redis事物transaction
- 3. 視頻教程-SpringBoot實戰教程：SpringBoot 博客項目開發及講解-Java
- 4. SQL SERVER TRANSACTION 事物
- 5. ****-SpringBoot實戰教程：SpringBoot企業級線上商城項目講解-Java
- 6. SpringBoot源碼之事物 Transaction官方文檔翻譯
- 7. angular.js 教程 -- 實例講解
- 8. MySQL事物實戰篇
- 9. 技術管理實戰36講教程
- 10. [SpringBoot實戰雜記]事務
- 更多相關文章...
- • SQLite 事務（Transaction） - SQLite教程
- • MySQL事務（TRANSACTION） - MySQL教程
- • Java 8 Stream 教程
- • YAML 入門教程
-
每一个你不满意的现在，都有一个你没有努力的曾经。