java 實現(xiàn)增量同步和自定義同步的操作
更新時間：2021年01月22日 11:13:30 作者：chushiyunen
這篇文章主要介紹了java 實現(xiàn)增量同步和自定義同步的操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
場景
公司有多個系統(tǒng)。 需要從某個系統(tǒng)拿數(shù)據(jù)。初始化拿一次，然后每天增量同步。
因為邏輯關系有些復雜，且涉及到多表，所以純sql不太方便。
項目之前的mybatis寫死了， sysdate-1的數(shù)據(jù)。
如何全量同步
老辦法
可以讓某系統(tǒng)調(diào)整modifyDate，本系統(tǒng)通過定時任務同步這些數(shù)據(jù)。
缺點： 按規(guī)定不允許改數(shù)據(jù)，別人也不樂意改。
較好的辦法
調(diào)整mybatis，傳入?yún)?shù)變?yōu)樽远x方法，這樣就可以同步任意時刻的數(shù)據(jù)。
一般有2種方法：
傳入游標方法： sysdate-n
直接傳入日期字符串： modifyDate between ‘888' and ‘999'
然后增加request請求，手動調(diào)用同步方法。
補充：java數(shù)據(jù)同步，增量更新表中記錄數(shù)據(jù)
背景：
我方系統(tǒng)中的數(shù)據(jù)從第三方系統(tǒng)同步過來。雙方通過json格式交互，數(shù)據(jù)格式如下：
{
"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、調(diào)用第三方接口，獲取數(shù)據(jù)，做解析，得到一個List1。
2、查詢數(shù)據(jù)庫出差表，得到另一個List2。
3、兩個list做比較，獲取不同的元素列表。
list2-list1：要刪除的記錄。
list1-list2 ：要新增的記錄。
主要實現(xiàn)代碼：
String result="調(diào)用接口返回的json串"; //參見交互的json數(shù)據(jù)格式
ResultObject<BusinessTrip> resultObject = JSON.parseObject(result, new TypeReference<ResultObject<BusinessTrip>>() {
});
List<BusinessTrip> list = resultObject.getData();
if (!CollectionUtils.isEmpty(list)) {
//查詢數(shù)據(jù)庫記錄條數(shù)
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("刪除出差記錄個數(shù)，removeCount=" + removeCount);
}
//新增出差
List<BusinessTrip> newAddList = map.get(ListUtils.LIST1_REMOVE_LIST2);
if (!CollectionUtils.isEmpty(newAddList)) {
int addCount = businessService.batchInsertBusinessTrip(newAddList);
log.error("新增出差記錄個數(shù)，addCount=" + addCount);
}
} else {
log.error("同步出差申請結(jié)束，沒有查詢到出差數(shù)據(jù)。");
}
出差實體類BusinessTrip.java
import lombok.Data;
/**
* 出差
*/
@Data
public class BusinessTrip {
/**
* 請求ID
*/
private String requestId;
/**
* 工號
*/
private String jobNumber;
/**
* 申請日期
*/
private String requestDate;
/**
* 申請人所在部門id
*/
private String department;
/**
* 出差天數(shù)
*/
private String businessDays;
/**
* 出發(fā)地
*/
private String cfd;
/**
* 目的地
*/
private String mdd;
/**
* 出差開始時間
*/
private String startTime;
/**
* 出差結(jié)束時間
*/
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);
// }
}
實際處理過程中出現(xiàn)的一個問題是：
接口返回的字段中，不是每個字段都有值。在第一次插入數(shù)據(jù)后，再查詢時，字段得到的值是null，不是空串。
操作中出現(xiàn)一個問題：
接口中拿到的數(shù)據(jù)是這樣：
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查詢出的數(shù)據(jù)，得到記錄格式是這樣。
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中元素在做比較的時候，總是不相等。
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方，望不吝賜教。
相關文章
這篇文章主要介紹了idea每次修改代碼都需要重新install的問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-08-08
在日常編碼過程中常常涉及到事務,在前兩天看到一篇文章提到了Spring事務,那么在此總結(jié)下在Spring環(huán)境下事務失效的幾種原因2021-09-09
關于訪問后端接口報404錯誤問題的解決方法(全網(wǎng)最細!)
404頁面的出現(xiàn)會降低用戶體驗,那么導致404頁面出現(xiàn)的原因是什么呢?這篇文章主要給大家介紹了關于訪問后端接口報404錯誤問題的解決方法,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-04-04
CSV是一種通用的、相對簡單的文件格式,其文件以純文本形式存儲表格數(shù)據(jù),下面這篇文章主要給大家介紹了關于Java中csv文件讀寫分析的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-05-05
在實際項目中經(jīng)常有發(fā)送短信的功能，今天進說一下SpringBoot整合阿里云短信服務的相關知識，新建短信微服務，編寫發(fā)送短信接口的方法文中給大家介紹的很詳細，需要的朋友參考下吧2021-10-10
本文主要介紹了MyBatis主鍵自增的兩種實現(xiàn)方法,主要包括注解方式或配置文件方式來實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2024-01-01
Java通過word模板實現(xiàn)創(chuàng)建word文檔報告
這篇文章主要為大家詳細介紹了Java如何通過word模板實現(xiàn)創(chuàng)建word文檔報告的教程，文中的示例代碼講解詳細，感興趣的小伙伴可以學習一下2022-09-09
SpringBoot Maven項目中Model間的最佳繼承設計詳解
這篇文章主要為大家詳細介紹了SpringBoot中一個優(yōu)秀Maven項目的各Model間最佳繼承設計的相關知識,文中的示例代碼講解詳細,感興趣的小伙伴可以了解下2024-01-01
這篇文章主要介紹了JAVA實現(xiàn)賬戶取款和存款操作,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
springSecurity之AuthenticationProvider用法解析
這篇文章主要介紹了springSecurity之AuthenticationProvider用法解析，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-03-03