[發(fā)明專利]分布式數(shù)據(jù)庫的表數(shù)據(jù)查詢方法、表數(shù)據(jù)查詢裝置及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202110943325.3
• 申請日: 2021-08-17
• 公開（公告）號(hào): CN113420033B
• 公開（公告）日: 2021-12-07
• 發(fā)明（設(shè)計(jì)）人: 唐銘豆;余璜;潘毅
• 申請（專利權(quán)）人: 北京奧星貝斯科技有限公司
• 主分類號(hào): G06F16/22
• 分類號(hào): G06F16/22;G06F16/2455;G06F16/2458;G06F16/27
• 代理公司: 北京永新同創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11376
• 代理人: 林錦輝;劉景峰

1.一種用于分布式數(shù)據(jù)庫的表數(shù)據(jù)查詢方法，所述方法由表數(shù)據(jù)處理節(jié)點(diǎn)中的表數(shù)據(jù)查詢裝置執(zhí)行，所述表數(shù)據(jù)查詢方法包括：

響應(yīng)于表數(shù)據(jù)處理節(jié)點(diǎn)執(zhí)行第一執(zhí)行計(jì)劃讀取到驅(qū)動(dòng)表的行數(shù)據(jù)，確定所述表數(shù)據(jù)處理節(jié)點(diǎn)的緩存裝置中是否緩存有所述行數(shù)據(jù)；

在所述緩存裝置中緩存有所述行數(shù)據(jù)時(shí)，生成數(shù)據(jù)重掃指令，所述數(shù)據(jù)重掃指令包括所述行數(shù)據(jù)的行號(hào)；

將所述數(shù)據(jù)重掃指令發(fā)送給所述表數(shù)據(jù)處理節(jié)點(diǎn)的被驅(qū)動(dòng)表掃描調(diào)度裝置，以指示所述被驅(qū)動(dòng)表掃描調(diào)度裝置根據(jù)所述行數(shù)據(jù)的行號(hào)從中間結(jié)果存儲(chǔ)裝置中讀取對應(yīng)的被驅(qū)動(dòng)表數(shù)據(jù)查詢結(jié)果；

在所述緩存裝置未緩存有所述行數(shù)據(jù)時(shí)，生成數(shù)據(jù)掃描指令，所述數(shù)據(jù)掃描指令包括所述行數(shù)據(jù)的行號(hào)；

將所讀取的驅(qū)動(dòng)表的行數(shù)據(jù)存儲(chǔ)在所述緩存裝置中；

將所述數(shù)據(jù)掃描指令發(fā)送給所述被驅(qū)動(dòng)表掃描調(diào)度裝置，以指示所述被驅(qū)動(dòng)表掃描調(diào)度裝置調(diào)度各個(gè)對應(yīng)的被驅(qū)動(dòng)表存儲(chǔ)節(jié)點(diǎn)執(zhí)行第二執(zhí)行計(jì)劃來獲取被驅(qū)動(dòng)表數(shù)據(jù)查詢結(jié)果，所述第二執(zhí)行計(jì)劃是部署在各個(gè)被驅(qū)動(dòng)表存儲(chǔ)節(jié)點(diǎn)處的分布式執(zhí)行計(jì)劃，其中，各個(gè)對應(yīng)的被驅(qū)動(dòng)表存儲(chǔ)節(jié)點(diǎn)的被驅(qū)動(dòng)表數(shù)據(jù)查詢結(jié)果被返回給所述被驅(qū)動(dòng)表掃描調(diào)度裝置，并且與所述行數(shù)據(jù)的行號(hào)相對應(yīng)地存儲(chǔ)在所述中間結(jié)果存儲(chǔ)裝置中，以及

從所述被驅(qū)動(dòng)表掃描調(diào)度裝置獲取所述被驅(qū)動(dòng)表數(shù)據(jù)查詢結(jié)果。

2.如權(quán)利要求1所述的表數(shù)據(jù)查詢方法，其中，在所述緩存裝置未緩存有所述行數(shù)據(jù)時(shí)，生成數(shù)據(jù)掃描指令包括：

在所述緩存裝置未緩存有所述行數(shù)據(jù)時(shí)，確定與所述行數(shù)據(jù)對應(yīng)的條件下推參數(shù)；以及

根據(jù)與所述行數(shù)據(jù)對應(yīng)的條件下推參數(shù)，生成數(shù)據(jù)掃描指令，所述數(shù)據(jù)掃描指令用于指示所述被驅(qū)動(dòng)表掃描調(diào)度裝置調(diào)度各個(gè)對應(yīng)的被驅(qū)動(dòng)表存儲(chǔ)節(jié)點(diǎn)在所述條件下推參數(shù)下執(zhí)行第二執(zhí)行計(jì)劃來獲取被驅(qū)動(dòng)表數(shù)據(jù)查詢結(jié)果。

3.如權(quán)利要求1所述的表數(shù)據(jù)查詢方法，還包括：

在所述緩存裝置未緩存有所述行數(shù)據(jù)時(shí)，確定與所述行數(shù)據(jù)對應(yīng)的條件下推參數(shù)，

所述條件下推參數(shù)與所述數(shù)據(jù)掃描指令一起被所述被驅(qū)動(dòng)表掃描調(diào)度裝置下發(fā)給對應(yīng)的被驅(qū)動(dòng)表存儲(chǔ)節(jié)點(diǎn)。

4.如權(quán)利要求2或3所述的表數(shù)據(jù)查詢方法，其中，在所述緩存裝置未緩存有所述行數(shù)據(jù)時(shí)，確定與所述行數(shù)據(jù)對應(yīng)的條件下推參數(shù)包括：

在所述緩存裝置未緩存有所述行數(shù)據(jù)時(shí)，根據(jù)所述行數(shù)據(jù)中的連接列的行值確定所述行數(shù)據(jù)所對應(yīng)的條件下推參數(shù)。

5.如權(quán)利要求1所述的表數(shù)據(jù)查詢方法，其中，所述第一執(zhí)行計(jì)劃包括嵌套式執(zhí)行計(jì)劃，在所述緩存裝置中緩存有所述行數(shù)據(jù)時(shí)，生成數(shù)據(jù)重掃指令包括：

在所述緩存裝置緩存有所述行數(shù)據(jù)且所述行數(shù)據(jù)是響應(yīng)于所述表數(shù)據(jù)處理節(jié)點(diǎn)執(zhí)行所述嵌套式執(zhí)行計(jì)劃的最內(nèi)層執(zhí)行計(jì)劃而讀取的行數(shù)據(jù)時(shí)，生成所述數(shù)據(jù)重掃指令，

在所述緩存裝置緩存有所述行數(shù)據(jù)且所述行數(shù)據(jù)不是響應(yīng)于所述表數(shù)據(jù)處理節(jié)點(diǎn)執(zhí)行所述嵌套式執(zhí)行計(jì)劃的最內(nèi)層執(zhí)行計(jì)劃而讀取的行數(shù)據(jù)時(shí)，生成所述數(shù)據(jù)掃描指令。

6.如權(quán)利要求5所述的表數(shù)據(jù)查詢方法，其中，所述嵌套式執(zhí)行計(jì)劃的最內(nèi)層執(zhí)行計(jì)劃經(jīng)由優(yōu)化器在執(zhí)行計(jì)劃編譯階段標(biāo)識(shí)出。

7.如權(quán)利要求1所述的表數(shù)據(jù)查詢方法，其中，所述被驅(qū)動(dòng)表掃描調(diào)度裝置所調(diào)度的第二執(zhí)行計(jì)劃包括至少兩個(gè)第二分布式執(zhí)行子計(jì)劃，各個(gè)第二分布式執(zhí)行子計(jì)劃之間通過所述中間結(jié)果存儲(chǔ)裝置傳遞各自的處理結(jié)果。

8.如權(quán)利要求1所述的表數(shù)據(jù)查詢方法，其中，所述表數(shù)據(jù)處理節(jié)點(diǎn)包括表連接節(jié)點(diǎn)或者子查詢節(jié)點(diǎn)。