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

有效

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

本發(fā)明公開了一種分布式數(shù)據(jù)庫中的表連接方法及系統(tǒng)，屬于信息技術領域。包括：將協(xié)調(diào)節(jié)點發(fā)送的第一數(shù)據(jù)表中第一目標列的數(shù)據(jù)存儲在本地存儲器；接收表連接請求；當?shù)谝荒繕肆猩系牡谝粩?shù)據(jù)與第二目標列上的第二數(shù)據(jù)相同時，將第一數(shù)據(jù)所在行的數(shù)據(jù)與第二數(shù)據(jù)所在行的數(shù)據(jù)進行連接；向協(xié)調(diào)節(jié)點發(fā)送連接結果。本發(fā)明中數(shù)據(jù)節(jié)點通過存儲第一數(shù)據(jù)表的第一目標列的數(shù)據(jù)，在接收到將第一數(shù)據(jù)表的第一目標列和第二數(shù)據(jù)表的第二目標列作連接的表連接請求后，直接在本地作連接，無需將節(jié)點上存儲的數(shù)據(jù)發(fā)送至協(xié)調(diào)節(jié)點，不僅減少了數(shù)據(jù)傳輸量，縮短了網(wǎng)絡響應時間，提高了業(yè)務性能，而且減少對協(xié)調(diào)節(jié)點和數(shù)據(jù)節(jié)點存儲資源的占用，節(jié)省了存儲空間。

技術領域

本發(fā)明涉及信息技術領域，特別涉及一種分布式數(shù)據(jù)庫系統(tǒng)中的表連接方法及分布式數(shù)據(jù)庫系統(tǒng)。

背景技術

在分布式數(shù)據(jù)庫系統(tǒng)中，節(jié)點按照功能可分為協(xié)調(diào)節(jié)點和數(shù)據(jù)節(jié)點，其中，數(shù)據(jù)節(jié)點用于存儲數(shù)據(jù)表中的數(shù)據(jù)，協(xié)調(diào)節(jié)點作為客戶端和數(shù)據(jù)節(jié)點之間通信的橋梁，用于臨時性存儲客戶端和數(shù)據(jù)節(jié)點所發(fā)送的數(shù)據(jù)，并在客戶端和數(shù)據(jù)節(jié)點之間傳遞數(shù)據(jù)。在分布式數(shù)據(jù)庫系統(tǒng)中，數(shù)據(jù)的存儲通常采用非共享體系(share nothing)的數(shù)據(jù)結構，在非共享體系的數(shù)據(jù)結構下，數(shù)據(jù)表中的數(shù)據(jù)以行為單位分布在各個數(shù)據(jù)節(jié)點中，在各個數(shù)據(jù)節(jié)點中數(shù)據(jù)表中的數(shù)據(jù)可以以行為單位進行存儲，還可以以列為單位進行存儲。

基于分布式數(shù)據(jù)庫系統(tǒng)中非共享體系的數(shù)據(jù)結構，分布式數(shù)據(jù)庫所采用的將兩張數(shù)據(jù)表中的數(shù)據(jù)進行連接的方法，由于數(shù)據(jù)表分布在不同的數(shù)據(jù)節(jié)點，協(xié)調(diào)節(jié)點需要從數(shù)據(jù)節(jié)點中將兩張表的數(shù)據(jù)都收集到本地，再在本地進行連接,由于傳輸?shù)臄?shù)據(jù)量較大故網(wǎng)絡響應時間長，使得協(xié)調(diào)節(jié)點處理數(shù)據(jù)的連接較慢，并且要占用大量的協(xié)調(diào)節(jié)點的資源，業(yè)務性能較差。

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

為了解決采用現(xiàn)有的數(shù)據(jù)表連接方法所導致的網(wǎng)絡響應時間長、資源占用率較大、業(yè)務性能差的問題，本發(fā)明實施例提供了一種分布式數(shù)據(jù)庫系統(tǒng)中的表連接方法及系統(tǒng)。所述技術方案如下：

第一方面，本發(fā)明實施例提供了一種分布式數(shù)據(jù)庫系統(tǒng)中的數(shù)據(jù)表連接方法，該分布式數(shù)據(jù)庫系統(tǒng)包括數(shù)據(jù)節(jié)點和協(xié)調(diào)節(jié)點，該方法用于數(shù)據(jù)節(jié)點，包括：

將協(xié)調(diào)節(jié)點發(fā)送的第一數(shù)據(jù)表中第一目標列的數(shù)據(jù)存儲在本地存儲器，該第一目標列為第一數(shù)據(jù)表中與其他數(shù)據(jù)表連接次數(shù)超過預設次數(shù)的列；接收協(xié)調(diào)節(jié)點發(fā)送的表連接請求，該表連接請求包括第一數(shù)據(jù)表的標識、第一目標列的標識、第二數(shù)據(jù)表的標識以及第二數(shù)據(jù)表的第二目標列的標識；根據(jù)表連接請求，從本地存儲器中獲取第一目標列及位于第二目標列上的第二數(shù)據(jù)；將第一目標列上的第一數(shù)據(jù)所在行的數(shù)據(jù)與第二數(shù)據(jù)所在行的數(shù)據(jù)進行連接，以得到連接結果，其中，第一數(shù)據(jù)為第一目標列上的任一數(shù)據(jù)，且第一數(shù)據(jù)與第二數(shù)據(jù)相同；向協(xié)調(diào)節(jié)點發(fā)送連接結果。在該過程中，每個數(shù)據(jù)節(jié)點無需將本地所存儲的數(shù)據(jù)發(fā)送至協(xié)調(diào)節(jié)點，根據(jù)第一目標列及第二目標列上的數(shù)據(jù)，在本地即可對第一數(shù)據(jù)表中的數(shù)據(jù)和第二數(shù)據(jù)表中的數(shù)據(jù)進行連接，不僅減少了數(shù)據(jù)傳輸量從而縮短了網(wǎng)絡響應時間，因而業(yè)務性能較佳，而且能減少對數(shù)據(jù)節(jié)點存儲資源的占用。

結合第一方面，在第一方面的第一種可能的實現(xiàn)方式中，該方法還包括：在第一數(shù)據(jù)表的分布列與第一目標列相異的情況下，數(shù)據(jù)節(jié)點接收協(xié)調(diào)節(jié)點發(fā)送的分布列的數(shù)據(jù)，該分布列為第一數(shù)據(jù)表的行標識所在的列；將分布列的數(shù)據(jù)存儲在本地存儲器。由于數(shù)據(jù)節(jié)點將分布列的數(shù)據(jù)與連接結果一同發(fā)送至協(xié)調(diào)節(jié)點，從而使得協(xié)調(diào)節(jié)點在對連接結果進行處理時，可根據(jù)該分布列查找到空洞行標識所在的數(shù)據(jù)節(jié)點，進而獲取到空洞行標識所在行上的數(shù)據(jù)，以提高連接后的數(shù)據(jù)表的準確性。

結合第一方面或第一方面的第一種實現(xiàn)方式，在第一方面的第二種可能的實現(xiàn)方式中，該方法還包括：