@Autowired
private SqlSessionTemplate sqlSessionTemplate;
public int insertFolder(List<IpsCatalogFolderDetail> ips) {
?? ??? ?//獲取sql會(huì)話
?? ??? ?SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false);
? ? ? ? //通過新的session獲取mapper，而不是常規(guī)的spring管理注入
? ? ? ? IipsCatalogFolderDetailDao folderDetailDao = session.getMapper(IipsCatalogFolderDetailDao.class);
? ? ? ? int size = ips.size();
? ? ? ? //如果有父類子類兩層都需要批量插入也可
? ? ? ? try {
? ? ? ? //外層循環(huán)
? ? ? ? ? ? for (int i = 0; i < size; i++) {
? ? ? ? ? ? ? ? ? ? ips.get(i).setType("folder");
? ? ? ? ? ? ? ? ? ? //用上面在session中獲取的mapper進(jìn)行插入操作
? ? ? ? ? ? ? ? ? ? folderDetailDao.insertFolder(ips.get(i));
? ? ? ? ? ? ? ? //內(nèi)層循環(huán)
? ? ? ? ? ? ? ? String cs = ips.get(i).getContentIds();
? ? ? ? ? ? ? ? if (StringUtils.isNotBlank(cs)){
? ? ? ? ? ? ? ? ? ? ? ? List<String> con = JSON.parseArray(cs,String.class);
? ? ? ? ? ? ? ? ? ? if (cs != null && con.size() > 0) {
? ? ? ? ? ? ? ? ? ? ? ? for (int j = 0; j < con.size(); j++) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? IpsCatalogFolderDetail ifd = new IpsCatalogFolderDetail();
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ifd.setParentCode(ips.get(i).getCode());
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ifd.setContentId(con.get(j));
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ifd.setType("contents");
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?//同樣用上面在session中獲取的mapper進(jìn)行插入操作
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? folderDetailDao.insertFolder(ifd);
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? //最后批量提交
? ? ? ? ? ? ? ? ? ? if (i % 200 == 0 || i == size - 1) {
? ? ? ? ? ? ? ? ? ? ? ? session.commit();//200個(gè)提交一次，手動(dòng)提交，提交后無(wú)法回滾
? ? ? ? ? ? ? ? ? ? ? ? session.clearCache(); //清理緩存，防止溢出
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }catch (Exception e) {
? ? ? ? ? ? System.out.println(e.toString());
? ? ? ? ? ?session.rollback(); //沒有提交的數(shù)據(jù)可以回滾
? ? ? ? } finally {
? ? ? ? ? ? session.close();
? ? ? ? }
? ? ? ? return 0;
? ? }

另外有時(shí)我們?cè)诓迦氲臅r(shí)候需要先查詢數(shù)據(jù)是否已存在，如果也需要批量操作可將insert和update語(yǔ)句合并，然后就可以繼續(xù)使用Batch Insert了

ORACLE數(shù)據(jù)庫(kù)sql示例

@Insert("merge into ips_catalog_folder_detail fd " +
? ? ? ? ? ? "using(select #{code,jdbcType=VARCHAR} c from dual)t " +
? ? ? ? ? ? "on(fd.FOLDERID = t.c)" +
? ? ? ? ? ??
? ? ? ? ? ? "when matched then"+
?? ??? ??? ?"update set "+
?? ??? ??? ?...(省略）...
?? ??? ??? ?"where ..."+
? ? ? ? ? ? "when not matched then insert(" +
? ? ? ? ? ? "fd.PROD_LINE," +
? ? ? ? ? ? "fd.TYPE," +
? ? ? ? ? ? "fd.PARENTFOLDERCODE," +
? ? ? ? ? ? "fd.FOLDERID," +
? ? ? ? ? ? "fd.FOLDERCODE," +
? ? ? ? ? ? "fd.FOLDERNAME," +
? ? ? ? ? ? "fd.COLUMN_SORTINDEX," +
? ? ? ? ? ? "fd.DESCRIPTION," +
? ? ? ? ? ? "fd.CONTENTID," +
? ? ? ? ? ? "fd.CREATETIME" +
? ? ? ? ? ? ")" +
? ? ? ? ? ? "VALUES" +
? ? ? ? ? ? "(" +
? ? ? ? ? ? "#{prod_line}," +
? ? ? ? ? ? "#{type,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{parentCode,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{code,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{aliasCode,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{name,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{sortIndex,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{desc,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{contentId,jdbcType=VARCHAR}," +
? ? ? ? ? ? "#{createTime,jdbcType=VARCHAR}" +
? ? ? ? ? ? ")")
? ? ? ? ? ? int insertFolder(IpsCatalogFolderDetail fd);

MYSQL示例：

REPLACE INTO users (id,name,age) VALUES(1, '張雨綺', 32);?

批量插入幾千條數(shù)據(jù)優(yōu)化(foreach)

項(xiàng)目中有一個(gè)耗時(shí)較長(zhǎng)的Job存在CPU占用過高的問題

經(jīng)排查發(fā)現(xiàn)，主要時(shí)間消耗在往MyBatis中批量插入數(shù)據(jù)。mapper configuration是用foreach循環(huán)做的，差不多是這樣。

<insert id="batchInsert" parameterType="java.util.List">
? ? insert into USER (id, name) values
? ? <foreach collection="list" item="model" index="index" separator=",">?
? ? ? ? (#{model.id}, #{model.name})
? ? </foreach>
</insert>

優(yōu)化代碼

可以看 http://www.mybatis.org/mybatis-dynamic-sql/docs/insert.html 中 Batch Insert Support 標(biāo)題里的內(nèi)容）

SqlSession session = sqlSessionFactory.openSession(ExecutorType.BATCH);
try {
? ? SimpleTableMapper mapper = session.getMapper(SimpleTableMapper.class);
? ? List<SimpleTableRecord> records = getRecordsToInsert(); // not shown
?
? ? BatchInsert<SimpleTableRecord> batchInsert = insert(records)
? ? ? ? ? ? .into(simpleTable)
? ? ? ? ? ? .map(id).toProperty("id")
? ? ? ? ? ? .map(firstName).toProperty("firstName")
? ? ? ? ? ? .map(lastName).toProperty("lastName")
? ? ? ? ? ? .map(birthDate).toProperty("birthDate")
? ? ? ? ? ? .map(employed).toProperty("employed")
? ? ? ? ? ? .map(occupation).toProperty("occupation")
? ? ? ? ? ? .build()
? ? ? ? ? ? .render(RenderingStrategy.MYBATIS3);
?
? ? batchInsert.insertStatements().stream().forEach(mapper::insert);
? ? session.commit();
} finally {
? ? session.close();
}

總結(jié)一下，如果MyBatis需要進(jìn)行批量插入，推薦使用 ExecutorType.BATCH 的插入方式，如果非要使用 <foreach>的插入的話，需要將每次插入的記錄控制在 20~50 左右

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: