转自:

Mybatis如何实现一个高效的批量插入操作呢？

下文是笔者收集的MyBatis高效插入数据的示例分享，请大家参阅

MyBatis简介

我们都知道MyBatis是目前市面上使用比较多的一个持久层框架(SSM中的M)，
MyBatis可以简化实体类的封装操作，MyBatis通过mapper.xml文件可实现数据库各中操作,详细请见Mybatis教程
那么MyBatis如何实现批量插入数据操作呢？下文将讲述具体的实现思路，如下所示:

方式一:使用MyBatis中的 foreach标签

借助foreach,在sql语句中实现一个迭代集合，
foreach标签拥有一下属性(item，index，collection，open，separator，close)
item:集合中每一个元素进行迭代时的别名
index：设置名称，用于表示在迭代过程中，每次迭代到的位置
open:设置语句开始符
separator：设置每次进行迭代之间使用的分隔符
close:设置迭代的结束符号

注意事项：必须指定collection属性，此属性可放入List,array,Map

例:
*Mapper.xml的定义如下:

INSERT INTO users(name,pwd)

SELECT #{item.name} as a, #{item.pwd} as b FROM DUAL

方式二:使用mybatis ExecutorType.BATCH

Mybatis中内置了3种ExecutorType有3种:

1. simple,此模式下它为每个语句的执行创建一个新的预处理语句，单条提交sql
2. REUSE,此模式是可重用执行器，重用对象是Statement（即该执行器会缓存同一个sql的Statement，省去Statement的重新创建，优化性能）（即会重用预处理语句）
3. batch,此模式重复使用已经预处理的语句，并且批量执行所有更新语句，显然batch性能将更优

注意事项:Batch模式是最快捷的一张方式，但是需用户自定义主键
当然Hibernate中也有类似Batch的处理方式

例:

方式一 spring+mybatis 的

//获取 sqlsession
//注入原有的sqlSessionTemplate
@Autowired
private SqlSessionTemplate sqlSessionTemplate;// 新获取一个模式为BATCH，并自动提交为false的session
// 当自动提交设置为true,将无法控制提交的条数，改为最后统一提交，可能导致内存溢出(注意控制提交数量，如达到1000条提交一次)SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH,false);
//通过新的session获取mapper
userMapper = session.getMapper(UserMapper.class);
int size = 10000;
try{
for(int i = 0; i < size; i++) {//生成实体类User user = new User();user.setName(String.valueOf(System.currentTimeMillis()));userMapper.insert(user);if(i % 1000 == 0 || i == size - 1) { //手动每1000个一提交，提交后无法回滚 session.commit();//清理缓存，防止溢出session.clearCache();}}
} catch (Exception e) {//没有提交的数据可以回滚session.rollback();
} finally{session.close();
}/*
使用mapper及sql别名:包名＋类名
*/public void insertBatch(Map paramMap, List list) throws Exception {
// 新获取一个模式为BATCH，自动提交为false的session
// 如果自动提交设置为true,将无法控制提交的条数，改为最后统一提交，可能导致内存溢出
SqlSession session = sqlSessionTemplate.getSqlSessionFactory().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= list.get(i);
user.setIndate((String)paramMap.get("indate"));
user.setDatadate((String)paramMap.get("dataDate"));//数据归属时间 session.insert(“包名+类名", user);if ((i>0 && i % 1000 == 0) || i == lsize - 1) {//if语句的作用设置每1000个一提交，提交后无法回滚session.commit();// 清理缓存，防止溢出session.clearCache();}}
}
} catch (Exception e) {// 没有提交的数据可以回滚session.rollback();
e.printStackTrace();} finally {session.close();}
}