MyBatis如何实现批量插入数据的两种高效策略？

本文共计481个文字，预计阅读时间需要2分钟。

1. 使用 `forEach` 循环拼接 SQL 语句（数量较少时适用）：javapublic int addPersons(@Param(persons) List persons) { // 接口 String insertSql=INSERT INTO person (username, email, gender) VALUES ; StringBuilder sqlBuilder=new StringBuilder(insertSql); for (Person person : persons) { sqlBuilder.append(() .append(').append(person.getUsername()).append(', ) .append(').append(person.getEmail()).append(', ) .append(').append(person.getGender()).append('), ); } // 移除最后一个逗号和空格 sqlBuilder.delete(sqlBuilder.length() - 2, sqlBuilder.length()); // 执行 SQL // ... return 0; // 假设返回值}

1.通过for each标签拼接sql（数量较少的时候使用）

　　a.拼接values（）

　　public int addPersons(@Param("persons") List<Person> persons);//接口

<insert id="addPersons"> insert into person(username,email,gender) VALUES <foreach collection="persons" item="person" separator=";"> (#{person.username},#{person.email},#{person.gender}) </foreach> </insert> <!--类似的效果 insert into person(username,email,gender) VALUES("zhangsan","zhangsan@163.com","F"),("lisi","lisi@163.com","F"),... -->

　　b.拼接insert sql语句（需设置属性allowMultiQueries=true）

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/mybatis?allowMultiQueries=true //需设置属性
jdbc.username=root
jdbc.password=123

public int addPersons(@Param("persons") List<Person> persons);//接口

<insert id="addPersons"> insert into person(username,email,gender) VALUES <foreach collection="persons" item="person" separator=","> (#{person.username},#{person.email},#{person.gender}) </foreach> </insert> <!--类似的效果 insert into person(username,email,gender) VALUES("tom","zhangsan@163.com","F"); insert into person(username,email,gender) VALUES("jerry","lisi@163.com","F");...-->

2.基于Session的ExecutorType进行批量添加

先定义一条插入一条记录的方法

public int addPerson(User user); //接口

<insert id="addPerson" parameterType="user"> insert into t_user(username,address) VALUES (#{username},#{address}) </insert>

在java代码中使用

public void testBatchForExecutor() { SqlSession sqlSession = this.getSqlSessionFactory().openSession(ExecutorType.BATCH); //通过session设置ExecutorType开启批量添加，类似jdbc的addBatch操作 PersonMapper personMapper = sqlSession.getMapper(PersonMapper.class); for (int i = 0; i <10000 ; i++) { personMapper.addPerson(new User("jerry","bj")); } sqlSession.commit(); sqlSession.close(); }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持易盾网络。