[發(fā)明專利]基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)及處理方法

有效

• 申請?zhí)枺?/td>: 202010799320.3
• 申請日: 2020-08-11
• 公開（公告）號: CN111930843B
• 公開（公告）日: 2023-07-28
• 發(fā)明（設(shè)計）人: 趙森;馮澤盛
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/25;G06F9/54;G06F11/14
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 王濤;單曉雙

1.一種基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)，其特征在于，所述系統(tǒng)包含數(shù)據(jù)訪問代理組件、消息隊列組件、數(shù)據(jù)同步組件和N個數(shù)據(jù)節(jié)點；

所述數(shù)據(jù)訪問代理組件用于根據(jù)接收到的交易請求進行路由分析，獲得執(zhí)行所述交易請求的數(shù)據(jù)節(jié)點，將所述交易請求對應(yīng)的查詢語句寫入所述數(shù)據(jù)節(jié)點；以及，通過切面攔截所述數(shù)據(jù)節(jié)點已處理的所述查詢語句，將所述查詢語句推送至所述消息隊列組件；

所述消息隊列組件用于接收所述數(shù)據(jù)訪問代理組件提供的所述查詢語句并存儲；

所述數(shù)據(jù)同步組件用于通過所述消息隊列組件獲得所述查詢語句，于預(yù)設(shè)的其他數(shù)據(jù)節(jié)點執(zhí)行所述查詢語句并完成數(shù)據(jù)同步；

各所述數(shù)據(jù)節(jié)點的環(huán)境配置和數(shù)據(jù)基礎(chǔ)一致，N為大于1的整數(shù)。

2.根據(jù)權(quán)利要求1所述的基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)，其特征在于，所述數(shù)據(jù)訪問代理組件還包含決策模塊；

所述決策模塊用于分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略；

所述執(zhí)行策略包含：當所述數(shù)據(jù)節(jié)點已處理完所述查詢語句，通過切面攔截所述查詢語句，將所述查詢語句推送至所述消息隊列組件；當所述數(shù)據(jù)節(jié)點未能處理完所述查詢語句，將所述交易請求退回至交易發(fā)起方并反饋提示信息。

3.根據(jù)權(quán)利要求2所述的基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)，其特征在于，所述決策模塊包含：通過分布式事務(wù)同步機制分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略。

4.根據(jù)權(quán)利要求1所述的基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)，其特征在于，所述數(shù)據(jù)訪問代理組件包含登記模塊，所述登記模塊用于將所述交易請求對應(yīng)的查詢語句寫入所述數(shù)據(jù)節(jié)點的節(jié)點流水表，并于所述節(jié)點流水表中記錄所述數(shù)據(jù)節(jié)點為待登記狀態(tài)；以及，當所述數(shù)據(jù)節(jié)點通過所述查詢語句獲取所述交易請求后，將所述節(jié)點流水表中所述數(shù)據(jù)節(jié)點改為已登記狀態(tài)。

5.根據(jù)權(quán)利要求4所述的基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)，其特征在于，所述數(shù)據(jù)同步組件還包含流水表更新模塊，所述流水表更新模塊用于在其他數(shù)據(jù)節(jié)點完成數(shù)據(jù)同步后，將所述節(jié)點流水表中其他數(shù)據(jù)節(jié)點設(shè)為已登記狀態(tài)。

6.一種基于數(shù)據(jù)庫的處理方法，其特征在于，所述方法包含：

根據(jù)接收到的交易請求進行路由分析，獲得執(zhí)行所述交易請求的數(shù)據(jù)節(jié)點；

將所述交易請求對應(yīng)的查詢語句寫入所述數(shù)據(jù)節(jié)點；

通過切面攔截所述數(shù)據(jù)節(jié)點已處理的所述查詢語句，將所述查詢語句推送至消息隊列中存儲；

其他數(shù)據(jù)節(jié)點通過所述消息隊列獲得所述查詢語句，執(zhí)行所述查詢語句并完成數(shù)據(jù)同步；

其中，各所述數(shù)據(jù)節(jié)點的環(huán)境配置和數(shù)據(jù)基礎(chǔ)一致；所述數(shù)據(jù)節(jié)點為N個，N為大于1的整數(shù)。

7.根據(jù)權(quán)利要求6所述的基于數(shù)據(jù)庫的處理方法，其特征在于，所述方法還包含：

分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略；

當所述數(shù)據(jù)節(jié)點已處理完所述查詢語句，生成執(zhí)行策略執(zhí)行通過切面攔截所述查詢語句，將所述查詢語句推送至所述消息隊列；

當所述數(shù)據(jù)節(jié)點未能處理完所述查詢語句，生成執(zhí)行策略執(zhí)行將所述交易請求退回至交易發(fā)起方并反饋提示信息。

8.根據(jù)權(quán)利要求7所述的基于數(shù)據(jù)庫的處理方法，其特征在于，分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略包含：通過分布式事務(wù)同步機制分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略。

9.根據(jù)權(quán)利要求6所述的基于數(shù)據(jù)庫的處理方法，其特征在于，所述方法還包含：

將所述交易請求對應(yīng)的查詢語句寫入所述數(shù)據(jù)節(jié)點的節(jié)點流水表，并于所述節(jié)點流水表中記錄所述數(shù)據(jù)節(jié)點為待登記狀態(tài)；

當所述數(shù)據(jù)節(jié)點通過所述查詢語句獲取所述交易請求后，將所述節(jié)點流水表中所述數(shù)據(jù)節(jié)點改為已登記狀態(tài)。

10.根據(jù)權(quán)利要求9所述的基于數(shù)據(jù)庫的處理方法，其特征在于，所述方法還包含：

在其他數(shù)據(jù)節(jié)點完成數(shù)據(jù)同步后，將所述節(jié)點流水表中其他數(shù)據(jù)節(jié)點設(shè)為已登記狀態(tài)。