[發明專利]數據查詢方法和集群數據庫系統

在審

• 申請號: 201310082063.1
• 申請日: 2013-03-14
• 公開（公告）號: CN103123652A
• 公開（公告）日: 2013-05-29
• 發明（設計）人: 宋懷明;狄靜舒;王勇;苗艷超;劉新春;邵宗有
• 申請（專利權）人: 曙光信息產業（北京）有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京德恒律治知識產權代理有限公司 11409
• 代理人: 章社杲;孫征

1.一種數據查詢方法，包括：

查詢解析器對接收到的查詢請求進行解析，分解成查詢任務流并產生查詢任務流的執行規則；

所述查詢解析器根據所述查詢任務流的執行規則將所述查詢任務流中的一個或多個查詢任務分配給相應的各數據庫節點；

各數據庫節點接收到所分配的查詢任務后，根據所述查詢任務流的執行規則并行執行對應的查詢任務，并且每個數據庫節點會將其執行某一查詢任務得到的查詢數據與其他相關聯數據庫節點執行同一查詢任務得到的查詢數據合并得到查詢結果數據，該查詢結果數據是與所述查詢請求對應的最終查詢結果數據，或者，是用作執行下一查詢任務的輸入數據以便所述多個數據庫節點根據所述查詢任務流的執行規則執行完所述查詢任務流后得到與所述查詢請求對應的最終查詢結果數據。

2.根據權利要求1的數據查詢方法，其特征在于，所述查詢任務流的執行規則包括為所述一個或多個查詢任務指定執行的數據庫節點，以及所述一個或多個查詢任務之間被執行的順序關系。

3.根據權利要求2的數據查詢方法，其特征在于，所述數據查詢方法還包括：

所述查詢解析器還用于根據所述查詢任務流的執行規則將所述查詢任務流中的第一查詢任務分配給執行所述第一查詢任務的各數據庫節點以及將其他查詢任務分配給執行所述其他查詢任務的各數據庫節點；

執行所述第一查詢任務的各數據庫節點并行執行所述第一查詢任務，并從其存儲的數據中獲得相應的查詢數據；

執行所述第一查詢任務的各數據庫節點將執行所述第一查詢任務得到的查詢數據發送給其他相關聯數據庫節點，以及，接收其他相關聯數據庫節點發送的執行所述第一查詢任務得到的查詢數據；

執行所述第一查詢任務的各數據庫節點將其執行所述第一查詢任務得到的查詢數據與其他相關聯數據節點執行所述第一查詢任務得到的查詢數據合并得到第一查詢任務的查詢結果數據，并作為執行所述第一查詢任務后的下一查詢任務的數據庫節點的輸入數據。

4.根據權利要求1-3任一項所述的數據查詢方法，其特征在于，每個查詢任務通過以下方式表示：{查詢算子；執行查詢任務的數據庫節點指示信息；目標數據庫節點指示信息；數據分派方法}。

5.根據權利要求4所述的數據查詢方法，其特征在于，所述數據查詢方法還包括：

執行所述第一查詢任務的各數據庫節點根據所述第一查詢任務中攜帶的目標數據庫節點信息和數據分配方法將所述第一查詢任務的查詢結果數據分派給相應的目標數據庫節點；和/或，

執行所述第一查詢任務的各數據庫節點在并行執行第一查詢任務且合并得到所述第一查詢任務的查詢結果數據后，在各數控庫節點之間進行一次同步。

6.一種集群數據庫系統，包括查詢解析器和多個數據庫節點，其中：

所述查詢解析器，用于對接收到的查詢請求進行解析，分解成查詢任務流并產生查詢任務流的執行規則；以及，根據所述查詢任務流的執行規則將所述查詢任務流中的一個或多個查詢任務分配給相應的各數據庫節點；

所述數據庫節點，用于執行以下功能：

接收到所分配的查詢任務后，根據所述查詢任務流的執行規則與其他相關聯數據庫節點一起并行執行相對應的查詢任務；以及，

將其執行某一查詢任務得到的查詢數據與其他相關聯數據庫節點執行同一查詢任務得到的查詢數據合并得到查詢結果數據，該查詢結果數據是與所述查詢請求對應的最終查詢結果數據，或者，是用作執行下一查詢任務的輸入數據以便所述多個數據庫節點根據所述查詢任務流的執行規則執行完所述查詢任務流后得到與所述查詢請求對應的最終查詢結果數據。