基于mybatis动态拼接SQL实现批量存储

最近公司有个需求就是将excel的数据存储到数据库，不过数据库有三百多张表，不同的excel存在不同的表中，如果每张表都建个实体去映射需要建三百多个实体，代码大量重复不说，工程量太大，所以想到去动态拼接sql，批量上传。持久层框架选择了强大的mybatis，因为动态拼接，不采用预编译，变量用${}代替。
将excel文件名和对应数据库表名存储在一张表里，每次导入时候先去查找相应表名。再根据表名查找表所有的字段名(通过MetaData)。
自己建一个转化工具类：

@Slf4j
@Component
public class GetCuloumListUtil {
    @Value("${spring.datasource.url}")
    private String datasource;
    @Value("${spring.datasource.username}")
    private String username;
    @Value("${spring.datasource.password}")
    private String password;

    public List<String> getCuloumList(String tableName) throws SQLException {

        List<String> list = null;

            Connection conn = DriverManager
                    .getConnection(datasource+"?user="+username+"&password="+password);
            DatabaseMetaData metaData = conn.getMetaData();
            ResultSet resultSet = metaData.getColumns(null, "%", tableName, "%");
            list = new ArrayList<>();
            while (resultSet.next()) {
                String columnName = resultSet.getString("COLUMN_NAME");
                list.add(columnName);
            }

        log.info(tableName+"表字段名：{}", list.toString());
        return list;
    }

}

由于动态构建sql不创建实体，所以将读取每一列的值放到一个map中，key是列的序号，value是列的值，由于要求map中值有序，所以采用TreeMap实例化。读取的每一行是一个map，再将每一行的map放到一个list中。poi导入就不介绍了，这里部分代码如下：

for(int r=1;r<totalRows;r++){
            Map<Integer,String> map=new TreeMap();//要求map有序
            Row row = sheet.getRow(r);
            if (row == null) continue;

            //循环Excel的列
            for(int c = 0; c <this.totalCells; c++){

                if(row.getCell(c)!=null&&!row.getCell(c).equals("")){
                    if (row.getCell(c).getCellType()== HSSFCell.CELL_TYPE_NUMERIC){
                        log.info("cell类型是：{}",row.getCell(c).getCellStyle().getDataFormatString());
                        if(HSSFDateUtil.isCellDateFormatted(row.getCell(c))){//时间类型的列
                            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                            Date date = HSSFDateUtil.getJavaDate(row.getCell(c).getNumericCellValue());
                            map.put(c,dateFormat.format(date));
                        }else {
                            row.getCell(c).setCellType(Cell.CELL_TYPE_STRING);
                            map.put(c,row.getCell(c).getStringCellValue());
                        }
                    }else {
                        row.getCell(c).setCellType(Cell.CELL_TYPE_STRING);//列类型转为String
                        map.put(c,row.getCell(c).getStringCellValue());//列值存在map中
                    }
                }else {
                    map.put(c,"");
                }
            }
            list.add(map);
        }

mapping.xml配置文件：

<insert id="add">
    INSERT INTO ${tableName}
    <foreach collection="culoum" item="item" separator="," open="(" close=")">
        ${item}
    </foreach>
    VALUES
    <foreach collection="value" item="list" separator=",">

       <foreach collection="list.values" item="val" separator="," open="(" close=")">
         '${val}'
       </foreach>
    </foreach>
</insert>

这里采用了嵌套foreach循环，里面的collection可以直接用list.values取出map的value值，如果想取出map的key值可以用list.key，这也是mybatis的强大之处啊。
dao层代码：

  void add(@Param("tableName") String tableName, @Param("culoum") List culoum, @Param("value") List<Map<Integer, String>> value);

注意：
1、由于动态sql没有采用预编译，所以需要我们手动处理sql注入的问题。
2、由于mysql默认接受data最大是1M，也就是超过了就会失败。所以excel文件过大时候要设置max_allow_packet。