[發明專利]一種結構化數據的同步方法及系統

有效

• 申請號: 201810256981.4
• 申請日: 2018-03-27
• 公開（公告）號: CN108536774B
• 公開（公告）日: 2020-10-20
• 發明（設計）人: 李乾;高曉鵬
• 申請（專利權）人: 中國農業銀行股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 古利蘭;王寶筠

1.一種結構化數據的同步方法，其特征在于，包括：

當源系統的數據發生變化時，基于所述變化數據包括的數據批次外鍵查詢變化數據的批次信息；所述批次信息至少包括所述變化數據的批次ID和收發狀態；

查詢到所述批次信息時，基于所述批次信息及其對應的變化數據生成同步數據視圖；

基于所述同步數據視圖將所述變化數據卸載至公共目錄并更新所述批次信息；

從所述公共目錄中加載所述變化數據至目標系統的臨時數據表；

從所述臨時數據表中查詢所述變化數據的數據批次外鍵，基于所述數據批次外鍵處理所述目標系統中的待處理數據；

將所述變化數據加載至所述目標系統的正式數據表中并反饋所述數據批次外鍵至源系統；

基于反饋的數據批次外鍵更新所述源系統中的批次信息。

2.如權利要求1所述的方法，其特征在于，所述批次信息包括所述變化數據的批次ID及收發狀態，還包括所述變化數據的發送批次、發送結束時間及接收反饋時間中的任意一項或多項。

3.如權利要求2所述的方法，其特征在于，還包括：

當查詢不到所述變化數據的批次信息時，生成所述變化數據的批次信息；

設置所述批次信息中的收發狀態為未發送。

4.如權利要求2所述的方法，其特征在于，基于所述同步數據視圖將所述變化數據卸載至公共目錄并更新所述批次信息時，所述批次信息中的收發狀態更新為已發送；

基于反饋的數據批次外鍵更新所述源系統中的批次信息時，所述批次信息中的收發狀態更新為已接收。

5.如權利要求1所述的方法，其特征在于，所述基于所述同步數據視圖將所述變化數據卸載至公共目錄包括：

基于所述同步數據視圖鎖定所述變化數據；

將所述變化數據卸載至公共目錄并更新所述批次信息。

6.一種結構化數據的同步系統，其特征在于，包括第一查詢模塊、視圖生成模塊、卸載模塊、更新模塊、第一加載模塊、第二查詢模塊、舊數據處理模塊、第二加載模塊及反饋模塊，其中：

所述第一查詢模塊用于在源系統的數據發生變化時，基于所述變化數據包括的數據批次外鍵查詢變化數據的批次信息；所述批次信息至少包括所述變化數據的批次ID和收發狀態；

所述視圖生成模塊用于在查詢到所述批次信息時，基于所述批次信息及其對應的變化數據生成同步數據視圖；

所述卸載模塊用于基于所述同步數據視圖將所述變化數據卸載至公共目錄，所述更新模塊用于更新所述批次信息；

所述第一加載模塊用于從所述公共目錄中加載所述變化數據至目標系統的臨時數據表；

所述第二查詢模塊用于從所述臨時數據表中查詢所述變化數據的數據批次外鍵，所述舊數據處理模塊用于基于所述數據批次外鍵處理所述目標系統中的待處理數據；

所述第二加載模塊用于將所述變化數據加載至所述目標系統的正式數據表中，所述反饋模塊用于反饋所述數據批次外鍵至源系統；

所述更新模塊還用于基于反饋的數據批次外鍵更新所述源系統中的批次信息。

7.如權利要求6所述的系統，其特征在于，所述批次信息包括所述變化數據的批次ID及收發狀態，還包括所述變化數據的發送批次、發送結束時間及接收反饋時間中的任意一項或多項。

8.如權利要求7所述的系統，其特征在于，還包括批次信息生成模塊，其中：

所述批次信息生成模塊用于當查詢不到所述變化數據的批次信息時，生成所述變化數據的批次信息；

所述批次信息生成模塊還用于設置所述批次信息中的收發狀態為未發送。

9.如權利要求7所述的系統，其特征在于，基于所述同步數據視圖將所述變化數據卸載至公共目錄并更新所述批次信息時，所述批次信息中的收發狀態更新為已發送。

10.如權利要求6所述的系統，其特征在于，所述卸載模塊包括鎖定單元及卸載單元，其中：

所述鎖定單元用于基于所述同步數據視圖鎖定所述變化數據；

所述卸載單元用于將所述變化數據卸載至公共目錄。