Java + Spring Boot + Mybatis 实现批量插入

在 Java 中使用 Spring Boot 和 MyBatis 实现批量插入可以通过以下步骤完成。这里提供两种常用方法：使用 MyBatis 的 <foreach> 标签和批处理模式（ExecutorType.BATCH）。

---

方法一：使用 XML 的 <foreach> 标签（推荐）

这是最高效的方式，通过单条 SQL 语句一次性插入多条数据。

1. Mapper 接口

java

复制

下载

@Mapper
public interface UserMapper {// 批量插入方法int batchInsert(@Param("users") List<User> users);
}

2. XML 映射文件 (UserMapper.xml)

xml

复制

下载

运行

<insert id="batchInsert">INSERT INTO user (name, email, age)VALUES<foreach collection="users" item="user" separator=",">(#{user.name}, #{user.email}, #{user.age})</foreach>
</insert>

3. Service 层实现

java

复制

下载

@Service
@RequiredArgsConstructor // Lombok 注解
public class UserService {private final UserMapper userMapper;@Transactionalpublic void batchInsertUsers(List<User> users) {if (users != null && !users.isEmpty()) {userMapper.batchInsert(users);}}
}

4. 实体类

java

复制

下载

@Data // Lombok 注解
public class User {private Long id;private String name;private String email;private Integer age;
}

---

方法二：使用 MyBatis 批处理模式

适合需要精确控制事务的场景，但性能略低于 <foreach> 方式。

1. Mapper 接口

java

复制

下载

@Mapper
public interface UserMapper {// 单条插入方法void insert(User user);
}

2. XML 映射文件

xml

复制

下载

运行

<insert id="insert">INSERT INTO user (name, email, age)VALUES (#{name}, #{email}, #{age})
</insert>

3. Service 层实现

java

复制

下载

@Service
@RequiredArgsConstructor
public class UserService {private final SqlSessionTemplate sqlSessionTemplate;@Transactionalpublic void batchInsert(List<User> users) {// 获取批处理模式的 SqlSessionSqlSession sqlSession = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false); // 关闭自动提交try {UserMapper mapper = sqlSession.getMapper(UserMapper.class);for (User user : users) {mapper.insert(user);}sqlSession.commit(); // 手动提交} catch (Exception e) {sqlSession.rollback();throw e;} finally {sqlSession.close();}}
}

---

关键配置

1. application.yml 配置

yaml

复制

下载

spring:datasource:url: jdbc:mysql://localhost:3306/test?useSSL=false&rewriteBatchedStatements=true # MySQL 批处理优化username: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Drivermybatis:mapper-locations: classpath:mapper/*.xml # XML 文件位置

2. 添加依赖 (pom.xml)

xml

复制

下载

运行

<dependencies><!-- Spring Boot Starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- MyBatis + Spring Boot --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.2.0</version></dependency><!-- MySQL 驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!-- Lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>
</dependencies>

---

性能优化建议

1. MySQL 参数：在 JDBC URL 中添加 rewriteBatchedStatements=true，启用真正的批处理（提升 5-10 倍性能）。

2. 批次大小：每批处理 500-1000 条数据（避免 SQL 过长）。

3. 事务控制：确保在 Service 层使用 @Transactional。

4. 连接池：使用 HikariCP 等高性能连接池（Spring Boot 默认集成）。

---

两种方法对比

方法	优点	缺点
<foreach> 标签	单次数据库交互，性能最高	超大数据可能使 SQL 过长
ExecutorType.BATCH	灵活控制事务，内存占用低	需要手动提交，性能略低

根据数据量选择合适方案：

• 数据量 < 1000：推荐 <foreach>

• 数据量 > 10000：推荐分批次 + <foreach>（每批 500 条）

项目实例：

BranchWarehouseApplyServiceImpl.java

    // 生成分仓物资申领（试剂耗材）@Overridepublic void generateDetailForReagent(List<ReagentOptionVO> reagentOptionList) {// 获取用户名（账号）String userName = PublicUtils.getUserName();// 通过用户名（账号），获取其所属部门Department department = departmentMapper.selectByUserName(userName);List<BranchWarehouseApplyDetail> applyDetailList = new ArrayList<>();reagentOptionList.forEach(item -> {BranchWarehouseApplyDetail applyDetail = new BranchWarehouseApplyDetail();applyDetail.setWarehouseId(1);applyDetail.setMaterialId(item.getId());applyDetail.setApplyTime(LocalDateTime.now());applyDetail.setApplyDept(department.getDeptId());applyDetail.setApplyOperator(userName);applyDetail.setAmount(item.getApplyAmount());applyDetail.setStage(0);applyDetailList.add(applyDetail);});// 集合不为空if (!applyDetailList.isEmpty()) {// 批处理，拆分数据，满50条，执行批量插入List<List<BranchWarehouseApplyDetail>> lists = (List<List<BranchWarehouseApplyDetail>>)PublicUtils.splitList(applyDetailList, 50);for (List<BranchWarehouseApplyDetail> list: lists) {branchWarehouseApplyMapper.insertDetail(list);}}}

BranchWarehouseApplyMapper.java

@Mapper
public interface BranchWarehouseApplyMapper {// 批量增加分仓物资申领void insertDetail(List<BranchWarehouseApplyDetail> applyDetailList);
}

 BranchWarehouseApplyMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.weiyu.mapper.BranchWarehouseApplyMapper"><!-- 分仓物资申领 mssql --><!-- 批量增加分仓物资申领，使用单条INSERT语句配合VALUES列表更高效 --><insert id="insertDetail">insert into BranchWarehouseApplyDetail (warehouse_id, material_id, apply_time, apply_dept, apply_operator,amount, purpose, stage, remark)<!-- 非空列表，并且有记录 --><if test="applyDetailList != null and applyDetailList.size() > 0">values<foreach collection="applyDetailList" item="item" separator=",">(#{item.warehouseId}, #{item.materialId}, #{item.applyTime}, #{item.applyDept}, #{item.applyOperator},#{item.amount}, #{item.purpose}, #{item.stage}, #{item.remark})</foreach></if><!-- 空集合安全处理：当传入空列表时，确保不插入实际数据，同时避免数据库报错 --><if test="applyDetailList == null or applyDetailList.size() == 0">selectnull, null, null, null, null, null, null, null, nullwhere 1 = 0</if></insert>
</mapper>