[發明專利]異構數據庫的數據同步方法、裝置、電子設備及介質

在審

• 申請號: 202010610726.2
• 申請日: 2020-06-29
• 公開（公告）號: CN111881209A
• 公開（公告）日: 2020-11-03
• 發明（設計）人: 張月;周燚健
• 申請（專利權）人: 平安國際智慧城市科技股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/25
• 代理公司: 深圳市賽恩倍吉知識產權代理有限公司 44334
• 代理人: 何春蘭;遲珊珊

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

獲取數據同步請求；

根據所述數據同步請求確定源數據庫及目標數據庫；

確定所述源數據庫與所述目標數據庫的映射文件；

獲取所述源數據庫中的變化數據；

根據所述映射文件及所述變化數據生成所述源數據庫的變化數據表，其中，所述變化數據表的數據格式與所述目標數據庫的數據格式相同；

封裝所述變化數據表，并將封裝后的變化數據表發送至所述目標數據庫中；

當監測到所述封裝后的變化數據表被所述目標數據庫接收時，解析所述封裝后的變化數據表，得到操作數據，并確定所述操作數據的操作類型；

根據所述操作類型及所述操作數據生成操作指令，在所述目標數據庫中執行所述操作指令，得到目標數據表。

2.如權利要求1所述的異構數據庫的數據同步方法，其特征在于，在獲取數據同步請求之前，所述異構數據庫的數據同步方法還包括：

從預先配置的連接池中獲取所有異構數據庫；

監聽每個異構數據庫的源數據表中是否發生數據變化；

當監聽到任意異構數據庫的源數據表中發生數據變化時，根據所述任意異構數據庫生成所述數據同步請求。

3.如權利要求2所述的異構數據庫的數據同步方法，其特征在于，所述根據所述數據同步請求確定源數據庫及目標數據庫包括：

采用JSON技術解析所述數據同步請求中的方法體，得到所述數據同步請求中攜帶的數據信息；

獲取預設標簽，并從所述數據信息中獲取與所述預設標簽對應的信息，作為變化數據庫；

當所述變化數據庫包括所述所有異構數據庫時，將所述變化數據庫中任意一個變化數據庫確定為所述目標數據庫，及將除所述目標數據庫外的異構數據庫確定為所述源數據庫；或者

當所述變化數據庫未包括所述所有異構數據庫時，將所述變化數據庫確定為所述源數據庫，及將除所述源數據庫外的異構數據庫確定為所述目標數據庫。

4.如權利要求2所述的異構數據庫的數據同步方法，其特征在于，所述獲取所述源數據庫中的變化數據包括：

獲取所述源數據庫中的目標日志；

從預先配置的線程池中獲取閑置線程，并調用start命令啟動所述閑置線程；

通過啟動后的閑置線程逐條讀取所述目標日志，并解析讀取到的目標日志，得到主鍵值及所述主鍵值對應的時間戳，所述主鍵值包括重復主鍵值及第一主鍵值，所述第一主鍵值不具有重復的主鍵值；

從所述重復主鍵值中確定時間戳最大的主鍵值，作為第二主鍵值；

融合所述第一主鍵值及所述第二主鍵值，得到目標主鍵值；

提取所述目標主鍵值對應的數據，作為所述變化數據。

5.如權利要求1所述的異構數據庫的數據同步方法，其特征在于，所述確定所述源數據庫與所述目標數據庫的映射文件包括：

獲取所述源數據庫的第一識別碼，及獲取所述目標數據庫的第二識別碼；

拼接所述第一識別碼及所述第二識別碼，得到目標序號；

從區塊鏈中確定與所述目標序號對應的文件，作為所述映射文件。

6.如權利要求1所述的異構數據庫的數據同步方法，其特征在于，所述確定所述操作數據的操作類型包括：

獲取所述操作數據在所述源數據庫中對應的原始數據；

確定所述原始數據在所述源數據庫中的位置；

根據所述位置確定所述原始數據的修訂模式，并將所述修訂模式確定為所述操作類型。

7.如權利要求1所述的異構數據庫的數據同步方法，其特征在于，所述異構數據庫的數據同步方法還包括：

獲取所述操作指令的生成時刻，作為第一時刻；

將加上預設時段后的第一時刻確定為第二時刻；

當檢測到在所述第二時刻之前未完成數據同步時，生成告警信息；

確定所述告警信息的告警等級；

根據所述告警等級確定告警方式；

以所述告警方式將所述告警信息發送至指定聯系人的終端設備。