[發明專利]系統間數據同步方法、裝置、計算機系統、存儲介質

在審

• 申請號: 202110369669.8
• 申請日: 2021-04-06
• 公開（公告）號: CN113010607A
• 公開（公告）日: 2021-06-22
• 發明（設計）人: 王明飛;張曙晟;劉玉紅
• 申請（專利權）人: 工銀科技有限公司;中國工商銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F11/14
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 周天宇

1.一種系統間數據同步方法，包括：

獲取第一數據庫系統的第一數據日志與第二數據庫系統的第二數據日志；

讀取所述第一數據日志和所述第二數據日志，將其中的數據操作語句按照時間順序重新排列，生成融合數據日志；

將所述融合數據日志中的數據操作語句轉換為所述第一數據庫系統和所述第二數據庫系統中的待同步數據庫可識別的數據操作語句；

將轉換后的所述融合數據日志發送給所述待同步數據庫，使所述待同步數據庫執行所述數據操作語句，實現數據同步。

2.根據權利要求1所述的方法，所述將所述融合數據日志中的數據操作語句轉換為所述第一數據庫系統和所述第二數據庫系統中的待同步數據庫可識別的數據操作語句包括：

解析所述融合數據日志中的數據操作語句，獲取所述數據操作語句包括的表、操作函數及字段名稱；

根據待同步數據庫的類型，將所述操作函數轉換為所述待同步數據庫可識別的操作函數；

基于所述表、所述待同步數據庫可識別的操作函數及所述字段名稱，重構所述數據操作語句，得到所述待同步數據庫可操作的數據操作語句。

3.根據權利要求2所述的方法，還包括：

預設包括各類數據庫的函數轉換關系的函數轉換庫，基于所述函數轉換庫進行所述操作函數的轉換。

4.根據權利要求2所述的方法，還包括：

在重構所述數據操作語句的過程中，忽略所述待同步數據庫自身的所述第一數據日志或所述第二數據日志中在預設時間段內已執行的所述數據操作語句。

5.根據權利要求1所述的方法，在所述待同步數據庫執行所述數據操作語句，實現數據同步的過程中，包括：

記錄各所述數據操作語句、各所述數據操作語句的執行時間、執行結果。

6.根據權利要求1所述的方法，所述第一數據庫系統包括至少一個第一數據庫，所述第二數據庫系統包括至少一個第二數據庫，所述獲取第一數據庫系統的第一數據日志與第二數據庫系統的第二數據日志包括：

定期獲取各所述第一數據庫的第一數據日志和各所述第二數據庫的第二數據日志；

將所有所述第一數據日志均存儲于所述第一數據庫系統中，將所有所述第二數據日志均存儲于第二數據庫系統中。

7.根據權利要求6所述的方法，所述讀取所述第一數據日志和所述第二數據日志，將其中的數據操作語句按照時間順序重新排列，生成融合數據日志包括：

讀取所述第一數據庫系統中全部的所述第一數據日志和所述第二數據庫系統中全部的所述第二數據日志，將具有所包括的數據操作語句按照時間順序排列，生成所述融合數據日志。

8.根據權利要求6所述的方法，還包括：

打包備份所述第一數據日志、所述第二數據日志和所述融合數據日志。

9.一種系統間數據同步裝置，包括：

日志獲取模塊，用于獲取第一數據庫系統的第一數據日志與第二數據庫系統的第二數據日志；

日志融合模塊，用于讀取所述第一數據日志和所述第二數據日志，將其中的數據操作語句按照時間順序重新排列，生成融合數據日志；

語句轉換模塊，用于將所述融合數據日志中的數據操作語句轉換為所述第一數據庫系統和所述第二數據庫系統中的待同步數據庫可識別的數據操作語句；

數據同步模塊，用于將轉換后的所述融合數據日志發送給所述待同步數據庫，使所述待同步數據庫執行所述數據操作語句，實現數據同步。

10.根據權利要求9所述的裝置，所述語句轉換模塊包括：

語句解析單元，用于解析所述融合數據日志中的數據操作語句，獲取所述數據操作語句包括的表、操作函數及字段名稱；

函數轉換單元，用于根據待同步數據庫的類型，將所述操作函數轉換為所述待同步數據庫可識別的操作函數；

語句重構單元，用于基于所述表、所述待同步數據庫可識別的操作函數及所述字段名稱，重構所述數據操作語句，得到所述待同步數據庫可操作的數據操作語句。