[發(fā)明專利]一種分布式系統(tǒng)數(shù)據(jù)同步方法、裝置、設(shè)備和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202210113501.5
• 申請日: 2022-01-30
• 公開（公告）號: CN114443773A
• 公開（公告）日: 2022-05-06
• 發(fā)明（設(shè)計(jì)）人: 邵碩;王憲剛;涂銳
• 申請（專利權(quán)）人: 中國農(nóng)業(yè)銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/22;G06Q40/04
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 陳金忠

1.一種分布式系統(tǒng)數(shù)據(jù)同步方法，其特征在于，包括：

獲取交易請求，所述交易請求中包含交易作用的數(shù)據(jù)庫表、操作類型、篩選條件和執(zhí)行參數(shù)；

查詢所述交易作用的數(shù)據(jù)庫表當(dāng)前的處理狀態(tài)，所述處理狀態(tài)包括已處理或未處理；

基于所述處理狀態(tài)根據(jù)所述交易請求對所述數(shù)據(jù)庫表進(jìn)行處理，獲取數(shù)據(jù)庫處理結(jié)果；

將所述數(shù)據(jù)庫處理結(jié)果返回給第一交易處理，在確定所述第一交易處理成功后調(diào)用第二交易，以使開放系統(tǒng)與主機(jī)系統(tǒng)保持?jǐn)?shù)據(jù)同步，

其中，所述第一交易屬于所述開放系統(tǒng)，所述第二交易屬于所述主機(jī)系統(tǒng)，并且所述第一交易與所述第二交易具備相同的功能。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述獲取交易請求，包括：

在預(yù)設(shè)時間內(nèi)未接收到所述主機(jī)系統(tǒng)的協(xié)同處理響應(yīng)時，生成聯(lián)機(jī)補(bǔ)償指示；

將所述聯(lián)機(jī)補(bǔ)償指示在前端交易界面進(jìn)行展示；

獲取用戶基于所述聯(lián)機(jī)補(bǔ)償指示所發(fā)送的所述交易請求。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述查詢所述交易作用的數(shù)據(jù)庫表當(dāng)前的處理狀態(tài)，包括：

從開放系統(tǒng)數(shù)據(jù)庫中查詢所述數(shù)據(jù)庫表的修改記錄；

根據(jù)所述操作類型對所述修改記錄進(jìn)行校驗(yàn)，獲取所述數(shù)據(jù)庫表當(dāng)前的處理狀態(tài)。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述操作類型包括插入insert操作、更新update操作、刪除delete操作或選擇select操作；

所述根據(jù)所述操作類型對所述修改記錄進(jìn)行校驗(yàn)，獲取所述數(shù)據(jù)庫表當(dāng)前的處理狀態(tài)，包括：

當(dāng)所述操作類型為插入insert操作時，判斷針對所述數(shù)據(jù)庫表的修改記錄的查詢結(jié)果是否為空，若是，則確定處理狀態(tài)為未處理，否則為已處理；

當(dāng)所述操作類型為更新update操作時，判斷針對所述數(shù)據(jù)庫表的修改記錄的查詢結(jié)果是否和執(zhí)行參數(shù)相同，若是，則確定處理狀態(tài)為已處理，否則為未處理；

當(dāng)所述操作類型為刪除delete操作時，判斷針對所述數(shù)據(jù)庫表的修改記錄的查詢結(jié)果是否為空，若是，則確定處理狀態(tài)為已處理，否則為未處理；

當(dāng)所述操作類型為選擇select操作時，則直接確定所述數(shù)據(jù)庫表當(dāng)前的處理狀態(tài)為未處理。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述基于所述處理狀態(tài)根據(jù)所述交易請求對所述數(shù)據(jù)庫表進(jìn)行處理，獲取數(shù)據(jù)庫處理結(jié)果,包括：

當(dāng)所述處理狀態(tài)為未處理時，則根據(jù)所述操作類型、篩選條件和執(zhí)行參數(shù)對所述數(shù)據(jù)庫進(jìn)行插入insert操作、更新update操作、刪除delete操作或選擇select操作，獲取所述數(shù)據(jù)庫處理結(jié)果；

將所述數(shù)據(jù)庫處理結(jié)果保存到所述開放系統(tǒng)數(shù)據(jù)庫。

6.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述基于所述處理狀態(tài)根據(jù)所述交易請求對所述數(shù)據(jù)庫表進(jìn)行處理，獲取數(shù)據(jù)庫處理結(jié)果,包括：

當(dāng)所述處理狀態(tài)為已處理，并且所述操作類型為插入insert操作時，判斷所述執(zhí)行參數(shù)與所述數(shù)據(jù)庫表的修改記錄是否一致，若否，則按照所述執(zhí)行參數(shù)對所述數(shù)據(jù)庫表進(jìn)行更新，否則直接跳過并將所述數(shù)據(jù)庫表當(dāng)前數(shù)據(jù)作為所述數(shù)據(jù)庫處理結(jié)果；

當(dāng)所述處理狀態(tài)為已處理，并且所述操作類型為更新update操作時，判斷所述執(zhí)行參數(shù)與所述數(shù)據(jù)庫表的修改記錄是否一致，若否，則按照所述執(zhí)行參數(shù)對所述數(shù)據(jù)庫表進(jìn)行更新，否則直接跳過并將所述數(shù)據(jù)庫表當(dāng)前數(shù)據(jù)作為所述數(shù)據(jù)庫處理結(jié)果；

當(dāng)所述處理狀態(tài)為已處理，并且所述操作類型為刪除delete操作或選擇select操作時，直接跳過并將所述數(shù)據(jù)庫表當(dāng)前數(shù)據(jù)作為所述數(shù)據(jù)庫處理結(jié)果。

7.根據(jù)權(quán)利要求1至6任一項(xiàng)所述的方法，其特征在于，所述將所述數(shù)據(jù)庫處理結(jié)果返回給第一交易處理，在確定所述第一交易處理成功后調(diào)用第二交易之后，還包括：

接收所述主機(jī)系統(tǒng)的協(xié)同響應(yīng)；

根據(jù)所述協(xié)同響應(yīng)生成交易完成指示。