DWD部分加工规则-替换数据源

HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_IN--个险现金流输入接口表.sql

 -- HADWS_PERSONAL_PLCRICK_IN  HADWS_个险现金流输入接口表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_IN -- 个险现金流输入接口表
 SELECT
 ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -32,8 +32,8 @@ ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
 ,LOCALTIMESTAMP     AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_PERSONAL_PLCRICK s1 -- 保单险种明细_个人业务
-LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息
+FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_PERSONAL_PLCRICK s1 -- 保单险种明细_个人业务
+LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_PRDINFO s2 -- 产品基本信息
 ON s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL
 
 

HAPOC/3-HADWS/HADWS_PERSONAL_PLCRICK_OUT--个险现金流输出接口表.sql

 -- HADWS_PERSONAL_PLCRICK_OUT  HADWS_个险现金流输出接口表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_OUT -- 个险现金流输出接口表
 SELECT
 ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -35,12 +35,12 @@ ConcatObjUDF( '${MEA_YM}',s1.PLC_ID)
 ,LOCALTIMESTAMP     AS      ARC_TIME	        --  '归档时间'
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_PERSONAL_PLCRICK_IN s1   -- 个险现金流输入接口表
-LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_LRISKPROF s2 -- 长险营利性配置信息
+FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_PERSONAL_PLCRICK_IN s1   -- 个险现金流输入接口表
+LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_LRISKPROF s2 -- 长险营利性配置信息
 ON s1.N_CDX ='长险'  and s1.PLC_RISK_CODE = s2.PRDCODE and s1.BUSY_CHAN = s2.CHNL and s1.N_CYEAR_D_PROFIT = s2.CYEAR
-LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_SRISKPROF s3 --短险营利性配置信息
+LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HADIM_SRISKPROF s3 --短险营利性配置信息
 ON s1.N_CDX ='短险'  and s1.PLC_RISK_CODE = s3.PRDCODE
-LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
+LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HAODS_EXT_CONCATINFO  s4 --合同分组基本信息
 ON s1.N_PRDTYPE = s4.N_PRDTYPE  and s1.N_CYEAR_D = s4.N_CYEAR_D
 and COALESCE(s2.PROFIT_FLAG ,s3.PROFIT_FLAG )  = s4.N_PROFIT_FLAG
 where s1.MEA_YM = cast('${MEA_YM}' as int)