JSON 转 mysql create table

我是白小白

JSON 转 mysql create table




运行

图片.png



结果

图片.png



刚工作一年的 java程序员 平时就 crud

如果有大佬看到bug 或者可以优化的地方
可以帮忙指出来 不胜感激

[Java] 纯文本查看 复制代码

package com.github.kewei1;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.github.kewei1.model.JsonMetaNode;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Set;

public class JsonToBean {

    public static String INTEGER = "java.lang.Integer";
    public static String LONG = "java.lang.Long";
    public static String STRING = "java.lang.String";
    public static String JSONOBJECT = "com.alibaba.fastjson.JSONObject";
    public static String JSONArray = "com.alibaba.fastjson.JSONArray";
    public static String FLOAT = "java.lang.Float";
    public static String DOUBLE = "java.lang.Double";
    public static String BIG_DECIMAL = "java.math.BigDecimal";
    public static String DATE = "java.util.Date";





    /**
     * 建表语句
     *
     * [url=home.php?mod=space&uid=686208]@AuThor[/url] sql
     * [url=home.php?mod=space&uid=686237]@date[/url] 10/23/17 3:43 PM
     */
    private static String createTable(String tableName, List<JsonMetaNode> jsonMetaNodeList) {

        String sqlCreate = "CREATE TABLE " + tableName + "(\n" + getRowName(jsonMetaNodeList);
        return sqlCreate;
    }

    private static String getRowName(List<JsonMetaNode> jsonMetaNodeList) {
        StringBuffer sqlRowNameBuffer = new StringBuffer();
        boolean hasId = false;
        for (JsonMetaNode jsonMetaNode : jsonMetaNodeList) {
            String key = jsonMetaNode.getKey();
            String valueType = jsonMetaNode.getValueType();
            String type = "";
            if (INTEGER.equals(valueType)) {
                type = "int(100)";
            } else if (LONG.equals(valueType)) {
                type = "bigint(100)";
            } else if (STRING.equals(valueType)) {
                type = "varchar(100)";
            } else if (BIG_DECIMAL.equals(valueType)) {
                type = "decimal(18,8)";
            } else if (FLOAT.equals(valueType)) {
                type = "float(100,10)";
            } else if (DOUBLE.equals(valueType)) {
                type = "double(100,10)";
            } else if (DATE.equals(valueType)) {
                type = "datetime";
            } else if (JSONOBJECT.equals(valueType) || JSONArray.equals(valueType)) {
                type = "json";
            }else {
                type = "varchar(100)";
            }
            sqlRowNameBuffer.append(key).append(" ").append(type).append(" ").append("NULL");
            if (key.equals("id")){
                hasId = true;
                sqlRowNameBuffer.append(" ").append("NOT NULL ,").append("\r\n");
            }else {
                sqlRowNameBuffer.append(",").append("\r\n");
            }
        }
        if (!hasId){
            sqlRowNameBuffer.append("id").append(" ").append("int(12)").append(" ").append(" ")
                    .append("NOT NULL ,").append("\r\n PRIMARY KEY (`id`) ");
        }
        sqlRowNameBuffer.deleteCharAt(sqlRowNameBuffer.length() - 1);
        sqlRowNameBuffer.append(" ) ENGINE=InnoDB;");
        String sqlRowName = sqlRowNameBuffer.toString();
        return sqlRowName;
    }


    public static String jsontosql(String tableName, String json)  {
        List<JsonMetaNode> jsonMetaNodeList = new ArrayList<JsonMetaNode>();
        // 转换成json对象
        JSONObject jsonObject = (JSONObject) JSON.parse(json);
        Set<String> strings = jsonObject.keySet();
        Iterator<String> iterator = strings.iterator();
        // 遍历json对象，根据key获取value并获取value的类型
        while (iterator.hasNext()) {
            JsonMetaNode jsonMete = new JsonMetaNode();
            String next = iterator.next();
            jsonMete.setKey(next);
            Object o = jsonObject.get(next);
            if (o != null) {
                String name = o.getClass().getName();
                jsonMete.setValueType(name);
            }
            jsonMetaNodeList.add(jsonMete);
        }
        //　调用建表语句的方法
        String sqlCreateTable = createTable(tableName, jsonMetaNodeList);
        System.out.println(sqlCreateTable);
        return sqlCreateTable;
    }


    public static void main(String[] args) {

        String s = "{\"p_id\":\"73\",\"p_title\":\"微光波炉\\/烤箱保养\",\"p_mode\":\"1\",\"p_summary\":\"健康生活\",\"p_icon\":\"1491634953186.jpeg\",\"p_imageUrl\":null,\"p_priceA\":\"80\",\"p_priceB\":null,\"p_duration\":\"60\",\"p_introduce\":\"微波炉、烤箱等长时间不清洁会造成机器内汤汁堆积，对加热食物带来种种异味，滋生细菌，直接会导致肠道疾病。我们的高温深层次消毒服务，将微波炉进行深度清洁，去异味，高温杀菌，保障健康生活，延长微波炉使用寿命。\",\"p_fit_people\":\"微波炉\\/烤箱\",\"p_service_introduce\":\"\",\"p_pubtime\":\"1491634954\",\"p_pv\":\"1927\",\"c_id\":\"30\",\"m_id\":\"100\"}";
        String yy = "{\n" +
                "\t\"animals\":{\n" +
                "\t\"dog\":[\n" +
                "\t\t{\"name\":\"Rufus\",\"breed\":\"labrador\",\"count\":1,\"twoFeet\":false},\n" +
                "\t\t{\"name\":\"Marty\",\"breed\":\"whippet\",\"count\":1,\"twoFeet\":false}\n" +
                "\t],\n" +
                "\t\"cat\":{\"name\":\"Matilda\"}\n" +
                "}\n" +
                "}";
        // create table
        String jsontosql = jsontosql("test", yy);
    }



}

psvajaz

我只懂C++、python、c#、vb，不懂java，学习以下。
但是按照NoSQL转关系型数据库，还是需要可能存在的完整字段名和数量才行。否者在insert中很容易出现字段名不存在的问题。
一般情况下不建议直接转，而是提取NoSQL中必要的字段转

crazy1989

刚工作一年就开始玩了，可以可以

psvajaz

还有一个就是Json的数据格式只有null, bool, int, double, string, objcet, array。判断的时候必须要按照这个顺序，否者会出现问题。其他类型都不存在

我是白小白

psvajaz 发表于 2023-1-13 15:36
我只懂C++、python、c#、vb，不懂java，学习以下。
但是按照NoSQL转关系型数据库，还是需要可能存在的完整 ...

谢谢大佬指点

我是白小白

psvajaz 发表于 2023-1-13 15:42
还有一个就是Json的数据格式只有null, bool, int, double, string, objcet, array。判断的时候必须要按照这 ...

谢谢大佬指点 我再研究下

wangdong123wuai

不错，还行就是少了一个JsonMetaNode，补充一下，网上找到了一个  public  class JsonMetaNode {
    private String key;
    private String valueType;
    //数据库中的列名
    private String dbColName;
    private List<JsonMetaNode> children;
    public JsonMetaNode() {
    }
    public JsonMetaNode(String key, String valueType) {
        this.key = key;
        this.valueType = valueType;
    }
    public String getKey() {
        return key;
    }
    public String getValueType() {
        return valueType;
    }
    public void setKey(String key) {
        this.key = key;
    }
    public void setValueType(String valueType) {
        this.valueType = valueType;
    }
}