替换 MyBatis-Plus 默认的 saveBatch的实现步骤
MyBatis-Plus 默认的 saveBatch 并不是真正意义上的“批量 SQL”,而是循环调用单条 INSERT,仅在 JDBC 层启用了 BATCH 模式。若数据库驱动未开启特定参数(如 MySQL 的 rewriteBatchedStatements=true),底层仍会逐条发送 SQL,导致大量网络往返和数据库解析开销。
实现步骤:
Mapper 接口
public interface YourMapper extends BaseMapper<YourModel> {
void insertBatch(@Param("list") List<YourModel> list);
}XML 文件(放在 resources/mapper/ 下)
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yourpackage.YourMapper">
<insert id="insertBatch">
INSERT INTO your_table_name (
id,
name,
create_time
<!-- 列出所有字段 -->
) VALUES
<foreach collection="list" item="item" separator=",">
(
#{item.id},
#{item.name},
#{item.createTime}
<!-- 对应字段值 -->
)
</foreach>
</insert>
</mapper>通用批量执行工具(基于函数式接口)
创建工具类BatchUtil.java
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.function.Consumer;
@Component
public class BatchUtil {
/**
* 通用分批执行方法
*
* @param dataList 要处理的数据列表
* @param batchSize 每批大小
* @param batchAction 每批数据的处理逻辑(例如:mapper::insertBatch)
* @param <T> 数据类型
*/
public <T> void executeBatch(List<T> dataList, int batchSize, Consumer<List<T>> batchAction) {
if (dataList == null || dataList.isEmpty()) {
return;
}
for (int i = 0; i < dataList.size(); i += batchSize) {
int end = Math.min(i + batchSize, dataList.size());
batchAction.accept(dataList.subList(i, end));
}
}
}在 Service 中使用(示例)
@Autowired private BatchUtil batchUtil; batchUtil.executeBatch(list, 500, YourMapper::insertBatch);
配合 @Transactional 使用
到此这篇关于替换 MyBatis-Plus 默认的 saveBatch的实现步骤的文章就介绍到这了,更多相关替换MyBatis-Plus saveBatch内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
详解Spring DeferredResult异步操作使用场景
本文主要介绍了Spring DeferredResult异步操作使用场景,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下2021-10-10
使用mybatis-plus报错Invalid bound statement (not found)错误
这篇文章主要介绍了使用mybatis-plus报错Invalid bound statement (not found)错误,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2020-09-09
SpringBoot 整合WebSocket 前端 uniapp 访问的详细方法
这篇文章主要介绍了SpringBoot 整合WebSocket 前端 uniapp 访问的详细方法,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2023-09-09
idea向System.getenv()添加系统环境变量的操作
这篇文章主要介绍了idea向System.getenv()添加系统环境变量的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2021-06-06


最新评论