[發明專利]數據庫的數據同步方法、裝置以及存儲介質有效
| 申請號: | 201911296442.4 | 申請日: | 2019-12-16 |
| 公開(公告)號: | CN112988883B | 公開(公告)日: | 2023-03-10 |
| 發明(設計)人: | 宦家佳 | 申請(專利權)人: | 金篆信科有限責任公司 |
| 主分類號: | G06F16/27 | 分類號: | G06F16/27;G06F9/46 |
| 代理公司: | 北京品源專利代理有限公司 11332 | 代理人: | 潘登 |
| 地址: | 100176 北京市大興區北京經濟技術開發區科谷*** | 國省代碼: | 北京;11 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 數據庫 數據 同步 方法 裝置 以及 存儲 介質 | ||
本申請公開了一種數據庫的數據同步方法、裝置以及存儲介質,所述方法包括在所述多個數據節點反饋的事務響應結果均為成功的情況下,接收所述客戶端發送的事務提交請求消息,并向事務處理表寫入全局事務ID;將所述事務提交請求消息發送給所述多個數據節點;接收所述多個數據節點反饋的事務提交結果;在所述多個數據節點反饋的事務提交結果均為成功的情況下,向全局事務管理器申請釋放所述全局事務ID。本申請可以實現異構數據庫系統中分布式數據庫與單機數據庫間的數據同步,采用單向同步以及將待處理事務信息與事務本身提交成功與否綁定的方式,解決了同時向兩個數據庫發送請求導致的不一致問題,大大提高了數據同步的可靠性。
技術領域
本申請涉及數據庫技術領域,特別是涉及一種數據庫的數據同步方法、裝置以及存儲介質。
背景技術
異構數據庫系統是相關的多個數據庫系統的集合,例如分布式數據庫系統和單機數據庫系統的集合。在異構數據庫系統的一種數據同步場景中,需要將客戶端的數據同步至分布式數據庫和單機數據庫中?,F有的一種可應用于該場景的數據同步方式是在客戶端和數據庫之間設置代理(Proxy),由Proxy接收客戶端的事務數據,并由Proxy將事務數據改寫成能相應被分布式數據庫和單機數據庫執行的結構化語言,并將相應的結構化語言發送給分布式數據庫和單機數據庫,進而實現將客戶端的數據同步至分布式數據庫和單機數據庫中。上述同步方式的弊端是如果分布式數據庫和單機數據庫接收到請求后反饋不同的響應結果,則Proxy無法處理,甚至可能會堵塞客戶端的事務請求。
發明內容
以下是對本文詳細描述的主題的概述。本概述并非是為了限制權利要求的保護范圍。
一方面,本申請實施例提供了一種數據庫的數據同步方法、裝置以及存儲介質,可實現異構數據庫系統中分布式數據庫和單機數據庫間的數據同步。
另一方面,本申請實施例提供了一種數據庫的數據同步方法,包括:
接收客戶端發送的事務啟動請求;
響應于所述事務啟動請求,向全局事務管理器申請全局事務ID;
接收所述全局事務管理器反饋的全局事務ID,反饋事務啟動成功消息給所述客戶端;
在接收到所述全局事務管理器反饋的全局事務ID的情況下,接收所述客戶端發送的事務請求消息,所述事務請求消息攜帶有待執行的第一事務語句;
將所述全局事務ID及所述事務請求消息發送給分布式數據庫的多個數據節點;
接收所述多個數據節點反饋的事務響應結果;
在所述多個數據節點反饋的事務響應結果均為成功的情況下,反饋事務響應成功消息給所述客戶端;
接收所述客戶端發送的事務提交請求消息,并向事務處理表寫入全局事務ID;
將所述事務提交請求消息發送給所述多個數據節點;
接收所述多個數據節點反饋的事務提交結果;
在所述多個數據節點反饋的事務提交結果均為成功的情況下,反饋事務提交成功消息給所述客戶端,向全局事務管理器申請釋放所述全局事務ID,以使同步模塊能夠根據釋放的所述全局事務ID,從所述多個數據節點獲取與所述全局事務ID對應的第一事務語句。
另一方面,本申請實施例提供了一種數據庫的數據同步方法,包括:
從事務處理表獲取待處理事務及與所述待處理事務對應的全局事務ID;
向全局事務管理器查詢所述待處理事務的全局事務ID是否已釋放;
對于全局事務ID已釋放的待處理事務,從分布式數據庫的多個數據節點獲取與所述全局事務ID對應的第一事務語句;
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于金篆信科有限責任公司,未經金篆信科有限責任公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/201911296442.4/2.html,轉載請聲明來源鉆瓜專利網。
- 上一篇:化妝鏡及用于控制化妝鏡的方法
- 下一篇:成像模組及其制造方法
- 數據顯示系統、數據中繼設備、數據中繼方法、數據系統、接收設備和數據讀取方法
- 數據記錄方法、數據記錄裝置、數據記錄媒體、數據重播方法和數據重播裝置
- 數據發送方法、數據發送系統、數據發送裝置以及數據結構
- 數據顯示系統、數據中繼設備、數據中繼方法及數據系統
- 數據嵌入裝置、數據嵌入方法、數據提取裝置及數據提取方法
- 數據管理裝置、數據編輯裝置、數據閱覽裝置、數據管理方法、數據編輯方法以及數據閱覽方法
- 數據發送和數據接收設備、數據發送和數據接收方法
- 數據發送裝置、數據接收裝置、數據收發系統、數據發送方法、數據接收方法和數據收發方法
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置





