Spring事物的傳播特性詳解

發(fā)布時(shí)間：2021-07-17 21:51 來(lái)源：腳本之家閱讀：0 作者：Albert_GW 欄目：編程語(yǔ)言歡迎投稿：712375056

一、事務(wù)的傳播性

研究的是多個(gè)事務(wù)存在時(shí)的處理策略

1）REQUIRED：如果存在一個(gè)事務(wù)，則支持當前事務(wù)，如果當前沒(méi)有事務(wù)，就新建一個(gè)事務(wù)。這是最常見(jiàn)的選擇。

2）SUPPORTS：如果存在一個(gè)事務(wù)，支持當前事務(wù)，如果當前沒(méi)有事務(wù)，就以非事務(wù)方式執行。

3）MANDATORY：如果存在一個(gè)事務(wù)，支持當前事務(wù)，如果當前沒(méi)有事務(wù)，就拋出異常。

4）REQUIRES_NEW：新建事務(wù)，如果當前存在事務(wù)，把當前事務(wù)掛起。

5）NOT_SUPPORTED：以非事務(wù)方式執行操作，如果當前存在事務(wù)，就把當前事務(wù)掛起。

6）NEVER：以非事務(wù)方式執行，如果當前存在事務(wù)，則拋出異常。

7）NESTED：支持當前事務(wù)，新增Savepoint點(diǎn)，與當前事務(wù)同步提交或回滾。

二、測試前準備

2.1、準備好數據庫表

數據庫transaction_propagation

賬號表account、書(shū)本表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, '基礎數據結構', 60.00);
INSERT INTO `book` VALUES (1002, '數據庫設計', 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項目

導入一些基本依賴(lài)包：jdbc、mysql驅動(dòng)包、測試模塊;

 <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、數據庫連接信息配置

#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

這里只使用測試調用，省略controller以及entity等層構；

1、首先Dao類(lèi)，編寫(xiě)一個(gè)購買(mǎi)的簡(jiǎn)單操作：查詢(xún)單價(jià)、更新庫存、更新賬戶(hù)余額；

@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é)性其實(shí)就是研究?jì)蓚€(gè)以上的事務(wù)在嵌套時(shí)的應用方式，所以這里需要寫(xiě)兩個(gè)Service進(jìn)行嵌套調用；接口類(lèi)此處省略BookShopServiceImpl 中的purchase用@Transactional是指一個(gè)購買(mǎi)單進(jìn)來(lái)必須保證（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、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }
}

CashierServiceImpl 中buy方法中的@Transactional是指一個(gè)訂單中出現多個(gè)購買(mǎi)單進(jìn)來(lái)必須保證的原子性；

因為一個(gè)訂單可能包含幾種商品的購買(mǎi)。

@Service
public class CashierServiceImpl implements CashierService {

    @Autowired
    private BookShopService bookShopService;


    @Transactional
    @Override
    public void buy(List<Map<String,Object>> buys){
        for (Map map : buys){
            //購買(mǎi)
            bookShopService.purchase((Integer) map.get("userId"),(Integer)map.get("bookId"),(int)map.get("num"));
        }
    }
}

2.5、測試類(lèi)

@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("購買(mǎi)成功！");
    }
}

2.6、說(shuō)明

以上是使用spring默認的事務(wù)傳播：REQUIRED，purchase使用同一個(gè)事務(wù)提交。那就會(huì )出現這樣的問(wèn)題：賬戶(hù)上有100塊錢(qián)，現在提交訂單是買(mǎi)一本60塊錢(qián)的《基礎數據結構》以及一本50塊錢(qián)的《數據庫設計》；那么訂單總金額是110元，顯然賬戶(hù)上余額是不足夠購買(mǎi)的，在第一次事務(wù)購買(mǎi)60塊錢(qián)的《基礎數據結構》是成功的，但再提交50塊錢(qián)的《數據庫設計》的時(shí)候就會(huì )拋出異常，那這時(shí)在CashierServiceImpl 的外層事務(wù)中就會(huì )異常并回滾。

三、使用其他傳播性

3.1、REQUIRES_NEW

在purchase事務(wù)中聲明(propagation = Propagation.REQUIRES_NEW)；那么在每一次調用purchase時(shí)都會(huì )開(kāi)啟一個(gè)新的事務(wù)去提交；那么此時(shí)進(jìn)行購買(mǎi)測試結果：第一本書(shū)就會(huì )購買(mǎi)成功，第二本書(shū)購買(mǎi)失??；因為異?；貪L的是第二次調用的purchase事務(wù)。

@Transactional(propagation = Propagation.REQUIRES_NEW)
    @Override
    public void purchase(Integer userId,Integer bookId,int num){

        //1、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }

3.2、MANDATORY

會(huì )強制要求一個(gè)事務(wù)提交，否則拋出異常，測試結果與REQUIRED一樣，回滾整個(gè)訂單。

@Transactional(propagation = Propagation.MANDATORY)
    @Override
    public void purchase(Integer userId,Integer bookId,int num){

        //1、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }

如果外層沒(méi)有事務(wù)就拋出異常

** No existing transaction found for transaction marked with propagation ‘mandatory'**

3.3、SUPPORTS

如果外層存在事務(wù)則以事務(wù)提交，測試結果與REQUIRED一樣，回滾整個(gè)訂單。

@Transactional(propagation = Propagation.SUPPORTS)
    @Override
    public void purchase(Integer userId,Integer bookId,int num){

        //1、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }

如果外層不存在事務(wù)，則不以事務(wù)提交，將可以成功購買(mǎi)一本書(shū)；

3.4、NOT_SUPPORTED

以非事務(wù)方式執行操作，如果當前存在事務(wù)，就把當前事務(wù)掛起。即外層是否有事務(wù)都不會(huì )影響結果：有一本書(shū)可購買(mǎi)成功。

@Transactional(propagation = Propagation.NOT_SUPPORTED)
    @Override
    public void purchase(Integer userId,Integer bookId,int num){

        //1、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }

3.5、NEVER

強制要求不能存在事務(wù)，否則拋出異常

@Transactional(propagation = Propagation.NEVER)
    @Override
    public void purchase(Integer userId,Integer bookId,int num){

        //1、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }

存在事務(wù)則拋出異常：

Existing transaction found for transaction marked with propagation ‘never'

3.6、NESTED

支持當前事務(wù)，新增Savepoint點(diǎn)，與當前事務(wù)同步提交或回滾。結果與REQUIRES一樣，回滾整個(gè)訂單。

@Transactional(propagation = Propagation.NESTED)
    @Override
    public void purchase(Integer userId,Integer bookId,int num){

        //1、獲取要購買(mǎi)的圖書(shū)價(jià)格
        double price = bookShopDao.getPriceById(bookId);
        //2、更新圖書(shū)庫存
        bookShopDao.updateBookStock(bookId,num);

        //3、更新用戶(hù)余額
        bookShopDao.updateBalance(userId,price*num);
    }

到此這篇關(guān)于Spring事物的傳播性詳解的文章就介紹到這了,更多相關(guān)Spring事物的傳播性?xún)热菡埶阉髂_本之家以前的文章或繼續瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

免責聲明：本站發(fā)布的內容（圖片、視頻和文字）以原創(chuàng )、來(lái)自本網(wǎng)站內容采集于網(wǎng)絡(luò )互聯(lián)網(wǎng)轉載等其它媒體和分享為主，內容觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如侵犯了原作者的版權，請告知一經(jīng)查實(shí)，將立刻刪除涉嫌侵權內容，聯(lián)系我們QQ:712375056，同時(shí)歡迎投稿傳遞力量。

上一篇新聞：
上一篇：Spring Boot Admin的使用詳解(Actuator監控接口)
下一篇新聞：
下一篇：Spring框架學(xué)習之AOP詳解

云主機8折虛擬主機6折

紅包可用于（云服務(wù)器、高防服務(wù)器、裸金屬服務(wù)器、高防IP、云數據庫、CDN加速）購買(mǎi)和續費

国产成人精品18p,天天干成人网,无码专区狠狠躁天天躁,美女脱精光隐私扒开免费观看

Spring事物的傳播特性詳解

目錄

一、事務(wù)的傳播性

二、測試前準備

2.1、準備好數據庫表

2.2、初始化spring項目

2.3、數據庫連接信息配置

2.4、Service、Dao

2.5、測試類(lèi)

2.6、說(shuō)明

三、使用其他傳播性

3.1、REQUIRES_NEW

3.2、MANDATORY

3.3、SUPPORTS

3.4、NOT_SUPPORTED

3.5、NEVER

3.6、NESTED

特網(wǎng)科技產(chǎn)品

解決方案

幫助與支持

其他鏈接

聯(lián)系我們

国产成人精品18p,天天干成人网,无码专区狠狠躁天天躁,美女脱精光隐私扒开免费观看

Spring事物的傳播特性詳解

目錄

一、事務(wù)的傳播性

二、測試前準備

2.1、準備好數據庫表

2.2、初始化spring項目

2.3、數據庫連接信息配置

2.4、Service、Dao

2.5、測試類(lèi)

2.6、說(shuō)明

三、使用其他傳播性

3.1、REQUIRES_NEW

3.2、MANDATORY

3.3、SUPPORTS

3.4、NOT_SUPPORTED

3.5、NEVER

3.6、NESTED

最新資訊

相關(guān)推薦

相關(guān)標簽

特網(wǎng)科技產(chǎn)品

解決方案

幫助與支持

其他鏈接

聯(lián)系我們

一、事務(wù)的傳播性

二、測試前準備

2.1、準備好數據庫表

2.2、初始化spring項目

2.3、數據庫連接信息配置

2.4、Service、Dao

2.5、測試類(lèi)

2.6、說(shuō)明

三、使用其他傳播性

3.1、REQUIRES_NEW

3.2、MANDATORY

3.3、SUPPORTS

3.4、NOT_SUPPORTED

3.5、NEVER

3.6、NESTED