原来Mybatis执行一个sql有这么多类型( 二 ) _Mybatis

BatchExecutor有些场景下，我们要批量保存或者删除，更新数据，这时候我们一条一条的执行效率就会很低，需要一个批量执行的机制。
JDBC 批量操作批量操作可以把相关的sql打包成一个 batch，一次发送到服务器，减少和服务器的交互，也就是 RTT 时间。
使用批量操作前要确认服务器是否支持批量操作，可通过 DatabaseMetaData.supportsBatchUpdates() 方法的返回值来判断。
实例代码，通过 JDBC 提供的 API 执行批量操作。
Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);DatabaseMetaData metaData = https://www.isolves.com/it/sjk/bk/2020-11-13/conn.getMetaData();System.out.println("metaData.supportsBatchUpdates() = " + metaData.supportsBatchUpdates());//执行 sqlSystem.out.println("Creating statement...");String sql = "update user set name=? where id = ?";pstmt = conn.prepareStatement(sql);// 设置变量pstmt.setString(1, "Pappu");pstmt.setInt(2, 1);// 添加到 batchpstmt.addBatch();// 设置变量pstmt.setString(1, "Pawan");pstmt.setInt(2, 2);// 添加到 batchpstmt.addBatch();//执行，并获取结果int[] count = pstmt.executeBatch();Mybatis 如何实现Mybatis 只有对 update 有支持批量操作，并且需要手动 flushStatements 。

insert、delete、update，都是update操作

BatchExecutor batchExecutor = new BatchExecutor(configuration, jdbcTransaction);final MappedStatement update = configuration.getMappedStatement("dm.UserMapper.updateName");final MappedStatement delete = configuration.getMappedStatement("dm.UserMapper.deleteById");final MappedStatement get = sessionFactory.getConfiguration().getMappedStatement("dm.UserMapper.getUserByID");final MappedStatement insertUser = sessionFactory.getConfiguration().getMappedStatement("dm.UserMapper.insertUser");// querybatchExecutor.doUpdate(insertUser, new User().setName("" + new Date()));batchExecutor.doUpdate(insertUser, new User().setName("" + new Date()));// batch updateUser user = new User();user.setId(2);user.setName("" + new Date());batchExecutor.doUpdate(update, user);user.setId(3);batchExecutor.doUpdate(update, user);batchExecutor.doUpdate(insertUser, new User().setName("" + new Date()));//final List<BatchResult> batchResults = batchExecutor.flushStatements(false);jdbcTransaction.commit();printBatchResult(batchResults);

执行日志：

[DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==>Preparing: insert into `user` (name) values(?); [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==> Parameters: Sat Jul 04 15:07:30 CST 2020(String) [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==> Parameters: Sat Jul 04 15:07:30 CST 2020(String) [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==>Preparing: update `user` set name=? where id = ? [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==> Parameters: Sat Jul 04 15:07:30 CST 2020(String), 2(Integer) [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==> Parameters: Sat Jul 04 15:07:30 CST 2020(String), 3(Integer) [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==>Preparing: insert into `user` (name) values(?); [DEBUG][main] o.a.i.l.j.BaseJdbcLogger.debug ==> Parameters: Sat Jul 04 15:07:30 CST 2020(String) [DEBUG][main] o.a.i.t.j.JdbcTransaction.commit Committing JDBC Connection [com.MySQL.cj.jdbc.ConnectionImpl@4b3ed2f0] 第 1 个结果[1, 1]第 2 个结果[1, 1]第 3 个结果[1]

从日志可以看到看到清晰的执行过程。

第一个insert语句后面跟着两个参数，是一个statement 。对应第 1 个结果
第二个update语句后面跟着两个参数，是一个statement 。对应第 2 个结果
第三个insert语句后面跟着两个参数，是一个statement 。对应第 3 个结果

整体逻辑和程序是一致的，但是有个问题，为什么三个相同的 insert，会分开两个结果返回呢？
这是因为 Mybatis 为了保证批次和逻辑顺序一致做了优化，并不是相同的sql就放到相同的statement 。而是要按照执行顺序把相同的sql当作一个批次。
从代码中可以看到这部分逻辑：

public int doUpdate(MappedStatement ms, Object parameterObject) throws SQLException {if (sql.equals(currentSql) && ms.equals(currentStatement)) {使用当前的 statement} else {创建新的statement}}

总结网络上有些文章介绍使用 foreach 的方式执行批量操作，我个人不建议这样操作。

因为 JDBC 已经提供了批量操作的接口，符合规范，兼容性和性能更好。
foreach拼接的 sql 比较长，会增加网络流量，而且驱动对sql长度是有限制的，并且要增加allowMultiQueries参数。
foreach 拼接的 sql 每次都不一定相同，服务器会重新编译。

Mysql 的 sql 执行流程是连接器，查询缓存，分析器，优化器，执行器。分析器先会做“词法分析” 。优化器是在表里面有多个索引的时候，决定使用哪个索引；或者在一个语句有多表关联（join）的时候，决定各个表的连接顺序。在适合的场景使用 ReuseExecutor 或 BatchExecutor 不仅可以提高性能，还可以减少对 Mysql 服务器的压力。