[發(fā)明專利]構(gòu)建數(shù)據(jù)的方法和裝置以及數(shù)據(jù)庫之間同步數(shù)據(jù)的系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202010181867.7
• 申請日: 2020-03-16
• 公開（公告）號: CN113407619A
• 公開（公告）日: 2021-09-17
• 發(fā)明（設(shè)計）人: 劉沛文
• 申請（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司;北京京東世紀貿(mào)易有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 中原信達知識產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張效榮;王志遠

1.一種構(gòu)建數(shù)據(jù)的方法，其特征在于，包括：

在數(shù)據(jù)庫的目標日志系統(tǒng)發(fā)生故障之后：當(dāng)監(jiān)測到針對所述數(shù)據(jù)庫的操作時，獲取該操作作用在所述數(shù)據(jù)庫的關(guān)聯(lián)數(shù)據(jù)；其中，所述目標日志系統(tǒng)中存儲有用于執(zhí)行數(shù)據(jù)同步或數(shù)據(jù)恢復(fù)的目標日志數(shù)據(jù)；

使用獲取到的關(guān)聯(lián)數(shù)據(jù)并依據(jù)目標日志數(shù)據(jù)的格式構(gòu)建模擬日志數(shù)據(jù)，將構(gòu)建完成的模擬日志數(shù)據(jù)存儲。

2.根據(jù)權(quán)利要求1所述的構(gòu)建數(shù)據(jù)的方法，其特征在于，所述構(gòu)建數(shù)據(jù)的方法還包括：在所述獲取該操作作用在所述數(shù)據(jù)庫的關(guān)聯(lián)數(shù)據(jù)之前，將所述數(shù)據(jù)庫的操作方法與預(yù)設(shè)的切面代碼關(guān)聯(lián)；以及，當(dāng)監(jiān)測到針對所述數(shù)據(jù)庫的操作時，獲取該操作作用在所述數(shù)據(jù)庫的關(guān)聯(lián)數(shù)據(jù)，包括：

當(dāng)監(jiān)測到針對所述數(shù)據(jù)庫的操作調(diào)用相應(yīng)的操作方法進而觸發(fā)該操作方法關(guān)聯(lián)的切面代碼時，利用觸發(fā)執(zhí)行的切面代碼獲取該操作作用在所述數(shù)據(jù)庫的關(guān)聯(lián)數(shù)據(jù)。

3.根據(jù)權(quán)利要求2所述的構(gòu)建數(shù)據(jù)的方法，其特征在于，所述關(guān)聯(lián)數(shù)據(jù)中包括操作類型；以及，所述構(gòu)建數(shù)據(jù)的方法還包括：

在所述使用獲取到的關(guān)聯(lián)數(shù)據(jù)并依據(jù)目標日志數(shù)據(jù)的格式構(gòu)建模擬日志數(shù)據(jù)之前，確定操作類型對應(yīng)的預(yù)設(shè)模板；其中，所述模板中包括該操作類型對應(yīng)的模擬日志數(shù)據(jù)的構(gòu)建邏輯并維護上下文對象；

使用獲取到的關(guān)聯(lián)數(shù)據(jù)并依據(jù)目標日志數(shù)據(jù)的格式構(gòu)建模擬日志數(shù)據(jù)，包括：

將獲取到的關(guān)聯(lián)數(shù)據(jù)存儲在確定的模板的上下文對象中，根據(jù)該模板中的構(gòu)建邏輯構(gòu)建模擬日志數(shù)據(jù)。

4.根據(jù)權(quán)利要求1所述的構(gòu)建數(shù)據(jù)的方法，其特征在于，所述構(gòu)建數(shù)據(jù)的方法還包括：

在所述數(shù)據(jù)庫的目標日志系統(tǒng)發(fā)生故障之后：接收針對所述數(shù)據(jù)庫的查詢語句，確定所述數(shù)據(jù)庫中對應(yīng)于該查詢語句的目的數(shù)據(jù)；

使用所述目的數(shù)據(jù)并依據(jù)目標日志數(shù)據(jù)的格式構(gòu)建模擬日志數(shù)據(jù)，將構(gòu)建完成的模擬日志數(shù)據(jù)存儲。

5.根據(jù)權(quán)利要求3所述的構(gòu)建數(shù)據(jù)的方法，其特征在于，所述數(shù)據(jù)庫是為目標數(shù)據(jù)庫提供支持的源數(shù)據(jù)庫，以及，所述構(gòu)建數(shù)據(jù)的方法還包括：

在模擬日志數(shù)據(jù)構(gòu)造完成之后，將所述模擬日志數(shù)據(jù)向目標數(shù)據(jù)庫的數(shù)據(jù)同步系統(tǒng)發(fā)送；其中，所述數(shù)據(jù)同步系統(tǒng)用于將所述模擬日志數(shù)據(jù)作為目標日志數(shù)據(jù)執(zhí)行從源數(shù)據(jù)庫到目標數(shù)據(jù)庫的數(shù)據(jù)同步。

6.根據(jù)權(quán)利要求5所述的構(gòu)建數(shù)據(jù)的方法，其特征在于，

源數(shù)據(jù)庫包括Mysql，目標數(shù)據(jù)庫包括Redis和/或Elastic Search；

目標日志數(shù)據(jù)為二進制日志binlog數(shù)據(jù)，目標日志系統(tǒng)為binlog系統(tǒng)；

所述操作類型包括增加、刪除和/或更新，所述操作方法包括增加方法、刪除方法和/或更新方法；

所述關(guān)聯(lián)數(shù)據(jù)還包括源數(shù)據(jù)庫中操作針對的數(shù)據(jù)表的標識、以及該數(shù)據(jù)表中操作針對的記錄的操作前數(shù)據(jù)和操作后數(shù)據(jù)；

所述切面代碼為基于面向切面編程AOP的增強代碼。

7.一種構(gòu)建數(shù)據(jù)的裝置，其特征在于，包括：

關(guān)聯(lián)數(shù)據(jù)獲取單元，用于：在數(shù)據(jù)庫的目標日志系統(tǒng)發(fā)生故障之后：當(dāng)監(jiān)測到針對所述數(shù)據(jù)庫的操作時，獲取該操作作用在所述數(shù)據(jù)庫的關(guān)聯(lián)數(shù)據(jù)；其中，所述目標日志系統(tǒng)中存儲有用于執(zhí)行數(shù)據(jù)同步或數(shù)據(jù)恢復(fù)的目標日志數(shù)據(jù)；

模擬日志數(shù)據(jù)構(gòu)建單元：用于使用獲取到的關(guān)聯(lián)數(shù)據(jù)并依據(jù)目標日志數(shù)據(jù)的格式構(gòu)建模擬日志數(shù)據(jù)，將構(gòu)建完成的模擬日志數(shù)據(jù)存儲。

8.一種數(shù)據(jù)庫之間同步數(shù)據(jù)的系統(tǒng)，其特征在于，包括：源數(shù)據(jù)庫、設(shè)置有源數(shù)據(jù)庫對外訪問接口的訪問系統(tǒng)、由源數(shù)據(jù)庫提供數(shù)據(jù)支持的目標數(shù)據(jù)庫、以及根據(jù)源數(shù)據(jù)庫生成的目標日志數(shù)據(jù)對目標數(shù)據(jù)庫執(zhí)行數(shù)據(jù)同步的數(shù)據(jù)同步系統(tǒng)；所述訪問系統(tǒng)中包括降級工具；其中，

在存儲有所述目標日志數(shù)據(jù)的目標日志系統(tǒng)發(fā)生故障之后：當(dāng)降級工具監(jiān)測到針對源數(shù)據(jù)庫的操作，則獲取該操作作用在源數(shù)據(jù)庫的關(guān)聯(lián)數(shù)據(jù)，使用獲取到的關(guān)聯(lián)數(shù)據(jù)并依據(jù)目標日志數(shù)據(jù)的格式構(gòu)建模擬日志數(shù)據(jù)，以及將構(gòu)建完成的模擬日志數(shù)據(jù)向數(shù)據(jù)同步系統(tǒng)發(fā)送。