⭐⭐⭐ Spring Boot 项目实战	⭐⭐⭐ Spring Cloud 项目实战
《Dubbo 实现原理与源码解析 —— 精品合集》	《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》	《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》	《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》	《Java 面试题 + Java 学习指南》

摘要: 原创出处 waynblog 「waynaqua」欢迎转载，保留摘要，谢谢！

🙂🙂🙂关注微信公众号：【芋道源码】有福利：

RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表

RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址

您对于源码的疑问每条留言都将得到认真回复。甚至不知道如何读源码也可以请教噢。

新的源码解析文章实时收到通知。每周更新一篇左右。

认真的源码交流微信群。

最近在开发一个后台发送消息的功能时，由于需要给多个用户发送消息，于是使用了 mybatis plus 提供的 saveBatch() 方法，在测试环境测试通过上预发布后，测试反应发送消息接口很慢得等 5、6 秒，于是我就登录线上环境查看执行日志，发现是 mybatis plus 提供的 saveBatch() 方法执行很慢导致，于是也就有了本篇文章。

mybatis plus 是一个流行的 ORM 框架，它基于 mybatis，提供了很多便利的功能，比如代码生成器、通用 CRUD、分页插件、乐观锁插件等。它可以让我们更方便地操作数据库，减少重复的代码，提高开发效率。

案发现场还原

/**
 * 先保存通知消息，在批量保存用户通知记录
 */
@Transactional(rollbackFor = Exception.class)
@Override
public boolean saveNotice(Notify notify, String receiveUserIds) {
    long begin = System.currentTimeMillis();
    notify.setCreateTime(new Date());
    notify.setCreateBy(ShiroUtil.getSessionUid());
    if (notify.getPublishTime() == null) {
        notify.setPublishTime(new Date());
    }
    boolean insert = save(notify);
    List<NotifyRecord> collect = new ArrayList<>();
    List<String> receiveUserList = fillNotifyRecordList(notify, receiveUserIds, collect);
    notifyRecordService.saveBatch(collect);
    long end = System.currentTimeMillis();
    System.out.println(end - begin);
    ...
    return insert;
}

/**
 * 根据用户id，组装用户通知记录集合，返回200条记录
 */
public List<String> fillNotifyRecordList(Notify notify, String receiveUserIds, List<NotifyRecord> collect) {
    List<String> noticeRecordList = new ArrayList<>(200);
    ...
    // 组将两百条用户通知记录
    return noticeRecordList;
}

如上代码，我有一个 saveNotice() 方法用于保存通知消息以及用户通知记录。执行逻辑如下，

保存通知消息
根据用户 id，组装用户通知记录集合，返回 200 条用户通知记录
批量保存用户通知记录集合

前两步骤耗时都很少，我们直接看第三步操作耗时，结合 sql 执行日志，如下，

-- slow sql 5542 millis. INSERT INTO oa_notify_record  ( notifyId, receiveUserId, receiveUserName, isRead,  createTime )  VALUES  ( ?, ?, ?, ?,  ? )[225,"fcd90fe3990e505d07c90a238f75e9c1","niuwawa",false,"2023-10-30 23:54:04"]
5681

再结合 mybatis free log 插件打印完整 sql 如下图，

可以看出，我们批量保存用户通知记录是一条记录一条进行保存得，已经可以猜测就是批量插入方法导致得耗时较高。

这里使用得是 mybatis log free 插件，它可以自动帮我们在控制台打印完整得 mybatis sql 语句。有需要可以在 idea 插件中心搜索 mybatis log free 下载安装。

结合 saveBatch() 底层源码也能够看出，mybatis plus 对于批量操作是通过 for 循环执行保存操作得，源码如下图，

到这里我们也就知道了在测试环境执行较快得原因，因为在测试环境需要批量保存得用户通知记录比较少，只有几条记录，所以很快。但是上预发布后，由于预发布中需要批量保存得用户通知记录比较多达到了数百条，所以执行较慢，耗时达到了 5、6 秒之久。

解决方法

到这里，也就是本文得重点所在了，那怎么解决这个问题嘞？如何既利用 mybatis plus 提供得便携性，也能够解决批量操作耗时较高得问题。

其实解决方法很简单，只需要在 jdbcurl 上添加 rewriteBatchedStatements=true 参数即可解决这个问题。

MySQL 的 JDBC 连接的 url 中要加 rewriteBatchedStatements 参数，并保证 5.1.13 以上版本的驱动，才能实现高性能的批量插入。

MySQL JDBC 驱动在默认情况下会无视 executeBatch()语句，把我们期望批量执行的一组 sql 语句拆散，一条一条地发给 MySQL 数据库，批量插入实际上是单条插入，直接造成较低的性能。只有把 rewriteBatchedStatements 参数置为 true, 驱动才会帮你批量执行 SQL。另外这个选项对 INSERT/UPDATE/DELETE 都有效。

rewriteBatchedStatements=true 的意思是，当你在 Java 程序中使用批量插入/修改/删除（batching）时，MySQL JDBC 驱动程序将尝试重新编写（rewrite）你的 SQL 语句，以便更有效地执行这些批量插入操作。

OK，在我们给 jdbcurl 上添加了参数后，看看效果，如下图，

可以看到 jdbcurl 添加了 rewriteBatchedStatements=true 参数后，批量操作的执行耗时已经只有 200 毫秒，自此也就解决了 mybatis plus 提供的 saveBatch() 方法执行耗时较高得问题。

总结

mybatis plus 给开发人员带来了很多便利，但是其中也有一些坑点，比如上文所提到得批量操作耗时问题，如果不注意的话，就有可能调入坑里，各位开发同学可以检查自己或者公司项目中 jdbcurl 是否缺失 rewriteBatchedStatements=true 参数，加以改正，避免重复掉入这个坑里。

芋道源码 —— 纯源码解析博客

Mybatis Plus很好，但也有坑！

案发现场还原

解决方法

总结