主體拉鏈表存儲過程
阿新 • • 發佈：2018-09-18
註銷 trunc ont org lar sele nis acc ace
pro_scd_reg_marpripinfo
CREATE OR REPLACE PROCEDURE pro_scd_reg_marpripinfo IS n_log_id PLS_INTEGER; BEGIN /* 1.變更信息、吊銷信息、註銷信息 2.根據REG_MARPRIPINFO中是否有記錄判斷全量或增量抽取，如無，則全量抽取，如有，則增量抽取 */ --REG_MARPRIPINFO主體登記信息 DECLARE n_log_id PLS_INTEGER := pkg_debug.log_start(‘REG_MARPRIPINFO‘); BEGIN pkg_idx.drop_all(‘ODS_REG_MARPRIPINFO_LOCAL‘, TRUE); EXECUTE IMMEDIATE ‘TRUNCATE TABLE ODS_REG_MARPRIPINFO_LOCAL‘; INSERT /*+append*/ INTO ods_reg_marpripinfo_local SELECT * FROM syn_reg_marpripinfo; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘ID,TIMESTAMP‘, in_v_table_name => ‘ODS_REG_MARPRIPINFO_LOCAL‘, in_b_force => TRUE); pkg_idx.create_idx(in_v_column_list => ‘ID,APPRDATE‘, in_v_table_name => ‘ODS_REG_MARPRIPINFO_LOCAL‘, in_b_force=> TRUE); pkg_debug.log_end(n_log_id); EXCEPTION WHEN OTHERS THEN pkg_debug.log_end(n_log_id); END; DECLARE n_log_id PLS_INTEGER; BEGIN n_log_id := pkg_debug.log_start(‘ODS_REG_MARPRIPINFO‘); pkg_idx.drop_all(‘F_BGXX‘, TRUE); --變更信息 EXECUTE IMMEDIATE ‘TRUNCATE TABLE F_BGXX‘; --變更信息 INSERT /*+append*/ INTO f_bgxx SELECT * FROM v_bgxx; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘MARPRID,APPRDATE‘, in_v_table_name => ‘F_BGXX‘, in_b_force => TRUE); --吊銷信息 pkg_idx.drop_all(‘F_DXXX‘, TRUE); --吊銷信息 EXECUTE IMMEDIATE ‘TRUNCATE TABLE F_DXXX‘; INSERT /*+append*/ INTO f_dxxx SELECT * FROM v_dxxx; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘MARPRID,APPRDATE‘, in_v_table_name => ‘F_DXXX‘, in_b_force => TRUE); --註銷信息 pkg_idx.drop_all(‘F_ZXXX‘, TRUE); --註銷信息 EXECUTE IMMEDIATE ‘TRUNCATE TABLE F_ZXXX‘; INSERT /*+append*/ INTO f_zxxx SELECT * FROM v_zxxx; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘MARPRID,APPRDATE‘, in_v_table_name => ‘F_ZXXX‘, in_b_force => TRUE); --改制信息 pkg_idx.drop_all(‘F_GZXX‘, TRUE); --改制信息（內資外資互轉） EXECUTE IMMEDIATE ‘TRUNCATE TABLE F_GZXX‘; INSERT /*+append*/ INTO f_gzxx SELECT * FROM v_gzxx; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘MARPRID,APPRDATE‘, in_v_table_name => ‘F_GZXX‘, in_b_force => TRUE); --遷入遷出信息 pkg_idx.drop_all(‘F_QRQC‘, TRUE); EXECUTE IMMEDIATE ‘TRUNCATE TABLE F_QRQC‘; INSERT /*+append*/ INTO f_qrqc SELECT * FROM v_qrqc; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘MARPRID,APPRDATE‘, in_v_table_name => ‘F_QRQC‘, in_b_force => TRUE); pkg_debug.log_end(n_log_id); EXCEPTION WHEN OTHERS THEN pkg_debug.log_end(n_log_id); END; IF NOT pkg_tab.no_data_in(‘ODS_REG_MARPRIPINFO‘) THEN n_log_id := pkg_debug.log_start(‘ODS_REG_MARPRIPINFO‘, ‘每日增量‘); --更新目標表中非緩慢變化字段 MERGE INTO ods_reg_marpripinfo dest USING ods_reg_marpripinfo_local src ON (src.id = dest.id AND to_char(src.apprdate, ‘yyyymmdd‘) = to_char(dest.apprdate, ‘yyyymmdd‘)) WHEN MATCHED THEN UPDATE SET /*TIMESTAMP = src.timestamp ,*/ namepreapprid = src.namepreapprid, entname = src.entname, enttra = src.enttra, grpshform = src.grpshform, oplocdistrict = src.oplocdistrict, industryphy = src.industryphy, industryco = src.industryco, lerep = src.lerep, regcap = src.regcap, regcapcur = src.regcapcur, reccap = src.reccap, forreccap = src.forreccap, forregcap = src.forregcap, congro = src.congro, dom = src.dom, tel = src.tel, postalcode = src.postalcode, email = src.email, abuitemco = src.abuitemco, opscope = src.opscope, ptbusscope = src.ptbusscope, enttype = src.enttype, enttypeitem = src.enttypeitem, enttypeminu = src.enttypeminu, opfrom = src.opfrom, opto = src.opto, regno = src.regno, oldregno = src.oldregno, forregno = src.forregno, supervper = src.supervper, superorgid = src.superorgid, estdate = src.estdate --apprdate=src.apprdate , perid = src.perid, accopin = src.accopin, remark = src.remark, state = src.state, orgid = src.orgid, jobid = src.jobid, adbusign = src.adbusign, townsign = src.townsign, regtype = src.regtype, priorgid = src.priorgid, superpriorgid = src.superpriorgid, approrgid = src.approrgid, enttypepro = src.enttypepro, optype = src.optype, empnum = src.empnum, compform = src.compform, supdistrict = src.supdistrict, venind = src.venind, parnum = src.parnum, exenum = src.exenum, opform = src.opform, insform = src.insform, hypotaxis = src.hypotaxis, forcapindcode = src.forcapindcode, midpreindcode = src.midpreindcode, protype = src.protype, impdatesign = src.impdatesign, oploc = src.oploc, copynum = src.copynum, enttypegb = src.enttypegb, compformgb = src.compformgb, hotindfocus = src.hotindfocus, parform = src.parform, industryphygb = src.industryphygb, industrycogb = src.industrycogb, appperid = src.appperid, uniscid = src.uniscid WHERE src.timestamp > dest.timestamp and src.estdate = dest.estdate; COMMIT; --當目標表中已存在ID相同且核準日期<源表核準日期，將插入新記錄 INSERT /*+append*/ INTO ods_reg_marpripinfo nologging SELECT src.*, NULL AS bgxm, NULL AS dxrq, NULL AS zxrq, NULL AS old_qylx, NULL AS old_djjg, sysdate as cqrq FROM ods_reg_marpripinfo_local src WHERE exists (select 1 from (SELECT t.*, row_number() over(PARTITION BY t.id ORDER BY timestamp desc) rn FROM ods_reg_marpripinfo t) t where t.rn = 1 and src.id = t.id and src.estdate <> t.estdate) or apprdate > (SELECT MAX(apprdate) FROM ods_reg_marpripinfo dest WHERE dest.id = src.id) log errors INTO ods_reg_marpripinfo_err; COMMIT; --當源表中有新增的企業時，直接插入新數據 INSERT /*+append*/ INTO ods_reg_marpripinfo nologging SELECT id, TIMESTAMP, namepreapprid, entname, enttra, grpshform, oplocdistrict, industryphy, industryco, lerep, regcap, regcapcur, reccap, forreccap, forregcap, congro, dom, tel, postalcode, email, abuitemco, opscope, ptbusscope, enttype, enttypeitem, enttypeminu, opfrom, opto, regno, oldregno, forregno, supervper, superorgid, estdate, apprdate, perid, accopin, remark, state, orgid, jobid, adbusign, townsign, regtype, priorgid, superpriorgid, approrgid, enttypepro, optype, empnum, compform, supdistrict, venind, parnum, exenum, opform, insform, hypotaxis, forcapindcode, midpreindcode, protype, impdatesign, oploc, copynum, enttypegb, compformgb, hotindfocus, parform, industryphygb, industrycogb, appperid, uniscid, NULL AS bgxm --變更項目 , NULL AS zxrq --註銷日期 , NULL AS dxrq --吊銷日期 , NULL AS old_qylx --原企業類型 , NULL AS old_djjg --原登記機關 , sysdate as cqrq FROM ods_reg_marpripinfo_local src WHERE NOT EXISTS (SELECT NULL FROM ods_reg_marpripinfo dest WHERE src.id = dest.id); COMMIT; --將遷出戶不存在於目標表的記錄追加到目標表 INSERT INTO ods_reg_marpripinfo (id, TIMESTAMP, namepreapprid, entname, enttra, grpshform, oplocdistrict, industryphy, industryco, lerep, regcap, regcapcur, reccap, forreccap, forregcap, congro, dom, tel, postalcode, email, abuitemco, opscope, ptbusscope, enttype, enttypeitem, enttypeminu, opfrom, opto, regno, oldregno, forregno, supervper, superorgid, estdate, apprdate, perid, accopin, remark, state, orgid, jobid, adbusign, townsign, regtype, priorgid, superpriorgid, approrgid, enttypepro, optype, empnum, compform, supdistrict, venind, parnum, exenum, opform, insform, hypotaxis, forcapindcode, midpreindcode, protype, impdatesign, oploc, copynum, enttypegb, uniscid, appperid, compformgb, hotindfocus, industrycogb, industryphygb, parform, cqrq) SELECT id, estdate, namepreapprid, entname, enttra, grpshform, oplocdistrict, industryphy, industryco, lerep, regcap, regcapcur, reccap, forreccap, forregcap, congro, dom, tel, postalcode, email, abuitemco, opscope, ptbusscope, enttype, enttypeitem, enttypeminu, opfrom, opto, regno, oldregno, forregno, supervper, superorgid, estdate, apprdate, perid, accopin, remark, ‘09‘ state --對遷出戶狀態設為09 , ‘999999‘ orgid --對遷出戶主管機關設為999999 , jobid, adbusign, townsign, regtype, priorgid, superpriorgid, approrgid, enttypepro, optype, empnum, compform, supdistrict, venind, parnum, exenum, opform, insform, hypotaxis, forcapindcode, midpreindcode, protype, impdatesign, oploc, copynum, enttypegb, uniscid, NULL AS appperid, NULL AS compformgb, NULL AS hotindfocus, NULL AS industrycogb, NULL AS industryphygb, NULL AS parform, sysdate as cqrq FROM ods_reg_marpripinfo_inv inv WHERE id NOT IN (SELECT id FROM ods_reg_marpripinfo dest); COMMIT; --更新目標表的變更項目字段 MERGE INTO ods_reg_marpripinfo dest USING f_bgxx bgxx ON (dest.id = bgxx.marprid AND dest.apprdate = bgxx.apprdate) WHEN MATCHED THEN UPDATE SET bgxm = bgxx.altitem; COMMIT; --更新目標表的吊銷日期字段 MERGE INTO ods_reg_marpripinfo dest USING f_dxxx dxxx ON (dest.id = dxxx.marprid AND dest.apprdate = dxxx.apprdate) WHEN MATCHED THEN UPDATE SET dxrq = dxxx.apprdate; --更新目標表的是否註銷字段 MERGE INTO ods_reg_marpripinfo dest USING f_zxxx zxxx ON (dest.id = zxxx.marprid AND dest.apprdate = zxxx.apprdate) WHEN MATCHED THEN UPDATE SET zxrq = zxxx.apprdate; COMMIT; --更新目標表的內轉外標誌 MERGE INTO ods_reg_marpripinfo dest USING f_gzxx gzxx ON (dest.id = gzxx.marprid AND dest.apprdate = gzxx.apprdate) WHEN MATCHED THEN UPDATE SET old_qylx = gzxx.enttype_old; pkg_debug.log_end(n_log_id); --更新目標表的原主管機構 MERGE INTO ods_reg_marpripinfo dest USING f_qrqc qrqc ON (dest.id = qrqc.marprid AND dest.apprdate = qrqc.apprdate) WHEN MATCHED THEN UPDATE SET old_djjg = qrqc.moutareregorgid; ELSE --如果為全量抽取，則TRUNCATE ODS_REG_MARPRIPINFO並重新抽取數據 n_log_id := pkg_debug.log_start(‘ODS_REG_MARPRIPINFO‘, ‘首次全量‘); pkg_idx.drop_all(‘ODS_REG_MARPRIPINFO‘); EXECUTE IMMEDIATE ‘TRUNCATE TABLE ODS_REG_MARPRIPINFO‘; INSERT /*+append*/ INTO ods_reg_marpripinfo nologging (id, TIMESTAMP, namepreapprid, entname, enttra, grpshform, oplocdistrict, industryphy, industryco, lerep, regcap, regcapcur, reccap, forreccap, forregcap, congro, dom, tel, postalcode, email, abuitemco, opscope, ptbusscope, enttype, enttypeitem, enttypeminu, opfrom, opto, regno, oldregno, forregno, supervper, superorgid, estdate, apprdate, perid, accopin, remark, state, orgid, jobid, adbusign, townsign, regtype, priorgid, superpriorgid, approrgid, enttypepro, optype, empnum, compform, supdistrict, venind, parnum, exenum, opform, insform, hypotaxis, forcapindcode, midpreindcode, protype, impdatesign, oploc, copynum, enttypegb, compformgb, hotindfocus, parform, industryphygb, industrycogb, appperid, uniscid, bgxm, dxrq, zxrq, cqrq) SELECT id, estdate TIMESTAMP, namepreapprid, entname, enttra, grpshform, oplocdistrict, industryphy, industryco, lerep, regcap, regcapcur, reccap, forreccap, forregcap, congro, dom, tel, postalcode, email, abuitemco, opscope, ptbusscope, enttype, enttypeitem, enttypeminu, opfrom, opto, regno, oldregno, forregno, supervper, superorgid, estdate, apprdate, perid, accopin, remark, state, orgid, jobid, adbusign, townsign, regtype, priorgid, superpriorgid, approrgid, enttypepro, optype, empnum, compform, supdistrict, venind, parnum, exenum, opform, insform, hypotaxis, forcapindcode, midpreindcode, protype, impdatesign, oploc, copynum, enttypegb, compformgb, hotindfocus, parform, industryphygb, industrycogb, appperid, uniscid, NULL AS bgxm, NULL AS sfdx, NULL AS sfzx, sysdate as cqrq FROM ods_reg_marpripinfo_local; COMMIT; pkg_idx.create_pk(in_v_column_list => ‘ID,APPRDATE‘, in_v_table_name => ‘ODS_REG_MARPRIPINFO_HZRQ‘); pkg_idx.create_idx(in_v_column_list => ‘ID,TIMESTAMP‘, in_v_table_name => ‘ODS_REG_MARPRIPINFO_HZRQ‘); pro_scd_reg_marpripinfo; pkg_debug.log_end(n_log_id); END IF; EXCEPTION WHEN OTHERS THEN pkg_debug.log_end(n_log_id); END;
主體拉鏈表存儲過程