[發(fā)明專利]處理事務(wù)的方法和裝置

有效

• 申請?zhí)枺?/td>: 202210049251.3
• 申請日: 2022-01-17
• 公開（公告）號: CN114064810B
• 公開（公告）日: 2022-05-03
• 發(fā)明（設(shè)計）人: 陽振坤;韓富晟;閆建良;肖金亮;喬國治
• 申請（專利權(quán)）人: 北京奧星貝斯科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/242;G06F16/25
• 代理公司: 北京布瑞知識產(chǎn)權(quán)代理有限公司 11505
• 代理人: 張欣

本公開披露了一種處理事務(wù)的方法和裝置。該方法包括：接收第一事務(wù)，第一事務(wù)為非只讀事務(wù)，第一事務(wù)包括第一數(shù)據(jù)庫語句和第二數(shù)據(jù)庫語句，第一數(shù)據(jù)庫語句和第二數(shù)據(jù)庫語句分別用于對分布式數(shù)據(jù)庫中的第一數(shù)據(jù)庫節(jié)點和第二數(shù)據(jù)庫節(jié)點進行操作；與第一數(shù)據(jù)庫節(jié)點建立第一數(shù)據(jù)庫連接；通過第一數(shù)據(jù)庫連接向第一數(shù)據(jù)庫節(jié)點發(fā)送第一數(shù)據(jù)庫語句；與第二數(shù)據(jù)庫節(jié)點建立第二數(shù)據(jù)庫連接；通過第二數(shù)據(jù)庫連接向第二數(shù)據(jù)庫節(jié)點發(fā)送第二數(shù)據(jù)庫語句；接收第一數(shù)據(jù)庫針對第一數(shù)據(jù)庫語句的反饋信息，反饋信息包括第一事務(wù)的控制信息；向第二數(shù)據(jù)庫語句對應(yīng)的數(shù)據(jù)庫節(jié)點發(fā)送控制信息。

技術(shù)領(lǐng)域

本公開涉及分布式數(shù)據(jù)庫領(lǐng)域，并且更為具體地，涉及一種處理事務(wù)的方法和裝置。

背景技術(shù)

分布式數(shù)據(jù)包括多個數(shù)據(jù)庫節(jié)點。在處理涉及多個數(shù)據(jù)庫節(jié)點的非只讀事務(wù)時，現(xiàn)有技術(shù)會先與其中一個數(shù)據(jù)庫節(jié)點建立數(shù)據(jù)庫連接，然后由該數(shù)據(jù)庫節(jié)點在數(shù)據(jù)庫內(nèi)部將該事務(wù)轉(zhuǎn)發(fā)至其他數(shù)據(jù)庫節(jié)點，從而在其他數(shù)據(jù)庫節(jié)點進行遠程事務(wù)執(zhí)行。過多的遠程事務(wù)執(zhí)行會降低非只讀事務(wù)的處理效率。

發(fā)明內(nèi)容

本公開提供一種事務(wù)處理方法和裝置，以提高分布式數(shù)據(jù)庫中的非只讀事務(wù)的處理效率。

第一方面，提供一種處理事務(wù)的方法，包括：接收第一事務(wù)，所述第一事務(wù)為非只讀事務(wù)，所述第一事務(wù)包括第一數(shù)據(jù)庫語句和第二數(shù)據(jù)庫語句，所述第一數(shù)據(jù)庫語句和所述第二數(shù)據(jù)庫語句分別用于對分布式數(shù)據(jù)庫中的第一數(shù)據(jù)庫節(jié)點和第二數(shù)據(jù)庫節(jié)點進行操作；與所述第一數(shù)據(jù)庫節(jié)點建立第一數(shù)據(jù)庫連接；通過所述第一數(shù)據(jù)庫連接向所述第一數(shù)據(jù)庫節(jié)點發(fā)送所述第一數(shù)據(jù)庫語句；與所述第二數(shù)據(jù)庫節(jié)點建立第二數(shù)據(jù)庫連接；通過所述第二數(shù)據(jù)庫連接向所述第二數(shù)據(jù)庫節(jié)點發(fā)送所述第二數(shù)據(jù)庫語句。

可選地，所述方法還包括：接收所述第一數(shù)據(jù)庫針對所述第一數(shù)據(jù)庫語句的反饋信息，所述反饋信息包括所述第一事務(wù)的控制信息；向所述第二數(shù)據(jù)庫語句對應(yīng)的數(shù)據(jù)庫節(jié)點發(fā)送所述控制信息。

可選地，所述第一事務(wù)的控制信息包括所述第一數(shù)據(jù)庫語句的執(zhí)行結(jié)果和/或所述第一事務(wù)的狀態(tài)。

可選地，在所述與所述第二數(shù)據(jù)庫節(jié)點建立第二數(shù)據(jù)庫連接之前，所述方法還包括：斷開所述第一數(shù)據(jù)庫連接。

可選地，所述第一事務(wù)中的數(shù)據(jù)庫語句為SQL語句。

第二方面，提供一種處理事務(wù)的裝置，包括：接收單元，被配置為接收第一事務(wù)，所述第一事務(wù)為非只讀事務(wù)，所述第一事務(wù)包括第一數(shù)據(jù)庫語句和第二數(shù)據(jù)庫語句，所述第一數(shù)據(jù)庫語句和所述第二數(shù)據(jù)庫語句分別用于對分布式數(shù)據(jù)庫中的第一數(shù)據(jù)庫節(jié)點和第二數(shù)據(jù)庫節(jié)點進行操作；第一連接單元，被配置為與所述第一數(shù)據(jù)庫節(jié)點建立第一數(shù)據(jù)庫連接；第一發(fā)送單元，被配置為通過所述第一數(shù)據(jù)庫連接向所述第一數(shù)據(jù)庫節(jié)點發(fā)送所述第一數(shù)據(jù)庫語句；第二連接單元，被配置為與所述第二數(shù)據(jù)庫節(jié)點建立第二數(shù)據(jù)庫連接；第二發(fā)送單元，被配置為通過所述第二數(shù)據(jù)庫連接向所述第二數(shù)據(jù)庫節(jié)點發(fā)送所述第二數(shù)據(jù)庫語句。

可選地，所述接收單元還被配置為：接收所述第一數(shù)據(jù)庫針對所述第一數(shù)據(jù)庫語句的反饋信息，所述反饋信息包括所述第一事務(wù)的控制信息；所述第二發(fā)送單元還被配置為：向所述第二數(shù)據(jù)庫語句對應(yīng)的數(shù)據(jù)庫節(jié)點發(fā)送所述控制信息。

可選地，所述第一事務(wù)的控制信息包括所述第一數(shù)據(jù)庫語句的執(zhí)行結(jié)果和/或所述第一事務(wù)的狀態(tài)。

可選地，在所述與所述第二數(shù)據(jù)庫節(jié)點建立第二數(shù)據(jù)庫連接之前，所述第一連接單元還被配置為：斷開所述第一數(shù)據(jù)庫連接。

可選地，所述第一事務(wù)中的數(shù)據(jù)庫語句為SQL語句。

第三方面，提供一種處理事務(wù)的裝置，包括存儲器和處理器，所述存儲器中存儲有可執(zhí)行代碼，所述處理器被配置為執(zhí)行所述可執(zhí)行代碼，以實現(xiàn)如第一方面所述的方法。

第四方面，提供一種計算機可讀存儲介質(zhì)，其上存儲有可執(zhí)行代碼，當(dāng)所述可執(zhí)行代碼被執(zhí)行時，能夠?qū)崿F(xiàn)如第一方面所述的方法。