当前位置：首页 > news >正文

Spring Boot项目里，MybatisPlus的saveBatch批量插入到底该怎么配才有效？（附完整yml示例）

news 2026/6/17 10:50:56

Spring Boot项目中MybatisPlus批量插入的工程化配置指南

在数据密集型应用中，批量操作往往是性能优化的关键。许多开发者在使用MybatisPlus的saveBatch方法时，误以为它默认就是高效的批量插入，直到性能测试时才惊觉——这竟然是个伪装成批处理的"单条循环插入"！本文将带你从JDBC驱动层到框架配置层，构建一套完整的批量插入解决方案。

1. 理解MybatisPlus批量插入的本质

MybatisPlus的saveBatch方法默认行为确实会让不少开发者感到困惑。表面上看是批量操作，底层却可能转换为单条SQL执行。这种现象背后有三个关键因素在起作用：

JDBC驱动对批处理的支持程度：不同数据库驱动对rewriteBatchedStatements参数的支持差异
Spring数据源配置的完整性：url参数拼接的正确性直接影响批处理是否生效
MybatisPlus自身的批处理策略：包括SQL会话模板、执行器类型等配置

典型误区警示：

即使正确配置了rewriteBatchedStatements=true，如果实体类字段存在null值，MybatisPlus仍会退化为单条插入

2. 从驱动到框架的全链路配置

2.1 JDBC驱动层关键配置

MySQL Connector/J驱动的rewriteBatchedStatements参数是批处理性能的关键开关。当设置为true时，驱动会将多个INSERT语句重写为单条多值语句：

spring: datasource: url: jdbc:mysql://localhost:3306/test?useSSL=false&rewriteBatchedStatements=true

驱动版本选择建议：

版本范围	批处理支持度	推荐场景
5.1.x	基础支持	兼容老系统
8.0.x	优化完善	新项目首选

2.2 Spring Boot数据源配置要点

在application.yml中，数据源配置需要特别注意参数顺序和转义问题：

spring: datasource: hikari: connection-test-query: SELECT 1 maximum-pool-size: 20 url: jdbc:mysql://${DB_HOST:localhost}:3306/${DB_NAME}?characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai

常见配置陷阱：

参数间缺少&分隔符
rewriteBatchedStatements拼写错误
参数位置不当导致部分配置失效

2.3 MybatisPlus批处理专属配置

在MybatisPlus配置类中，需要特别关注SQL会话模板的配置：

@Configuration public class MybatisPlusConfig { @Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); // 添加分页插件 interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); return interceptor; } @Bean public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) { ExecutorType executorType = ExecutorType.BATCH; return new SqlSessionTemplate(sqlSessionFactory, executorType); } }

3. 实体类字段处理策略

MybatisPlus对实体类字段的非空检查极为严格，这是许多批量插入失效的隐藏原因。以下是三种合法跳过非空检查的方案：

3.1 自增主键处理

@TableId(value = "id", type = IdType.AUTO) private Long id; // 无需手动set值

3.2 字段忽略策略

@TableField(insertStrategy = FieldStrategy.IGNORED) private Date expireTime; // 允许插入时为null

3.3 自动填充字段

@TableField(fill = FieldFill.INSERT) private String createUser; @TableField(fill = FieldFill.INSERT_UPDATE) private Date updateTime;

字段策略对照表：

策略类型	效果	适用场景
NOT_NULL	非空检查	必填字段
IGNORED	忽略检查	可选字段
NEVER	禁止插入	只读字段

4. 完整示例与验证方案

4.1 服务层实现示例

@Service @RequiredArgsConstructor public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService { private final UserMapper userMapper; @Transactional @Override public boolean batchInsert(List<User> users) { return saveBatch(users, 1000); // 每批1000条 } }

4.2 性能验证方案

通过日志级别调整，可以直观验证批处理是否生效：

# application.yml logging: level: org.springframework.jdbc.core.JdbcTemplate: DEBUG

有效批处理日志特征：

DEBUG 12345 --- [main] o.s.jdbc.core.JdbcTemplate : Executing SQL batch update [INSERT INTO user (...) VALUES (...), (...), (...)]

4.3 批量插入性能优化参数

在极高并发场景下，还需调整以下JVM参数：

# 增加批处理缓冲区 -Dspring.datasource.hikari.data-source-properties=rewriteBatchedStatements=true&cachePrepStmts=true&prepStmtCacheSize=250&prepStmtCacheSqlLimit=2048

5. 高级场景应对策略

当数据量达到百万级时，单纯的saveBatch可能仍会遇到性能瓶颈。此时可采用分片批处理方案：

public <T> void shardingBatchSave(List<T> data, int shardSize, Consumer<List<T>> consumer) { Lists.partition(data, shardSize).forEach(consumer); } // 使用示例 shardingBatchSave(userList, 5000, subList -> userService.batchInsert(subList));

对于超大批量数据导入，建议结合Spring Batch框架实现分段提交和失败重试机制。

查看全文

http://www.jsqmd.com/news/1017931/