今天就跟大家聊聊有關(guān)Greenplum數(shù)據(jù)庫中拉鏈表的實(shí)現(xiàn)是怎樣的，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

成都創(chuàng)新互聯(lián)始終堅(jiān)持【策劃先行，效果至上】的經(jīng)營理念，通過多達(dá)十多年累計(jì)超上千家客戶的網(wǎng)站建設(shè)總結(jié)了一套系統(tǒng)有效的推廣解決方案，現(xiàn)已廣泛運(yùn)用于各行各業(yè)的客戶，其中包括：履帶攪拌車等企業(yè)，備受客戶稱揚(yáng)。

歷史拉鏈表是一種數(shù)據(jù)模型，主要是針對數(shù)據(jù)倉庫設(shè)計(jì)中表存儲數(shù)據(jù)的方式而定義的；顧名思義，所謂歷史拉鏈表，就是記錄一個(gè)事務(wù)從開始一直到當(dāng)前狀態(tài)的所有變化的信息，拉鏈表可以避免按每一天存儲所有記錄造成的海量存儲問題，同事也是處理緩慢變化數(shù)據(jù)的一種常見方式。

一、概念

在拉鏈表中，每一條數(shù)據(jù)都有一個(gè)生效日期(sdate) 和 失效日期(edate)。假設(shè)在一個(gè)用戶表中，在 2019年10月8日 新增了兩個(gè)用戶，則這兩條記錄的生效時(shí)間為當(dāng)天，由于到 2019年10月8日 為止，這兩條記錄還沒有被修改過，所以失效時(shí)間為無窮大，這里設(shè)置為數(shù)據(jù)庫中的最大值(2999-12-31)，如圖所示：

第二天(2019-10-09)，用戶 1001 被刪除，用戶 1002 的電話號碼被修改成 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號 的歷史數(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ù)庫(如 oracle)表推送過來的數(shù)據(jù) ，表結(jié)構(gòu)和源數(shù)據(jù)庫的表結(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
);

三、存儲過程的創(chuàng)建

在這里為了方便閱讀以及代碼的編寫，先寫出整體的存儲過程架構(gòu)，然后我們在一步一步添加代碼：

-- 將當(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')
                               );

五、測試

要測試?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)行拉鏈測試：

select My_FIN_GL_SUBJECT_PRO('2019-10-11');  --調(diào)用函數(shù)
select * from T_FIN_ACCTION_TAR;   --查詢拉鏈表

測試結(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)表

效果圖如下：

看完上述內(nèi)容，你們對Greenplum數(shù)據(jù)庫中拉鏈表的實(shí)現(xiàn)是怎樣的有進(jìn)一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

當(dāng)前題目：Greenplum數(shù)據(jù)庫中拉鏈表的實(shí)現(xiàn)是怎樣的
分享路徑：http://chinadenli.net/article8/gepeop.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供域名注冊、動(dòng)態(tài)網(wǎng)站、品牌網(wǎng)站建設(shè)、ChatGPT、外貿(mào)建站、品牌網(wǎng)站設(shè)計(jì)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)