[發(fā)明專利]數(shù)據(jù)處理方法、相應(yīng)裝置、設(shè)備及存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 201910869719.1
• 申請日: 2019-09-16
• 公開（公告）號: CN110569257B
• 公開（公告）日: 2022-04-01
• 發(fā)明（設(shè)計(jì)）人: 韓朱忠;郭振崗
• 申請（專利權(quán)）人: 上海達(dá)夢數(shù)據(jù)庫有限公司
• 主分類號: G06F16/2453
• 分類號: G06F16/2453;G06F16/2458;G06F16/27
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發(fā)明實(shí)施例公開了一種數(shù)據(jù)處理方法、相應(yīng)裝置、設(shè)備及存儲介質(zhì)。該方法應(yīng)用于主數(shù)據(jù)庫服務(wù)器，包括：將執(zhí)行計(jì)劃樹分發(fā)給從數(shù)據(jù)庫服務(wù)器，以使所述主數(shù)據(jù)庫服務(wù)器和所述從數(shù)據(jù)庫服務(wù)器同步執(zhí)行所述執(zhí)行計(jì)劃樹，執(zhí)行到所述預(yù)設(shè)條件節(jié)點(diǎn)時(shí)，與所述從數(shù)據(jù)庫服務(wù)器同步執(zhí)行所述預(yù)設(shè)條件節(jié)點(diǎn)對應(yīng)的操作，并在操作執(zhí)行結(jié)束后返回執(zhí)行所述執(zhí)行計(jì)劃樹，直至所述執(zhí)行計(jì)劃樹執(zhí)行完畢，匯總所述從數(shù)據(jù)庫服務(wù)器執(zhí)行所述執(zhí)行計(jì)劃樹的執(zhí)行結(jié)果，并發(fā)送給用戶。本發(fā)明實(shí)施例的技術(shù)方案保證了主、從數(shù)據(jù)庫服務(wù)器執(zhí)行的同步，防止了因主、從數(shù)據(jù)庫服務(wù)器執(zhí)行不同步而引發(fā)死鎖等異常的發(fā)生，保證了數(shù)據(jù)處理的正常進(jìn)行，滿足了用戶的需求。

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

本發(fā)明實(shí)施例涉及數(shù)據(jù)庫技術(shù)領(lǐng)域，尤其涉及數(shù)據(jù)處理方法、相應(yīng)裝置、設(shè)備及存儲介質(zhì)。

背景技術(shù)

大規(guī)模并行處理(Massively Parallel Processing，MPP)支持將多個(gè)數(shù)據(jù)庫服務(wù)器實(shí)例組織為一個(gè)分布式的并行計(jì)算集群系統(tǒng)，以對外提供統(tǒng)一的數(shù)據(jù)庫服務(wù)。MPP系統(tǒng)中每一個(gè)運(yùn)行的數(shù)據(jù)庫服務(wù)器實(shí)例稱為一個(gè)執(zhí)行節(jié)點(diǎn)(Execute Point，EP)，每個(gè)EP的作用相同，用戶可以根據(jù)需要連接其中的任何一個(gè)EP進(jìn)行操作。對于每個(gè)用戶會話來說，EP有主從之分，用戶會話連接的EP對該用戶會話來說稱為主EP，其余的EP稱為從EP。

實(shí)際應(yīng)用時(shí)，主EP對用戶輸入的結(jié)構(gòu)化查詢語句(Structured Query Language，簡稱SQL語句)解析，生成對應(yīng)的執(zhí)行計(jì)劃，將執(zhí)行計(jì)劃分發(fā)給從EP，收集從EP的執(zhí)行結(jié)果，對收集的執(zhí)行結(jié)果進(jìn)行處理得到結(jié)果集反饋給用戶。由于SQL語句中通常會存在函數(shù)調(diào)用或函數(shù)的嵌套調(diào)用，每一層函數(shù)調(diào)用中可能還包含SQL語句，如果采用上述方式進(jìn)行處理，容易造成不同的EP執(zhí)行不同的SQL，導(dǎo)致信息不匹配而引發(fā)死鎖等異常，其中，死鎖是兩個(gè)或兩個(gè)以上的進(jìn)程在執(zhí)行過程中，由于競爭資源或者由于彼此通信而造成的一種阻塞的現(xiàn)象，若無外力作用，它們都將無法推進(jìn)下去。

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

本發(fā)明實(shí)施例提供一種數(shù)據(jù)處理方法、相應(yīng)裝置、設(shè)備及存儲介質(zhì)，以防止數(shù)據(jù)處理過程中因信息不匹配而引發(fā)死鎖等異常，保證數(shù)據(jù)處理的正常進(jìn)行。

第一方面，本發(fā)明實(shí)施例提供一種數(shù)據(jù)處理方法，應(yīng)用于主數(shù)據(jù)庫服務(wù)器，包括：

將執(zhí)行計(jì)劃樹分發(fā)給從數(shù)據(jù)庫服務(wù)器，以使所述主數(shù)據(jù)庫服務(wù)器和所述從數(shù)據(jù)庫服務(wù)器同步執(zhí)行所述執(zhí)行計(jì)劃樹，所述執(zhí)行計(jì)劃樹由所述主數(shù)據(jù)庫服務(wù)器通過對用戶輸入的結(jié)構(gòu)化查詢語句解析生成，所述執(zhí)行計(jì)劃樹包括預(yù)設(shè)條件節(jié)點(diǎn)；

執(zhí)行到所述預(yù)設(shè)條件節(jié)點(diǎn)時(shí)，與所述從數(shù)據(jù)庫服務(wù)器同步執(zhí)行所述預(yù)設(shè)條件節(jié)點(diǎn)對應(yīng)的操作，并在操作執(zhí)行結(jié)束后返回執(zhí)行所述執(zhí)行計(jì)劃樹，直至所述執(zhí)行計(jì)劃樹執(zhí)行完畢；

匯總所述從數(shù)據(jù)庫服務(wù)器執(zhí)行所述執(zhí)行計(jì)劃樹的執(zhí)行結(jié)果，并發(fā)送給所述用戶。

第二方面，本發(fā)明實(shí)施例還提供一種數(shù)據(jù)處理方法，應(yīng)用于從數(shù)據(jù)庫服務(wù)器，包括：

接收主數(shù)據(jù)庫服務(wù)器發(fā)送的執(zhí)行計(jì)劃樹，所述執(zhí)行計(jì)劃樹由所述主數(shù)據(jù)庫服務(wù)器通過對用戶輸入的結(jié)構(gòu)化查詢語句解析生成，所述執(zhí)行計(jì)劃樹包括預(yù)設(shè)條件節(jié)點(diǎn)；

執(zhí)行到所述預(yù)設(shè)條件節(jié)點(diǎn)時(shí)，與所述主數(shù)據(jù)庫服務(wù)器同步執(zhí)行所述預(yù)設(shè)條件節(jié)點(diǎn)對應(yīng)的操作，并在操作執(zhí)行結(jié)束后返回執(zhí)行所述執(zhí)行計(jì)劃樹，直至所述執(zhí)行計(jì)劃樹執(zhí)行完畢；

將執(zhí)行所述執(zhí)行計(jì)劃樹的執(zhí)行結(jié)果發(fā)送給所述主數(shù)據(jù)庫服務(wù)器。

第三方面，本發(fā)明實(shí)施例還提供一種數(shù)據(jù)處理裝置，設(shè)置于主數(shù)據(jù)庫服務(wù)器，包括：

分發(fā)模塊，用于將執(zhí)行計(jì)劃樹分發(fā)給從數(shù)據(jù)庫服務(wù)器，以使所述主數(shù)據(jù)庫服務(wù)器和所述從數(shù)據(jù)庫服務(wù)器同步執(zhí)行所述執(zhí)行計(jì)劃樹，所述執(zhí)行計(jì)劃樹由所述主數(shù)據(jù)庫服務(wù)器通過對用戶輸入的結(jié)構(gòu)化查詢語句解析生成，所述執(zhí)行計(jì)劃樹包括預(yù)設(shè)條件節(jié)點(diǎn)；