這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)Greenplum數(shù)據(jù)庫(kù)中怎么實(shí)現(xiàn)拉鏈表,文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
成都創(chuàng)新互聯(lián)公司,為您提供重慶網(wǎng)站建設(shè)、成都網(wǎng)站制作、網(wǎng)站營(yíng)銷推廣、網(wǎng)站開發(fā)設(shè)計(jì),對(duì)服務(wù)成都地磅秤等多個(gè)行業(yè)擁有豐富的網(wǎng)站建設(shè)及推廣經(jīng)驗(yàn)。成都創(chuàng)新互聯(lián)公司網(wǎng)站建設(shè)公司成立于2013年,提供專業(yè)網(wǎng)站制作報(bào)價(jià)服務(wù),我們深知市場(chǎng)的競(jìng)爭(zhēng)激烈,認(rèn)真對(duì)待每位客戶,為客戶提供賞心悅目的作品。 與客戶共同發(fā)展進(jìn)步,是我們永遠(yuǎn)的責(zé)任!
一、概念
在拉鏈表中,每一條數(shù)據(jù)都有一個(gè)生效日期(sdate) 和 失效日期(edate)。假設(shè)在一個(gè)用戶表中,在 2019年10月8日 新增了兩個(gè)用戶,則這兩條記錄的生效時(shí)間為當(dāng)天,由于到 2019年10月8日 為止,這兩條記錄還沒有被修改過,所以失效時(shí)間為無窮大,這里設(shè)置為數(shù)據(jù)庫(kù)中的最大值(2999-12-31),如圖所示:
第二天(2019-10-09),用戶 1001 被刪除,用戶 1002 的電話號(hào)碼被修改成 16500000006。為了保留歷史狀態(tài),用戶 1001 的失效時(shí)間被修改成 2019-10-09,用戶 1002 則變成兩條記錄,如圖所示:
第三天(2019-10-10),又新增了用戶 1003,則用戶表數(shù)據(jù)如圖:
如果要查詢最新的數(shù)據(jù),那么只要查詢失效時(shí)間為 2999-12-31 的數(shù)據(jù)即可,如果要查詢 10月8號(hào) 的歷史數(shù)據(jù),則篩選生效時(shí)間 <= 2019-10-08 并且失效時(shí)間 > 2019-10-08 的數(shù)據(jù)即可;如果查詢的是 10月9日的數(shù)據(jù),那么篩選條件則是生效時(shí)間 <= 2019-10-09 并且失效時(shí)間 > 2019-10-09;以此類推。
二、表的創(chuàng)建
臨時(shí)源表 T_FIN_ACCTION_SRC,接收其它數(shù)據(jù)庫(kù)(如 oracle)表推送過來的數(shù)據(jù) ,表結(jié)構(gòu)和源數(shù)據(jù)庫(kù)的表結(jié)構(gòu)一致。
--源表 create table T_FIN_ACCTION_SRC( eNo varchar(6), eName varchar(10), ePhone varchar(11), eData_date date );
目標(biāo)表 ( 即拉鏈表 ) T_FIN_ACCTION_TAR,這里注意的是:拉鏈表把源表的時(shí)間字段改成了生效時(shí)間和失效時(shí)間。
--拉鏈表 create table T_FIN_ACCTION_TAR( eNo varchar(6), eName varchar(10), ePhone varchar(11), sdate date, edate date );
三、存儲(chǔ)過程的創(chuàng)建
在這里為了方便閱讀以及代碼的編寫,先寫出整體的存儲(chǔ)過程架構(gòu),然后我們?cè)谝徊揭徊教砑哟a:
-- 將當(dāng)前時(shí)間傳入 (也可以傳入昨天的時(shí)間哦,隨機(jī)應(yīng)變,如果傳入的時(shí)間是今天則使用中要將時(shí)間減一,因?yàn)槲覀円幚淼氖亲蛱斓臄?shù)據(jù))
-- 將當(dāng)前時(shí)間傳入 (也可以傳入昨天的時(shí)間哦,隨機(jī)應(yīng)變,如果傳入的時(shí)間是今天則使用中要將時(shí)間減一,因?yàn)槲覀円幚淼氖亲蛱斓臄?shù)據(jù)) create or replace function My_FIN_GL_SUBJECT_PRO(IN P_TODAY VARCHAR) returns void as $$ declare begin --1.目標(biāo)表中沒有此主鍵的則確定為新增 - 新增 --2.源表中沒有該ID則進(jìn)行關(guān)鏈 - 刪除 --3.修改 --3.1 閉鏈:目標(biāo)表中有此主鍵的記錄,狀態(tài)值不同,更新結(jié)束日期為當(dāng)天 --3.2 開鏈:目標(biāo)表中新增一條修改的數(shù)據(jù),更新結(jié)束日期為無窮大 end; $$ language plpgsql;
四、拉鏈的過程實(shí)現(xiàn)
1.目標(biāo)表中沒有此主鍵的則確定為新增 - 新增
insert into gplcydb.public.T_FIN_ACCTION_TAR(eNo,eName,ePhone,sdate,edate) select s.eNo,s.eName,s.ePhone,s.eData_date,to_date('2999-12-31','yyyy-mm-dd') from gplcydb.public.T_FIN_ACCTION_SRC s where s.eData_date=(to_date(P_TODAY,'yyyy-mm-dd') - 1) and not exists( select 1 from gplcydb.public.T_FIN_ACCTION_TAR t where s.eNo=t.eNo and s.eName=t.eName and s.ePhone=t.ePhone );
2.源表中沒有該ID則進(jìn)行關(guān)鏈 - 刪除
update gplcydb.public.T_FIN_ACCTION_TAR a set edate=(to_date(P_TODAY,'yyyy-mm-dd')-1) where not exists( select 1 from gplcydb.public.T_FIN_ACCTION_SRC s where s.eNo=a.eNo and a.edate=to_date('2999-12-31', 'yyyy-mm-dd') );
3.修改
3.1 閉鏈:目標(biāo)表中有此主鍵的記錄,狀態(tài)值不同,更新結(jié)束日期為當(dāng)天
update gplcydb.public.T_FIN_ACCTION_TAR b set edate=(to_date(P_TODAY,'yyyy-mm-dd')-1) where b.edate=to_date('2999-12-31','yyyy-mm-dd') and exists( select 1 from gplcydb.public.T_FIN_ACCTION_SRC s where s.eNo = b.eNo and b.sdate < (to_date(P_TODAY,'yyyy-mm-dd')-1) and ( s.eName <> b.eName or s.ePhone <> b.ePhone ) );
3.2 開鏈:目標(biāo)表中新增一條修改的數(shù)據(jù),更新結(jié)束日期為無窮大
insert into gplcydb.public.T_FIN_ACCTION_TAR(eNo,eName,ePhone,sdate,edate) select s.eNo,s.eName,s.ePhone,(to_date(P_TODAY,'yyyy-mm-dd') - 1),to_date('2999-12-31','yyyy-mm-dd') from gplcydb.public.T_FIN_ACCTION_SRC s where s.eData_date=(to_date(P_TODAY,'yyyy-mm-dd') - 1) and exists( --處理數(shù)據(jù)斷鏈新增的情況 select 1 from ( select eNo,sdate,max(edate) end_date from gplcydb.public.T_FIN_ACCTION_TAR group by eNo,sdate) t where t.eNo=s.eNo and s.eData_date = t.sdate and t.end_date <= to_date(P_TODAY,'yyyy-mm-dd') );
五、測(cè)試
要測(cè)試?yán)満瘮?shù),首先我們必須要在原表中插入數(shù)據(jù)(模擬一天全量的數(shù)據(jù)):
insert into T_FIN_ACCTION_SRC values('1001','feiniu','18500000001','2019-10-10'); insert into T_FIN_ACCTION_SRC values('1002','beibei','18400000005','2019-10-10'); insert into T_FIN_ACCTION_SRC values('1003','yuyu','13800000005','2019-10-10');
調(diào)用函數(shù)進(jìn)行拉鏈測(cè)試:
select My_FIN_GL_SUBJECT_PRO('2019-10-11'); --調(diào)用函數(shù) select * from T_FIN_ACCTION_TAR; --查詢拉鏈表
測(cè)試結(jié)果如下圖:
插入第二天全量數(shù)據(jù),這些數(shù)據(jù)中有新增的數(shù)據(jù),有源數(shù)據(jù)被刪除,還有源數(shù)據(jù)被修改,完整的模擬sql語句如下:
delete from T_FIN_ACCTION_SRC where eno='1003'; insert into T_FIN_ACCTION_SRC values('1004','kongkong','13800000666','2019-10-11'); update T_FIN_ACCTION_SRC set ename='xiaofeifei' where eno='1001'; select * from T_FIN_ACCTION_SRC;
原表的效果圖如下:
接下來執(zhí)行拉鏈函數(shù):
--執(zhí)行拉鏈函數(shù) select My_FIN_GL_SUBJECT_PRO('2019-10-12'); select * from T_FIN_ACCTION_TAR; --查詢目標(biāo)表
效果圖如下:
上述就是小編為大家分享的Greenplum數(shù)據(jù)庫(kù)中怎么實(shí)現(xiàn)拉鏈表了,如果剛好有類似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
名稱欄目:Greenplum數(shù)據(jù)庫(kù)中怎么實(shí)現(xiàn)拉鏈表
文章URL:http://muchs.cn/article36/ghejsg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供標(biāo)簽優(yōu)化、小程序開發(fā)、企業(yè)建站、全網(wǎng)營(yíng)銷推廣、品牌網(wǎng)站建設(shè)、移動(dòng)網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)