最近公司有个需求就是将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。