[發(fā)明專利]更新消息處理方法、數(shù)據(jù)同步方法、配置信息配置方法

有效

• 申請(qǐng)?zhí)枺?/td>: 202110952805.6
• 申請(qǐng)日: 2021-08-19
• 公開(kāi)（公告）號(hào): CN113407560B
• 公開(kāi)（公告）日: 2021-11-05
• 發(fā)明（設(shè)計(jì)）人: 楊永興
• 申請(qǐng)（專利權(quán)）人: 太平金融科技服務(wù)（上海）有限公司深圳分公司
• 主分類號(hào): G06F16/23
• 分類號(hào): G06F16/23;G06F16/28
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 姜曉云

本申請(qǐng)涉及一種更新消息處理方法、數(shù)據(jù)同步方法、配置信息配置方法。數(shù)據(jù)庫(kù)更新消息處理方法包括：獲取第一數(shù)據(jù)庫(kù)的數(shù)據(jù)更新消息，所述數(shù)據(jù)更新消息攜帶有數(shù)據(jù)表標(biāo)識(shí)；查詢預(yù)先配置的配置信息以獲得與所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的更新標(biāo)識(shí)；判斷是否已存在與所述更新標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)更新消息；當(dāng)已存在與所述更新標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)更新消息，刪除所述數(shù)據(jù)更新消息。采用本方法能夠避免數(shù)據(jù)更新消息重復(fù)所造成的重復(fù)操作，降低資源利用率，提高處理效率。

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

本申請(qǐng)涉及數(shù)據(jù)庫(kù)技術(shù)領(lǐng)域，特別是涉及一種更新消息處理方法、數(shù)據(jù)同步方法、配置信息配置方法。

背景技術(shù)

隨著線上化的應(yīng)用越來(lái)越廣泛，導(dǎo)致數(shù)據(jù)量暴增，海量數(shù)據(jù)搜索及跨數(shù)據(jù)源結(jié)合查詢的應(yīng)用場(chǎng)景越來(lái)越多。傳統(tǒng)關(guān)系型數(shù)據(jù)庫(kù)的查詢性能相對(duì)較差、靈活性不足，需要使用一些可擴(kuò)展、高性能的新型數(shù)據(jù)庫(kù)做補(bǔ)充。

傳統(tǒng)技術(shù)中，通過(guò)將傳統(tǒng)關(guān)系型數(shù)據(jù)庫(kù)的數(shù)據(jù)同步到新型數(shù)據(jù)庫(kù)中，這樣搜索時(shí)直接從新型數(shù)據(jù)庫(kù)進(jìn)行搜索。

然而，目前在數(shù)據(jù)庫(kù)之間進(jìn)行消息同步時(shí)，一個(gè)數(shù)據(jù)庫(kù)中的數(shù)據(jù)發(fā)生更新，需要及時(shí)同步到另外一個(gè)數(shù)據(jù)庫(kù)中，但是一個(gè)數(shù)據(jù)庫(kù)中的同一個(gè)數(shù)據(jù)可能存在不同的數(shù)據(jù)表中，即一個(gè)數(shù)據(jù)模型中包括多個(gè)關(guān)聯(lián)的數(shù)據(jù)表，當(dāng)對(duì)數(shù)據(jù)進(jìn)行更新時(shí)，多個(gè)數(shù)據(jù)表一起更新，從而另外一個(gè)數(shù)據(jù)庫(kù)針對(duì)該數(shù)據(jù)庫(kù)的一次更新可能需要進(jìn)行多次同步，造成重復(fù)無(wú)價(jià)值的處理，降低系統(tǒng)性能。

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

基于此，有必要針對(duì)上述技術(shù)問(wèn)題，提供一種能夠避免數(shù)據(jù)更新消息重復(fù)所造成的重復(fù)操作，降低資源利用率，提高處理效率的更新消息處理方法、數(shù)據(jù)同步方法、配置信息配置方法。

一種數(shù)據(jù)庫(kù)更新消息處理方法，所述數(shù)據(jù)庫(kù)更新消息處理方法包括：

獲取第一數(shù)據(jù)庫(kù)的數(shù)據(jù)更新消息，所述數(shù)據(jù)更新消息攜帶有數(shù)據(jù)表標(biāo)識(shí)；

查詢預(yù)先配置的配置信息以獲得與所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的更新標(biāo)識(shí)；

判斷是否已存在與所述更新標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)更新消息；

當(dāng)已存在與所述更新標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)更新消息，刪除所述數(shù)據(jù)更新消息。

在其中一個(gè)實(shí)施例中，所述查詢預(yù)先配置的配置信息以獲得與所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的更新標(biāo)識(shí)，包括：

查詢預(yù)先配置的配置信息中是否存在所述數(shù)據(jù)表標(biāo)識(shí)；

當(dāng)存在所述數(shù)據(jù)表標(biāo)識(shí)時(shí)，獲取預(yù)先配置的配置信息中與所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)模型標(biāo)識(shí)；

根據(jù)預(yù)先配置的配置信息確定所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)表是否為主表；

當(dāng)所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)表為主表時(shí)，根據(jù)所述數(shù)據(jù)模型標(biāo)識(shí)和所述主表的主鍵值生成更新標(biāo)識(shí)；

當(dāng)所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)表為從表時(shí)，根據(jù)所述數(shù)據(jù)模型標(biāo)識(shí)和所述從表的外鍵值生成更新標(biāo)識(shí)。

在其中一個(gè)實(shí)施例中，所述判斷是否已存在與所述更新標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)更新消息之后，還包括：

當(dāng)不存在與所述更新標(biāo)識(shí)對(duì)應(yīng)的數(shù)據(jù)更新消息，建立所述數(shù)據(jù)更新消息與所述更新標(biāo)識(shí)的對(duì)應(yīng)關(guān)系。

在其中一個(gè)實(shí)施例中，所述建立所述數(shù)據(jù)更新消息與所述更新標(biāo)識(shí)的對(duì)應(yīng)關(guān)系，包括：

獲取預(yù)先配置的配置信息中與所述數(shù)據(jù)表標(biāo)識(shí)對(duì)應(yīng)的更新標(biāo)識(shí)有效時(shí)間；

根據(jù)所述更新標(biāo)識(shí)有效時(shí)間建立所述數(shù)據(jù)更新消息與所述更新標(biāo)識(shí)的對(duì)應(yīng)關(guān)系。

一種數(shù)據(jù)同步方法，所述數(shù)據(jù)同步方法包括：

獲取根據(jù)上述任意一個(gè)實(shí)施例中的數(shù)據(jù)庫(kù)更新消息處理方法所得到的數(shù)據(jù)更新消息；

根據(jù)所述數(shù)據(jù)更新消息從第一數(shù)據(jù)庫(kù)獲取更新數(shù)據(jù)；