JSON转SQL小工具源码分享
JSON转SQL小工具源码分享
dongfanger
发布于 2023-11-09 09:22:30
发布于 2023-11-09 09:22:30
将key-value的JSON数据，转换为insert的SQL语句，进而实现网页数据存储到数据库。
- 解析MySQL建表语句，找出”字符串“字段
- 遍历JSON结构，拼接为SQL语句
1、解析建表语句
之所以要解析建表语句，是因为在拼接SQL时，”字符串“字段没有双引号，需要手动加上。第一步就是通过JDBC来解析表字段，根据字段类型，筛选出”字符串“字段。
public static Map<String, String[]> parseTable(String tableName) {
List<String> stringType = new ArrayList<>(Arrays.asList("CHAR", "VARCHAR", "TEXT", "DATE", "TIME", "DATETIME", "TIMESTAMP"));
List<String> stringFieldList = new ArrayList<>();
try {
DatabaseMetaData databaseMetaData = conn.getMetaData();
ResultSet specificResultSet = databaseMetaData.getColumns(null, "%", tableName, "%");
String columnName;
String columnType;
while (specificResultSet.next()) {
columnName = specificResultSet.getString("COLUMN_NAME");
columnType = specificResultSet.getString("TYPE_NAME");
if (stringType.contains(columnType) && !stringFieldList.contains(columnName)) {
stringFieldList.add(columnName);
}
}
} catch (Exception e) {
log.error("parse error ", e);
}
Map<String, String[]> map = new HashMap<>();
map.put(tableName, stringFieldList.toArray(new String[0]));
return map;
}”字符串“字段识别了类型为"CHAR", "VARCHAR", "TEXT", "DATE", "TIME", "DATETIME", "TIMESTAMP"。conn是通过mysql-connector-java创建的数据库连接对象。
2、拼接insert语句
public static String json2Sql(JSONObject json, String tableName) {
Map<String, String[]> map = parseTable(tableName);
ArrayList<String> keys = new ArrayList<>();
ArrayList<String> values = new ArrayList<>();
for (Map.Entry<String, Object> entry : json.entrySet()) {
if (entry.getKey().equals("id")) {
continue;
}
keys.add(entry.getKey());
String value = entry.getValue() == null ? null : entry.getValue().toString();
if (Arrays.asList(map.get(tableName)).contains(entry.getKey())) {
if (value != null) {
if (value.indexOf('"') != -1) { // 处理扩展字段包含json情况
value = String.format("\"%s\"", value.replace("\"", "\\\""));
} else {
value = '"' + value + '"'; // 字符串字段给sql语句手动加上双引号
}
}
}
values.add(value);
}
return String.format("insert into %s(%s) values (%s);", tableName, String.join(",", keys), String.join(",", values));
}拼接时先过滤id字段，然后判空，最后根据”字符串“字段判断是否需要手动添加双引号，注意扩展字段有可能json，也就是会出现双重双引号，需要加上转移字符。
3、测试
@Test
void json2sql() {
String json = "{\n" +
" \"id\": \"1\",\n" +
" \"name\": \"gang\",\n" +
" \"no\": null,\n" +
" \"type\": 1,\n" +
" \"created\": \"2020-05-09 11:35:40\",\n" +
" \"ext\": \"{\\\"email\\\":\\\"abc@qq.com\\\"}\"\n" +
"}";
JSONObject jsonObject = JSON.parseObject(json);
String sql = DBUtil.json2Sql(jsonObject, "my_test_table");
log.info(sql);
}输出：
insert into my_test_table(ext,no,created,name,type) values ("{\"email\":\"abc@qq.com\"}",null,"2020-05-09 11:35:40","gang",1);JSON转SQL，需要根据字段类型做特殊处理转换。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2023-11-08，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
云数据库 MySQL
腾讯云数据库 MySQL（TencentDB for MySQL）为用户提供安全可靠，性能卓越、易于维护的企业级云数据库服务。其具备6大企业级特性，包括企业级定制内核、企业级高可用、企业级高可靠、企业级安全、企业级扩展以及企业级智能运维。通过使用腾讯云数据库 MySQL，可实现分钟级别的数据库部署、弹性扩展以及全自动化的运维管理，不仅经济实惠，而且稳定可靠，易于运维。