调用接口,解析Json字符串并存入数据库

Posted 孔祥宙

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了调用接口,解析Json字符串并存入数据库相关的知识,希望对你有一定的参考价值。

目录

一.通过api接口获取json字符串

二.使用JSONArray和JSONObject解析json字符串

三.将实例化对象的数据存入数据库中


一.通过api接口获取json字符串

通过get(httpGet)请求获取接口数据,使用HttpClient基本分六步:

  1. 创建HttpClient实例
  2. 创建某种连接方法的实例
  3. 调用HttpClient实例的execute方法来执行请求方法
  4. 读取response
  5. 释放连接,无论执行方法是否成功
    //创建httpClient实例
    CloseableHttpClient client = HttpClients.createDefault();
    //汽车之家api接口
    String apiPath = "https://www.autohome.com.cn/ashx/index/GetHomeFindCar.ashx";
    //创建get方法请求实例
    HttpGet httpGet = new HttpGet(apiPath);
    //添加表头,text/xml表示XML格式
    httpGet.addHeader("content-type","text/xml");
    //调用HttpClient实例执行GET实例,返回response
    HttpResponse response = client.execute(httpGet);
    //解析response,这个过程主要取决于获取的json格式,是一个对象还是一个数组,放到后面详解
    String result = EntityUtils.toString(response.getEntity());
    //释放连接
    response.close();
    client.close();

    其中我们可以对response的状态(state)进行判断,验证是否获取数据.    页面请求的状态值,分别有:200请求成功、303重定向、400请求错误、401未授权、403禁止访问、404文件未找到、500服务器错误.(HttpStatus.OK = 200;HttpStatus.BAD_REQUEST = 400;HttpStatus.FORBIDDEN = 403;HttpStatus.NOT_FOUND = 404;HttpStatus.SERVICE_UNAVAILABLE =500)

    if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) 
        String result = EntityUtils.toString(response.getEntity());//解析response
    //getStatusLine()方法返回保存请求状态的StatusLine对象,getStatusCode()获取状态码

    二.使用JSONArray和JSONObject解析json字符串

        在解析json字符串之前,我们一定要先确定json字符串的格式,针对不同的格式要使用不同的解析方法这里列举了一些常见的json字符串格式,例如:数值,字符串,数组,对象数组或数组对象.重点就在于花括号和中括号的使用,一定要注意这两个符号,可能会导致json解析错误.

//json数值

    "key" : 520,
    "key1" : 1314
    
//json字符串

    "key" : "我爱你",
    "key1" : "一生一世"

//json数组

    "key" : [520, 1314],
    "key1" : [520, 3344]

//json对象数组

    "我" : [
                  "key": "我爱你",
                  "key1": "一生一世"
    ]

//json数组对象

    "我" : 
                  [520,1314],
                  ["我爱你", "一生一世"]
    

 可以看出从汽车之家获取的json字符串是json数组格式的,所以我们要用JSONArray进行解析,然后再对json数组进行遍历,获取每一个json对象,然后对json对象进行数据的读取.

//将json字符串解析成json数组的形式
JSONArray jsonArray = JSONArray.parseArray(result);
//利用遍历解析json数组,并在循环中解析每一个json对象
for (int i = 0; i < jsonArray.size(); i++) 
    //将json数组解析为每一个jsonObject对象
    JSONObject object=jsonArray.getJSONObject(i);
    //实例化一个dao层或者domain层的对象
    CarBrand Brand = new CarBrand();
    //将json对象中的数据写入实例化的对象中
    //注意object读取的字段要和json对象中的字段一样,否则无法解析
    Brand.setId(object.getInteger("id"));
    Brand.setName(object.getString("name"));
    Brand.setGroup(object.getString("letter"));

三.将实例化对象的数据存入数据库中

在springboot框架之中,mybatis-generator可以生成domain层的实体文件,xml文件,mapper文件和相应的service文件,利用这个插件可以省去我们写sql语句的时间,我们可以在service层直接调用相应的方法.

//调用service层的add方法,直接将实例化对象写入数据库
CarBrandService.add(Brand);

完整代码如下

package org.linlinjava.litemall.admin.service;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.linlinjava.litemall.db.dao.LitemallCarBrandMapper;
import org.linlinjava.litemall.db.domain.LitemallCarBrand;
import org.linlinjava.litemall.db.service.LitemallCarBrandService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;


@Service
public class AdminCarBrandService 



    @Autowired
    CarBrandService carBrandService;


    public void httpRequest() 
    
        //使用httpclient获取api数据
        CloseableHttpClient client = HttpClients.createDefault();
        String apiPath = "https://www.autohome.com.cn/ashx/index/GetHomeFindCar.ashx";
        HttpGet httpGet = new HttpGet(apiPath);
        try
            httpGet.addHeader("content-type","text/xml");
            HttpResponse response = client.execute(httpGet);
            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) 
                //对获取的string数据进行json解析
                String result = EntityUtils.toString(response.getEntity());
                JSONArray jsonArray = JSONArray.parseArray(result);

                for (int i = 0; i < jsonArray.size(); i++) 
                    //将json对象中的数据写入实例化对象中
                    CarBrand carBrand = new CarBrand();
                    JSONObject object=jsonArray.getJSONObject(i);
                    carBrand.setId(object.getInteger("id"));
                    carBrand.setName(object.getString("name"));
                    carBrand.setGroup(object.getString("letter"));

                    //将实例化对象存入数据库
                    carBrandService.add(CarBrand);
                

            
        catch (Exception e)
            throw new RuntimeException(e);
        

    

将自己的学习过程记录下来,如果有错误的地方,欢迎大家讨论并指出.

C++下如何将json数据存入mysql数据库

请问如何用C++实现将返回的json结果存入到MySql数据库中,求解决办法,有实例最好,万分感谢!json数据如下图

当做字符串存入数据库
或者把json解析成不同的字段 根据层次创建表格 保存数据
mongodb可以存json数据
参考技术A 这完全可以当成一个字符串来保存到数据库
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
参考技术B 额 序列化啊 然后存储
使用的时候再解析

以上是关于调用接口,解析Json字符串并存入数据库的主要内容,如果未能解决你的问题,请参考以下文章

kettle调用一个web service 如何将返回的json字符串解析并放入数据表中

C++下如何将json数据存入mysql数据库

关于json格式字符串解析并用mybatis存入数据库

使用接口回调解析数据并下载网络图片

遍历win10文件夹并解析json文件,按照json格式存入mongo数据库(基于python 3.6)

安卓用httpurlconnection怎么调用接口地址并获取返回值