常用的读取数据库数据两种方法

Posted 2023-03-02 weixin_ancenhw

//第一种while方法
@Resoure
private ProxyClient proxyClient;

public ApiResult<?> addBatch(QueryParam queryParam)
   queryParam.setPageNum(0);
   queryParam.setPageSize(1000);
   while(true)
      pageNum++;
      logger.info("开始查询第页数据。",pageNum);
     ApiResult<PageVO<DepositResp>> apiResult = proxyClient.getSearchData(queryParam);
     if(!apiResult.isSuccess())
        logger.error("查询第页失败，错误信息",pageNum,apiResult.getMessage());
     
     PageVO<UserResp> pageVo=Convert.convert(new TypeReference<PageVo<UserResp>>(),JSONUtil.parseObj(apiResult.getData()));
     List<User> rows=pageVo.getRows();
     if(ObjectUtils.isEmpty(rows))
        logger.info("查询第页完成，",pageNum)
        return ApiResult.ok();
     
     logger.info("查询第页，",pageNum);
    List<User> list= JSONUtil.parseArray(rows).toList(User.class);
    //开始批量插入数据
   

//第二种方式
@Resoure
private ProxyClient proxyClient;

public ApiResult<?> addBatch(QueryParam queryParam)
    int total=1;
    int pageSize=1000;
    queryParam.setPageSize(pageSize);
    for(int i=1;i<=total;i++)
        queryParam.setPageNum(i);
        ApiResult<PageVO<DepositResp>> apiResult = proxyClient.getSearchData(queryParam);
        if(!apiResult.isSuccess())
        logger.error("查询第页失败，错误信息",i,apiResult.getMessage());
        JSONObject jsonobject=JSONUtil.parseObj(apiResult.getData());
        if(i=1)
           //计算出总页数
          total=(Integer.parseInt(jsonObject.get("total").toString())+pageSize-1)/pageSize;
         List<UserEntity> rows=JSONUtil.parseArray(jsonObject.get("rows")).toList(UserEntity.class) ;
         //添加数据