[發(fā)明專利]數(shù)據(jù)庫變更數(shù)據(jù)的處理方法、裝置、計算機設(shè)備和介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110601826.3
• 申請日: 2021-05-31
• 公開（公告）號: CN113377789A
• 公開（公告）日: 2021-09-10
• 發(fā)明（設(shè)計）人: 錢威
• 申請（專利權(quán)）人: 上海數(shù)禾信息科技有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/22
• 代理公司: 北京市萬慧達律師事務(wù)所 11111
• 代理人: 劉鋒;邱忠貺

1.一種數(shù)據(jù)庫變更數(shù)據(jù)的處理方法，其特征在于，所述方法包括：

實時拉取指定數(shù)據(jù)庫生成的數(shù)據(jù)變更日志，將拉取到數(shù)據(jù)變更日志解析為變更數(shù)據(jù)；

按照預(yù)設(shè)關(guān)鍵字對所述變更數(shù)據(jù)進行過濾，在從所述變更數(shù)據(jù)中過濾得到用于變更數(shù)據(jù)的操作語句時，從所述變更數(shù)據(jù)中解析出與過濾得到的操作語句中的各條操作語句對應(yīng)的變更信息，以及各條變更信息對應(yīng)的存儲位置信息；

將各條變更信息處理為符合歷史數(shù)據(jù)庫的數(shù)據(jù)結(jié)構(gòu)要求的變更記錄，并存儲至所述歷史數(shù)據(jù)庫中的與其存儲位置信息對應(yīng)的數(shù)據(jù)表中。

2.如權(quán)利要求1所述的方法，其特征在于，

從所述變更數(shù)據(jù)中解析出各條變更信息對應(yīng)的存儲位置信息的步驟，包括：

從所述變更數(shù)據(jù)中解析出各條操作語句對應(yīng)的數(shù)據(jù)庫實例名、數(shù)據(jù)庫名和數(shù)據(jù)表名；

通過各條操作語句對應(yīng)的數(shù)據(jù)庫實例名、數(shù)據(jù)庫名和數(shù)據(jù)表名映射得到各條操作語句對應(yīng)的歷史數(shù)據(jù)表名，將各條操作語句對應(yīng)的歷史數(shù)據(jù)表名作為該各條操作語句對應(yīng)的變更信息的存儲位置信息。

3.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

定時查詢所述指定數(shù)據(jù)庫的索引，以及所述歷史數(shù)據(jù)庫的索引；

將所述指定數(shù)據(jù)庫的索引和所述歷史數(shù)據(jù)庫的索引進行比較，并根據(jù)比較得到的結(jié)果對所述指定數(shù)據(jù)庫和所述歷史數(shù)據(jù)庫的索引進行同步。

4.如權(quán)利要求3所述的方法，其特征在于，

將所述指定數(shù)據(jù)庫的索引和所述歷史數(shù)據(jù)庫的索引進行比較，并根據(jù)比較得到的結(jié)果對所述指定數(shù)據(jù)庫和所述歷史數(shù)據(jù)庫的索引進行同步的步驟，包括：

將所述指定數(shù)據(jù)庫的索引和所述歷史數(shù)據(jù)庫的索引進行比較，確定出所述指定數(shù)據(jù)庫的索引和所述歷史數(shù)據(jù)庫的索引之間的交集；

刪除所述歷史數(shù)據(jù)庫的索引中的不屬于所述交集的索引；

將所述指定數(shù)據(jù)庫的索引中的不屬于所述交集的索引，新增至所述歷史數(shù)據(jù)庫中。

5.如權(quán)利要求3所述的方法，其特征在于，所述方法還包括：

接收來自用戶端的攜帶有查詢條件的查詢請求；

根據(jù)所述歷史數(shù)據(jù)庫的索引從所述歷史數(shù)據(jù)庫中查詢與所述查詢條件符合的變更信息；

將查詢到的變更信息作為查詢結(jié)果返回給所述用戶端，使得所述用戶端通過預(yù)設(shè)查詢結(jié)果展示界面將其接收到的查詢結(jié)果展示給用戶。

6.如權(quán)利要求1所述的方法，其特征在于，所述用于變更數(shù)據(jù)的操作語句為用于新增數(shù)據(jù)、刪除數(shù)據(jù)或更新數(shù)據(jù)的SQL語句；所述歷史數(shù)據(jù)庫為Mongo數(shù)據(jù)庫或ElasticSearch數(shù)據(jù)庫；所述數(shù)據(jù)變更日志為binlog日志文件。

7.如權(quán)利要求1所述的方法，其特征在于，任一條所述操作語句對應(yīng)的變更信息包括數(shù)據(jù)變更類型、數(shù)據(jù)變更時間、變更后數(shù)據(jù)和變更前數(shù)據(jù)。

8.一種數(shù)據(jù)庫變更數(shù)據(jù)的處理裝置，其特征在于，所述裝置包括：

第一數(shù)據(jù)處理模塊，用于實時拉取指定數(shù)據(jù)庫生成的數(shù)據(jù)變更日志，將拉取到數(shù)據(jù)變更日志解析為變更數(shù)據(jù)；

第二數(shù)據(jù)處理模塊，用于按照預(yù)設(shè)關(guān)鍵字對所述變更數(shù)據(jù)進行過濾，在從所述變更數(shù)據(jù)中過濾得到用于變更數(shù)據(jù)的操作語句時，從所述變更數(shù)據(jù)中解析出與過濾得到的操作語句中的各條操作語句對應(yīng)的變更信息，以及各條變更信息對應(yīng)的存儲位置信息；

數(shù)據(jù)存儲模塊，用于將各條變更信息處理為符合歷史數(shù)據(jù)庫的數(shù)據(jù)結(jié)構(gòu)要求的變更記錄，并存儲至所述歷史數(shù)據(jù)庫中的與其存儲位置信息對應(yīng)的數(shù)據(jù)表中。

9.一種計算機設(shè)備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執(zhí)行所述計算機程序時實現(xiàn)權(quán)利要求1至7中任一項所述方法的步驟。

10.一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，其特征在于，所述計算機程序被處理器執(zhí)行時實現(xiàn)權(quán)利要求1至7中任一項所述的方法的步驟。