第一种：
因为Mysql数据每次发送sql语句的长度不能超过1M,所以，每次发送insert语句以固定长度发送：
将sql语句在provider中，以固定长度装入List集合中，然后返回service层，调用mapp,发送sql语句
//provider类public class sql { private List sqlList = new ArrayList<>(); private void makeUpSql(StringBuilder sql, StringBuilder paramSql2) { sqlList.add(sql.append(paramSql2.substring(0, paramSql2.length()-1)).toString()); } @SuppressWarnings("unchecked") public List batchInsert(Map map) throws Exception { List beans = (List ) map.get("list"); int length = Numbers.parseInt(map.get("length")); Class bclz = beans.get(0).getClass(); StringBuilder sql = batchInsertBeforeSql(beans); int sizeBefore = sql.toString().getBytes().length; StringBuilder paramSql2 = new StringBuilder(); for (IBean bean : beans) { int sizeSql1 = paramSql2.toString().getBytes().length+sizeBefore; StringBuilder paramSql2c = new StringBuilder(paramSql2.toString()); paramSql2.append("("); for(Field f : bclz.getDeclaredFields()) { f.setAccessible(true); if (!Modifier.isStatic(f.getModifiers())) {// 非静态资源 String fname = f.getName(); if("id".equals(fname) ) { continue; } String value = Strings.of(f.get(bean)).replaceAll("\"", "\\\\\""); value = value.replaceAll("\'", "\\\\\'"); paramSql2.append("\"").append(value).append("\", "); } } paramSql2 = new StringBuilder(paramSql2.substring(0, paramSql2.length()-2)); paramSql2.append("),"); if(sizeSql1 =length) { makeUpSql(sql,paramSql2c); Map map1 = new HashMap<>(); List nextList = beans.subList(beans.indexOf(bean), beans.size()); map1.put("list", nextList); map1.put("length", length); return batchInsert(map1); } } sqlList.add(sql.append(paramSql2.substring(0, paramSql2.length()-1)).toString()); return sqlList; } public StringBuilder batchInsertBeforeSql(List beans) { StringBuilder sql = new StringBuilder("insert into "); Class bclz = beans.get(0).getClass(); sql.append(bclz.getSimpleName().toLowerCase()).append(" ("); StringBuilder paramSql = new StringBuilder(); for(Field f : bclz.getDeclaredFields()) { f.setAccessible(true); if (!Modifier.isStatic(f.getModifiers())) {// 非静态资源 String fname = f.getName(); if("id".equals(fname) ) { continue; } paramSql.append(",").append(fname); } } return sql.append(paramSql.substring(1)).append(") values "); }//service层public void sendSql(List listSql) { for (String sql : listSql) { Mapper.batchInsert3(sql); }//mapper层@Insert("${sql}")int batchInsert3(@Param("sql") String sql);
第二种：
创建一个session，将每条insert语句单条调用mapper,使用session统一commit
//若指定有多个数据源，需要添加注解@Qualifier，指明使用哪个数据库的SqlSessionTemplate @Qualifier("kwSqlSessionTemplate")@Autowiredprivate SqlSessionTemplate sqlSessionTemplate;public void batchInsert(List beanList) { SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH,false); IssueMapper mapper = session.getMapper(IssueMapper.class); try { for (int i = 0;i