[發明專利]數據同步方法和相關設備

在審

• 申請號: 202211178596.5
• 申請日: 2022-09-26
• 公開（公告）號: CN115587145A
• 公開（公告）日: 2023-01-10
• 發明（設計）人: 陳華海;林國養
• 申請（專利權）人: 中國建設銀行股份有限公司;建信金融科技有限責任公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 丁鑫;臧建明

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

在流水表中讀取任務對象，所述任務對象包括第一同步對象，所述第一同步對象包括多個數據對象以及對應的操作方式，各個所述數據對象是事務的不同節點所產生的數據，所述操作方式用于指示數據源對所述數據對象進行所述操作方式對應的數據同步操作；

根據所述任務對象確定目標適配器，并控制所述目標適配器對所述任務對象中的第一同步對象進行寫入操作，以將所述第一同步對象寫入至所述目標適配器對應的數據源。

2.根據權利要求1所述的數據同步方法，其特征在于，所述根據所述任務對象確定的目標適配器，包括：

獲取所述任務對象中的描述信息，并根據所述描述信息確定所述第一同步對象待寫入的目標數據源；

將所述目標數據源對應的適配器確定為所述任務對象對應的目標適配器。

3.根據權利要求2所述的數據同步方法，其特征在于，所述獲取所述任務對象中的描述信息之后，還包括：

在根據所述描述信息無法確定所述第一同步對象待寫入的數據源時，輸出提示信息，并間隔目標時長再次獲取所述任務對象中的描述信息，所述提示信息用于提示所述第一同步對象未指定數據源。

4.根據權利要求3所述的數據同步方法，其特征在于，所述輸出提示信息，包括：

在根據所述描述信息無法確定所述第一同步對象待寫入的數據源時，更新所述第一同步對象的重復執行寫入操作的次數；

在所述次數未達到預設次數，輸出所述提示信息。

5.根據權利要求4所述的數據同步方法，其特征在于，所述更新所述第一同步對象的重復執行寫入操作的次數之后，還包括：

在所述次數達到預設次數，丟棄所述任務對象。

6.根據權利要求1所述的數據同步方法，其特征在于，所述在流水表中讀取任務對象之前，還包括：

在檢測到所述事務發生時，獲取所述事務的各個節點產生的數據對象；

根據所述節點確定所述數據對象的操作方式；

根據各個所述數據對象以及對應的操作方式生成第一同步對象，并根據所述第一同步對象創建任務對象；

將所述任務對象插入至所述流水表中。

7.根據權利要求6所述的數據同步方法，其特征在于，所述根據所述第一同步對象創建任務對象，包括：

在所述數據對象的操作方式是修改時，獲取所述事務上一次的第二同步對象，并根據所述第一同步對象以及所述第二同步對象生成所述任務對象；

所述控制所述目標適配器對所述任務對象中的第一同步對象進行寫入操作，以將所述第一同步對象寫入至所述目標適配器對應的數據源，包括：

控制所述目標適配器對所述任務對象的第一同步對象以及第二同步對象進行寫入操作，以將所述第一同步對象以及所述第二同步對象寫入至所述目標適配器對應的數據源。

8.一種數據同步裝置，其特征在于，包括：

讀取模塊，用于在流水表中讀取任務對象，所述任務對象包括第一同步對象，所述第一同步對象包括多個數據對象以及對應的操作方式，各個所述數據對象是事務的不同節點所產生的數據，所述操作方式用于指示數據源對所述數據對象進行所述操作方式對應的數據同步操作；

確定模塊，用于根據所述任務對象確定的目標適配器，并控制所述目標適配器對所述任務對象中的第一同步對象進行寫入操作，以將所述第一同步對象寫入至所述目標適配器對應的數據源。

9.一種數據同步設備，其特征在于，包括：存儲器以及處理器；

所述存儲器存儲計算機執行指令；

所述處理器執行所述存儲器存儲的計算機執行指令，使得所述處理器執行如權利要求1至7任一項所述的數據同步方法。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質中存儲有計算機執行指令，所述計算機執行指令被處理器執行時用于實現如權利要求1至7任一項所述的數據同步方法。

11.一種計算機程序產品，包括計算機程序，其特征在于，所述計算機程序被處理器執行時實現權利要求1-7中任一項所述的數據同步方法。