java 实现增量同步和自定义同步的操作

更新时间：2021年01月22日 11:13:30 作者：chushiyunen

这篇文章主要介绍了java 实现增量同步和自定义同步的操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

场景

公司有多个系统。需要从某个系统拿数据。初始化拿一次，然后每天增量同步。

因为逻辑关系有些复杂，且涉及到多表，所以纯sql不太方便。

项目之前的mybatis写死了， sysdate-1的数据。

如何全量同步

老办法

可以让某系统调整modifyDate，本系统通过定时任务同步这些数据。

缺点：按规定不允许改数据，别人也不乐意改。

较好的办法

调整mybatis，传入参数变为自定义方法，这样就可以同步任意时刻的数据。

一般有2种方法：

传入游标方法： sysdate-n

直接传入日期字符串： modifyDate between ‘888' and ‘999'

然后增加request请求，手动调用同步方法。

补充：java数据同步，增量更新表中记录数据

背景：

我方系统中的数据从第三方系统同步过来。双方通过json格式交互，数据格式如下：

{
"resInfo":{"code":"0","msg":"查询成功"},
"columns":"requestId,jobNumber,requestDate,department,businessDays,cfd,mdd,startTime,endTime,reason,remark",
"data":[
{"requestId"="11925", "jobNumber"="5721", "requestDate"="2019-05-06", "department"="57", "businessDays"="21", "cfd"="上海", "mdd"="南京", "startTime"="2019-05-06 13:36", "endTime"="2019-05-07 13:36", "reason"="", "remark"=""}
]
}

增量更新处理思路：

1、调用第三方接口，获取数据，做解析，得到一个List1。

2、查询数据库出差表，得到另一个List2。

3、两个list做比较，获取不同的元素列表。

list2-list1：要删除的记录。

list1-list2 ：要新增的记录。

主要实现代码：

String result="调用接口返回的json串"; //参见交互的json数据格式

ResultObject<BusinessTrip> resultObject = JSON.parseObject(result, new TypeReference<ResultObject<BusinessTrip>>() {
      });
      List<BusinessTrip> list = resultObject.getData();
      if (!CollectionUtils.isEmpty(list)) {
        //查询数据库记录条数
        List<BusinessTrip> list2 = businessService.queryBusinessTripList();
  Map<String, List<BusinessTrip>> map = ListUtils.getMap(list, list2);
        //删除出差
        List<BusinessTrip> newRemoveList = map.get(ListUtils.LIST2_REMOVE_LIST1);
        if (!CollectionUtils.isEmpty(newRemoveList)) {
          List<String> newChangeList2 = newRemoveList.stream().map(item -> item.getRequestId()).collect(Collectors.toList());
          int removeCount = businessService.batchDeleteBusinessTrip(newChangeList2);
          log.error("删除出差记录个数，removeCount=" + removeCount);
        }
        //新增出差
        List<BusinessTrip> newAddList = map.get(ListUtils.LIST1_REMOVE_LIST2);
        if (!CollectionUtils.isEmpty(newAddList)) {
          int addCount = businessService.batchInsertBusinessTrip(newAddList);
          log.error("新增出差记录个数，addCount=" + addCount);
        }
      } else {
        log.error("同步出差申请结束，没有查询到出差数据。");
      }

出差实体类BusinessTrip.java

import lombok.Data;
/**
 * 出差
 */
@Data
public class BusinessTrip {
  /**
   * 请求ID
   */
  private String requestId;
  /**
   * 工号
   */
  private String jobNumber;
  /**
   * 申请日期
   */
  private String requestDate;
  /**
   * 申请人所在部门id
   */
  private String department;
  /**
   * 出差天数
   */
  private String businessDays;
  /**
   * 出发地
   */
  private String cfd;
  /**
   * 目的地
   */
  private String mdd;
  /**
   * 出差开始时间
   */
  private String startTime;
  /**
   * 出差结束时间
   */
  private String endTime;
  /**
   * 出差事由
   */
  private String reason;
 
 /**
 * 备注
 */
 private String remark;
}

ResultObject.java

/**
 * @Name: ResultObject
 * @Desc: 基类泛型
 * @Author: Administrator
 * @Date: 2019-08-28 18:32
 * {
"resInfo":{"code":"0","msg":"查询成功"},
"columns":"requestId,jobNumber,requestDate,department,businessDays,cfd,mdd,startTime,endTime,reason,remark",
"data":[
{"requestId"="11925", "jobNumber"="5721", "requestDate"="2019-05-06", "department"="57", "businessDays"="21", "cfd"="上海", "mdd"="南京", "startTime"="2019-05-06 13:36", "endTime"="2019-05-07 13:36", "reason"="", "remark"=""}
]
}
 */
@Data
public class ResultObject<T> {
  private String columns;
  private ResInfo resInfo;
  private List<T> data;
}

ResInfo.java

import lombok.Data;
/**
 * @Name: ResInfo
 * @Desc
 * @Author: Administrator
 * @Date: 2019-08-28 18:38
 * {"code":"0","msg":"查询成功"}
 */
@Data
public class ResInfo {
  private String code;
  private String msg;
}

ListUtils.java工具类：

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
 * @Name: ListUtils
 * @Desc
 * @Author: Administrator
 * @Date: 2019-08-29 14:03
 */
public class ListUtils {
  /**
   * 交集
   */
  public static final String LIST1_AND_LIST2 = "0";
  /**
   * 差集（list1 - list2）
   */
  public static final String LIST1_REMOVE_LIST2 = "1";
  /**
   * 差集（list2 - list1）
   */
  public static final String LIST2_REMOVE_LIST1 = "2";
  public static <T> Map<String, List<T>> getMap(List<T> list1, List<T> list2) {
    //交集
    List<T> intersection = list1.stream().filter(item -> list2.contains(item)).collect(Collectors.toList());
    //差集（list1 - list2）
    List<T> reduce1 = list1.stream().filter(item -> !list2.contains(item)).collect(Collectors.toList());
    //差集（list2 - list1）
    List<T> reduce2 = list2.stream().filter(item -> !list1.contains(item)).collect(Collectors.toList());
    Map<String, List<T>> map = new HashMap<>();
    map.put(LIST1_AND_LIST2, intersection);
    map.put(LIST1_REMOVE_LIST2, reduce1);
    map.put(LIST2_REMOVE_LIST1, reduce2);
    return map;
  }
//  public static void main(String[] args) {
//    List<String> list1 = new ArrayList<>();
//    list1.add("1111");
//    list1.add("2222");
//    list1.add("3333");
//    list1.add("4444");
//
//    List<String> list2 = new ArrayList<>();
//    list2.add("3333");
//    list2.add("4444");
//    list2.add("5555");
//    list2.add("6666");
//
//    Map<String, List<String>> map = getMap(list1, list2);
//    System.out.println(map);
//  }
}

实际处理过程中出现的一个问题是：

接口返回的字段中，不是每个字段都有值。在第一次插入数据后，再查询时，字段得到的值是null，不是空串。

操作中出现一个问题：

接口中拿到的数据是这样：

BusinessTrip(requestId=11925, jobNumber=5721, requestDate=2019-05-06, department=57, businessDays=21, cfd=上海, mdd=南京, startTime=2019-05-06 13:36, endTime=2019-05-07 13:36, reason=, remark=)

就是通过mybatis查询出的数据，得到记录格式是这样。

BusinessTrip(requestId=11925, jobNumber=5721, requestDate=2019-05-06, department=57, businessDays=21, cfd=上海, mdd=南京, startTime=2019-05-06 13:36, endTime=2019-05-07 13:36, reason=null, remark=null)

两个格式差别是，部分字段，比如reason字段，一个是空串，一个是null，导致List中元素在做比较的时候，总是不相等。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。如有错误或未考虑完全的地方，望不吝赐教。

您可能感兴趣的文章:

idea每次修改代码都需要重新install的问题
这篇文章主要介绍了idea每次修改代码都需要重新install的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-08-08
Java spring事务及事务不生效的原因详解
在日常编码过程中常常涉及到事务,在前两天看到一篇文章提到了Spring事务,那么在此总结下在Spring环境下事务失效的几种原因
2021-09-09
关于访问后端接口报404错误问题的解决方法(全网最细!)
404页面的出现会降低用户体验,那么导致404页面出现的原因是什么呢?这篇文章主要给大家介绍了关于访问后端接口报404错误问题的解决方法,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-04-04
Java中csv文件读写超详细分析
CSV是一种通用的、相对简单的文件格式,其文件以纯文本形式存储表格数据,下面这篇文章主要给大家介绍了关于Java中csv文件读写分析的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-05-05
SpringBoot整合阿里云短信服务的方法
在实际项目中经常有发送短信的功能，今天进说一下SpringBoot整合阿里云短信服务的相关知识，新建短信微服务，编写发送短信接口的方法文中给大家介绍的很详细，需要的朋友参考下吧
2021-10-10
MyBatis主键自增的两种实现方法
本文主要介绍了MyBatis主键自增的两种实现方法,主要包括注解方式或配置文件方式来实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
2024-01-01
Java通过word模板实现创建word文档报告
这篇文章主要为大家详细介绍了Java如何通过word模板实现创建word文档报告的教程，文中的示例代码讲解详细，感兴趣的小伙伴可以学习一下
2022-09-09
SpringBoot Maven项目中Model间的最佳继承设计详解
这篇文章主要为大家详细介绍了SpringBoot中一个优秀Maven项目的各Model间最佳继承设计的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下
2024-01-01
JAVA实现账户取款和存款操作
这篇文章主要介绍了JAVA实现账户取款和存款操作,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-11-11
springSecurity之AuthenticationProvider用法解析
这篇文章主要介绍了springSecurity之AuthenticationProvider用法解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-03-03