Mybatis批量更新和插入数据

batchUpdate

第一种方式

[html] view
plaincopy





<update id="updateBatch" parameterType="Map">

update aa set

a=#{fptm},

b=#{csoftrain}

where c in

<foreach collection="cs" index="index" item="item" pen="("separator=","close=")">

#{item}

</foreach>

</update>

但是这种方式修改的字段值都是一样的。

第二种方式

修改数据库连接配置：&allowMultiQueries=true

比如：jdbc:mysql://192.168.1.236:3306/test?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true

[html] view
plaincopy





<update id="batchUpdate" parameterType="java.util.List">

<foreach collection="list" item="item" index="index" open="" close="" separator=";">

update test

<set>

test=${item.test}+1

</set>

where id = ${item.id}

</foreach>

</update>

这种方式，可以一次执行多条SQL语句

batchInsert

MyBatis-spring和spring JDBC批量插入Mysql的效率比较

工具框架用spring-batch，数据库是mysql（未做特殊优化）。

比较数据框架mybatis和spring jdbc的插入效率。

Mybatis三种实现：

1、mybatis的官方写法

Java代码


public void batchInsert1(List<Poi> poilist) throws Exception {

SqlSession sqlSession = sqlSessionFactory.getObject().openSession(ExecutorType.BATCH);

PoiMapper pmapper = sqlSession.getMapper(PoiMapper.class);

try {

for (Poi poi : poilist) {

pmapper.insertPoi(poi);

}

sqlSession.commit();

} finally {

sqlSession.close();

}

}

其中Poi是一个bean。

PoiMapper定义：

Java代码


public interface PoiMapper {

@Insert("insert into tb_poi (tag, poi, poiid, meshid, owner, featcode, sortcode, namec, namee, namep, names) values (#{tag}, GeomFromText(#{point}), #{poiid}, #{meshid}, #{owner}, #{featcode}, #{sortcode}, #{namec}, #{namee}, #{namep}, #{names}) ")

public void insertPoi(Poi poi);

}

2、利用mysql特性，拼写insert sql。

Java代码


public void batchInsert2(List<Poi> poilist) throws Exception {

SqlSession sqlSession = sqlSessionFactory.getObject().openSession(ExecutorType.BATCH);

try {

sqlSession.insert("com.emg.trans.mapper.batchMapper.batchInsert", poilist);

sqlSession.commit();

} finally {

sqlSession.close();

}

}

“com.emg.trans.mapper.batchMapper.batchInsert”在mybatis的xml中定义的sql，定义如下：

Xml代码


<mapper namespace="com.emg.trans.mapper.batchMapper">

<insert id="batchInsert" parameterType="List">

insert into tb_poi (tag, poi, poiid, meshid, owner, featcode, sortcode, namec, namee, namep, names) values

<foreach collection="list" item="poi" index="index" separator="," >

(#{poi.tag}, GeomFromText(#{poi.point}), #{poi.poiid}, #{poi.meshid}, #{poi.owner}, #{poi.featcode}, #{poi.sortcode}, #{poi.namec}, #{poi.namee}, #{poi.namep}, #{poi.names})

</foreach>

</insert>

</mapper>

3、利用spring的事务，直接执行插入操作。

Java代码


@Transactional("dbTransaction")

public void batchInsert3(List<Poi> poilist) throws Exception {

for (Poi poi : poilist) {

apmapper.insertPoi(poi);

}

}

apmapper是PoiMapper的实例，用@Autowired配置。

Spring-JDBC的三种实现：

A、用spring事务执行插入操作

Java代码


@Transactional("dbTransaction")

public void batchInsertJDBC1(List<Poi> poilist) throws DataAccessException {

String sql = "insert into tb_poi (tag, poi, poiid, meshid, owner, featcode, sortcode, namec, namee, namep, names) values (?, GeomFromText(?), ?, ?, ?, ?, ?, ?, ?, ?, ?)";

for (Poi poi : poilist) {

Object[] args = {poi.getTag(), poi.getPoint(), poi.getPoiid(), poi.getMeshid(), poi.getOwner(), poi.getFeatcode(), poi.getSortcode(), poi.getNamec(),

poi.getNamee(), poi.getNamep(), poi.getNames()};

jdbcTemplate.update(sql, args);

}

}

B、用spring事务和springjdbc的batchUpdate

Java代码


@Transactional("dbTransaction")

public void batchInsertJDBC2(List<Poi> poilist) throws DataAccessException {

String sql = "insert into tb_poi (tag, poi, poiid, meshid, owner, featcode, sortcode, namec, namee, namep, names) values (?, GeomFromText(?), ?, ?, ?, ?, ?, ?, ?, ?, ?)";

List<Object[]> batchArgs = new ArrayList<Object[]>();

for (Poi poi : poilist) {

Object[] args = {poi.getTag(), poi.getPoint(), poi.getPoiid(), poi.getMeshid(), poi.getOwner(), poi.getFeatcode(), poi.getSortcode(), poi.getNamec(),

poi.getNamee(), poi.getNamep(), poi.getNames()};

batchArgs.add(args);

}

jdbcTemplate.batchUpdate(sql, batchArgs);

}

C、用spring事务，利用mysql特性，拼写insert sql。

Java代码


@Transactional("dbTransaction")

public void batchInsertJDBC3(List<Poi> poilist) throws DataAccessException {

StringBuffer sqlbuf = new StringBuffer()

.append("insert into tb_poi (tag, poi, poiid, meshid, owner, featcode, sortcode, namec, namee, namep, names) values ");

MessageFormat form = new MessageFormat("(''{0}'', GeomFromText(''{1}''), ''{2}'', ''{3}'', ''{4}'', ''{5}'', ''{6}'', ''{7}'', ''{8}'', ''{9}'', ''{10}''),");

for (Poi poi : poilist) {

Object[] args = {poi.getTag(), poi.getPoint(), poi.getPoiid(), poi.getMeshid(), poi.getOwner(), poi.getFeatcode(), poi.getSortcode(), poi.getNamec().replaceAll("'", "\\\\'"),

poi.getNamee().replaceAll("'", "\\\\'"), poi.getNamep().replaceAll("'", "\\\\'"), poi.getNames().replaceAll("'", "\\\\'")};

sqlbuf.append(form.format(args));

}

String sql = sqlbuf.toString();

sql = sql.substring(0, sql.length()-1);

jdbcTemplate.update(sql);

}

测试一：每次处理100条，共600条。

测试二：每次处理1000条，共9000条。

直接上结论：

mybatis.1最慢。而且慢很多，很多。

mybatis.2很快。是mybatis中最快的。

mybatis.3比2慢一点。

jdbc.A比B稍快，两者差不多，和mybatis.3也在伯仲之间。

jdbc.C最快，比其他5种都快。

大排行，从用时少到用时多：

jdbc.C < mybatis.2 < jdbc.A < jdbc.B , mybatis.3 << mybatis.1