欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Spring事物的傳播特性詳解

 更新時間：2021年05月07日 08:40:04   作者：Albert_GW  
這篇文章主要介紹了Spring事物的傳播性詳解,文中有非常詳細(xì)的代碼示例,對正在學(xué)習(xí)java的小伙伴們有非常好的幫助,需要的朋友可以參考下

一、事務(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é)果：第一本書就會購買成功，第二本書購買失??；因為異常回滾的是第二次調(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)文章

  • springboot集成Swagger的方法(讓你擁有屬于自己的api管理器)

    springboot集成Swagger的方法(讓你擁有屬于自己的api管理器)

    在大型的項目中，如果你有非常多的接口需要統(tǒng)一管理，或者需要進(jìn)行接口測試，那么我們通常會在繁雜地api中找到需要進(jìn)行測試或者管理的接口,接下來通過本文給大家介紹springboot集成Swagger的方法讓你擁有屬于自己的api管理器，感興趣的朋友一起看看吧
    2021-11-11
  • Java中hashMap遍歷的9種方式

    Java中hashMap遍歷的9種方式

    hashMap是非常重要的容器類,本文主要介紹了Java中hashMap遍歷的9種方式,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2024-06-06
  • SpringCloud集成Eureka并實現(xiàn)負(fù)載均衡的過程詳解

    SpringCloud集成Eureka并實現(xiàn)負(fù)載均衡的過程詳解

    這篇文章主要給大家詳細(xì)介紹了SpringCloud集成Eureka并實現(xiàn)負(fù)載均衡的過程,文章通過代碼示例和圖文講解的非常詳細(xì),對大家的學(xué)習(xí)或工作有一定的參考價值,需要的朋友可以參考下
    2023-11-11
  • Java實現(xiàn)發(fā)送短信驗證碼功能

    Java實現(xiàn)發(fā)送短信驗證碼功能

    這篇文章主要為大家詳細(xì)介紹了Java實現(xiàn)發(fā)送短信驗證碼功能，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2017-11-11
  • java多線程編程之join方法的使用示例

    java多線程編程之join方法的使用示例

    join方法的功能就是使異步執(zhí)行的線程變成同步執(zhí)行。也就是說，當(dāng)調(diào)用線程實例的start方法后，這個方法會立即返回，如果在調(diào)用start方法后后需要使用一個由這個線程計算得到的值，就必須使用join方法
    2014-01-01
  • Java實現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫的方法

    Java實現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫的方法

    這篇文章主要介紹了Java實現(xiàn)基于JDBC操作mysql數(shù)據(jù)庫的方法,結(jié)合實例形式分析了java使用JDBC實現(xiàn)針對mysql數(shù)據(jù)庫的連接、查詢、輸出等相關(guān)操作技巧,需要的朋友可以參考下
    2017-12-12
  • spring cglib 與 jdk 動態(tài)代理

    spring cglib 與 jdk 動態(tài)代理

    本篇文章主要介紹了spring cglib與jdk動態(tài)代理的相關(guān)知識，具有很好的參考價值。下面跟著小編一起來看下吧
    2017-05-05
  • Java中Static關(guān)鍵字的五種用法詳解

    Java中Static關(guān)鍵字的五種用法詳解

    這篇文章主要介紹了Java中static的五種用法：修飾成員變量，修飾成員方法，修飾內(nèi)部類，靜態(tài)代碼塊，靜態(tài)導(dǎo)包，想詳細(xì)了解的小伙伴可以參考閱讀本文
    2023-03-03
  • 在IDEA中實現(xiàn)同時運(yùn)行2個相同的java程序

    在IDEA中實現(xiàn)同時運(yùn)行2個相同的java程序

    這篇文章主要介紹了在IDEA中實現(xiàn)同時運(yùn)行2個相同的java程序，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-02-02
  • arthas排查jvm中CPU占用過高問題解決

    arthas排查jvm中CPU占用過高問題解決

    這篇文章主要介紹了arthas排查jvm中CPU占用過高問題解決,有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
    2022-09-09

最新評論