Java调用接口如何获取json数据解析后保存到数据库
作者：半度纳 发布时间：2023-11-16 15:01:36
标签：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 < 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);
}
}
}
来源：https://blog.csdn.net/Five297/article/details/127093510
0
投稿猜你喜欢
- 最近在开发项目的时候遇到一个问题，在myecilpes上使用googlede gson读取项目中的json文件成功，然后把项目发布到tomc
前言RefreshIndicator是Flutter里常见的下拉刷新组件，使用是比较方便的。但由于产品兄弟对其固定的刷新样式很是不满，而且代- 在gitee上创建springcloud仓库 application.yaml(https方式)server: por
- Android植物大战僵尸小游戏全部内容如下：相关下载：Android植物大战僵尸小游戏具体代码如下所示：package com.examp
- 这几天自己研究了关于地手机上面开发安卓地图的问题，发现百度官方示例demo讲解百度持续定位方面还是讲解的有些不清楚，本人研究了几次之后将其弄
- spring in action第三版读书笔记spring3.0引入了spring expression language(spel)语言,
- Java 数据库连接池详解数据库连接池的原理是：连接池基本的思想是在系统初始化的时候，将数据库连接作为对象存储在内存中，当用户需要访问数据库
- 1.在res上面右键->New->Android resource directory2.点击之后，出现下图Resource t
- monitor概念管程，监视器。在操作系统中，存在着semaphore和mutex，即信号量和互斥量，使用基本的mutex进行开发时，需要小
- 先上代码新建一个Thread,代码如下:package com.thread.test;public class MyThread exte
- 样例代码在讲 Flutter 的盒子模型前，先看看HTML 中的盒子模型。如下图所示，一个页面元素包括了与父级容器的外边距（margin），
- 在看别人的关于CopyOnWriteArrayList 这个类的时候，看到有人提出了关于：数组拷贝的方法Arrays.copyOf() 的问
- 本文实例为大家分享了flutter实现appbar下选项卡切换的具体代码，供大家参考，具体内容如下TabBar 、Tab、TabBarVie
- Spring JPA 增加字段执行异常用Spring jpa Entity里面增加了几个字段，但启动报错，提示column Unable t
- 一、前言对于任何框架而言，在使用前都要进行一系列的初始化，MyBatis也不例外。二、MyBatis的初始化做了什么2.1 Mybatis的
- mybatis 查询返回Map<String,Object> 类型，平时没太注意怎么用，今天又遇到了总结记录一下，方便以后处理此
- maven3 安装：安装 Maven 之前要求先确定你的 JDK 已经安装配置完成。Maven是 Apache 下的一个项目，目前最新版本是
- 这是Hadoop学习全程记录第1篇，在这篇里我将介绍一下如何在Linux下安装Hadoop1.x。先说明一下我的开发环境：虚拟机：VMwar
- 本文实例讲述了Android之复选框对话框用法。分享给大家供大家参考。具体如下：main.xml布局文件<?xml version=&
- MyBatis简介MyBatis是一个支持普通SQL查询，存储过程和高级映射的优秀持久层框架。MyBatis消除了几乎所有的JDBC代码和参
