[發明專利]數據庫數據一致性檢測方法、裝置、介質和電子設備

有效

• 申請號: 202011017249.5
• 申請日: 2020-09-24
• 公開（公告）號: CN112162989B
• 公開（公告）日: 2023-09-15
• 發明（設計）人: 魏乾;黃海峰
• 申請（專利權）人: 北京人大金倉信息技術股份有限公司;太極計算機股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27
• 代理公司: 北京開陽星知識產權代理有限公司 11710
• 代理人: 安偉

1.一種數據庫數據一致性檢測方法，其特征在于，包括：

獲取源數據庫的第一數據庫連接，配置隔離級別為串行化隔離級別，并關閉自動提交；

在所述第一數據庫連接中開啟數據檢測事務；

獲取所述源數據庫當前時刻的全量數據和第一數據庫日志信息；

獲取目標數據庫的目標同步系統中已同步完成的第二數據庫日志信息；

基于所述第一數據庫日志信息和第二數據庫日志信息，從所述源數據庫的源端同步系統中獲取對應的同步日志；

將所述同步日志解析為SQL語句以在所述目標數據庫執行；

執行完畢后獲取所述目標數據庫的全量數據；

基于所述目標數據庫的全量數據與所述源數據庫的全量數據進行數據一致性檢測；

數據一致性檢測完成后提交數據檢測事務。

2.根據權利要求1所述的數據庫數據一致性檢測方法，其特征在于，還包括：

在獲取源數據庫的第一數據庫連接之后，在所述第一數據庫連接中開啟數據檢測事務之前，獲取目標數據庫的第二數據庫連接，配置隔離級別為串行化隔離級別，并關閉自動提交；

在將所述同步日志解析為SQL語句以在所述目標數據庫執行之前，在所述目標數據庫的第二數據庫連接中配置保存點；

數據一致性檢測完成后將所述第二數據庫連接回滾至所述保存點，并關閉所述第一數據庫連接和第二數據庫連接以提交數據檢測事務。

3.根據權利要求2所述的數據庫數據一致性檢測方法，其特征在于，所述第一數據庫日志信息和第二數據庫日志信息均為數據庫日志號；所述基于所述第一數據庫日志信息和第二數據庫日志信息，從所述源數據庫的源端同步系統中獲取對應的同步日志，包括：

從所述源端同步系統中獲取大于第二數據庫日志號而小于第一數據庫日志號的所有同步日志。

4.根據權利要求2所述的數據庫數據一致性檢測方法，其特征在于，所述將所述同步日志解析為SQL語句以在所述目標數據庫執行，包括：

基于用戶輸入的選擇操作，確定所述目標數據庫中待執行的預設數據表；

在所述預設數據表中執行所述SQL語句已完成相應數據操作。

5.根據權利要求1～4任一項所述的數據庫數據一致性檢測方法，其特征在于，獲取所述源數據庫當前時刻的第一數據庫日志信息，包括：

獲取所述源數據庫的第三數據庫連接，基于該第三數據庫連接獲取所述源數據庫當前時刻的第一數據庫日志信息；

在所述第三數據庫連接獲取所述源數據庫當前時刻的第一數據庫日志信息之后，關閉所述第三數據庫連接。

6.根據權利要求1～4任一項所述的數據庫數據一致性檢測方法，其特征在于，所述獲取所述源數據庫當前時刻的全量數據，包括：

基于所述源數據庫的所述第一數據庫連接獲取所述源數據庫當前時刻的的全量數據。

7.一種數據庫數據一致性檢測裝置，其特征在于，包括：

第一連接處理模塊，用于獲取源數據庫的第一數據庫連接，配置隔離級別為串行化隔離級別，并關閉自動提交；

事務開啟模塊，用于在所述第一數據庫連接中開啟數據檢測事務；

第一數據獲取模塊，用于獲取所述源數據庫當前時刻的全量數據和第一數據庫日志信息；

日志獲取模塊，用于獲取所述目標數據庫的目標同步系統中已同步完成的第二數據庫日志信息；

同步日志獲取模塊，用于基于所述第一數據庫日志信息和第二數據庫日志信息，從所述源數據庫的源端同步系統中獲取對應的同步日志；

數據同步模塊，用于將所述同步日志解析為SQL語句以在所述目標數據庫執行；

第二數據獲取模塊，用于執行完畢后獲取所述目標數據庫的全量數據；

數據檢測模塊，用于基于所述目標數據庫的全量數據與所述源數據庫的全量數據進行數據一致性檢測；

事務提交模塊，用于數據一致性檢測完成后提交數據檢測事務。