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();
            // 获取 Mapper
            HcPassRecordsProcessMapper 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();
            }
        }

    }
}