SqlSession sqlSession = null; try { //如果自动提交设置为true,将无法控制提交的条数,改为最后统一提交 sqlSession = sqlSessionFactoryXXX.openSession(ExecutorType.BATCH, false); xxxMapper mapper = sqlSession.getMapper(xxxMapper.class); for (TraceRecord record : batchRecords) { mapper.insertTraceRecord(record); } sqlSession.commit(); } catch (Exception e) { if (sqlSession != null) { sqlSession.rollback(); } throw new Exception("Failed to save records to database", e); } finally { if (sqlSession != null) { sqlSession.close(); } }
|