[發(fā)明專利]一種異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201810980129.1
• 申請(qǐng)日: 2018-08-27
• 公開（公告）號(hào): CN109284312A
• 公開（公告）日: 2019-01-29
• 發(fā)明（設(shè)計(jì)）人: 耿慶霄;杜黎言;吳曉龍;王冠男;滕曉東
• 申請(qǐng)（專利權(quán)）人: 山東威爾數(shù)據(jù)股份有限公司
• 主分類號(hào): G06F16/2457
• 分類號(hào): G06F16/2457;G06F16/25
• 代理公司: 煙臺(tái)雙聯(lián)專利事務(wù)所(普通合伙) 37225
• 代理人: 申國棟

1.一種異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于通過計(jì)算機(jī)裝置實(shí)現(xiàn)下述步驟：

（1）確定源表集和目標(biāo)表集，所述源表集用于指定需要監(jiān)聽的源表，所述目標(biāo)表集用于指定源表所對(duì)應(yīng)的目標(biāo)表；通過數(shù)據(jù)變更捕獲機(jī)制，監(jiān)聽源表集，當(dāng)對(duì)源表進(jìn)行數(shù)據(jù)的增加或刪除或改變操作時(shí)，數(shù)據(jù)變更捕獲機(jī)制將DML操作記錄到目標(biāo)表集中對(duì)應(yīng)的目標(biāo)表中；

（2）通過數(shù)據(jù)轉(zhuǎn)換程序，從目標(biāo)表集中獲取變更數(shù)據(jù)，并將變更數(shù)據(jù)轉(zhuǎn)換為統(tǒng)一格式后存放到另行建立的變更數(shù)據(jù)庫中；

（3）變更數(shù)據(jù)庫中新增變更數(shù)據(jù)后，將變更消息通過消息隊(duì)列機(jī)制推送給用戶。

2.如權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：所述源表集還指定源表中需要監(jiān)聽的字段。

3.如權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：所述數(shù)據(jù)變更機(jī)制基于CDC或者Trigger；當(dāng)異構(gòu)數(shù)據(jù)庫中某數(shù)據(jù)庫支持CDC捕獲數(shù)據(jù)變更時(shí)，所述目標(biāo)表是指該數(shù)據(jù)庫的CDC Schema表；如果異構(gòu)數(shù)據(jù)庫中某數(shù)據(jù)庫不支持CDC捕獲數(shù)據(jù)變更，則采用Trigger機(jī)制捕獲數(shù)據(jù)變更，所述目標(biāo)表為另建的用于存儲(chǔ)DML操作記錄的中間數(shù)據(jù)表。

4.如權(quán)利要求3所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：使用模塊化的數(shù)據(jù)庫CDC啟動(dòng)方案，對(duì)不屬于既定業(yè)務(wù)模塊的表不進(jìn)行CDC功能開啟。

5.如權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：所述統(tǒng)一格式為JSON格式。

6.如權(quán)利要求2所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：所述消息隊(duì)列機(jī)制采用訂閱/通知模式。

7.如權(quán)利要求6所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：所述消息隊(duì)列機(jī)制通過Exchange代理和Queue通道進(jìn)行消息的推送。

8.如權(quán)利要求6所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：用戶訂閱時(shí)設(shè)置訂閱規(guī)則，所述訂閱規(guī)則指定訂閱的源表及源表中的字段。

9.如權(quán)利要求8所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：消息推送前，根據(jù)訂閱規(guī)則將待推送消息分組為多個(gè)Collection，推送時(shí)每個(gè)Queue只負(fù)責(zé)推送一個(gè)Collection中的數(shù)據(jù)記錄，以減少消息隊(duì)列壓力。

10.如權(quán)利要求1至9任一所述的異構(gòu)數(shù)據(jù)庫變更實(shí)時(shí)通知方法，其特征在于：變更數(shù)據(jù)庫中新增變更數(shù)據(jù)后，對(duì)新增的變更數(shù)據(jù)進(jìn)行合并整理：如果新增變更數(shù)據(jù)中部分記錄所對(duì)應(yīng)的字段之間在數(shù)據(jù)庫的關(guān)系模型中存在關(guān)聯(lián)關(guān)系，則將相關(guān)聯(lián)的記錄合并為一條記錄。