java解析json数据生成mysql省市区街道四级联动sql

阳光穿透心脏的1/2处 2021-12-18 23:57 925阅读 1赞

##### 省市区联动在项目中算是比较常见的功能了，但是基础数据却非常多，网上很难找到比较全的数据，不过在github上有人利用爬虫抓取了国家统计局的数据，并生成了json文件，这样就可以利用java解析json文件并生成相应的sql文件，非常简单。(注意：数据不含港澳台，因为原json就没有。) #####

> github地址：[https://github.com/modood/Administrative-divisions-of-China][https_github.com_modood_Administrative-divisions-of-China]  
> 本文所使用到的json数据为上面链接所得

这里需要导入两个包：

<dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.54</version>
    </dependency>
    <dependency>
        <groupId>commons-io</groupId>
        <artifactId>commons-io</artifactId>
        <version>2.4</version>
    </dependency>

解析的java代码如下：

private static void main() throws IOException { 
    	// 我这里直接创建了一个springboot项目（习惯了）
        ClassPathResource resource = new ClassPathResource("pcas-code.json");
        // 需要生成到的位置，我直接放在了项目中
        File regionFile = new File("/Users/XXXXXXXX/demo/src/main/resources/region.sql");
        // 不存在则创建，存在则覆盖
        if (regionFile.exists()) { 
            regionFile.delete();
            regionFile.createNewFile();
        } else { 
            regionFile.createNewFile();
        }
        System.out.println(regionFile.getPath());
        // 写入文件即可
        Writer writer = new FileWriter(regionFile);
    
        File file = resource.getFile();
        String jsonString = FileUtils.readFileToString(file);
        JSONArray jsonArray = JSONArray.parseArray(jsonString);
        for (int i = 0; i < jsonArray.size(); i++) { 
            JSONObject jsonObject = jsonArray.getJSONObject(i);
            String code = jsonObject.getString("code");
            String name = jsonObject.getString("name");
            String sql = "insert into region(code, name, pid) values('"+code+"', '"+name+"', '0');";
    // System.out.println(sql);
            writer.write(sql);
            writer.write("\r\n");
            JSONArray children = jsonObject.getJSONArray("children");
            if (children != null) { 
                for (int i1 = 0; i1 < children.size(); i1++) { 
                    JSONObject jsonObject1 = children.getJSONObject(i1);
                    String code1 = jsonObject1.getString("code");
                    String name1 = jsonObject1.getString("name");
                    String sql1 = "insert into region(code, name, pid) values('"+code1+"', '"+name1+"', '"+code+"');";
    // System.out.println(sql1);
                    writer.write(sql1);
                    writer.write("\r\n");
                    JSONArray children1 = jsonObject1.getJSONArray("children");
                    if (children1 != null) { 
                        for (int i2 = 0; i2 < children1.size(); i2++) { 
                            JSONObject jsonObject2 = children1.getJSONObject(i2);
                            String code2 = jsonObject2.getString("code");
                            String name2 = jsonObject2.getString("name");
                            String sql2 = "insert into region(code, name, pid) values('"+code2+"', '"+name2+"', '"+code1+"');";
    // System.out.println(sql2);
                            writer.write(sql2);
                            writer.write("\r\n");
                            JSONArray children2 = jsonObject2.getJSONArray("children");
                            if (children2 != null) { 
                                for (int i3 = 0; i3 < children2.size(); i3++) { 
                                    JSONObject jsonObject3 = children2.getJSONObject(i3);
                                    String code3 = jsonObject3.getString("code");
                                    String name3 = jsonObject3.getString("name");
                                    String sql3 = "insert into region(code, name, pid) values('"+code3+"', '"+name3+"', '"+code2+"');";
    // System.out.println(sql3);
                                    writer.write(sql3);
                                    writer.write("\r\n");
                                }
                            }
                        }
                    }
                }
            }
        }
        writer.close();
    }

生成的效果如下：

insert into region(code, name, pid) values('11', '北京市', '0');
    insert into region(code, name, pid) values('1101', '市辖区', '11');
    insert into region(code, name, pid) values('110101', '东城区', '1101');
    insert into region(code, name, pid) values('110101001', '东华门街道', '110101');
    insert into region(code, name, pid) values('110101002', '景山街道', '110101');
    insert into region(code, name, pid) values('110101003', '交道口街道', '110101');
    insert into region(code, name, pid) values('110101004', '安定门街道', '110101');
    insert into region(code, name, pid) values('110101005', '北新桥街道', '110101');
    insert into region(code, name, pid) values('110101006', '东四街道', '110101');
    insert into region(code, name, pid) values('110101007', '朝阳门街道', '110101');

这里为了省事直接用嵌套的for循环了，生成sql文件以后直接用sql工具运行即可，需要提前创建好数据库表。

### 我知道你们懒，所以直接分享文件给你们吧，好用的话点个关注哦！ ###

链接:https://pan.baidu.com/s/1zjBtlzV_EKuZwf_8gYILCA  密码:a7om

[https_github.com_modood_Administrative-divisions-of-China]: https://github.com/modood/Administrative-divisions-of-China