日期:2014-05-16  浏览次数:21039 次

拉链表或是type2表脏数据修复问题
表名ABC
字段
ACCT_ID    PROD_ID     ETL_LOAD_DATE     ETL_UPDATE_DATE     ETL_CURR_FLAG
522     6437     2/1/2013       2/2/2013     D
522     6437     2/3/2013       2/4/2013     D
522     6437     2/7/2013       2/8/2013     U
522     6437     2/8/2013       2/9/2013     D
522     6437     2/28/2013     3/31/2013   D

ACCT_ID和PROD_ID是联合主键

要把数据修复成如下:
522     6437     2/1/2013      2/3/2013     U
522     6437     2/3/2013      2/7/2013     U
522     6437     2/7/2013      2/8/2013     U
522     6437     2/8/2013      2/28/2013   U
522     6437     2/28/2013    12/31/2999  I

U is update
D is delete
I is insert

就是把这张表按主键分组,找到最大的ETL_UPATE_DATE, 把它转换成29991231;ETL_CURR_FLAG转换成I

ETL_UPDATE_DATE 非最大的,所有ETL_CURR_FLAG转换成U;ETL_UPDATE_DATE 第一条的要跟第二条的ETL_LOAD_DATE衔接一致,像这个例子一样,按主键来查有五条,其中最大的一条是i,其她都是U,并且时间要衔接上

------解决方案--------------------
connect by ETL_UPDATE_DATE = ETL_LOAD_DATE做出拉链表,然后再partition by取出最大ETL_UPDATE_DATE的纪录,对应更新就完了吧
select *
  from (select cc.*,
               row_number() over(partition by ACCT_ID, PROD_ID order by ETL_UPDATE_DATE desc) rn
          from (select * from ABC CONNECT BY ETL_UPDATE_DATE = ETL_LOAD_DATE) cc)
 where rn = 1

------解决方案--------------------
MERGE INTO TEST1 T1
USING (SELECT T1.*,
              NVL(T2.UP_DT, '31/DEC/2099') UP_DT,
              NVL(T2.UP_FLAG, 'I') UP_FLAG
         FROM TEST1 T1,
              (SELECT T1