[發(fā)明專利]一種異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)方法及裝置

有效

• 申請?zhí)枺?/td>: 201910510663.0
• 申請日: 2019-06-13
• 公開（公告）號: CN110347746B
• 公開（公告）日: 2020-06-26
• 發(fā)明（設(shè)計(jì)）人: 付銓;孫峰;余院蘭;趙家威
• 申請（專利權(quán)）人: 武漢達(dá)夢數(shù)據(jù)庫有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23
• 代理公司: 武漢智嘉聯(lián)合知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 42231
• 代理人: 黃君軍

1.一種異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)方法，其特征在于，包括以下步驟：

在目標(biāo)端數(shù)據(jù)庫建立提交事務(wù)表，在所述提交事務(wù)表中記錄同步的源庫事務(wù)信息；

捕獲并解析源端數(shù)據(jù)庫的源端事務(wù)日志；

捕獲并解析目標(biāo)端數(shù)據(jù)庫的目標(biāo)端事務(wù)日志；

將所述目標(biāo)端事務(wù)日志發(fā)送至源端數(shù)據(jù)同步校驗(yàn)服務(wù)；

根據(jù)所述同步的源庫事務(wù)信息對比所述源端事務(wù)日志與所述目標(biāo)端事務(wù)日志，校驗(yàn)同步數(shù)據(jù)的一致性；

在所述提交事務(wù)表中記錄同步的源庫事務(wù)信息，具體為：

以事務(wù)為最小同步單位，在同步事務(wù)的最后增加插入所述提交事務(wù)表的插入操作；

目標(biāo)端數(shù)據(jù)庫提交一個所述同步事務(wù)時，在所述提交事務(wù)表中插入一行提交事務(wù)記錄；

所述源庫事務(wù)信息包括事務(wù)ID、事務(wù)起始SCN以及事務(wù)提交SCN，所述提交事務(wù)表記錄的事務(wù)ID為源端數(shù)據(jù)庫的事務(wù)ID；

根據(jù)所述同步的源庫事務(wù)信息對比所述源端事務(wù)日志與所述目標(biāo)端事務(wù)日志，校驗(yàn)同步數(shù)據(jù)的一致性，具體為：

對比所述提交事務(wù)表記錄的事務(wù)ID與所述源端事務(wù)日志捕獲的事務(wù)ID，匹配事務(wù)ID相同的源端事務(wù)日志中同步事務(wù)和目標(biāo)端事務(wù)日志中同步事務(wù)，校驗(yàn)匹配的同步事務(wù)中各個操作的一致性。

2.根據(jù)權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)方法，其特征在于，所述提交事務(wù)表還用于記錄同步斷點(diǎn)信息。

3.根據(jù)權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)方法，其特征在于，捕獲并解析源端數(shù)據(jù)庫的源端事務(wù)日志，具體為：

以事務(wù)為單位，將同一同步事務(wù)的所有操作進(jìn)行緩存。

4.根據(jù)權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)方法，其特征在于，捕獲并解析目標(biāo)端數(shù)據(jù)庫的目標(biāo)端事務(wù)日志，具體包括：

提取所述提交事務(wù)表的事務(wù)日志，提取出所述提交事務(wù)表記錄的事務(wù)ID。

5.根據(jù)權(quán)利要求1所述的異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)方法，其特征在于，校驗(yàn)匹配的同步事務(wù)中各個操作的一致性，具體為：

計(jì)算同步事務(wù)中各個操作的MD5值，根據(jù)MD5值對同步事務(wù)中各個操作進(jìn)行比較。

6.一種異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)裝置，其特征在于，包括源端服務(wù)器和目標(biāo)端服務(wù)器；所述源端服務(wù)器內(nèi)部署有源端對比程序，所述目標(biāo)端服務(wù)器內(nèi)部署有目標(biāo)端對比程序；

所述目標(biāo)端服務(wù)器用于建立提交事務(wù)表，在所述提交事務(wù)表中記錄同步的源庫事務(wù)信息；

所述源端對比程序用于捕獲并解析源端數(shù)據(jù)庫的源端事務(wù)日志；

所述目標(biāo)端對比程序用于捕獲并解析目標(biāo)端數(shù)據(jù)庫的目標(biāo)端事務(wù)日志；將所述目標(biāo)端事務(wù)日志發(fā)送至源端數(shù)據(jù)同步校驗(yàn)服務(wù)；

所述源端對比程序還用于根據(jù)所述同步的源庫事務(wù)信息對比所述源端事務(wù)日志與所述目標(biāo)端事務(wù)日志，校驗(yàn)同步數(shù)據(jù)的一致性；

在所述提交事務(wù)表中記錄同步的源庫事務(wù)信息，具體為：

以事務(wù)為最小同步單位，在同步事務(wù)的最后增加插入所述提交事務(wù)表的插入操作；

目標(biāo)端數(shù)據(jù)庫提交一個所述同步事務(wù)時，在所述提交事務(wù)表中插入一行提交事務(wù)記錄；

所述源庫事務(wù)信息包括事務(wù)ID、事務(wù)起始SCN以及事務(wù)提交SCN，所述提交事務(wù)表記錄的事務(wù)ID為源端數(shù)據(jù)庫的事務(wù)ID；

根據(jù)所述同步的源庫事務(wù)信息對比所述源端事務(wù)日志與所述目標(biāo)端事務(wù)日志，校驗(yàn)同步數(shù)據(jù)的一致性，具體為：

對比所述提交事務(wù)表記錄的事務(wù)ID與所述源端事務(wù)日志捕獲的事務(wù)ID，匹配事務(wù)ID相同的源端事務(wù)日志中同步事務(wù)和目標(biāo)端事務(wù)日志中同步事務(wù)，校驗(yàn)匹配的同步事務(wù)中各個操作的一致性。

7.根據(jù)權(quán)利要求6所述的異構(gòu)數(shù)據(jù)庫同步數(shù)據(jù)一致性校驗(yàn)裝置，其特征在于，所述源端對比程序包括源端日志捕獲模塊、源端日志分析模塊、源端日志接收模塊以及日志對比模塊；所述源端日志捕獲模塊用于捕獲源端數(shù)據(jù)庫的源端事務(wù)日志，所述源端日志分析模塊用于解析源端數(shù)據(jù)庫的源端事務(wù)日志，所述源端日志接收模塊用于接收所述目標(biāo)端發(fā)送模塊發(fā)送的所述目標(biāo)端事務(wù)日志，所述日志對比模塊用于根據(jù)所述同步的源庫事務(wù)信息對比所述源端事務(wù)日志與所述目標(biāo)端事務(wù)日志，校驗(yàn)同步數(shù)據(jù)的一致性；

所述目標(biāo)端對比程序包括目標(biāo)端日志捕獲模塊、目標(biāo)端日志分析模塊以及目標(biāo)端日志發(fā)送模塊；所述目標(biāo)端日志捕獲模塊用于捕獲目標(biāo)端數(shù)據(jù)庫的目標(biāo)端事務(wù)日志，所述目標(biāo)端分析模塊用于解析目標(biāo)端數(shù)據(jù)庫的目標(biāo)端事務(wù)日志，所述目標(biāo)端發(fā)送模塊用于發(fā)送所述目標(biāo)端事務(wù)日志至所述源端日志接收模塊。