«

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

时间：2024-5-13 09:00     作者：韩俊     分类： Javascript

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

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

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

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

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

        /**
     * @Title: 查询
     * @Description: 查询车辆的记录
     * @Author: 半度纳
     * @Date: 2022/9/27 17:33
     */
    @GetMapping("/Blacklist")
    public void selectBlacklist(){
        boolean a = imBuBlacklistService.selectBlacklist();//调用业务层方法
    }

    3.在Service中添加方法

        /**
     * @Title: 查询
     * @Description: 查询车辆的记录
     * @Author: 半度纳
     * @Date: 2022/9/27 17:33
     * @return
     */
    public boolean selectBlacklist();//返回值类型没要求

    4.在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
 
 
    /**
     * @Title: 查询
     * @Description: 查询车辆的记录
     * @Author: 半度纳
     * @Date: 2022/9/27 17:33
     * @return
     */
    @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实例，返回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);
        }
 
    }
}

    标签: javascript

    热门推荐

    1 JS怎么实现将图片URL转base64
    2 Node.js中的Promise异步编程怎么掌握
    3 解决js函数闭包内存泄露问题的办法
    4 学习javascript面向对象 理解javascript原型和原型链
    5 如何用Vue实现数据的双向绑定
    6 解决JS无法调用Controller问题的方法
    7 深入理解JS正则表达式---分组
    8 jquery如何实现点击跳转到新页面
    9 vue转发200状态码如何解决
    10 javascript实现数组去重的多种方法

    日历

    标签

    hbase maven eclipse sybase PostgreSQL spring emcache oracle mongodb redis nginx golang java vue android ios mysql linux 微信小程序 css html php教程 javascript python php

    搜索

    最新文章

    热门文章