mybatis批处理数据

批处理数据主要有三种方式:java

1.传统jdbc处理    2.mybatis批处理插入    3.使用executortype处理 sql

jdbc 处理 session

1.经过 for循环插入 

main方法以下所示:

Connection comm=null;

PreparedStatement preparedStatement=null;

conn=JdbcUtil.getConnection();

JdbcUtil.begin(conn);

String sql="insert into t_user(username,password)  values(?,?)";

preparedStatement=conn.preparedStatement(sql);

for (int i=0;i<1000;i++)
{
preparedStatement.setString(1, "hello"+(i+1));
preparedStatement.setString(2, "world"+(i+1));
preparedStatement.executeUpdate();
}
JdbcUtil.commit(conn);
}

这样就能够进行批量插入 mybatis

第二种是使用addbatch方法 app

main方法以下所示:

Connection comm=null;

PreparedStatement preparedStatement=null;

conn=JdbcUtil.getConnection();

JdbcUtil.begin(conn);

String sql="insert into t_user(username,password)  values(?,?)";

preparedStatement=conn.preparedStatement(sql);

for (int i=0;i<1000;i++)
{
preparedStatement.setString(1, "hello"+(i+1));
preparedStatement.setString(2, "world"+(i+1));
if((i+1)%1000==0){
preparedStatement.addBatch();
preparedStatement.executeBatch();
preparedStatement.clearBatch();
}
}
JdbcUtil.commit(conn);
}

二者差距在效果上后者更好一些。this

传统的jdbc对数据的批处理有一些缺点 :好比一直使用的是for循环,会浪费大量的时间在session的链接上,并且java代码和sql语句耦合度很大。spa

mybatis 在处理数据的时候有两种方式,第一种是使用foreach标签,另外一种是使用allowMultiQueries=true来完成。code

第一种使用foreach xml

xml文件内容以下:

insert into person(username,email,gender) VALUES 
<foreach collection="persons" item="person" separator=",">
(#{person.username},#{person.email},#{person.gender})
</foreach>

java文件以下
SqlSession sqlSession=this.getSqlSessionFactory.opensession();
PerSonMapper personMapper=sqlSession.getMapper(PersonMapper.class);
List<Person> persons=new ArrayList<Person>();
for(int i=0;i<5;i++){
Person person=new Person("tom"+i,"email@"+i,"F");
persons.add(person);
}
personMapper.addPersons(persons)
sqlSession.commit();
}

另一种须要配置文件声明allowMultiQueries=true   而后更改 xml文件中, 为;就能够了blog

 

最后一种批量操做的方法是 executortype的方式 

1. xml语句 
insert into person(username,email,gender) values (#{username},#{email},#{gender}) 

java语句
SqlSession sqlSession=this.getSqlSessionFactory.opensession(ExecutorType.BATCH);PerSonMapper personMapper=sqlSession.getMapper(PersonMapper.class);for(int i=0;i<5;i++){personMapper.addPerson(new Person("wang","email@123.com","F"));}
相关文章
相关标签/搜索