[發(fā)明專利]一種單源多節(jié)點的數(shù)據(jù)同步方法和系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202011306111.7
• 申請日: 2020-11-19
• 公開（公告）號: CN112445799A
• 公開（公告）日: 2021-03-05
• 發(fā)明（設計）人: 衛(wèi)周華
• 申請（專利權）人: 北京思特奇信息技術股份有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/27;G06F16/23
• 代理公司: 北京輕創(chuàng)知識產(chǎn)權代理有限公司 11212
• 代理人: 翟磊

1.一種單源多節(jié)點的數(shù)據(jù)同步方法，其特征在于，包括：

S1，通過觸發(fā)器建立一個變化數(shù)據(jù)表；

S2，將多個變化數(shù)據(jù)插入到所述變化數(shù)據(jù)表中；

S3，通過多個節(jié)點分別讀取多個所述變化數(shù)據(jù)，并選擇所述變化數(shù)據(jù)中待同步數(shù)據(jù)進行同步。

2.根據(jù)權利要求1所述的一種單源多節(jié)點的數(shù)據(jù)同步方法，其特征在于，還包括：分別記錄每個所述節(jié)點已經(jīng)同步過的每個所述變化數(shù)據(jù)的流水值和所述流水值中的最大流水值；

根據(jù)所述節(jié)點當前處理的變化數(shù)據(jù)的流水值，更新所述最大流水值。

3.根據(jù)權利要求1或2所述的一種單源多節(jié)點的數(shù)據(jù)同步方法，其特征在于，所述S3還具體包括：

讀取所述變化數(shù)據(jù)表中的流水值大于所述最大流水值且小于預設數(shù)值的變化數(shù)據(jù)，選擇所述變化數(shù)據(jù)中待同步數(shù)據(jù)進行同步。

4.根據(jù)權利要求1或2所述的一種單源多節(jié)點的數(shù)據(jù)同步方法，其特征在于，還包括：通過所述變化數(shù)據(jù)表中的主鍵字段獲取源表數(shù)據(jù)，根據(jù)同步結果對所述源表數(shù)據(jù)進行增刪改操作。

5.根據(jù)權利要求3所述的一種單源多節(jié)點的數(shù)據(jù)同步方法，其特征在于，還包括：在對所述變化數(shù)據(jù)表插入變化數(shù)據(jù)時，設置所述變化數(shù)據(jù)表中的流水字段的值為預設數(shù)值。

6.一種單源多節(jié)點的數(shù)據(jù)同步系統(tǒng)，其特征在于，包括：變化表建立模塊、數(shù)據(jù)插入模塊和同步模塊；

所述變化表建立模塊用于通過觸發(fā)器建立一個變化數(shù)據(jù)表；

所述數(shù)據(jù)插入模塊用于將多個變化數(shù)據(jù)插入到所述變化數(shù)據(jù)表中；

所述同步模塊用于通過多個節(jié)點分別讀取多個所述變化數(shù)據(jù)，并選擇所述變化數(shù)據(jù)中待同步數(shù)據(jù)進行同步。

7.根據(jù)權利要求6所述的一種單源多節(jié)點的數(shù)據(jù)同步系統(tǒng)，其特征在于，還包括：記錄更新模塊，用于分別記錄每個所述節(jié)點已經(jīng)同步過的每個所述變化數(shù)據(jù)的流水值和所述流水值中的最大流水值；

根據(jù)所述節(jié)點當前處理的變化數(shù)據(jù)的流水值，更新所述最大流水值。

8.根據(jù)權利要求6或7所述的一種單源多節(jié)點的數(shù)據(jù)同步系統(tǒng)，其特征在于，所述同步模塊還具體用于讀取所述變化數(shù)據(jù)表中的流水值大于所述最大流水值且小于預設數(shù)值的變化數(shù)據(jù)，選擇所述變化數(shù)據(jù)中待同步數(shù)據(jù)進行同步。

9.根據(jù)權利要求6或7所述的一種單源多節(jié)點的數(shù)據(jù)同步系統(tǒng)，其特征在于，還包括：源數(shù)據(jù)處理模塊，用于通過所述變化數(shù)據(jù)表中的主鍵字段獲取源表數(shù)據(jù)，根據(jù)同步結果對所述源表數(shù)據(jù)進行增刪改操作。

10.根據(jù)權利要求8所述的一種單源多節(jié)點的數(shù)據(jù)同步系統(tǒng)，其特征在于，還包括：設置模塊，用于當多個變化數(shù)據(jù)插入到所述變化數(shù)據(jù)表時，設置所述變化表中的流水字段的值為預設數(shù)值。