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

这篇文章主要介绍了Java调用接口如何获取json数据解析后保存到数据库问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

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

今天给大家带来一个调用接口，来获取数据解析后再保存到数据库中的业务，业务中的Mapper和实体类我就不在这里写了，相信大家都会写新增的SQL和定义实体类。

下面是我写的业务代码，有什么建议可以给我评论留言。

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

调用接口,解析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

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

在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