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

在審

• 申請號: 201710670181.2
• 申請日: 2017-08-08
• 公開（公告）號: CN107301251A
• 公開（公告）日: 2017-10-27
• 發明（設計）人: 楊高峰;孟軍霞;朱炯圳;郭海峰
• 申請（專利權）人: 鄭州仁峰軟件開發有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 暫無信息
• 代理人: 暫無信息

技術領域

本發明涉及一種數據庫系統，具體是一種數據庫同步的方法及系統。

背景技術

數據庫是按照數據結構來組織、存儲和管理數據的倉庫，數據庫通常包括如下部署模式：主備模式、雙主模式、跨地域主備容災模式、異構數據庫復制模式等。其中，雙主模式是指兩個節點的數據庫都支持業務訪問，支持負載均衡，當一個節點發生故障時，可以將業務切換到另一個節點。上述任何部署模式都需要復制源節點的更新事務到對端節點，復制的方式通常有物理復制和邏輯復制，物理復制是將數據文件物理位置的修改復制到目標節點同樣的位置，這種方式只適用于主備模式。邏輯復制是將源節點的修改操作記錄為日志信息，在目標節點上以重放事務的方式完成數據同步復制。邏輯復制的處理流程比物理復制復雜的多，其處理性能與系統的可靠性緊密相關。現有數據庫雙主模式中，源數據庫在修改事務時產生日志信息，接收端將日志信息還原成結構化查詢語言（Structured Query Language，sql），對于每一條日志信息，均需要解析和編譯sql語句，并逐條執行sql語句，從而完成事務同步。然而，這種方式使得數據庫同步效率低下。

發明內容

本發明的目的在于提供一種數據庫同步的方法及系統，以解決上述背景技術中提出的問題。

為實現上述目的，本發明提供如下技術方案：

一種數據庫同步的方法，包括如下步驟：接收源數據庫發送的日志信息，所述日志信息用于表示所述源數據庫中的數據修改操作；獲取所述日志信息中所述數據修改操作的類型和參數，并將獲取的所述數據修改操作的參數綁定到與所述數據修改操作的類型對應的語句模板中，生成數據修改操作語句；運行所述數據修改操作語句，完成對目標數據庫中相同存儲位置的數據的修改；由處理器監視源數據庫中數據屬性的集合；由處理器基于所監視的屬性的集合選擇數據組用于同步；由處理器將優先級級別分派給每個所選擇的數據和每個設備；由處理器基于優先級級別按優先序排列將對所選擇的數據的組執行的同步操作；以及由處理器根據同步的優先序排列來同步所選擇的數據的組。

作為本發明進一步的方案：所述將獲取的所述數據修改操作的參數綁定到與所述數據修改操作的類型對應的語句模板中，生成數據修改操作語句之前，還包括：生成所述語句類型。

作為本發明進一步的方案：在所述運行所述數據修改操作語句之前，還包括：將所述數據修改操作語句添加到語句組；所述運行所述數據修改操作語句，完成對目標數據庫中相同存儲位置的數據的修改具體包括：在所述語句組的語句類型為預設類型時，運行所述語句組，完成對目標數據庫中相同存儲位置的數據的修改。

作為本發明再進一步的方案：包括：監視模塊，其監視源數據庫中數據屬性的集合；預測模塊，其基于所監視的數據屬性的集合選擇數據組用于同步，并且將優先級級別分派給每個所選擇的數據和每個設備；數據管理器，其基于優先級級別按優先序排列將對所選擇的數據的組執行的同步操作；以及數據管理器，其根據同步的優先序排列同步所選擇的數據的組。

與現有技術相比，本發明的有益效果是：本發明數據庫同步的方法及系統，由處理器監視源數據庫中數據屬性的集合；由處理器基于所監視的屬性的集合選擇數據組用于同步；由處理器將優先級級別分派給每個所選擇的數據和每個設備；由處理器基于優先級級別按優先序排列將對所選擇的數據的組執行的同步操作；以及由處理器根據同步的優先序排列來同步所選擇的數據的組，從而提升了數據庫同步的效率。

具體實施方式

下面對本發明實施例中的技術方案進行清楚、完整地描述，顯然，所描述的實施例僅僅是本發明一部分實施例，而不是全部的實施例。基于本發明中的實施例，本領域普通技術人員在沒有做出創造性勞動前提下所獲得的所有其他實施例，都屬于本發明保護的范圍。

本發明實施例中，一種數據庫同步的方法，包括如下步驟：接收源數據庫發送的日志信息，所述日志信息用于表示所述源數據庫中的數據修改操作；獲取所述日志信息中所述數據修改操作的類型和參數，并將獲取的所述數據修改操作的參數綁定到與所述數據修改操作的類型對應的語句模板中，生成數據修改操作語句；運行所述數據修改操作語句，完成對目標數據庫中相同存儲位置的數據的修改；由處理器監視源數據庫中數據屬性的集合；由處理器基于所監視的屬性的集合選擇數據組用于同步；由處理器將優先級級別分派給每個所選擇的數據和每個設備；由處理器基于優先級級別按優先序排列將對所選擇的數據的組執行的同步操作；以及由處理器根據同步的優先序排列來同步所選擇的數據的組。