Java는 어떻게 인터페이스를 호출하여 json 데이터를 얻고 이를 구문 분석한 후 데이터베이스에 저장합니까?-java지도 시간-php.cn

Java는 인터페이스를 호출하여 json 데이터를 가져와 데이터베이스에 저장합니다

1. yml 파일에 정의된 인터페이스 URL을 구성합니다

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

로그인 후 복사

2. 컨트롤러에 요청 메서드와 경로를 추가합니다

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

로그인 후 복사

. 3. 서비스 메서드

    /**
     * @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 get(httpGet) 요청을 통한 인터페이스 데이터, HttpClient 기본 분석 사용 6단계:

HttpClient 인스턴스 생성
특정 연결 메서드의 인스턴스 생성
HttpClient 인스턴스의 실행 메서드를 호출하여 실행 요청 메소드
응답 읽기
실행 메소드 성공 여부에 관계없이 연결 해제

//创建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();

로그인 후 복사

응답 상태를 판단하고 데이터를 얻었는지 확인할 수 있습니다. 페이지 요청 중 200개 요청 성공, 303 리디렉션, 400개 요청 오류, 401 승인 안 됨, 403 액세스 금지, 404 파일 찾을 수 없음, 500 서버 오류입니다.

(HttpStatus.OK = 200;HttpStatus.BAD_REQUEST = 400; HttpStatus.FORBIDDEN = 403;HttpStatus.NOT_FOUND = 404;HttpStatus.SERVICE_UN AVAILABLE =500)

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

로그인 후 복사

JSONArray 및 JSONObject를 사용하여 json 문자열을 구문 분석합니다

json 문자열을 구문 분석하기 전에 먼저 json 문자열의 형식을 결정해야 합니다. 다양한 형식에 대해 다양한 구문 분석 방법을 사용하세요. 다음은 몇 가지 일반적인 json 문자열입니다. Format

예: 숫자 값, 문자열, 배열, 배열 개체 중요한 점은 중괄호와 대괄호를 사용하는 것입니다. 이 두 기호에 주의하세요. json 파싱 오류가 발생할 수 있습니다.

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

로그인 후 복사

Java는 어떻게 인터페이스를 호출하여 json 데이터를 얻고 이를 구문 분석한 후 데이터베이스에 저장합니까?

Autohome에서 얻은 json 문자열이 json 배열 형식임을 알 수 있으므로 JSONArray를 사용하여 파싱한 후 traverse해야 합니다.

//将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는 도메인 계층 엔터티 파일, xml 파일을 생성할 수 있습니다. , 매퍼 파일 및 해당 서비스 파일을 사용하면 SQL 문을 작성할 때 서비스 계층에서 해당 메서드를 직접 호출할 수 있습니다.

//调用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);
        }
 
    }
}

로그인 후 복사

위 내용은 Java는 어떻게 인터페이스를 호출하여 json 데이터를 얻고 이를 구문 분석한 후 데이터베이스에 저장합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!