分布式SQL的實(shí)時(shí)查詢方法和系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN202110995553.5 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN113761024A 公開(kāi)(公告)日 2021-12-07
申請(qǐng)公布號(hào) CN113761024A 申請(qǐng)公布日 2021-12-07
分類號(hào) G06F16/2458(2019.01)I;G06F16/2455(2019.01)I;G06F16/242(2019.01)I;G06F16/27(2019.01)I;G06F8/41(2018.01)I 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 張雷;陳凌云;李寧;張一鵬;陳炎 申請(qǐng)(專利權(quán))人 德邦證券股份有限公司
代理機(jī)構(gòu) 北京萬(wàn)思博知識(shí)產(chǎn)權(quán)代理有限公司 代理人 劉冀
地址 200120上海市浦東新區(qū)福山路500號(hào)城建國(guó)際中心18樓
法律狀態(tài) -

摘要

摘要 本申請(qǐng)實(shí)施例提供一種分布式SQL的實(shí)時(shí)查詢方法和系統(tǒng)。該方法包括:接收SQL跨庫(kù)查詢請(qǐng)求,所述跨庫(kù)查詢請(qǐng)求包括多個(gè)子查詢請(qǐng)求;解析所述跨庫(kù)查詢請(qǐng)求,通過(guò)with語(yǔ)法標(biāo)注,確定每個(gè)子查詢對(duì)應(yīng)的源數(shù)據(jù)庫(kù)和查詢計(jì)劃;根據(jù)所述查詢計(jì)劃,將子查詢分發(fā)到各個(gè)源數(shù)據(jù)庫(kù)上執(zhí)行分布式并行查詢,每個(gè)查詢得到相應(yīng)的一張內(nèi)存數(shù)據(jù)表;將所述內(nèi)存數(shù)據(jù)表均存入內(nèi)存數(shù)據(jù)庫(kù);合并所有內(nèi)存數(shù)據(jù)表,將合并后的結(jié)果返回給客戶端。本申請(qǐng)支持實(shí)時(shí)跨庫(kù)查詢,不需要類似數(shù)倉(cāng)的數(shù)據(jù)同步過(guò)程。避免跨庫(kù)表名沖突,能夠直接利用源庫(kù)的語(yǔ)法和函數(shù)庫(kù)。具有良好的可讀性,物理源庫(kù)自身的函數(shù)庫(kù)和語(yǔ)法特性、索引優(yōu)化都可以直接使用。