[發(fā)明專利]一種跨數(shù)據(jù)庫增量同步數(shù)據(jù)的方法

在審

• 申請?zhí)枺?/td>: 202010968271.1
• 申請日: 2020-09-15
• 公開（公告）號: CN112231396A
• 公開（公告）日: 2021-01-15
• 發(fā)明（設(shè)計）人: 王守金
• 申請（專利權(quán)）人: 山東浪潮通軟信息科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/242;G06F16/23
• 代理公司: 北京君慧知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11716
• 代理人: 董延麗

本申請公開了一種跨數(shù)據(jù)庫增量同步數(shù)據(jù)的方法，包括：根據(jù)源數(shù)據(jù)庫與目標數(shù)據(jù)庫建立配置文件，根據(jù)所述配置文件在所述源數(shù)據(jù)庫中生成數(shù)據(jù)同步日志表；根據(jù)所述數(shù)據(jù)同步日志表判斷所述源數(shù)據(jù)庫中變化的數(shù)據(jù)，生成SQL語句，所述SQL語句包括：DELETE語句、UPDATE語句、INSERT語句；在所述目標數(shù)據(jù)庫中執(zhí)行所述SQL語句，將所述源數(shù)據(jù)庫中變化的數(shù)據(jù)同步到所述目標數(shù)據(jù)庫中。

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

本申請涉及計算機技術(shù)領(lǐng)域，尤其涉及一種跨數(shù)據(jù)庫增量同步數(shù)據(jù)的方法。

背景技術(shù)

在信息化社會，充分有效地管理和利用各類信息資源，是進行科學研究和決策管理的前提條件。數(shù)據(jù)庫是管理信息系統(tǒng)、企業(yè)經(jīng)營系統(tǒng)等信息系統(tǒng)的核心部分，是企業(yè)進行經(jīng)營管理的重要部分。數(shù)據(jù)庫的種類繁多，企業(yè)經(jīng)營中使用的各種信息系統(tǒng)可能使用不同類型的數(shù)據(jù)庫，為了充分利用各個信息系統(tǒng)的數(shù)據(jù)，實現(xiàn)數(shù)據(jù)共享，可能需要在各個不同類型的數(shù)據(jù)庫之間進行數(shù)據(jù)的同步。

在現(xiàn)有技術(shù)中，數(shù)據(jù)庫同步主要有兩種方式：全量同步和增量同步，目前在各種不同數(shù)據(jù)庫之間進行數(shù)據(jù)的同步，主要方法是把源數(shù)據(jù)庫中的數(shù)據(jù)讀取到內(nèi)存，再把內(nèi)存中的數(shù)據(jù)傳輸?shù)侥繕藬?shù)據(jù)庫進行更新。

這種全量同步的方式使用數(shù)據(jù)庫的整表數(shù)據(jù)進行傳輸，網(wǎng)絡(luò)流量占用太大，數(shù)據(jù)傳輸速度慢且效率低。

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

本發(fā)明提供了一種跨數(shù)據(jù)庫增量同步數(shù)據(jù)的方法，解決了不同類型數(shù)據(jù)庫之間數(shù)據(jù)快速同步的技術(shù)問題。

一種跨數(shù)據(jù)庫增量同步數(shù)據(jù)的方法，其特征在于，包括：

根據(jù)源數(shù)據(jù)庫與目標數(shù)據(jù)庫建立配置文件，根據(jù)所述配置文件在所述源數(shù)據(jù)庫中生成數(shù)據(jù)同步日志表；

根據(jù)所述數(shù)據(jù)同步日志表判斷所述源數(shù)據(jù)庫中變化的數(shù)據(jù)，生成SQL語句，所述SQL語句包括：DELETE語句、UPDATE語句、INSERT語句；

在所述目標數(shù)據(jù)庫中執(zhí)行所述SQL語句，將所述源數(shù)據(jù)庫中變化的數(shù)據(jù)同步到所述目標數(shù)據(jù)庫中。

可選地，所述配置文件，具體包括：所述配置文件中記錄所述源數(shù)據(jù)庫和所述目標數(shù)據(jù)庫的參數(shù)信息；

其中，所述源數(shù)據(jù)庫和所述目標數(shù)據(jù)庫的參數(shù)信息包括：

所述源數(shù)據(jù)庫和所述目標數(shù)據(jù)庫的數(shù)據(jù)庫類型、數(shù)據(jù)庫服務(wù)名、數(shù)據(jù)庫名稱、登錄用戶和口令、表名、主鍵、字段名、字段類型及長度。

可選地，在源數(shù)據(jù)庫中生成數(shù)據(jù)同步日志表之前，讀取所述配置文件中的所述源數(shù)據(jù)庫的數(shù)據(jù)庫類型、數(shù)據(jù)庫服務(wù)名、數(shù)據(jù)庫名稱、登錄用戶和口令，登錄所述源數(shù)據(jù)庫。

可選地，在源數(shù)據(jù)庫中生成數(shù)據(jù)同步日志表，具體包括：讀取所述配置文件中所述源數(shù)據(jù)庫的表名、主鍵、字段名、字段類型及長度信息，根據(jù)此信息在源數(shù)據(jù)庫中建立數(shù)據(jù)同步日志表；

所述源數(shù)據(jù)庫中的每個表建立一個對應(yīng)的數(shù)據(jù)同步日志表，用于記錄并更新同步數(shù)據(jù)。

可選地，生成DELETE語句，具體包括：

根據(jù)所述源數(shù)據(jù)庫中各個表的主鍵判斷需要刪除的數(shù)據(jù)，生成DELETE語句。

可選地，生成UPDATE語句，具體包括：根據(jù)所述源數(shù)據(jù)庫中各個表的主鍵及其他字段判斷需要更新的數(shù)據(jù)，生成UPDATE語句。

可選地，生成INSERT語句，具體包括：根據(jù)各表的主鍵及其他字段判斷需要新增的數(shù)據(jù)，生成INSERT語句。

可選地，生成所述SQL語句的順序按照DELETE語句、UPDATE語句、INSERT語句的順序依次生成。

可選地，在執(zhí)行所述SQL語句之前，讀取配置文件中的所述目標數(shù)據(jù)庫的數(shù)據(jù)庫類型、數(shù)據(jù)庫服務(wù)名、數(shù)據(jù)庫名稱、登錄用戶和口令，登錄所述目標數(shù)據(jù)庫。