SpringBoot 快速开启事务（附常见坑点）

清疚 2021-10-23 23:22 180阅读 0赞

做一个积极的人编码、改bug、提升自己

我有一个乐园，面向编程，春暖花开！

![640?wx\_fmt=png][640_wx_fmt_png]

> 序言：此前，我们主要通过XML配置Spring来托管事务。在SpringBoot则非常简单，只需在业务层添加事务注解(@Transactional )即可快速开启事务。虽然事务很简单，但对于数据方面是需要谨慎对待的，识别常见坑点对我们开发有帮助。

### 1.引入依赖 ###

<dependencies>
            <dependency> 
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency> 
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>1.3.1</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

### 2. 添加配置 ###

主要是配置数据源和开启Mybatis的自动驼峰映射

@SpringBootApplication
    public class MybatisTransactionApplication {
    
        public static void main(String[] args) {
            //1.初始化
            SpringApplication application=  new SpringApplication(MybatisTransactionApplication.class);
    
            //2.添加数据源
            Map<String,Object> map = new HashMap<>();
            map.put("spring.datasource.url","jdbc:mysql://localhost:3306/socks?useSSL=false");
            map.put("spring.datasource.username","root");
            map.put("spring.datasource.password","root");
    
            //3.开启驼峰映射 (Such as account_id ==> accountId)
            map.put("mybatis.configuration.map-underscore-to-camel-case",true);
            application.setDefaultProperties(map);
    
            //4.启动应用
            application.run(args);
        }
    }

### 3. 添加数据库记录 ###

打开 Navicat 的查询窗口，然后执行以下SQL：

DROP TABLE IF EXISTS `account`;	
    CREATE TABLE `account` (	
      `account_id` varchar(30) ,	
      `account_name` varchar(30),	
      `balance` decimal(20,2),	
      PRIMARY KEY (`account_id`)	
    );	
    insert into account values ('1','admin','1000.25');

执行完毕后，可以查询到账户数据，如图：

![640?wx\_fmt=png][640_wx_fmt_png 1]

### 4. 编写代码 ###

以操作账户金额为例，模拟正常操作金额提交事务，以及发生异常回滚事务。其中控制层代码如下：

package com.hehe.controller;	
    @RestController	
    public class AccountController {	
        @SuppressWarnings("all")	
        @Autowired	
        AccountService accountService;	
        @GetMapping("/")	
        public Account getAccount() {	
            //查询账户	
            return accountService.getAccount();	
        }	
        @GetMapping("/add")	
        public Object addMoney() {	
            try {	
                accountService.addMoney();	
            } catch (Exception e) {	
                return "发生异常了：" + accountService.getAccount();	
            }	
            return getAccount();	
        }	
    }

在业务层使用 @Transactional 开启事务，执行数据库操作后抛出异常。具体代码如下：

package com.hehe.service;	
    @Service	
    public class AccountService {	
        @SuppressWarnings("all")	
        @Autowired	
        AccountMapper accountMapper;	
        public Account getAccount() {	
            return accountMapper.getAccount();	
        }	
        @Transactional	
        public void addMoney() throws Exception {	
            //先增加余额	
            accountMapper.addMoney();	
            //然后遇到故障	
            throw new RuntimeException("发生异常了..");	
        }	
    }

数据库层就很简单了，我们通过注解来实现账户数据的查询，具体如下：

package com.hehe.mapper;	
    @Mapper	
    public interface AccountMapper {	
        @Select("select * from account where account_id=1")	
        Account getAccount();	
        @Update("update account set balance = balance+100 where account_id=1")	
        void addMoney();	
    }

其中 Account 实体对象如下：

package com.hehe.pojo;	
    public class Account {	
        private String accountId;	
        private String accountName;	
        private BigDecimal balance;	
        // Override toString Method ..	
        // Getter & Setters  ..	
    }

### 5. 测试事务 ###

启动应用，访问 http://localhost:8080 ，可以看到账户数据，如下：

![640?wx\_fmt=png][640_wx_fmt_png 2]

然后访问 http://localhost:8080/add ，可以看到账户余额并没有增加，如下：

![640?wx\_fmt=png][640_wx_fmt_png 3]

也就是说事务开启成功，数据得到回滚。

### 6. 常见坑点 ###

> 使用事务注解@Transactional 之前，应该先了解它的相关属性，避免在实际项目中踩中各种各样的坑点。

常见坑点1：遇到检测异常时，事务默认不回滚。

例如下面这段代码，账户余额依旧增加成功，并没有因为后面遇到SQLException（检测异常）而进行事务回滚！！

@Transactional	
    public void addMoney() throws Exception {	
        //先增加余额	
        accountMapper.addMoney();	
        //然后遇到故障	
        throw new SQLException("发生异常了..");	
    }

原因分析：**因为Spring的默认的事务规则是遇到运行异常（RuntimeException及其子类）和程序错误（Error）才会进行事务回滚，显然SQLException并不属于这个范围**。如果想针对检测异常进行事务回滚，可以在@Transactional 注解里使用 rollbackFor 属性明确指定异常。例如下面这样，就可以正常回滚：

@Transactional(rollbackFor = Exception.class)	
    public void addMoney() throws Exception {	
        //先增加余额	
        accountMapper.addMoney();	
        //然后遇到故障	
        throw new SQLException("发生异常了..");	
    }

常见坑点2：在业务层捕捉异常后，发现事务不生效。

这是许多新手都会犯的一个错误，在业务层手工捕捉并处理了异常，你都把异常“吃”掉了，Spring自然不知道这里有错，更不会主动去回滚数据。例如：下面这段代码直接导致增加余额的事务回滚没有生效。

@Transactional	
    public void addMoney() throws Exception {	
        //先增加余额	
        accountMapper.addMoney();	
        //谨慎：尽量不要在业务层捕捉异常并处理	
        try {	
            throw new SQLException("发生异常了..");	
        } catch (Exception e) {	
            e.printStackTrace();	
        }	
    }

**不要小瞧了这些细节，往前暴露异常很大程度上很能够帮我们快速定位问题，而不是经常在项目上线后出现问题，却无法刨根知道哪里报错。**

推荐做法：若非实际业务要求，则在业务层统一抛出异常，然后在控制层统一处理。

@Transactional	
    public void addMoney() throws Exception {	
        //先增加余额	
        accountMapper.addMoney();	
        //推荐：在业务层将异常抛出	
        throw new RuntimeException("发生异常了..");	
    }

》》END《《

**推荐阅读**：

![640?][640][Spring中使用 @Transactional 注解配置事务管理详解][Spring_ _Transactional]

[一文学会Java死锁和CPU 100% 问题的排查技巧][Java_CPU 100_]

[【面试】MySQL 中NULL和空值的区别？][MySQL _NULL]

[Mybatis 批量插入引发的血案][Mybatis]

[Java内存管理-Stackoverflow问答-Java是传值还是传引用？（十一）][Java_-Stackoverflow_-Java]

[你有遇到过MySQL因大小写敏感导致的问题吗][MySQL]

[MySQL 的COUNT(x)性能怎么样？][MySQL _COUNT_x]

[共勉：作为一名程序员你应该怎么提一个高质量的问题？][Link 1]

640?wx\_fmt=png 图像 小部件

\[640?Wx\_fmt=png túxiàng xiǎo bùjiàn\]

640? Wx\_fmt = png image widget

[640_wx_fmt_png]: /images/20211023/720ec870a054466db58769e2c13b8826.png
[640_wx_fmt_png 1]: /images/20211023/f4316231729a4d4090dacc19d7f7fedd.png
[640_wx_fmt_png 2]: /images/20211023/ef65d05f4d5c4386981c6a91d2dec408.png
[640_wx_fmt_png 3]: /images/20211023/f59bba53553a4064bfa00eea55272897.png
[640]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2dpZi92NHZ6NTJDY0IxMGc2ZDNDVUZraWFDazJyTnpJWHdpY1Q5a0d6eG5aUFhSR0gwUU5HUlFpYTM1RlVtWGljYnZPUHk0T01iQ2JoSWNvNVJRaWFRMm4zYzEzQWF3LzY0MD8?x-oss-process=image/format,png
[Spring_ _Transactional]: /images/20211023/6060f53ac3b4402bad6845cffb4ecb7c.png
[Java_CPU 100_]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456329&idx=1&sn=7285e2df04a4319006ba2315409d1e4d&chksm=f28c0c99c5fb858f5876d50ef8e00f722ff01fe781e3eeaca9a95dfa6369f03dc6474c95e35d&scene=21#wechat_redirect
[MySQL _NULL]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456321&idx=1&sn=184298e88e7501ace87540ae5bca9e24&chksm=f28c0c91c5fb858720fc33ce41ea393247a17523839c6575e04a773db85c4d688accea8b4e9f&scene=21#wechat_redirect
[Mybatis]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456309&idx=1&sn=535f8e429c65ab9fcd9912a15144eb41&chksm=f28c0ce5c5fb85f36be8b335b0c8c697832390e0021a27bdc4ee04f889788a62b90bc02c388a&scene=21#wechat_redirect
[Java_-Stackoverflow_-Java]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456079&idx=1&sn=dbb7765272193af3d43c55f45900156f&chksm=f28c0f9fc5fb8689d335fd0e68f793149cedb919b9be61296e3798f7a07fa29b3c5b97fe2680&scene=21#wechat_redirect
[MySQL]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456291&idx=1&sn=9bd9e4a8e31b52aa486c310677bc8d3c&chksm=f28c0cf3c5fb85e590c447d144c42703cafeebaeaa8f95763187a08f627bdafedabcbcaead58&scene=21#wechat_redirect
[MySQL _COUNT_x]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456261&idx=1&sn=7e9a14c4429e7091db9cf592c7200806&chksm=f28c0cd5c5fb85c3850dcf5b51ccd3c3efc67edebf402bca611dabdfb641f7cf522c413d535c&scene=21#wechat_redirect
[Link 1]: http://mp.weixin.qq.com/s?__biz=MzI2NjA2MTYzMQ==&mid=2649456226&idx=1&sn=26a1f034932889d6825bfea75f657e08&chksm=f28c0c32c5fb8524687db7ab3dc4ac9a001f98d17ec3b160a0dbf39d38f8aedf94a9cef4e016&scene=21#wechat_redirect