Spring事物的傳播特性詳解
一、事務(wù)的傳播性
研究的是多個事務(wù)存在時的處理策略
1）REQUIRED：如果存在一個事務(wù)，則支持當(dāng)前事務(wù)，如果當(dāng)前沒有事務(wù)，就新建一個事務(wù)。這是最常見的選擇。
2）SUPPORTS：如果存在一個事務(wù)，支持當(dāng)前事務(wù)，如果當(dāng)前沒有事務(wù)，就以非事務(wù)方式執(zhí)行。
3）MANDATORY：如果存在一個事務(wù)，支持當(dāng)前事務(wù)，如果當(dāng)前沒有事務(wù)，就拋出異常。
4）REQUIRES_NEW：新建事務(wù)，如果當(dāng)前存在事務(wù)，把當(dāng)前事務(wù)掛起。
5）NOT_SUPPORTED：以非事務(wù)方式執(zhí)行操作，如果當(dāng)前存在事務(wù)，就把當(dāng)前事務(wù)掛起。
6）NEVER：以非事務(wù)方式執(zhí)行，如果當(dāng)前存在事務(wù)，則拋出異常。
7）NESTED：支持當(dāng)前事務(wù)，新增Savepoint點，與當(dāng)前事務(wù)同步提交或回滾。
二、測試前準(zhǔn)備
2.1、準(zhǔn)備好數(shù)據(jù)庫表
數(shù)據(jù)庫transaction_propagation
賬號表account、書本表book、庫存表book_stock
SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- ---------------------------- -- Table structure for account -- ---------------------------- DROP TABLE IF EXISTS `account`; CREATE TABLE `account` ( `user_id` int(11) NOT NULL AUTO_INCREMENT, `user_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL, `balance` double(11, 2) UNSIGNED NULL DEFAULT NULL, PRIMARY KEY (`user_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic STORAGE MEMORY; -- ---------------------------- -- Records of account -- ---------------------------- INSERT INTO `account` VALUES (1, 'Albert', 100.00); -- ---------------------------- -- Table structure for book -- ---------------------------- DROP TABLE IF EXISTS `book`; CREATE TABLE `book` ( `book_id` int(11) NOT NULL AUTO_INCREMENT, `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL, `price` double(11, 2) UNSIGNED NULL DEFAULT NULL, PRIMARY KEY (`book_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 1003 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of book -- ---------------------------- INSERT INTO `book` VALUES (1001, '基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)', 60.00); INSERT INTO `book` VALUES (1002, '數(shù)據(jù)庫設(shè)計', 50.00); -- ---------------------------- -- Table structure for book_stock -- ---------------------------- DROP TABLE IF EXISTS `book_stock`; CREATE TABLE `book_stock` ( `book_id` int(11) NOT NULL AUTO_INCREMENT, `stock` int(11) UNSIGNED NULL DEFAULT NULL, PRIMARY KEY (`book_id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 1003 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic; -- ---------------------------- -- Records of book_stock -- ---------------------------- INSERT INTO `book_stock` VALUES (1001, 100); INSERT INTO `book_stock` VALUES (1002, 100); SET FOREIGN_KEY_CHECKS = 1;
2.2、初始化spring項目
導(dǎo)入一些基本依賴包：jdbc、mysql驅(qū)動包、測試模塊;
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
2.3、數(shù)據(jù)庫連接信息配置
#jdbc
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost/transaction_propagation?useUnicode=true&characterEncoding=utf-8
username: root
password: 123456
2.4、Service、Dao
這里只使用測試調(diào)用，省略controller以及entity等層構(gòu)；
1、首先Dao類，編寫一個購買的簡單操作：查詢單價、更新庫存、更新賬戶余額；
@Repository
public class BookShopDao {
@Autowired
private JdbcTemplate jdbcTemplate = new JdbcTemplate();
public double getPriceById(Integer bookId) {
String sql = "SELECT price FROM BOOK WHERE book_id = ?";
double price = jdbcTemplate.query(sql, new PreparedStatementSetter() {
@Override
public void setValues(PreparedStatement preparedStatement) throws SQLException {
preparedStatement.setInt(1, bookId);
}
}, new ResultSetExtractor<Double>() {
@Override
public Double extractData(ResultSet resultSet) throws SQLException, DataAccessException {
double p = 0.0;
while (resultSet.next()) {
p = resultSet.getDouble("price");
}
return p;
}
});
return price;
}
public void updateBookStock(Integer bookId, int num) {
String sql = "UPDATE book_stock SET stock = stock - ? WHERE book_id = ?";
jdbcTemplate.update(sql, new PreparedStatementSetter() {
@Override
public void setValues(PreparedStatement preparedStatement) throws SQLException {
preparedStatement.setInt(1, num);
preparedStatement.setInt(2, bookId);
}
});
}
public void updateBalance(Integer userId, double balance) {
//修改金額
String sql = "UPDATE account SET balance = balance - ? WHERE user_id = ?";
jdbcTemplate.update(sql, new PreparedStatementSetter() {
@Override
public void setValues(PreparedStatement preparedStatement) throws SQLException {
preparedStatement.setDouble(1, balance);
preparedStatement.setInt(2, userId);
}
});
}
}
2、研究事務(wù)傳播學(xué)性其實就是研究兩個以上的事務(wù)在嵌套時的應(yīng)用方式，所以這里需要寫兩個Service進(jìn)行嵌套調(diào)用；接口類此處省略BookShopServiceImpl 中的purchase用@Transactional是指一個購買單進(jìn)來必須保證（1、2、3）的原子性；
@Service
public class BookShopServiceImpl implements BookShopService {
@Autowired
private BookShopDao bookShopDao;
@Transactional
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
}
CashierServiceImpl 中buy方法中的@Transactional是指一個訂單中出現(xiàn)多個購買單進(jìn)來必須保證的原子性；
因為一個訂單可能包含幾種商品的購買。
@Service
public class CashierServiceImpl implements CashierService {
@Autowired
private BookShopService bookShopService;
@Transactional
@Override
public void buy(List<Map<String,Object>> buys){
for (Map map : buys){
//購買
bookShopService.purchase((Integer) map.get("userId"),(Integer)map.get("bookId"),(int)map.get("num"));
}
}
}
2.5、測試類
@SpringBootTest
public class TestBuy {
@Autowired
private CashierService cashierService;
@Test
void testBookShop(){
List<Map<String,Object>> list = new ArrayList<>();
Map<String,Object> map = new HashMap<>();
map.put("userId",1);
map.put("bookId",1001);
map.put("num",1);
list.add(map);
map = new HashMap<>();
map.put("userId",1);
map.put("bookId",1002);
map.put("num",1);
list.add(map);
try {
cashierService.buy(list);
}catch (Exception e){
e.printStackTrace();
}
System.out.println("購買成功！");
}
}
2.6、說明
以上是使用spring默認(rèn)的事務(wù)傳播：REQUIRED，purchase使用同一個事務(wù)提交。那就會出現(xiàn)這樣的問題：賬戶上有100塊錢，現(xiàn)在提交訂單是買一本60塊錢的《基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)》以及一本50塊錢的《數(shù)據(jù)庫設(shè)計》；那么訂單總金額是110元，顯然賬戶上余額是不足夠購買的，在第一次事務(wù)購買60塊錢的《基礎(chǔ)數(shù)據(jù)結(jié)構(gòu)》是成功的，但再提交50塊錢的《數(shù)據(jù)庫設(shè)計》的時候就會拋出異常，那這時在CashierServiceImpl 的外層事務(wù)中就會異常并回滾。
三、使用其他傳播性
3.1、REQUIRES_NEW
在purchase事務(wù)中聲明(propagation = Propagation.REQUIRES_NEW)；那么在每一次調(diào)用purchase時都會開啟一個新的事務(wù)去提交；那么此時進(jìn)行購買測試結(jié)果：第一本書就會購買成功，第二本書購買失??；因為異?；貪L的是第二次調(diào)用的purchase事務(wù)。
@Transactional(propagation = Propagation.REQUIRES_NEW)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
3.2、MANDATORY
會強(qiáng)制要求一個事務(wù)提交，否則拋出異常，測試結(jié)果與REQUIRED一樣，回滾整個訂單。
@Transactional(propagation = Propagation.MANDATORY)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
如果外層沒有事務(wù)就拋出異常
** No existing transaction found for transaction marked with propagation ‘mandatory'**
3.3、SUPPORTS
如果外層存在事務(wù)則以事務(wù)提交，測試結(jié)果與REQUIRED一樣，回滾整個訂單。
@Transactional(propagation = Propagation.SUPPORTS)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
如果外層不存在事務(wù)，則不以事務(wù)提交，將可以成功購買一本書；
3.4、NOT_SUPPORTED
以非事務(wù)方式執(zhí)行操作，如果當(dāng)前存在事務(wù)，就把當(dāng)前事務(wù)掛起。即外層是否有事務(wù)都不會影響結(jié)果：有一本書可購買成功。
@Transactional(propagation = Propagation.NOT_SUPPORTED)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
3.5、NEVER
強(qiáng)制要求不能存在事務(wù)，否則拋出異常
@Transactional(propagation = Propagation.NEVER)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
存在事務(wù)則拋出異常：
Existing transaction found for transaction marked with propagation ‘never'
3.6、NESTED
支持當(dāng)前事務(wù)，新增Savepoint點，與當(dāng)前事務(wù)同步提交或回滾。 結(jié)果與REQUIRES一樣，回滾整個訂單。
@Transactional(propagation = Propagation.NESTED)
@Override
public void purchase(Integer userId,Integer bookId,int num){
//1、獲取要購買的圖書價格
double price = bookShopDao.getPriceById(bookId);
//2、更新圖書庫存
bookShopDao.updateBookStock(bookId,num);
//3、更新用戶余額
bookShopDao.updateBalance(userId,price*num);
}
到此這篇關(guān)于Spring事物的傳播性詳解的文章就介紹到這了,更多相關(guān)Spring事物的傳播性內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
本章簡要介紹GC的基本原理和相關(guān)技術(shù), 下一章節(jié)再詳細(xì)講解GC算法的具體實現(xiàn)。各種垃圾收集器的實現(xiàn)細(xì)節(jié)雖然并不相同,但總體而言,垃圾收集器都專注于兩件事情:查找所有存活對象，拋棄其他的部分,即死對象,不再使用的對象2022-01-01
SSH框架網(wǎng)上商城項目第7戰(zhàn)之整合Struts2和Json
SSH框架網(wǎng)上商城項目第7戰(zhàn)之整合Struts2和Json，打通EasyUI和Struts2之間的交互，感興趣的小伙伴們可以參考一下2016-05-05
SpringBoot整合Redis并且用Redis實現(xiàn)限流的方法 附Redis解壓包
這篇文章主要介紹了SpringBoot整合Redis并且用Redis實現(xiàn)限流的方法 附Redis解壓包,本文給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-06-06
在@Value注解內(nèi)使用SPEL自定義函數(shù)方式
這篇文章主要介紹了在@Value注解內(nèi)使用SPEL自定義函數(shù)方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-02-02
Java線程狀態(tài)及切換、關(guān)閉線程的正確姿勢分享
這篇文章主要給大家介紹了關(guān)于Java線程狀態(tài)及切換、關(guān)閉線程的正確姿勢，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者使用Java具有一定的參考學(xué)習(xí)價值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2019-10-10
這篇文章主要介紹了JDK反序列化時修改類的全限定性名解析，具有一定借鑒價值，需要的朋友可以參考下。2017-12-12
解決struts2 攔截器修改request的parameters參數(shù)失敗的問題
這篇文章主要介紹了解決struts2 攔截器修改request的parameters參數(shù)失敗的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
本文介紹了如何創(chuàng)建和使用Spring框架,包括模塊創(chuàng)建、依賴引入、環(huán)境搭建、Bean的生命周期管理、AOP編程以及代碼托管,通過實際操作和代碼示例,詳細(xì)講解了Spring的核心概念和功能2024-12-12
本篇文章主要介紹了Spring依賴注入的三種方式小結(jié)，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2021-07-07
解決swagger2中@ApiResponse的response不起作用
這篇文章主要介紹了解決swagger2中@ApiResponse的response不起作用問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06