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

在審

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

1.一種數據庫的同步方法，其特征在于，所述方法包括：

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

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

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

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

2.根據權利要求1所述的方法，其特征在于，所述獲取對目標數據庫的操作，包括：

當監聽到對目標數據庫的操作為事務操作時，采用線程變量記錄所述事務操作；

當所述事務操作結束時，將記錄的所述事務操作確定為目標操作。

3.根據權利要求2所述的方法，其特征在于，所述將記錄的所述事務操作確定為目標操作之后，所述方法還包括：

從所述線程變量中刪除所述事務操作。

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

當所述事務操作回滾時，從所述線程變量中刪除所述事務操作。

5.根據權利要求1所述的方法，其特征在于，所述獲取對目標數據庫的操作，包括：

當監聽到對目標數據庫的操作為非事務操作時，確定所述非事務操作為目標操作。

6.根據權利要求1所述的方法，其特征在于，所述確定所述操作對應的主題，包括：

所述操作中攜帶有待操作數據表的標識和/或待操作數據所屬的賬戶標識，根據所述待操作數據表的標識和/或所述賬戶標識確定所述操作對應的主題。

7.根據權利要求1至6任一項所述的方法，其特征在于，所述在待同步數據庫執行各分區中所述JSON消息對應的操作，包括：

在所述待同步數據庫，對所述各分區中所述JSON消息對應的操作按設定數量批量執行。

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

當批量執行失敗時，對批量執行失敗的所述分區中的所述JSON消息對應的操作進行逐條執行；

記錄每一條操作的執行結果，所述執行結果包括執行成功或執行失敗的結果。

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

當所述執行結果為執行失敗時，發送失敗告警信息。

10.一種數據庫的同步裝置，其特征在于，所述裝置包括：

操作獲取模塊，用于獲取對目標數據庫的操作；

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

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

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

11.一種計算機設備，包括存儲器和處理器，所述存儲器存儲有計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求1至9中任一項所述的方法的步驟。

12.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，所述計算機程序被處理器執行時實現權利要求1至9中任一項所述的方法的步驟。

13.一種計算機程序產品，包括計算機程序，其特征在于，該計算機程序被處理器執行時實現權利要求1至9中任一項所述的方法的步驟。