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
转载：/article/4055639.html