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中元素在做比较的时候，总是不相等。

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