[發明專利]數據庫的同步方法、裝置、計算機設備以及存儲介質

在審

• 申請號: 202211474546.1
• 申請日: 2022-11-23
• 公開（公告）號: CN115712683A
• 公開（公告）日: 2023-02-24
• 發明（設計）人: 李晶;鄧玉;江魁棟;李尚真;彭宙碩;蘇建標
• 申請（專利權）人: 中國建設銀行股份有限公司;建信金融科技有限責任公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F16/28
• 代理公司: 華進聯合專利商標代理有限公司 44224
• 代理人: 舒丁

本公開涉及大數據技術領域，具體公開了一種數據庫的同步方法、裝置、計算機設備、存儲介質和計算機程序產品，其中方法通過獲取對目標數據庫的操作，當確定操作為目標操作時，將目標操作封裝成對應的JSON消息，并確定操作對應的主題，根據主題將JSON消息存儲在消息隊列的對應分區中，進而在待同步數據庫執行各分區中JSON消息對應的操作，從而更新待同步數據庫。由于本實施例通過監聽數據庫的操作，并將監聽到的目標操作封裝成JSON消息按區存儲，進而按區消費并在待同步數據庫執行JSON消息，從而可以實現數據庫間的雙向同步，且不依賴于數據庫的支持，對主流數據庫都具有普適性，能夠從根本上解決數據庫的雙向同步問題。

技術領域

本申請涉及大數據技術領域，特別是涉及一種數據庫的同步方法、裝置、計算機設備、存儲介質和計算機程序產品。

背景技術

隨著網絡技術的發展，數據量也呈指數級別的增長，互聯網及金融系統中單體應用連接單個數據庫的方式，已無法滿足數據量快速增長的需求。而大數據技術的出現，使得系統可以通過分布式應用來解決高并發及大數據量問題。其通過將單體應用系統拆分成各個子系統，使得各個子系統連接獨立數據庫，彼此通過API接口(Application ProgrammingInterface，應用程序編程接口)調用串聯業務邏輯，以對外提供服務。

在單體應用向分布式應用過渡的過程中，對外存在新、舊服務并行的過渡態，不僅需要保證業務功能不能中斷，且在技術層面需要保證用戶通過新、舊服務訪問的數據同步，即在原單體應用所連的主數據庫和拆分后的子系統所連的子數據庫一致。

傳統技術中，關系型數據庫管理系統(MySQL)可以實現主從復制。但MySQL的主從復制依賴于數據庫的支持，且只支持將主庫數據同步到從庫(即子數據庫)，而不支持將從庫的數據同步到主庫。且當網絡無法直連的情況下兩個數據庫無法同步。因此，傳統的MySQL的主從復制方式受到了較多限制，且無法實現主數據庫與從數據庫之間的雙向同步。

發明內容

基于此，有必要針對上述技術問題，提供一種能夠實現數據庫間雙向同步的數據庫的同步方法、裝置、計算機設備、計算機可讀存儲介質和計算機程序產品。

第一方面，本申請提供了一種數據庫的同步方法。所述方法包括：

獲取對目標數據庫的操作；

當確定所述操作為目標操作時，將所述目標操作封裝成對應的JSON消息；

確定所述操作對應的主題，根據所述主題將所述JSON消息存儲在消息隊列的對應分區中；

在待同步數據庫執行各分區中所述JSON消息對應的操作，更新所述待同步數據庫；當所述目標數據庫為主數據庫時，所述待同步數據庫為子數據庫，當所述目標數據庫為子數據庫時，所述待同步數據庫為主數據庫。

在其中一個實施例中，所述獲取對目標數據庫的操作，包括：當監聽到對目標數據庫的操作為事務操作時，采用線程變量記錄所述事務操作；當所述事務操作結束時，將記錄的所述事務操作確定為目標操作。

在其中一個實施例中，所述將記錄的所述事務操作確定為目標操作之后，所述方法還包括：從所述線程變量中刪除所述事務操作。

在其中一個實施例中，所述方法還包括：當所述事務操作回滾時，從所述線程變量中刪除所述事務操作。

在其中一個實施例中，所述獲取對目標數據庫的操作，包括：當監聽到對目標數據庫的操作為非事務操作時，確定所述非事務操作為目標操作。

在其中一個實施例中，所述確定所述操作對應的主題，包括：所述操作中攜帶有待操作數據表的標識和/或待操作數據所屬的賬戶標識，根據所述待操作數據表的標識和/或所述賬戶標識確定所述操作對應的主題。