小心 MybatisPlus 的一个坑

news2024/11/24 18:45:52

小心 MybatisPlus 的一个坑

昨天测试说有个 xx 功能用不了，扔给我一个截图，说有报错：

在这里插入图片描述
报错信息就是：Transaction rolled back because it has been marked as rollback-only，很好理解：事务被回滚了，因为它已经被标记了只能回滚。

我一看巧了，这不就是我之前分析过的面试题吗！
在这里插入图片描述
之前的文章我解释过：这种错一般发生在嵌套事务中，即内层事务出错，但是由于是否提交事务的操作由外层事务触发，于是乎内层事务只能做个标记，来设置当前事务只能回滚。

紧接着它想抛出错误，但是由于被 try catch 了，于是乎正常执行后续的逻辑，等执行到最后，外层要提交事务了，发现当前事务已经被打了回滚的标记，所以提交失败，报了上面的错。

具体原理可以看我之前的那篇文章，这里简单举例下会出错的示例代码：

大致就是下面这个代码调用逻辑，有一个 service 标记了 @Transcational，采用默认的事务传播机制：


@Service
public class AddressService {

@Autowired
AddressMapper addressMapper:

@Transactional(rollbackFor = Exception.class)
public void errorInvoker(Address address){
     addressMapper.insert(address) ;
}

}

紧接着 UserService#insert 调用了 addressService#errorInvoker，这个方法也标记了 @Transcational：


@Service
public class UserService {

@Autowired
UserMapper userMapper;

@Autowired
AddressService addressService:

@Transactional(rolbackFor = Exception.class)
public void insert(User user){
	try {
	     addressService.errorInvoker(new Address(1, "aaaa"') )
	} catch (Exception e) {
	      e.printStackTrace() ;
	}
	     userMapper.insert(user);
  }
}

这样一来，只要 addressService#errorInvoker 的调用发生报错，那么必然能重现上面的报错信息。

使用嵌套事务报错事例二:

大致的代码如下：

@Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean xxx(xxx dto) {
        list1 = .....;
        try {
              数据库批量保存list1;
        } catch (Exception e) {
            if (e instanceof DuplicateKeyException) {
                //筛选过滤重复 key 的数据
                //打标发送
                数据库批量保存过滤之后的list1;
            }
            ....
        }
        sendToMQ(xxx);
        list2 = .....;
        try {
             数据库批量保存list2;
        } catch (Exception e) {
            if (e instanceof DuplicateKeyException) {
                //筛选过滤重复 key 的数据
                //打标发送
                数据库批量保存过滤之后的list2;
            }
            ...
        }
        sendToMQ(xxx);
        return Boolean.TRUE;
    }

这里的代码逻辑不复杂，明面上来看，我并没有调用别的 service ！也并不存在嵌套事务的问题，所以我思来想去也看不明白。

看 try-catch,但是 try 里面就是一个 mybatis-plus 的 IService，批量保存数据的操作。

难道它有什么骚操作？点进去一看突然发现：
在这里插入图片描述
mybatis-plus 为了保证批量保存的事务性，加了 @Transactional。

合着我确实没想着使用嵌套事务，但是这被迫上了“贼船”啊！

这本是好意，但是在我这个场景有点麻，它完美的复现了上文提到的那个错误使用，在有重复 key 的场景确实报错了，但是被外层 try-catch 拦住了抛错，不过事务上已经打了失败的标了！

解决办法其实很简单：

把 saveBatch 上的 @Transactional 注解删了，很明显我做不到，这是 mybatisplus 的源码。
把 saveBatch 上的 @Transactional 注解上设置事务传播机制为：REQUIRES_NEW 或 NESTED，很明显，我也做不到，这是 mybatis-plus 的源码。

然后我找了下，好像也没有什么参数可以指定 saveBatch 的事务传播机制。

所以咋办。。。测试还在催我，没办法，只能不用 mybatis-plus 的 saveBatch ，自己通过 mapper 写个批量插入了：
在这里插入图片描述
一波操作提交代码重启服务，让测试再试试，且轻飘飘的甩一句：这不是我的bug，我被框架坑了。