[發明專利]數據庫的同步方法、裝置、系統及電子設備

在審

• 申請號: 202011391514.6
• 申請日: 2020-12-03
• 公開（公告）號: CN112199447A
• 公開（公告）日: 2021-01-08
• 發明（設計）人: 焦學寧
• 申請（專利權）人: 深圳市易博天下科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F11/30
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 榮穎佳

1.一種數據庫的同步方法，其特征在于，應用于數據同步服務，其中，所述數據同步服務被配置為對數據庫進行數據同步，所述方法包括：

獲取當前數據庫的變更信息，其中，所述變更信息攜帶有變更數據；

提取所述變更數據，以及，在所述變更信息中嵌入所述當前數據庫的同步標記，生成攜帶有所述同步標記的同步信息；

在預先配置的數據同步環關系中查找所述當前數據庫對應的同步端；

將查找到的所述同步端作為目標數據庫，并將所述同步信息發送至所述目標數據庫，以使所述目標數據庫的數據同步服務基于所述同步信息進行數據同步操作。

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

接收配置信息，其中，所述配置信息包括監聽組件、所述監聽組件所監聽的數據庫，以及，設置在不同區域的多個所述數據庫的數據庫地址，其中，多個所述數據庫地址包括所述當前數據庫和所述目標數據庫的數據庫地址；

基于所述配置信息生成所述數據同步環關系，并將所述數據同步環關系存儲在預設的位置；

其中，所述數據同步環關系記載有多個所述數據庫的進行數據同步時的邏輯環同步方向。

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

響應作用于所述當前數據庫的數據變更操作，所述數據變更操作攜帶有所述變更數據，則根據所述變更數據生成所述變更信息。

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

接收所述當前數據庫的上游數據庫對應的數據同步服務發送的所述同步信息；其中，所述上游數據庫為所述邏輯環同步方向上，處于所述當前數據庫上游的數據庫；

判斷所述同步信息中是否攜帶有所述當前數據庫的同步標記；

如果否，則將所述同步信息確定為所述當前數據庫的變更信息。

5.根據權利要求4所述的方法，其特征在于，所述方法還包括：

如果所述同步信息中攜帶有所述當前數據庫的同步標記，則丟棄所述同步信息。

6.根據權利要求2所述的方法，其特征在于，在預先配置的數據同步環關系中查找所述當前數據庫對應的同步端的步驟包括：

根據所述數據同步環關系記載的所述邏輯環同步方向查找所述當前數據庫的下游數據庫；

將所述下游數據庫確定為所述當前數據庫對應的同步端。

7.根據權利要求4所述的方法，其特征在于，所述數據同步服務包括第一節點和第二節點；

將所述同步信息發送至所述目標數據庫的步驟包括：

將所述同步信息發送至所述第一節點，通過所述第一節點將所述同步信息發送至所述目標數據庫；

接收所述當前數據庫的上游數據庫對應的數據同步服務發送的所述同步信息的步驟包括：

通過所述第二節點接收所述當前數據庫的上游數據庫對應的數據同步服務發送的所述同步信息。

8.一種數據庫的同步裝置，其特征在于，應用于數據同步服務，其中，所述數據同步服務被配置為對數據庫進行數據同步，所述裝置包括：

獲取模塊，用于獲取當前數據庫的變更信息，其中，所述變更信息攜帶有變更數據；

標記模塊，用于提取所述變更數據，以及，在所述變更信息中嵌入所述當前數據庫的同步標記，生成攜帶有所述同步標記的同步信息；

查找模塊，用于在預先配置的數據同步環關系中查找所述當前數據庫對應的同步端；

發送模塊，用于將查找到的所述同步端作為目標數據庫，并將所述同步信息發送至所述目標數據庫，以使所述目標數據庫的數據同步服務基于所述同步信息進行數據同步操作。

9.一種數據庫的同步系統，其特征在于，包括多個所述數據庫，每個所述數據庫配置有數據同步服務，以及，監聽組件；

多個所述數據庫的所述數據同步服務組成服務集群；

所述數據同步服務用于執行權利要求1~7任一項所述的方法，以對數據庫進行數據同步。