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.SERVLE_UNAVA.D.NOT_FOUND = 404;HttpStatus.SERVLE> #使用JSONArray和JSONObject解析json字串

在解析json字串之前，我們一定要先確定json字串的格式，針對不同的格式要使用不同的解析方法這裡列舉了一些常見的json字串格式

例如:數值，字串，數組，物件數組或數組物件.重點就在於花括號和中括號的使用，一定要注意這兩個符號，可能會導致json解析錯誤.

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

可以看出從汽車之家取得的json字串是json陣列格式的，所以我們要用JSONArray進行解析，然後再對json陣列進行遍歷，取得每一個json對象，然後對json對象進行資料的讀取.

//json数值
{
    "key" : 520,
    "key1" : 1314
}    
//json字符串
{
    "key" : "我爱你",
    "key1" : "一生一世"
}
//json数组
{
    "key" : [520, 1314],
    "key1" : [520, 3344]
}
//json对象数组
{
    "我" : [
                  {"key": "我爱你"},
                  {"key1": "一生一世"}
    ]
}
//json数组对象
{
    "我" : {
                  [520,1314],
                  ["我爱你", "一生一世"]
    }
}

將實例化對象的資料存入資料庫中

在springboot框架之中，mybatis-generator可以生成domain層的實體文件，xml文件，mapper文件和相應的service文件，利用這個插件可以省去我們寫sql語句的時間，我們可以在service層直接調用相應的方法.

//将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"));
}

完整程式碼如下

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

以上是Java怎麼呼叫介面取得json資料解析後儲存到資料庫的詳細內容。更多資訊請關注PHP中文網其他相關文章！