[發(fā)明專利]數(shù)據(jù)庫(kù)同步方法、系統(tǒng)、裝置、電子設(shè)備及介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110379979.8
• 申請(qǐng)日: 2021-04-08
• 公開（公告）號(hào): CN113094434A
• 公開（公告）日: 2021-07-09
• 發(fā)明（設(shè)計(jì)）人: 陳磊;陳雪峰
• 申請(qǐng)（專利權(quán)）人: 中國(guó)工商銀行股份有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/23;G06F16/242;G06F16/2455
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 趙婷

本公開提供了一種數(shù)據(jù)庫(kù)同步方法，屬于數(shù)據(jù)庫(kù)技術(shù)領(lǐng)域。該方法包括：響應(yīng)于M個(gè)數(shù)據(jù)庫(kù)中的任意一個(gè)數(shù)據(jù)庫(kù)接收到數(shù)據(jù)操作的用戶請(qǐng)求，獲取用戶請(qǐng)求；基于用戶請(qǐng)求，得到數(shù)據(jù)同步消息，其中，數(shù)據(jù)同步消息包括用于指示用戶請(qǐng)求所操作的數(shù)據(jù)的標(biāo)識(shí)信息、以及用于指示數(shù)據(jù)在數(shù)據(jù)庫(kù)之間的同步方向的方向信息；將數(shù)據(jù)同步消息推送到分布式消息隊(duì)列；從分布式消息隊(duì)列中訂閱數(shù)據(jù)同步消息；以及在訂閱到數(shù)據(jù)同步消息后，從方向信息所指示的源數(shù)據(jù)庫(kù)中獲取由標(biāo)識(shí)信息所指示的完整數(shù)據(jù)，并將完整數(shù)據(jù)寫入方向信息指示的目標(biāo)數(shù)據(jù)庫(kù)。本公開還提供了一種數(shù)據(jù)庫(kù)同步系統(tǒng)及裝置、電子設(shè)備、以及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

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

本公開屬于數(shù)據(jù)庫(kù)技術(shù)領(lǐng)域，更具體地，涉及一種數(shù)據(jù)庫(kù)同步方法、系統(tǒng)、裝置、電子設(shè)備及介質(zhì)。

背景技術(shù)

在系統(tǒng)進(jìn)行技術(shù)轉(zhuǎn)型需要更換數(shù)據(jù)庫(kù)等諸多場(chǎng)景下，一般會(huì)進(jìn)行兩套或多套集群并行運(yùn)行。其中，不同集群的數(shù)據(jù)庫(kù)間需要進(jìn)行準(zhǔn)實(shí)時(shí)數(shù)據(jù)同步，以滿足并行期間該兩套或多套集群上的用戶之間的數(shù)據(jù)能相互交互，且當(dāng)用戶從一個(gè)集群切換到另一個(gè)集群使用時(shí)，能保證業(yè)務(wù)的連續(xù)性。

在相關(guān)技術(shù)中，各類數(shù)據(jù)庫(kù)基本都有各自的數(shù)據(jù)同步機(jī)制，但一般都依賴數(shù)據(jù)庫(kù)本身的核心技術(shù)，僅局限于同構(gòu)數(shù)據(jù)庫(kù)之間或少部分?jǐn)?shù)據(jù)庫(kù)之間相互同步。當(dāng)需要數(shù)據(jù)同步的集群的數(shù)據(jù)庫(kù)為異構(gòu)數(shù)據(jù)庫(kù)時(shí)，往往要源數(shù)據(jù)庫(kù)將要同步的數(shù)據(jù)導(dǎo)出成文件，然后通過(guò)一定的外部工具將文件傳輸至目標(biāo)數(shù)據(jù)庫(kù)的所在服務(wù)器再加工導(dǎo)入。整個(gè)過(guò)程存在處理時(shí)效低、且較難處理多表之間的關(guān)系等問題。

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

有鑒于此，本公開實(shí)施例提供了一種數(shù)據(jù)庫(kù)同步方法、系統(tǒng)及裝置、一種電子設(shè)備、以及一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

本公開實(shí)施例的一個(gè)方面提供了一種數(shù)據(jù)庫(kù)同步方法。所述方法包括：響應(yīng)于M個(gè)數(shù)據(jù)庫(kù)中的任意一個(gè)數(shù)據(jù)庫(kù)接收到數(shù)據(jù)操作的用戶請(qǐng)求，獲取所述用戶請(qǐng)求，其中M為大于或等于1的整數(shù)；基于所述用戶請(qǐng)求，得到數(shù)據(jù)同步消息，其中，所述數(shù)據(jù)同步消息包括用于指示所述用戶請(qǐng)求所操作的數(shù)據(jù)的標(biāo)識(shí)信息、以及用于指示數(shù)據(jù)在數(shù)據(jù)庫(kù)之間的同步方向的方向信息；將所述數(shù)據(jù)同步消息推送到分布式消息隊(duì)列；從所述分布式消息隊(duì)列中訂閱所述數(shù)據(jù)同步消息；以及在訂閱到所述數(shù)據(jù)同步消息后，從所述方向信息所指示的源數(shù)據(jù)庫(kù)中獲取所述標(biāo)識(shí)信息所指示的完整數(shù)據(jù)，并將所述完整數(shù)據(jù)寫入所述方向信息所指示的目標(biāo)數(shù)據(jù)庫(kù)。

根據(jù)本公開的實(shí)施例，所述響應(yīng)于M個(gè)數(shù)據(jù)庫(kù)中的任意一個(gè)數(shù)據(jù)庫(kù)接收到數(shù)據(jù)操作的用戶請(qǐng)求，獲取所述用戶請(qǐng)求包括：響應(yīng)于接收到所述用戶請(qǐng)求，識(shí)別所述用戶請(qǐng)求中的交易名稱，所述交易名稱用于指示所述用戶請(qǐng)求所執(zhí)行的業(yè)務(wù)功能；以及在所述交易名稱屬于預(yù)設(shè)的交易名稱集合時(shí)，獲取所述用戶請(qǐng)求，其中，所述交易名稱集合為預(yù)設(shè)的需要進(jìn)行數(shù)據(jù)同步的交易名稱的集合。

根據(jù)本公開的實(shí)施例，所述數(shù)據(jù)同步消息還包括所述交易名稱。其中，所述基于所述用戶請(qǐng)求，得到數(shù)據(jù)同步消息包括：從所述用戶請(qǐng)求中提取所述交易名稱以及所述標(biāo)識(shí)信息；根據(jù)對(duì)所述用戶請(qǐng)求所操作的數(shù)據(jù)庫(kù)的數(shù)據(jù)同步配置，得到所述方向信息；以及將所述交易名稱、所述標(biāo)識(shí)信息、以及所述方向信息封裝得到所述數(shù)據(jù)同步消息。

根據(jù)本公開的實(shí)施例，所述從所述方向信息所指示的源數(shù)據(jù)庫(kù)中獲取所述標(biāo)識(shí)信息所指示的完整數(shù)據(jù)包括：獲取所述交易名稱所指示的交易涉及的N個(gè)數(shù)據(jù)表的信息；從所述源數(shù)據(jù)庫(kù)中的N個(gè)所述數(shù)據(jù)表中查詢數(shù)據(jù)，以得到所述完整數(shù)據(jù)，具體包括：利用從所述源數(shù)據(jù)庫(kù)中的每個(gè)所述數(shù)據(jù)表中獲取數(shù)據(jù)操縱結(jié)果的查詢語(yǔ)句，從所述源數(shù)據(jù)庫(kù)中的每個(gè)所述數(shù)據(jù)表中獲取所述標(biāo)識(shí)信息所指示的數(shù)據(jù)，得到每個(gè)所述數(shù)據(jù)表對(duì)應(yīng)的局部數(shù)據(jù)，其中，N個(gè)所述數(shù)據(jù)表對(duì)應(yīng)得到N個(gè)所述局部數(shù)據(jù)；以及將所述N個(gè)局部數(shù)據(jù)的合并，得到所述完整數(shù)據(jù)。