基于高級(jí)語(yǔ)言并發(fā)聚合計(jì)算的分庫(kù)分表merge查詢(xún)方法

基本信息

申請(qǐng)?zhí)?/td> CN201510567753.5 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN105138676B 公開(kāi)(公告)日 2017-11-24
申請(qǐng)公布號(hào) CN105138676B 申請(qǐng)公布日 2017-11-24
分類(lèi)號(hào) G06F17/30(2006.01)I 分類(lèi) 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 魏偉;陳祥獻(xiàn);馮國(guó)平;商莖正;虞華鋒;陳小勇 申請(qǐng)(專(zhuān)利權(quán))人 中國(guó)銀行股份有限公司蒼南縣支行
代理機(jī)構(gòu) 杭州求是專(zhuān)利事務(wù)所有限公司 代理人 葉志堅(jiān)
地址 325899 浙江省溫州市蒼南縣靈溪鎮(zhèn)蒼南縣工業(yè)園區(qū)塘河南路以北
法律狀態(tài) -

摘要

摘要 本發(fā)明公開(kāi)了一種基于高級(jí)語(yǔ)言并發(fā)聚合計(jì)算的分庫(kù)分表merge查詢(xún)方法,該方法首先通過(guò)擴(kuò)展Spring?template技術(shù)解決關(guān)系數(shù)據(jù)庫(kù)分庫(kù)分表的問(wèn)題。利用ThreadLocal來(lái)保證并發(fā)訪問(wèn)的分庫(kù)鍵值的安全性。其次利用CompletableFuture技術(shù)來(lái)異步的、非阻塞的查詢(xún)各分庫(kù)和分表;最后使用stream技術(shù)來(lái)聚合所有的查詢(xún)結(jié)果,形成最終結(jié)果返回給客戶(hù)端。既利用了傳統(tǒng)關(guān)系數(shù)據(jù)的強(qiáng)大數(shù)據(jù)分析能力,又使用了最新的stream技術(shù)將中間結(jié)果reduce成最終結(jié)果。既保留了傳統(tǒng)關(guān)系數(shù)據(jù)庫(kù)的穩(wěn)定性和強(qiáng)大的功能,又給傳統(tǒng)數(shù)據(jù)庫(kù)擴(kuò)展了最新的MapReduce技術(shù)。