[發明專利]一種單源多節點的數據同步方法和系統

在審

• 申請號: 202011306111.7
• 申請日: 2020-11-19
• 公開（公告）號: CN112445799A
• 公開（公告）日: 2021-03-05
• 發明（設計）人: 衛周華
• 申請（專利權）人: 北京思特奇信息技術股份有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/27;G06F16/23
• 代理公司: 北京輕創知識產權代理有限公司 11212
• 代理人: 翟磊

本發明公開了一種單源多節點的數據同步方法和系統，涉及數據同步領域。該方法包括：通過觸發器建立一個變化數據表，將多個變化數據插入到變化數據表中，通過多個節點分別讀取多個變化數據，并選擇變化數據中待同步數據進行同步，本發明方案通過多個節點分別讀取一個變化數據表中的多個變化數據，并選擇變化數據中待同步數據進行同步，實現只產生一份數據源的觸發數據。就可以將數據同步到任意一個節點，同時兼顧數據同步的及時性，減小數據庫產生的垃圾數據及數據庫壓力。

技術領域

本發明涉及數據同步領域，尤其涉及一種單源多節點的數據同步方法和系統。

背景技術

目前將數據庫中表的變化數據同步到內存數據庫或應用時，一般都是在源表上建一個觸發器，將變化數據插入到變化表，應用讀取變化表的數據進行數據同步。同步后同時將變化表的數據刪除。那么，如果需要同步多份數據時，由兩種方式：需要同步多少份數據，觸發器中就觸發出多少張變化或者用級聯方式，第一張變化表數據同步后，將變化表記錄插入第二個變化表，依次往下同步；這兩種方式都會產生不必要的垃圾數據。

發明內容

本發明所要解決的技術問題是針對現有技術的不足，提供一種單源多節點的數據同步方法和系統。

本發明解決上述技術問題的技術方案如下：

一種單源多節點的數據同步方法，包括：S1，通過觸發器建立一個變化數據表；

S2，將多個變化數據插入到所述變化數據表中；

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

本發明的有益效果是：本發明方案通過多個節點分別讀取一個變化數據表中的多個所述變化數據，并選擇所述變化數據中待同步數據進行同步，實現只產生一份數據源的觸發數據。就可以將數據同步到任意一個節點，同時兼顧數據同步的及時性，減小數據庫產生的垃圾數據及數據庫壓力。

進一步地，還包括：分別記錄每個所述節點已經同步過的每個所述變化數據的流水值和所述流水值中的最大流水值；

根據所述節點當前處理的變化數據的流水值，更新所述最大流水值。

采用上述進一步方案的有益效果是：本發明方案通過實時更新最大流水值實現根據最大流水值及時更新變化數據，在數據同步的同時兼顧數據同步的及時性。

進一步地，所述S3還具體包括：

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

采用上述進一步方案的有益效果是：本發明方案通過讀取流水值大于所述最大流水值且小于預設數值的變化數據，并選擇變化數據中待同步數據進行同步，流水值大于所述最大流水值且小于預設數值的變化數據是是本節點上次同步后新產生的數據，通過本方案能夠及時處理新產生的數據，能夠快速響應前端應用的業務需求。

進一步地，還包括：通過所述變化數據表中的主鍵字段獲取源表數據，根據同步結果對所述源表數據進行增刪改操作。

采用上述進一步方案的有益效果是：本發明方案通過根據數據同步結果，對源表數據進行相應的增加新增數據，刪除多余數據，修改已變化的數據，減小數據庫產生的垃圾數據及數據庫壓力，響應前端應用的業務需求更加迅速高效。

進一步地，還包括：在對所述變化數據表插入變化數據時，設置所述變化數據表中的流水字段的值為預設數值。

采用上述進一步方案的有益效果是：本發明方案通過在對所述變化數據表插入變化數據時，設置所述變化數據表中的流水字段的值為預設數值，實現變化數據的流水值控制在合適范圍內，保證插入的變化數據不會溢出失控。

本發明解決上述技術問題的另一種技術方案如下：