[發(fā)明專利]數(shù)據(jù)庫(kù)的數(shù)據(jù)同步方法和裝置、計(jì)算機(jī)設(shè)備和介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110829482.1
• 申請(qǐng)日: 2021-07-22
• 公開(kāi)（公告）號(hào): CN113486119A
• 公開(kāi)（公告）日: 2021-10-08
• 發(fā)明（設(shè)計(jì)）人: 賀禮雄
• 申請(qǐng)（專利權(quán)）人: 京東方科技集團(tuán)股份有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/2455;G06F16/23;G06F16/22;G06F9/52
• 代理公司: 北京正理專利代理有限公司 11257
• 代理人: 付生輝

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

基于Kettle客戶端創(chuàng)建用于數(shù)據(jù)同步目標(biāo)數(shù)據(jù)庫(kù)與源數(shù)據(jù)庫(kù)的數(shù)據(jù)的可執(zhí)行文件，所述可執(zhí)行文件包括數(shù)據(jù)同步過(guò)程的流程索引；

通過(guò)容器化引擎創(chuàng)建鏡像文件，所述鏡像文件包括Kettle環(huán)境和可執(zhí)行文件；

通過(guò)所述容器化引擎啟動(dòng)所述鏡像文件并將所述可執(zhí)行文件的調(diào)用文件導(dǎo)入到所述容器化引擎中；

根據(jù)所述可執(zhí)行文件的名稱經(jīng)由瀏覽器啟動(dòng)并訪問(wèn)所述可執(zhí)行文件以完成所述目標(biāo)數(shù)據(jù)庫(kù)與源數(shù)據(jù)庫(kù)的數(shù)據(jù)同步。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)同步方法，其特征在于，所述基于Kettle客戶端創(chuàng)建用于數(shù)據(jù)同步目標(biāo)數(shù)據(jù)庫(kù)與源數(shù)據(jù)庫(kù)的數(shù)據(jù)的可執(zhí)行文件進(jìn)一步包括：

基于所述Kettle客戶端創(chuàng)建同步任務(wù)并設(shè)置所述同步任務(wù)的配置項(xiàng)，所述配置項(xiàng)包括所述可執(zhí)行文件的起始參數(shù)和變量；

設(shè)置所述同步任務(wù)的轉(zhuǎn)換流程；以及

設(shè)置所述同步任務(wù)的消息發(fā)布流程。

3.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，所述可執(zhí)行文件的變量進(jìn)一步包括：

用于同步的所述源數(shù)據(jù)庫(kù)和所述目標(biāo)數(shù)據(jù)庫(kù)的變量參數(shù)，所述變量參數(shù)包括數(shù)據(jù)庫(kù)地址、數(shù)據(jù)庫(kù)名稱、數(shù)據(jù)庫(kù)的通信端口、以及登錄數(shù)據(jù)庫(kù)的用戶名和密碼。

4.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，所述可執(zhí)行文件的起始參數(shù)進(jìn)一步包括：

所述可執(zhí)行文件的名稱；

所述可執(zhí)行文件的運(yùn)行信息，所述運(yùn)行信息包括運(yùn)行頻率，以使得在訪問(wèn)所述可執(zhí)行文件后，所述可執(zhí)行文件依照所述運(yùn)行頻率循環(huán)執(zhí)行所述可執(zhí)行文件。

5.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，所述轉(zhuǎn)換流程包括：

獲取所述源數(shù)據(jù)庫(kù)的包括表名的SQL語(yǔ)句并對(duì)其進(jìn)行字段拆分獲取表名；

通過(guò)預(yù)設(shè)置的執(zhí)行腳本根據(jù)所述表名更新所述目標(biāo)數(shù)據(jù)庫(kù)；

根據(jù)所述表名緩存所述源數(shù)據(jù)庫(kù)的表數(shù)據(jù)，并輸出至所述目標(biāo)數(shù)據(jù)庫(kù)。

6.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，所述設(shè)置所述同步任務(wù)的消息發(fā)布流程進(jìn)一步包括：

設(shè)置郵箱地址以在所述數(shù)據(jù)同步結(jié)束后通過(guò)該郵箱地址發(fā)布所述同步過(guò)程完成的通知消息。

7.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，所述根據(jù)所述可執(zhí)行文件的名稱經(jīng)由瀏覽器啟動(dòng)并訪問(wèn)所述可執(zhí)行文件以完成所述目標(biāo)數(shù)據(jù)庫(kù)與源數(shù)據(jù)庫(kù)的數(shù)據(jù)同步進(jìn)一步包括：

啟動(dòng)所述可執(zhí)行文件；

根據(jù)所述可執(zhí)行文件的流程索引讀取所述同步任務(wù)的配置項(xiàng)；

根據(jù)所述可執(zhí)行文件的流程索引執(zhí)行所述同步任務(wù)的轉(zhuǎn)換流程；

根據(jù)所述可執(zhí)行文件的流程索引執(zhí)行所述同步任務(wù)的消息發(fā)布流程。

8.根據(jù)權(quán)利要求7所述的數(shù)據(jù)同步方法，其特征在于，

所述根據(jù)所述可執(zhí)行文件的流程索引執(zhí)行所述同步任務(wù)的轉(zhuǎn)換流程進(jìn)一步包括：

根據(jù)所述源數(shù)據(jù)庫(kù)的名稱獲取數(shù)據(jù)庫(kù)的模式名和表名；

根據(jù)所述模式名使所述目標(biāo)數(shù)據(jù)庫(kù)判斷其是否存在所述模式名，若不存在則創(chuàng)建所述模式名；

根據(jù)所述表名獲取每個(gè)模式名的表對(duì)應(yīng)的執(zhí)行腳本；

向所述目標(biāo)數(shù)據(jù)庫(kù)發(fā)送所述執(zhí)行腳本以使所述目標(biāo)數(shù)據(jù)庫(kù)運(yùn)行所述執(zhí)行腳本后刪除其中的所述表并重新創(chuàng)建表；

根據(jù)每個(gè)表的表名獲取并緩存所述表數(shù)據(jù)并將所述表數(shù)據(jù)輸出至所述目標(biāo)數(shù)據(jù)庫(kù)。

9.根據(jù)權(quán)利要求1-8中任一項(xiàng)所述的數(shù)據(jù)同步方法，其特征在于，所述源數(shù)據(jù)庫(kù)和所述目標(biāo)數(shù)據(jù)庫(kù)為關(guān)系型數(shù)據(jù)庫(kù)。

10.根據(jù)權(quán)利要求9所述的數(shù)據(jù)同步方法，其特征在于，所述容器化引擎為Docker。