[發(fā)明專利]基于數(shù)據(jù)庫表的時效同步方法及裝置

有效

• 申請?zhí)枺?/td>: 202010540923.1
• 申請日: 2020-06-15
• 公開（公告）號: CN111737348B
• 公開（公告）日: 2023-10-10
• 發(fā)明（設(shè)計(jì)）人: 歐喜菊;朱樂和
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 王濤;湯在彥

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

生成表級同步配置表以及表級同步日志表；

根據(jù)所述表級同步配置表以及所述表級同步日志表配置同步表；

源數(shù)據(jù)庫根據(jù)所述同步表進(jìn)行同步數(shù)據(jù)讀操作；

目標(biāo)數(shù)據(jù)庫根據(jù)所述同步表進(jìn)行同步數(shù)據(jù)寫操作；

根據(jù)所述表級同步配置表以及所述表級同步日志表監(jiān)控多個數(shù)據(jù)庫的數(shù)據(jù)同步狀態(tài)。

2.根據(jù)權(quán)利要求1所述的時效同步方法，其特征在于，生成所述表級同步日志表的步驟包括：

根據(jù)同步信息屬性生成所述表級同步日志表，所述同步信息屬性包括：同步表名、表所屬、源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識、目標(biāo)結(jié)點(diǎn)、同步序列號、同步狀態(tài)、同步開始時間戳、同步完成時間戳、同步讀記錄數(shù)以及同步寫記錄數(shù)；

生成所述表級同步配置表的步驟包括：

根據(jù)同步配置表參數(shù)屬性生成所述表級同步配置表，所述參數(shù)屬性包括：同步表名、表所屬、源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識、目標(biāo)數(shù)據(jù)庫節(jié)點(diǎn)、增存量模式、上一次同步時間戳、同步頻率、同步開關(guān)狀態(tài)以及同步周期。

3.根據(jù)權(quán)利要求2所述的時效同步方法，其特征在于，所述源數(shù)據(jù)庫根據(jù)所述同步表進(jìn)行同步數(shù)據(jù)讀操作包括：

所述源數(shù)據(jù)庫以預(yù)設(shè)時間間隔讀取所述表級同步配置表中的源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識、當(dāng)前數(shù)據(jù)的唯一源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識ID以及所述同步開關(guān)狀態(tài)；

所述源數(shù)據(jù)庫根據(jù)所述源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識、所述唯一源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識ID、同步開關(guān)狀態(tài)、當(dāng)前系統(tǒng)時間、所述上一次同步時間戳以及所述同步頻率判斷是否需要進(jìn)行同步數(shù)據(jù)讀操作；

若獲知需要進(jìn)行同步數(shù)據(jù)讀操作，所述源數(shù)據(jù)庫則根據(jù)所述增存量模式獲取同步數(shù)據(jù)，并將所述同步數(shù)據(jù)寫入所述目標(biāo)數(shù)據(jù)庫中。

4.根據(jù)權(quán)利要求2所述的時效同步方法，其特征在于，所述目標(biāo)數(shù)據(jù)庫根據(jù)所述同步表進(jìn)行同步數(shù)據(jù)寫操作包括：

所述目標(biāo)數(shù)據(jù)庫獲取并解析消息隊(duì)列中的同步指令；

所述目標(biāo)數(shù)據(jù)庫根據(jù)所述同步指令解析出內(nèi)存塊對應(yīng)的數(shù)據(jù)對象；

所述目標(biāo)數(shù)據(jù)庫根據(jù)所述表級同步配置表中的配置信息，按照增存量模式寫入所述數(shù)據(jù)對象。

5.根據(jù)權(quán)利要求1所述的時效同步方法，其特征在于，還包括：生成同步信息并注冊到消息隊(duì)列，所述同步信息包括:目標(biāo)數(shù)據(jù)庫、同步表名、同步序列號以及同步時間戳。

6.根據(jù)權(quán)利要求1所述的時效同步方法，其特征在于，還包括：將同步日志表寫入到共享緩存中，所述表級同步日志表包括：表所屬、源節(jié)點(diǎn)，目標(biāo)結(jié)點(diǎn)、步序列號、同步開始時間戳、同步讀數(shù)據(jù)量，同步狀態(tài)為處理中。

7.一種基于數(shù)據(jù)庫表的時效同步裝置，其特征在于，包括：

表生成單元，用于生成表級同步配置表以及表級同步日志表；

同步表配置單元，用于根據(jù)所述表級同步配置表以及所述表級同步日志表配置同步表；

讀操作單元，用于源數(shù)據(jù)庫根據(jù)所述同步表進(jìn)行同步數(shù)據(jù)讀操作；

寫數(shù)據(jù)單元，用于目標(biāo)數(shù)據(jù)庫根據(jù)所述同步表進(jìn)行同步數(shù)據(jù)寫操作；

狀態(tài)監(jiān)控單元，用于根據(jù)所述表級同步配置表以及所述表級同步日志表監(jiān)控多個數(shù)據(jù)庫的數(shù)據(jù)同步狀態(tài)。

8.根據(jù)權(quán)利要求7所述的時效同步裝置，其特征在于，所述表生成單元包括：

日志表生成模塊，用于根據(jù)同步信息屬性生成所述表級同步日志表，所述同步信息屬性包括：同步表名、表所屬、源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識、目標(biāo)結(jié)點(diǎn)、同步序列號、同步狀態(tài)、同步開始時間戳、同步完成時間戳、同步讀記錄數(shù)以及同步寫記錄數(shù)；

配置表生成模塊，用于根據(jù)同步配置表參數(shù)屬性生成所述表級同步配置表，所述參數(shù)屬性包括：同步表名、表所屬、源數(shù)據(jù)庫節(jié)點(diǎn)標(biāo)識、目標(biāo)數(shù)據(jù)庫節(jié)點(diǎn)、增存量模式、上一次同步時間戳、同步頻率、同步開關(guān)狀態(tài)以及同步周期。