时间:2021-03-02 11:46:44 | 栏目:JAVA代码 | 点击:次
我发现不管改成Mybatis Batch提交或者原生JDBC Batch的方法都不起作用,实际上在插入的时候仍然是一条条记录的插,速度远不如原来Mybatis的foreach拼接SQL的方法。
// 第一步判断更新或添加
String[] splitUserId = userGroup.getUserId().split(",");
String[] spiltUserName = userGroup.getUserName().split(",");
if (StringUtils.isBlank(userGroup.getId())) {
userGroup.setNum(spiltUserName.length);
userGroupMapper.insert(userGroup);
} else {
userGroup.setNum(spiltUserName.length);
userGroupMapper.updateById(userGroup);
}
/* 第二部删除中间表信息,字段冗余 */
Map<String, Object> columnMap = new HashMap<String, Object>();
columnMap.put("USER_GROUP_ID", userGroup.getId());
groupUsersService.removeByMap(columnMap);
/* 第三步,批量保存中间表 */
if (splitUserId.length != 0) {
List<GroupUsers> groupUsersList = Lists.newArrayList();
for (int i = 0; i < splitUserId.length; i++) {
GroupUsers gu = new GroupUsers();
gu.setUserId(splitUserId[i]);
gu.setUserName(spiltUserName[i]);
gu.setUserGroupId(userGroup.getId());
groupUsersList.add(gu);
}
groupUsersService.saveBatch(groupUsersList);
}
最近项目用的mybatis-plus做的映射,有个批处理文件内容的需求,在使用mybatis-plus的批处理方法saveBatch时发现速度特别慢,测试从1000到10000到80000条基本上是线性增加,80000条时差不多要90秒。

经debug排查sql语句是批量执行,所以应该不是框架本身的问题,由于用的是公司的手脚架,在mysql连接配置中发现了问题

这里少配置了一个参数rewriteBatchedStatements=true
结果
修改前24w数据大概在254709 ms
修改后24w数据大概在42506 ms
单次批量插入10000条大概在1700ms