[發(fā)明專利]分布式數(shù)據(jù)庫(kù)系統(tǒng)中的表連接方法及分布式數(shù)據(jù)庫(kù)系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201610263605.9
• 申請(qǐng)日: 2016-04-25
• 公開(kāi)（公告）號(hào): CN107305581B
• 公開(kāi)（公告）日: 2020-06-16
• 發(fā)明（設(shè)計(jì)）人: 張國(guó)強(qiáng);黃琳;孫東旺
• 申請(qǐng)（專利權(quán)）人: 華為技術(shù)有限公司
• 主分類號(hào): G06F16/2455
• 分類號(hào): G06F16/2455;G06F16/27
• 代理公司: 北京三高永信知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11138
• 代理人: 羅振安

1.一種分布式數(shù)據(jù)庫(kù)系統(tǒng)中的表連接方法，所述分布式數(shù)據(jù)庫(kù)系統(tǒng)包括數(shù)據(jù)節(jié)點(diǎn)和協(xié)調(diào)節(jié)點(diǎn)，其特征在于，所述方法用于所述數(shù)據(jù)節(jié)點(diǎn)，所述方法包括：

將所述協(xié)調(diào)節(jié)點(diǎn)發(fā)送的第一數(shù)據(jù)表中第一目標(biāo)列的數(shù)據(jù)存儲(chǔ)在本地存儲(chǔ)器，所述第一目標(biāo)列為所述第一數(shù)據(jù)表中與其他數(shù)據(jù)表連接次數(shù)超過(guò)預(yù)設(shè)次數(shù)的列；

接收所述協(xié)調(diào)節(jié)點(diǎn)發(fā)送的表連接請(qǐng)求，所述表連接請(qǐng)求包括所述第一數(shù)據(jù)表的標(biāo)識(shí)、所述第一目標(biāo)列的標(biāo)識(shí)、第二數(shù)據(jù)表的標(biāo)識(shí)以及第二數(shù)據(jù)表的第二目標(biāo)列的標(biāo)識(shí)；

根據(jù)所述表連接請(qǐng)求，從所述本地存儲(chǔ)器中獲取所述第一目標(biāo)列及位于所述第二目標(biāo)列上的第二數(shù)據(jù)；

將第一目標(biāo)列上的第一數(shù)據(jù)所在行的數(shù)據(jù)與所述第二數(shù)據(jù)所在行的數(shù)據(jù)進(jìn)行連接，以得到連接結(jié)果，其中，所述第一數(shù)據(jù)為所述第一目標(biāo)列上的任一數(shù)據(jù)，且所述第一數(shù)據(jù)與所述第二數(shù)據(jù)相同；

向所述協(xié)調(diào)節(jié)點(diǎn)發(fā)送所述連接結(jié)果。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

在第一數(shù)據(jù)表的分布列與所述第一目標(biāo)列相異的情況下，接收所述協(xié)調(diào)節(jié)點(diǎn)發(fā)送的所述分布列的數(shù)據(jù)，所述分布列為所述第一數(shù)據(jù)表的行標(biāo)識(shí)所在的列；

將所述分布列的數(shù)據(jù)存儲(chǔ)在本地存儲(chǔ)器。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述方法還包括：

接收所述協(xié)調(diào)節(jié)點(diǎn)發(fā)送的數(shù)據(jù)獲取請(qǐng)求，所述數(shù)據(jù)獲取請(qǐng)求表示所述協(xié)調(diào)節(jié)點(diǎn)的整合數(shù)據(jù)表中存在空洞行，所述整合數(shù)據(jù)表由所述協(xié)調(diào)節(jié)點(diǎn)對(duì)至少一個(gè)數(shù)據(jù)節(jié)點(diǎn)發(fā)送的連接結(jié)果整合得到，所述數(shù)據(jù)獲取請(qǐng)求包括空洞行標(biāo)識(shí)；

獲取所述空洞行標(biāo)識(shí)所在行上的數(shù)據(jù)；

向所述協(xié)調(diào)節(jié)點(diǎn)發(fā)送所述空洞行標(biāo)識(shí)所在行上的數(shù)據(jù)。

4.一種分布式數(shù)據(jù)庫(kù)系統(tǒng)中的表連接方法，所述分布式數(shù)據(jù)庫(kù)系統(tǒng)包括數(shù)據(jù)節(jié)點(diǎn)和協(xié)調(diào)節(jié)點(diǎn)，其特征在于，所述方法用于所述協(xié)調(diào)節(jié)點(diǎn)，所述方法包括：

從第一數(shù)據(jù)表中獲取第一目標(biāo)列，所述第一目標(biāo)列為與其他數(shù)據(jù)表連接次數(shù)超過(guò)預(yù)設(shè)次數(shù)的列；

向所述數(shù)據(jù)節(jié)點(diǎn)發(fā)送所述第一目標(biāo)列的數(shù)據(jù)；

向所述數(shù)據(jù)節(jié)點(diǎn)發(fā)送表連接請(qǐng)求，所述表連接請(qǐng)求包括所述第一數(shù)據(jù)表的標(biāo)識(shí)、所述第一目標(biāo)列的標(biāo)識(shí)、第二數(shù)據(jù)表的標(biāo)識(shí)以及第二數(shù)據(jù)表的第二目標(biāo)列的標(biāo)識(shí)，所述表連接請(qǐng)求用于觸發(fā)所述數(shù)據(jù)節(jié)點(diǎn)返回對(duì)所述第一數(shù)據(jù)表和所述第二數(shù)據(jù)表中數(shù)據(jù)的連接結(jié)果；

接收所述數(shù)據(jù)節(jié)點(diǎn)發(fā)送的所述連接結(jié)果。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述方法還包括：

在第一數(shù)據(jù)表的分布列與所述第一目標(biāo)列相異的情況下，向所述數(shù)據(jù)節(jié)點(diǎn)發(fā)送所述分布列的數(shù)據(jù)，所述分布列為所述第一數(shù)據(jù)表的行標(biāo)識(shí)所在的列。

6.根據(jù)權(quán)利要求4或5所述的方法，其特征在于，所述方法還包括：

對(duì)至少一個(gè)數(shù)據(jù)節(jié)點(diǎn)發(fā)送的連接結(jié)果進(jìn)行整合，以得到整合數(shù)據(jù)表；

在所述整合數(shù)據(jù)表中存在空洞行的情況下，向所述空洞行對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)發(fā)送數(shù)據(jù)獲取請(qǐng)求，所述數(shù)據(jù)獲取請(qǐng)求包括空洞行標(biāo)識(shí)，所述空洞行標(biāo)識(shí)是根據(jù)所述第一數(shù)據(jù)表的分布列確定的；

接收所述空洞行對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)發(fā)送的所述空洞行標(biāo)識(shí)所在行上的數(shù)據(jù)；

將所述空洞行標(biāo)識(shí)所在行上的數(shù)據(jù)添加到所述整合數(shù)據(jù)表中所述空洞行標(biāo)識(shí)對(duì)應(yīng)的行上，以得到新的數(shù)據(jù)表。