[發(fā)明專利]數(shù)據(jù)遷移方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請?zhí)枺?/td>: 202210037709.3
• 申請日: 2022-01-13
• 公開（公告）號: CN114385595A
• 公開（公告）日: 2022-04-22
• 發(fā)明（設(shè)計(jì)）人: 姜雷
• 申請（專利權(quán)）人: 平安付科技服務(wù)有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/27
• 代理公司: 深圳市精英專利事務(wù)所 44242
• 代理人: 武志峰

本申請涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，揭露一種數(shù)據(jù)遷移方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)，其中方法包括將賬戶信息對應(yīng)的數(shù)據(jù)進(jìn)行打標(biāo)分庫，得到初始分庫值，并將初始分庫值分為臨時(shí)分庫值和目標(biāo)分庫值；構(gòu)建目標(biāo)分庫和臨時(shí)分庫，并構(gòu)建源端數(shù)據(jù)庫與目標(biāo)分庫之間數(shù)據(jù)鏈路；再將目標(biāo)分庫值對應(yīng)的數(shù)據(jù)從源端數(shù)據(jù)庫同步到目標(biāo)分庫中；當(dāng)檢測到賬戶號發(fā)生變更信息時(shí)，獲取變更分庫值，并將變更分庫值轉(zhuǎn)換成臨時(shí)分庫值；當(dāng)目標(biāo)分庫值對應(yīng)的數(shù)據(jù)同步完成時(shí)，將臨時(shí)數(shù)據(jù)同步到臨時(shí)分庫中。本申請還涉及區(qū)塊鏈技術(shù)，賬戶信息存儲(chǔ)于區(qū)塊鏈中。本申請避免因?yàn)榉謳鞓?biāo)記值的變動(dòng)，所造成數(shù)據(jù)遷移的出錯(cuò)，有利于提高數(shù)據(jù)遷移的可靠性。

技術(shù)領(lǐng)域

本申請涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)遷移方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

OGG軟件是一種基于數(shù)據(jù)庫日志的結(jié)構(gòu)化數(shù)據(jù)復(fù)制軟件，其能夠?qū)崿F(xiàn)數(shù)據(jù)的實(shí)時(shí)捕捉、變換和投遞，實(shí)現(xiàn)源端數(shù)據(jù)庫與目標(biāo)分庫的數(shù)據(jù)同步，保持亞秒級的數(shù)據(jù)延遲。并支持按條件對數(shù)據(jù)進(jìn)行策略遷移(按不同條件做不同遷移策略)。

基于上述特性在分庫拆分的時(shí)候可以按照不同的遷移策略將數(shù)據(jù)遷移到對應(yīng)的目標(biāo)庫中。當(dāng)前OGG僅支持對單一表進(jìn)行固定策略遷移，無法按照某一規(guī)則將整個(gè)業(yè)務(wù)域的數(shù)據(jù)進(jìn)行遷移，另外當(dāng)已遷移的數(shù)據(jù)在源庫規(guī)則條件值發(fā)生表更，OGG在應(yīng)用變更日志的時(shí)候會(huì)因?yàn)樾轮翟趯?yīng)的新庫中不存在而失敗，OGG異常終止，從而導(dǎo)致數(shù)據(jù)的遷移可靠性較低。現(xiàn)亟需一種能夠提高數(shù)據(jù)遷移可靠性的方法。

發(fā)明內(nèi)容

本申請實(shí)施例的目的在于提出一種數(shù)據(jù)遷移方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)，以提高數(shù)據(jù)遷移的可靠性。

為了解決上述技術(shù)問題，本申請實(shí)施例提供一種數(shù)據(jù)遷移方法，包括：

在源端數(shù)據(jù)庫中，基于賬戶信息，生成分庫值標(biāo)記，并根據(jù)所述分庫值標(biāo)記，將所述賬戶信息對應(yīng)的數(shù)據(jù)進(jìn)行打標(biāo)分庫，得到初始分庫值，以及將所述分庫值標(biāo)記對應(yīng)的初始分庫值作為臨時(shí)分庫值，將除所述臨時(shí)分庫值以外的分庫值對應(yīng)的初始分庫值作為目標(biāo)分庫值；

構(gòu)建所述目標(biāo)分庫值對應(yīng)的目標(biāo)分庫，以及構(gòu)建所述臨時(shí)分庫值對應(yīng)的臨時(shí)分庫，并構(gòu)建所述源端數(shù)據(jù)庫與所述目標(biāo)分庫之間數(shù)據(jù)鏈路，得到目標(biāo)數(shù)據(jù)鏈路；

根據(jù)數(shù)據(jù)同步命令，獲取所述目標(biāo)分庫值對應(yīng)的數(shù)據(jù)，并基于所述目標(biāo)數(shù)據(jù)鏈路，將所述目標(biāo)分庫值對應(yīng)的數(shù)據(jù)從所述源端數(shù)據(jù)庫同步到所述目標(biāo)分庫中；

當(dāng)檢測到所述賬戶號發(fā)生變更信息時(shí)，獲取所述賬戶號發(fā)生變更信息對應(yīng)的初始分庫值，作為變更分庫值，并將所述變更分庫值轉(zhuǎn)換成所述臨時(shí)分庫值；

當(dāng)所述目標(biāo)分庫值對應(yīng)的數(shù)據(jù)同步完成時(shí)，基于所述臨時(shí)分庫值，構(gòu)建所述源端數(shù)據(jù)庫與所述臨時(shí)分庫之間數(shù)據(jù)鏈路，得到臨時(shí)數(shù)據(jù)鏈路；

基于所述臨時(shí)數(shù)據(jù)鏈路，將所述臨時(shí)分庫值對應(yīng)的數(shù)據(jù)，從所述源端數(shù)據(jù)庫同步到所述臨時(shí)分庫中。

為了解決上述技術(shù)問題，本申請實(shí)施例提供一種數(shù)據(jù)遷移裝置，包括：

初始分庫值生成模塊，用于在源端數(shù)據(jù)庫中，基于賬戶信息，生成分庫值標(biāo)記，并根據(jù)所述分庫值標(biāo)記，將所述賬戶信息對應(yīng)的數(shù)據(jù)進(jìn)行打標(biāo)分庫，得到初始分庫值，以及將所述分庫值標(biāo)記對應(yīng)的初始分庫值作為臨時(shí)分庫值，將除所述臨時(shí)分庫值以外的分庫值對應(yīng)的初始分庫值作為目標(biāo)分庫值；

目標(biāo)數(shù)據(jù)鏈路構(gòu)建模塊，用于構(gòu)建所述目標(biāo)分庫值對應(yīng)的目標(biāo)分庫，以及構(gòu)建所述臨時(shí)分庫值對應(yīng)的臨時(shí)分庫，并構(gòu)建所述源端數(shù)據(jù)庫與所述目標(biāo)分庫之間數(shù)據(jù)鏈路，得到目標(biāo)數(shù)據(jù)鏈路；

第一數(shù)據(jù)同步模塊，用于根據(jù)數(shù)據(jù)同步命令，獲取所述目標(biāo)分庫值對應(yīng)的數(shù)據(jù)，并基于所述目標(biāo)數(shù)據(jù)鏈路，將所述目標(biāo)分庫值對應(yīng)的數(shù)據(jù)從所述源端數(shù)據(jù)庫同步到所述目標(biāo)分庫中；