mybatis中批量插⼊的两种⽅式（⾼效插⼊）
MyBatis简介
MyBatis是⼀个⽀持普通SQL查询，存储过程和⾼级映射的优秀持久层框架。MyBatis消除了⼏乎所有的JDBC代码和参数的⼿⼯设置以及对结果集的检索封装。MyBatis可以使⽤简单的XML或注解⽤于配置和原始映射，将接⼝和Java的POJO（Plain Old Java Objects，普通的Java对象）映射成数据库中的记录。
⼀、mybiats foreach标签
foreach的主要⽤在构建in条件中，它可以在SQL语句中进⾏迭代⼀个集合。foreach元素的属性主要有
item，index，collection，open，separator，close。item表⽰集合中每⼀个元素进⾏迭代时的别名，index指定⼀个名字，⽤于表⽰在迭代过程中，每次迭代到的位置，open表⽰该语句以什么开始，separator表⽰在每次进⾏迭代之间以什么符号作为分隔符，close表⽰以什么结束，在使⽤foreach的时候最关键的也是最容易出错的就是collection属性，该属性是必须指定的，但是在不同情况下，该属性的值是不⼀样的，主要有⼀下3种情况：
如果传⼊的是单参数且参数类型是⼀个List的时候，collection属性值为list
如果传⼊的是单参数且参数类型是⼀个array数组的时候，collection的属性值为array
如果传⼊的参数是多个的时候，我们就需要把它们封装成⼀个Map了
具体⽤法如下:
1 2 3 4 5 6<insert id="insertBatch"parameterType="List">
INSERT INTO TStudent(name,age)
<foreach collection="list"item="item"index="index"open="("close=")"separator="union all"> SELECT #{item.name} as a, #{item.age} as b FROM DUAL
</foreach>
</insert>
⼆、mybatis ExecutorType.BATCH
Mybatis内置的ExecutorType有3种，默认的是simple，该模式下它为每个语句的执⾏创建⼀个新的预处理语句，单条提交sql；⽽batch模式重复使⽤已经预处理的语句，并且批量执⾏所有更新语句，显
然batch性能将更优；但batch模式也有⾃⼰的问题，⽐如在Insert操作时，在事务没有提交之前，是没有办法获取到⾃增的id，这在某型情形下是不符合业务要求的
具体⽤法如下:
*⽅式⼀ spring+mybatis 的
1
2
3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29//获取sqlsession
//从spring注⼊原有的sqlSessionTemplate
@Autowired
private SqlSessionTemplate sqlSessionTemplate;
// 新获取⼀个模式为BATCH，⾃动提交为false的session
// 如果⾃动提交设置为true，将⽆法控制提交的条数，改为最后统⼀提交，可能导致内存溢出
SqlSession session = SqlSessionFactory().openSession(ExecutorType.BATCH,false); //通过新的session获取mapper
fooMapper = Mapper(FooMapper.class);
int size = 10000;
try{
for(int i = 0; i < size; i++) {
Foo foo = new Foo();
foo.setName(String.valueOf(System.currentTimeMillis()));
fooMapper.insert(foo);
if(i % 1000== 0|| i == size - 1) {
//⼿动每1000个⼀提交，提交后⽆法回滚
sessionmit();
//清理缓存，防⽌溢出
session.clearCache();
}
}
} catch(Exception e) {
//没有提交的数据可以回滚
} finally{
session.close();
}
spring+mybatis
29
⽅法⼆:
结合通⽤mapper sql别名最好是包名＋类名1
2
3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30public void insertBatch(Map<String,Object> paramMap, List<User> list) throws Exception {
// 新获取⼀个模式为BATCH，⾃动提交为false的session
// 如果⾃动提交设置为true，将⽆法控制提交的条数，改为最后统⼀提交，可能导致内存溢出
SqlSession session = SqlSessionFactory().openSession(ExecutorType.BATCH, false); try{
if(null!= list || list.size()>0){
int lsize=list.size();
for(int i = 0, n=list.size(); i < n; i++) {
User user= (i);
user.setIndate((("indate"));
user.setDatadate((("dataDate"));//数据归属时间
//session.insert("apper.UserMapper.insert",user);
//session.update("apper.UserMapper.updateByPrimaryKeySelective",_entity);
session.insert(“包名+类名", user);
if((i>0&& i % 1000== 0) || i == lsize - 1) {
// ⼿动每1000个⼀提交，提交后⽆法回滚
sessionmit();
/
/ 清理缓存，防⽌溢出
session.clearCache();
}
}
}
} catch(Exception e) {
// 没有提交的数据可以回滚
e.printStackTrace();
} finally{
session.close();
}
}
以上所述是⼩编给⼤家介绍的mybatis中批量插⼊的两种⽅式(⾼效插⼊)，希望对⼤家有所帮助
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论