1 環境準備
1.1 搭建 MyBatis-Plus 環境
- 創建 maven springboot 工程
- 導入依賴：web 啟動器、jdbc、、JAVA 連接 MySQL、Lombok、druid 連接池啟動器、mybatis-plus 啟動器
- 編寫 yaml 配置文件，配置 druid 數據源、mybatis-plus
注意要點：
- mApper 接口繼承 BaseMapper<實體類>
- service 接口繼承 IService<實體類>
- service 接口實現類繼承 ServiceImpl<mapper 接口, 實體類> 實現 service 接口
1.2 批量插入測試接口
- MyBatis 批量插入接口
@GetMapping("/mybatis-batch-insert") public String mybatisBatchInsert(){ // 開始時間 long stime = System.currentTimeMillis(); // 批量插入 orderService.mySaveBatch(list); // 結束時間 long etime = System.currentTimeMillis(); return "mybatis 批量插入 1w 條數據的時間: " + (etime - stime) / 1000.0 + "秒"; }
- Mybatis 的批量插入是調用 mapper 的批量插入接口，使用 標簽拼接 sql 進行插入
- Mybatis-Plus 批量插入接口
- @GetMapping("/mybatis-batch-insert") public String mybatisBatchInsert(){ // 開始時間 long stime = System.currentTimeMillis(); // 批量插入 orderService.mySaveBatch(list); // 結束時間 long etime = System.currentTimeMillis(); return "mybatis 批量插入 1w 條數據的時間: " + (etime - stime) / 1000.0 + "秒"; }
- MyBatis-Plus 的批量插入是調用 mybatis-plus 的 IService 接口的 saveBatch 進行批量插入
1.3 批量更新測試接口
- MyBatis 批量更新接口
- @GetMapping("/mybatis-batch-update") public String mybatisBatchUpdate(){ long stime = System.currentTimeMillis(); orderService.myUpdateBatchById(updateList); long etime = System.currentTimeMillis(); return "mybatis 批量更新 1w 條數據的時間: " + (etime - stime) / 1000.0 + "秒"; }
- MyBatis 的批量插入是調用 mapper 的批量更新接口，使用 標簽拼接 sql 進行更新，是將多個更新語句拼接在同一個 mapper 接口中，需要在數據庫連接 url 添加 allowMultiQueries=true 開啟多查詢
- MyBatis-Plus 批量更新接口
- @GetMapping("/mybatis-plus-batch-update") public String mybatisPlusBatchUpdate(){ long stime = System.currentTimeMillis(); orderService.updateBatchById(updateList); long etime = System.currentTimeMillis(); return "mybatis plus 批量更新 1w 條數據的時間: " + (etime - stime) / 1000.0 + "秒"; }
- MyBatis -Plus 的批量更新是調用 mybatis-plus 的 IService 接口的 updateBatchById 進行批量更新
2. 性能對比
經過預熱，盡量避免了緩存的影響。
2.1 批量插入性能對比
數據量：1w 條數據，每條數據 4 個字段
測試結果：
- MyBatis：5 次運行平均耗時：0.3212 秒
- MyBatis-Plus：5次運行平均耗時：1.35 秒
- MyBatis-Plus（開啟批處理）：5次運行平均耗時：0.2424 秒
2.2 批量更新性能對比
數據量：1w 條數據，每條數據更新 4 個字段
測試結果：
- MyBatis：5 次運行平均耗時：1.0378 秒
- MyBatis-Plus：5次運行平均耗時：1.6448 秒
- MyBatis-Plus（開啟批處理）：5次運行平均耗時：0.743 秒
3. 原理探究
3.1 批量插入
3.1.1 MyBatis
MyBatis 的批量插入 xml
<insert id="mySaveBatch">
insert into order_table(id, product_id, total_amount, status) values
<foreach collection="list" separator="," item="item">
(#{item.id}, #{item.productId}, #{item.totalAmount}, #{item.status})
</foreach>
</insert>
通過 標簽，將插入的數據拼接成一條 SQL 語句，一次性進行插入操作，拼接完的 SQL 語句如下例子：
insert into order_table(id, product_id, total_amount, status) values(1, 2. 2.0, 1),(2, 2, 2.0, 1);
3.1.2 MyBatis-Plus
MyBatis-Plus 的批量插入本質采用 for 遍歷每條數據依次插入，但使用了批處理優化，默認是每 1000 條數據，刷新一次 statement 提交到數據庫，執行插入操作。
注意：批處理需要在數據庫連接中添加 rewriteBatchedStatements=true 否則 jdbc 驅動在默認情況下會無視executeBatch() 語句
源碼如下：
@Transactional(rollbackFor = Exception.class) // 開啟事務
@Override
public boolean saveBatch(Collection<T> entityList, int batchSize) {
String sqlStatement = getSqlStatement(SqlMethod.INSERT_ONE); // 獲得插入 statement
// 執行批處理操作
// 參數是：待插入集合，批次大小（默認1000），函數式接口 accept
return executeBatch(entityList, batchSize, (sqlSession, entity) -> sqlSession.insert(sqlStatement, entity));
}
public static <E> boolean executeBatch(Class<?> entityClass, Log log, Collection<E> list, int batchSize, BiConsumer<SqlSession, E> consumer) {
Assert.isFalse(batchSize < 1, "batchSize must not be less than one");
return !CollectionUtils.isEmpty(list) && executeBatch(entityClass, log, sqlSession -> {
int size = list.size();
int idxLimit = Math.min(batchSize, size);
int i = 1;
// 遍歷插入
for (E element : list) {
// 調用 sqlSession.insert(sqlStatement, entity));
// 對元素執行插入操作，但此時數據庫還沒真正執行插入語句
consumer.accept(sqlSession, element);
// 計數達到 1000 或者 集合結束
if (i == idxLimit) {
// 刷新 statement 提交批處理語句，數據庫真正執行 SQL
sqlSession.flushStatements();
idxLimit = Math.min(idxLimit + batchSize, size);
}
i++;
}
});
}
3.2 批量更新
3.2.1 MyBatis
MyBatis 的批量更新 xml
<update id="myUpdateBatchById">
<foreach collection="list" item="item" index="index" open="" close="" separator=";">
update order_table
<set>
product_id = #{item.productId},
total_amount = #{item.totalAmount},
status = #{item.status}
</set>
where id = #{item.id}
</foreach>
</update>
通過 標簽，拼接成多條更新的 SQL 語句，一次性提交數據庫執行。語句例子如下：
update order_table set product_id = 1, total_amount = 2, status = 1 where id = 1;
update order_table set product_id = 1, total_amount = 2, status = 1 where id = 2;
3.1.2 MyBatis-Plus
MyBatis-Plus 批量更新的原理基本和其批量插入的原理一致，都是調用 executeBatch 執行批處理操作。
4. 優缺點分析
4.1 批量插入
對于批量插入，MyBatis 拼接 SQL 的寫法比 MyBatis-Plus 的批量插入方法有明顯更高的性能。
但在開啟批處理優化之后，MyBatis-Plus 的方法性能更高了。
MyBatis:
- 優點：性能較高
- 缺點：在處理大數據量（SQL 語句大于 64MB 時）會報錯，MySQL 8.0.33 默認最大 SQL 大小為 64MB
也要考慮內存異常等問題。
MyBatisPlus：
- 優點：分組提交，適用于大數據量的處理
- 缺點：單條插入語句執行，性能較低
總結：
- 沒開啟批處理時：10w 數據量以下建議使用 MyBatis、10w 數據量以上建議使用 MyBatis-Plus
- 開啟批處理時：建議使用 MyBatis-Plus
4.2 批量更新
對于批量更新，MyBatis 拼接 SQL 的寫法與 MyBatis-Plus 的批量更新方法無明顯的性能差別.
大于大數據量，拼接寫法甚至容易出現內存耗盡等問題，相比之下 MyBatis-Plus 的方法更優。
總結：建議使用 MyBatis-Plus
