[發明專利]一種交易數據同步方法、服務器

在審

• 申請號: 202010961768.0
• 申請日: 2020-09-14
• 公開（公告）號: CN112231395A
• 公開（公告）日: 2021-01-15
• 發明（設計）人: 劉浩;許磊磊;陳新軍
• 申請（專利權）人: 蘇寧金融科技（南京）有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06Q20/38
• 代理公司: 北京市萬慧達律師事務所 11111
• 代理人: 段曉玲

1.一種交易數據同步方法，其特征在于，所述方法包括：

獲取切換開關的狀態信息，當所述切換開關處于打開狀態時，對路由設備分配的交易請求進行處理并將產生的交易數據保存至切換數據庫；

當所述切換開關處于關閉狀態時，則判斷處理所述路由設備分配的交易請求的所需數據是否存在于所述切換數據庫中，若存在，則連接所述切換數據庫以處理交易，若不存在，則連接目標數據庫以處理交易，同時將所述切換數據庫中的交易數據同步至與目標服務器對應的所述目標數據庫中；

判斷所述切換數據庫中的交易數據是否全部同步成功，若是，則向客戶端發送同步成功響應，以使所述客戶端在接收到所述同步成功響應后向路由設備發送路由請求，以使所述路由設備對所述路由請求進行解析，并在確定所述路由請求中包括目標服務器的標識信息后，將所述交易請求分配至所述目標服務器進而處理交易。

2.根據權利要求1所述的方法，其特征在于，所述對路由設備分配的交易請求進行處理并將產生的交易數據保存至切換數據庫具體包括：

判斷處理所述交易請求所需數據是否存在于所述切換數據庫中，若存在，則連接所述切換數據庫以處理交易，若不存在，則連接所述源數據庫以獲取所需數據并寫入所述切換數據庫中以處理交易。

3.根據權利要求2所述的方法，其特征在于，所述判斷處理所述交易請求所需數據是否存在于所述切換數據庫中，若存在，則連接所述切換數據庫以處理交易，若不存在，則連接所述源數據庫以獲取所需數據并寫入所述切換數據庫中具體包括：

根據接收到的所述交易請求開啟一對應事務；

捕獲所述事務內執行的執行語句并保存，生成基礎表和明細表；其中，所述基礎表記錄了每一事務的路由字段和對應的執行語句交易序號，所述明細表記錄了每一事務的路由字段、對應的執行語句序號、執行語句內容和執行語句同步狀態值；

獲取執行的第一條執行語句的路由字段，當所述路由字段在基礎表中存在時，連接所述切換數據庫以處理交易，當所述路由字段在基礎表中不存在時，連接所述源數據庫以獲取所需數據并寫入所述切換數據庫。

4.根據權利要求3所述的方法，其特征在于，所述判斷處理所述路由設備分配的交易請求的所需數據是否存在于所述切換數據庫中，若存在，則連接所述切換數據庫以處理交易，若不存在，則連接所述目標數據庫以處理交易具體包括：

獲取與當前接收到的所述交易請求相對應的事務內執行的第一條執行語句的路由字段；

判斷所述切換數據庫中是否存在與當前接收到的所述交易請求的路由字段相匹配的基礎表；

若存在，則判斷所述基礎表的執行語句交易序號是否為零，當為零時，連接所述目標數據庫以處理交易，當不為零時，連接所述切換數據庫以處理所述交易請求；

若不存在，則連接所述目標數據庫以處理交易。

5.根據權利要求3或4所述的方法，其特征在于，所述將所述切換數據庫中的交易數據同步至與目標服務器對應的目標數據庫具體包括：

判斷所述切換數據庫中已存儲的基礎表中執行語句交易序號是否為零；

當為零時，則確定對應交易的交易數據同步成功；

當不為零時，按照預設順序將事務中的執行語句提交至所述目標數據庫中以進行逐條執行，當所有執行語句執行成功時，提交所述事務并確定對應交易的交易數據同步成功；

當所述事務中任一執行語句執行失敗時，回滾所述事務并確定對應交易的交易數據同步失敗；

其中，當執行語句執行成功時，變更明細表中的執行語句同步狀態值。

6.根據權利要求5所述的方法，其特征在于，所述方法還包括：

定時檢測所述切換數據庫中所述交易對應的明細表的每一條執行語句的執行語句同步狀態值，當明細表的每一條執行語句的執行語句同步狀態值都與預設值時相同，則確定所述交易的交易數據同步成功；

當明細表中執行語句的執行語句同步狀態值與預設值不同時，則確定所述交易的交易數據未同步成功。