[發(fā)明專利]數(shù)據(jù)校驗(yàn)方法、裝置、電子設(shè)備以及可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010581955.6
• 申請(qǐng)日: 2020-06-23
• 公開(kāi)（公告）號(hào): CN111737230A
• 公開(kāi)（公告）日: 2020-10-02
• 發(fā)明（設(shè)計(jì)）人: 朱博帥
• 申請(qǐng)（專利權(quán)）人: 北京奇藝世紀(jì)科技有限公司
• 主分類(lèi)號(hào): G06F16/21
• 分類(lèi)號(hào): G06F16/21;G06F16/23;G06F16/27
• 代理公司: 北京潤(rùn)澤恒知識(shí)產(chǎn)權(quán)代理有限公司 11319
• 代理人: 呂俊秀

1.一種數(shù)據(jù)校驗(yàn)方法，其特征在于，所述方法包括：

在源端數(shù)據(jù)庫(kù)和目標(biāo)端數(shù)據(jù)庫(kù)之間進(jìn)行數(shù)據(jù)遷移或數(shù)據(jù)同步期間，根據(jù)待校驗(yàn)數(shù)據(jù)行的索引信息，從所述源端數(shù)據(jù)庫(kù)中獲取所述索引信息對(duì)應(yīng)的源端數(shù)據(jù)行，并從所述目標(biāo)端數(shù)據(jù)庫(kù)中獲取所述索引信息對(duì)應(yīng)的目標(biāo)端數(shù)據(jù)行；

在獲取到所述源端數(shù)據(jù)行和所述目標(biāo)端數(shù)據(jù)行的情況下，對(duì)所述源端數(shù)據(jù)行和所述目標(biāo)端數(shù)據(jù)行進(jìn)行比較，以判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)；

在所述待校驗(yàn)數(shù)據(jù)行未通過(guò)一致性校驗(yàn)的情況下，等待指定時(shí)長(zhǎng)后，重新獲取所述索引信息對(duì)應(yīng)的源端數(shù)據(jù)行和目標(biāo)端數(shù)據(jù)行，并根據(jù)重新獲取的源端數(shù)據(jù)行和目標(biāo)端數(shù)據(jù)行，再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，對(duì)所述等待指定時(shí)長(zhǎng)后，重新獲取所述索引信息對(duì)應(yīng)的源端數(shù)據(jù)行和目標(biāo)端數(shù)據(jù)行，并根據(jù)重新獲取的源端數(shù)據(jù)行和目標(biāo)端數(shù)據(jù)行，再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)的步驟重復(fù)執(zhí)行多次，直至一致性校驗(yàn)通過(guò)或者直至重復(fù)次數(shù)達(dá)到次數(shù)閾值為止。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在所述重復(fù)次數(shù)達(dá)到所述次數(shù)閾值之后，所述方法還包括：

按照獲取的先后順序，對(duì)先后獲取到的多個(gè)源端數(shù)據(jù)行進(jìn)行排序，獲得第一源端數(shù)據(jù)行序列；

按照獲取的先后順序，對(duì)先后獲取到的多個(gè)目標(biāo)端數(shù)據(jù)行進(jìn)行排序，獲得第一目標(biāo)端數(shù)據(jù)行序列；

將所述第一源端數(shù)據(jù)行序列與所述第一目標(biāo)端數(shù)據(jù)行序列進(jìn)行比較，以再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述將所述第一源端數(shù)據(jù)行序列與所述第一目標(biāo)端數(shù)據(jù)行序列進(jìn)行比較，以再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)的步驟，包括：

將所述第一源端數(shù)據(jù)行序列與所述第一目標(biāo)端數(shù)據(jù)行序列進(jìn)行錯(cuò)位配對(duì)，獲得一對(duì)或多對(duì)數(shù)據(jù)行，其中，每對(duì)數(shù)據(jù)行中包括一個(gè)源端數(shù)據(jù)行和一個(gè)目標(biāo)端數(shù)據(jù)行；

對(duì)每對(duì)數(shù)據(jù)行中的源端數(shù)據(jù)行和目標(biāo)端數(shù)據(jù)行進(jìn)行比較，獲得每對(duì)數(shù)據(jù)行各自對(duì)應(yīng)的比較結(jié)果；

根據(jù)所獲得的比較結(jié)果，再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，在經(jīng)過(guò)所述第一源端數(shù)據(jù)行序列與所述第一目標(biāo)端數(shù)據(jù)行序列的比較，確定所述待校驗(yàn)數(shù)據(jù)行未通過(guò)一致性校驗(yàn)的情況下，所述方法還包括：

從所述源端數(shù)據(jù)庫(kù)的日志記錄中，獲取針對(duì)所述索引信息對(duì)應(yīng)的源端數(shù)據(jù)行的第一近期操作記錄；

從所述目標(biāo)端數(shù)據(jù)庫(kù)的日志記錄中，獲取針對(duì)所述索引信息對(duì)應(yīng)的目標(biāo)端數(shù)據(jù)行的第二近期操作記錄；

根據(jù)所述第一近期操作記錄和所述第二近期操作記錄，再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述根據(jù)所述第一近期操作記錄和所述第二近期操作記錄，再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)的步驟，包括：

根據(jù)所述第一近期操作記錄，確定針對(duì)源端數(shù)據(jù)行的多次歷史操作，并獲得每次歷史操作后更新的源端數(shù)據(jù)行；

按照更新的先后順序，對(duì)獲得的多個(gè)源端數(shù)據(jù)行進(jìn)行排序，獲得第二源端數(shù)據(jù)行序列；

根據(jù)所述第二近期操作記錄，確定針對(duì)目標(biāo)端數(shù)據(jù)行的多次歷史操作，并獲得每次歷史操作后更新的目標(biāo)端數(shù)據(jù)行；

按照更新的先后順序，對(duì)獲得的多個(gè)目標(biāo)端數(shù)據(jù)行進(jìn)行排序，獲得第二目標(biāo)端數(shù)據(jù)行序列；

將所述第二源端數(shù)據(jù)行序列與所述第二目標(biāo)端數(shù)據(jù)行序列進(jìn)行錯(cuò)位比較，以再次判斷所述待校驗(yàn)數(shù)據(jù)行是否通過(guò)一致性校驗(yàn)。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

在獲取到所述源端數(shù)據(jù)行，但未獲取到所述目標(biāo)端數(shù)據(jù)行的情況下，等待指定時(shí)長(zhǎng)后，重新獲取所述索引信息對(duì)應(yīng)的目標(biāo)端數(shù)據(jù)行；

在重新獲取到所述索引信息對(duì)應(yīng)的目標(biāo)端數(shù)據(jù)行的情況下，將所述重新獲取到的目標(biāo)端數(shù)據(jù)行與已經(jīng)獲取到的源端數(shù)據(jù)行進(jìn)行比較；

在所述重新獲取到的目標(biāo)端數(shù)據(jù)行與已經(jīng)獲取到的源端數(shù)據(jù)行相一致的情況下，確定所述待校驗(yàn)數(shù)據(jù)行通過(guò)一致性校驗(yàn)。