Mybatis 之批量处理
该内容参考于 MybatisPlus 的批量操作方法
通过继承 MybatisPlus 的 ServiceImpl 来获取 SqlSession （实际上可以通过其他方式获取，因为使用了 MybatisPlus，所以就拿来直接用了），然后获取 Mapper 执行对应的方法，然后执行 flushStatements() 发送到数据库吗，代码如下
public void invalidProcessBatch(List<HcPassRecords> list) {Assert.notEmpty(list, "error: entityList must not be empty", new Object[0]);SqlSession batchSqlSession = this.sqlSessionBatch();Throwable throwable = null;try {int i = 0;for(Iterator<HcPassRecords> iteratored = list.iterator(); iteratored.hasNext(); ++i) {HcPassRecords hcPassRecords = iteratored.next();// 获取 MapperHcPassRecordsProcessMapper sqlSessionMapper = batchSqlSession.getMapper(HcPassRecordsProcessMapper.class);// 执行方法sqlSessionMapper.invalidProcess(hcPassRecords.getPassRecordsId(), TrucksNodeType.PARK_OUT.getName(), PassRecordConstant.PROCESS_INVALID);if (i >= 1 && i % 1000 == 0) {// 这里是没循环 1000 次，发送到数据库一次batchSqlSession.flushStatements();}}batchSqlSession.flushStatements();} catch (Throwable e) {throwable = e;throw e;} finally {if (batchSqlSession != null) {if (throwable != null) {try {batchSqlSession.close();} catch (Throwable var16) {throwable.addSuppressed(var16);}} else {batchSqlSession.close();}}}
}