Java怎么调用接口获取json数据解析后保存到数据库

本篇内容主要讲解“Java怎么调用接口获取JSON数据解析后保存到数据库”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Java怎么调用接口获取json数据解析后保存到数据库”吧!

Java调用接口获取json数据保存到数据库

在yml文件中配置自己定义的接口URL

    //自己定义的JSON接口URL    blacklist_data_url: 接口URL

在Controller中添加请求方法和路径

        @GetMapping("/Blacklist")    public void selectBlacklist(){        boolean a = imBuBlacklistService.selectBlacklist();//调用业务层方法    }

在Service中添加方法

        public boolean selectBlacklist();//返回值类型没要求

在ServiceImpl中实现方法

    import cn.hutool.json.JSONArray;    import cn.hutool.json.JSONObject;    import com.alibaba.fastjson2.JSON;      @Value("${blacklist_data_url}")    public String blacklist_data_url;//接口URL          @Override    public boolean selectBlacklist() {        //获取的JSON接口数据(在输出测试时sendGet方法可能会自动输出,具体需看底层代码)        String list= HttpUtils.sendGet(blacklist_data_url);        JSONObject j = JSON.parseObject(list);//将获取的JSON数据存储到变量中        if(j.getBoolean("success")){//获取success判断是否为空            JSONObject jsonData = j.getJSONObject("body");//解析JSON的body            JSONArray jsonArray = jsonData.getJSONArray("data");//解析JSON的data数据            JSONObject row = null;//定义一个空变量            ImBuBlacklist buBlacklist=new ImBuBlacklist();//new一个实体类用来接收数据            for (int y = 0; y < jsonArray.size(); ++y) {//循环将JSON数据存储到数据库中                buBlacklist = new ImBuBlacklist();//new一个实体类存储数据                row = jsonArray.getJSONObject(y);//获取数组中的数据                   //设置获取到的JSON号牌号码到实体类的相同字段中                buBlacklist.setPlateNumber(row.getString("mechanicalNumber"));                //设置获取到的JSON车辆类型到实体类的相同字段中                buBlacklist.setVehicleType(row.getString("MachType"));                //设置获取到的JSON检查日期到实体类的相同字段中                   buBlacklist.setExamineDate(row.getDate("createDate"));                //设置获取到的JSON检查地点到实体类的相同字段中                buBlacklist.setExamineAddress(row.getString("machineAddr"));                //设置获取到的JSON违规行为到实体类的相同字段中                buBlacklist.setIllegalBehavior(row.getString("joinTheBlacklistReason"));                //设置获取到的JSON黑名单类型到实体类的相同字段中                buBlacklist.setBlacklistType(row.getInteger("violations"));                //通过mapper的新增方法,把实体类中的JSON数据存到数据库中                imBuBlacklistMapper.insertImBuBlacklist(buBlacklist);            }            return true;//自己定义的返回值(没有用)        }else{            return false;        }    }

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

通过api接口获取json字符串

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

• 创建HttpClient实例

• 创建某种连接方法的实例

• 调用HttpClient实例的execute方法来执行请求方法

• 读取response

• 释放连接，无论执行方法是否成功

//创建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实例，返回responseHttpResponse 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;  @Servicepublic 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);        }     }}

到此，相信大家对“Java怎么调用接口获取json数据解析后保存到数据库”有了更深的了解，不妨来实际操作一番吧！这里是编程网网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！