[發(fā)明專利]集群數(shù)據(jù)庫并行查詢的通訊方法和通訊裝置

在審

• 申請?zhí)枺?/td>: 201310353976.2
• 申請日: 2013-08-14
• 公開（公告）號: CN103399943A
• 公開（公告）日: 2013-11-20
• 發(fā)明（設(shè)計(jì)）人: 宋懷明;王勇;苗艷超;劉新春;邵宗有
• 申請（專利權(quán)）人: 曙光信息產(chǎn)業(yè)（北京）有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京德恒律治知識產(chǎn)權(quán)代理有限公司 11409
• 代理人: 章社杲;孫征

1.一種數(shù)據(jù)庫集群并行查詢的通訊方法，其特征在于，包括：

對來自查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行劃分，得到劃分塊；

對每個劃分塊以獨(dú)立數(shù)據(jù)文件的形式傳輸至目標(biāo)節(jié)點(diǎn)；

在所有數(shù)據(jù)文件均傳輸至所述目標(biāo)節(jié)點(diǎn)的情況下，對所述目標(biāo)節(jié)點(diǎn)上的數(shù)據(jù)文件進(jìn)行數(shù)據(jù)合并。

2.根據(jù)權(quán)利要求1所述的通訊方法，其特征在于，如果所述目標(biāo)節(jié)點(diǎn)是所述查詢節(jié)點(diǎn)的下一級查詢節(jié)點(diǎn)，并且所述目標(biāo)節(jié)點(diǎn)需要對來自所述查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行進(jìn)一步查詢并排序，則在對來自所述查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行劃分時，采用范圍劃分的方式進(jìn)行劃分。

3.根據(jù)權(quán)利要求1所述的通訊方法，其特征在于，如果所述目標(biāo)節(jié)點(diǎn)是所述查詢節(jié)點(diǎn)的下一級查詢節(jié)點(diǎn)，并且所述目標(biāo)節(jié)點(diǎn)需要對來自所述查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行關(guān)聯(lián)查詢或者分組統(tǒng)計(jì)，則在對來自所述查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行劃分時，采用哈希劃分的方式進(jìn)行劃分。

4.根據(jù)權(quán)利要求1所述的通訊方法，其特征在于，所述劃分塊的數(shù)量與所述查詢節(jié)點(diǎn)的下一級查詢節(jié)點(diǎn)的數(shù)量相符。

5.根據(jù)權(quán)利要求1所述的通訊方法，其特征在于，對來自所述查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行劃分之后，進(jìn)一步包括：

根據(jù)預(yù)先配置的標(biāo)識信息對每個劃分塊進(jìn)行標(biāo)識，并對標(biāo)識后的劃分塊以數(shù)據(jù)文件的形式進(jìn)行保存，其中，所述標(biāo)識信息包括以下至少之一：查詢?nèi)蝿?wù)編號、與所述查詢?nèi)蝿?wù)編號對應(yīng)的所述查詢節(jié)點(diǎn)的編號、與所述查詢?nèi)蝿?wù)編號對應(yīng)的所述目標(biāo)節(jié)點(diǎn)的編號。

6.根據(jù)權(quán)利要求5所述的通訊方法，其特征在于，對每個劃分塊以獨(dú)立數(shù)據(jù)文件的形式傳輸至目標(biāo)節(jié)點(diǎn)包括：

根據(jù)每個數(shù)據(jù)文件的標(biāo)識信息，確定與該數(shù)據(jù)文件對應(yīng)的查詢?nèi)蝿?wù)、查詢節(jié)點(diǎn)和目標(biāo)節(jié)點(diǎn)；

根據(jù)確定的所述查詢?nèi)蝿?wù)、查詢節(jié)點(diǎn)和目標(biāo)節(jié)點(diǎn)，將該數(shù)據(jù)文件拷貝到目標(biāo)節(jié)點(diǎn)上；并且在拷貝成功的情況下，將該數(shù)據(jù)文件從查詢節(jié)點(diǎn)刪除，在拷貝失敗的情況下，記錄操作日志。

7.根據(jù)權(quán)利要求1所述的通訊方法，其特征在于，對所述目標(biāo)節(jié)點(diǎn)上的數(shù)據(jù)文件進(jìn)行數(shù)據(jù)合并包括：

對所述數(shù)據(jù)文件進(jìn)行分析，確定所述數(shù)據(jù)文件的存儲路徑和所述數(shù)據(jù)文件包含的數(shù)據(jù)信息；

根據(jù)確定的所述數(shù)據(jù)文件的存儲路徑和所述數(shù)據(jù)文件包含的數(shù)據(jù)信息，生成數(shù)據(jù)庫外部表。

8.一種集群數(shù)據(jù)庫并行查詢的通訊裝置，其特征在于，包括：

劃分模塊，用于對來自查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行劃分，得到劃分塊；

傳輸模塊，用于對每個劃分塊以獨(dú)立數(shù)據(jù)文件的形式傳輸至目標(biāo)節(jié)點(diǎn)；

合并模塊，用于在所有數(shù)據(jù)文件均傳輸至所述目標(biāo)節(jié)點(diǎn)的情況下，對所述目標(biāo)節(jié)點(diǎn)上的數(shù)據(jù)文件進(jìn)行合并。

9.根據(jù)權(quán)利要求8所述的通訊裝置，其特征在于，進(jìn)一步包括：

標(biāo)識模塊，用于在對來自查詢節(jié)點(diǎn)的查詢結(jié)果進(jìn)行劃分之后，根據(jù)預(yù)先配置的標(biāo)識信息對每個劃分塊進(jìn)行標(biāo)識，并對標(biāo)識后的劃分塊以數(shù)據(jù)文件的形式進(jìn)行保存，其中，所述標(biāo)識信息包括以下至少之一：查詢?nèi)蝿?wù)編號、與所述查詢?nèi)蝿?wù)編號對應(yīng)的所述查詢節(jié)點(diǎn)的編號、與所述查詢?nèi)蝿?wù)編號對應(yīng)的所述目標(biāo)節(jié)點(diǎn)的編號。

10.根據(jù)權(quán)利要求8所述的通訊裝置，其特征在于，所述合并模塊進(jìn)一步包括分析模塊和生成模塊，其中，

分析模塊，用于對所述數(shù)據(jù)文件進(jìn)行分析，確定所述數(shù)據(jù)文件的存儲路徑和所述數(shù)據(jù)文件包含的數(shù)據(jù)信息；

生成模塊，用于根據(jù)確定的所述數(shù)據(jù)文件的存儲路徑和所述數(shù)據(jù)文件的數(shù)據(jù)信息，生成數(shù)據(jù)庫外部表。