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

HAPOC/3-HADWS/HADWS_TEAM_INV_SPLIT--团险投资成分拆分数据表.sql

 -- HADWS_TEAM_INV_SPLIT  团险投资成分拆分数据表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_INV_SPLIT --团险投资成分拆分数据表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_INV_SPLIT --团险投资成分拆分数据表
 SELECT
 MD5(ConcatObjUDF('${MEA_YM}',N_RISKCLASS,N_PRDTYPE,MDL,N_PROFIT_FLAG,GRP_ID,N_GRP__ID))
                                     AS DATAPKID             -- 物理主键
@@ -94,10 +94,10 @@ FROM (
         ,s2.N_CDX                           AS N_CDX                -- '长短险标识 || 长险 短险 极短险' ,
         ,cast(s3.ACCI_DAY_CV as decimal)    AS ACCI_DAY_CV          -- '保单现价' ,
         ,s3.CLAIM_REVIEW_CODE               AS CLAIM_REVIEW_CODE    -- '给付责任类型 || 理赔 理赔（豁免） 生存金' ,
-        FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_PAY s1 --现金流_团险
-        LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT s2-- 团险现金流输出接口表
+        FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_PAY s1 --现金流_团险
+        LEFT JOIN IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT s2-- 团险现金流输出接口表
         ON s1.GRP_INS_PLC_ID = s2.GRP_INS_PLC_ID
-        LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_LP s3 --理赔数据_团险
+        LEFT JOIN IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_LP s3 --理赔数据_团险
         ON s1.GRP_INS_PLC_ID = s3.GRP_INS_PLC_ID and s1.BUSI_NO = s3.CLAIM_NO
         where s2.GRP_INS_PLC_ID is not null
         and s2.MEA_YM = cast('${MEA_YM}' as int)

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

 -- HADWS_TEAM_PLCRICK_IN  HADWS_团险现金流输入接口表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN     --团险现金流输入接口表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_IN     --团险现金流输入接口表
 SELECT
 ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -32,8 +32,8 @@ ConcatObjUDF('${MEA_YM}',s1.GRP_INS_PLC_ID)
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.IFRS17_HAODS_MYSQL.HAODS_TEAM_PLCRICK s1   --保单险种明细数据_团险
-LEFT JOIN IFRS17.IFRS17_HAODS_MYSQL.HADIM_PRDINFO s2 -- 产品基本信息
+FROM IFRS17.IFRS17_HAODS_SRDB.HAODS_TEAM_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_TEAM_PLCRICK_OUT--团险现金流输出接口表.sql

 -- HADWS_TEAM_PLCRICK_OUT  HADWS_团险现金流输出接口表
-INSERT INTO IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表
+INSERT INTO IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_OUT --团险现金流输出接口表
 SELECT
 ConcatObjUDF( '${MEA_YM}',s1.GRP_INS_PLC_ID)
                                     AS DATAPKID             -- 物理主键
@@ -35,12 +35,12 @@ ConcatObjUDF( '${MEA_YM}',s1.GRP_INS_PLC_ID)
 ,''                 AS      MEA_BAT	            --  '计量批次'
 ,''                 AS      ARC_BAT	            --  '归档批次'
 
-FROM IFRS17.IFRS17_HAODS_MYSQL.HADWS_TEAM_PLCRICK_IN s1 -- 团险现金流输入接口表
+FROM IFRS17.IFRS17_HADWS_SRDB.HADWS_TEAM_PLCRICK_IN s1 -- 团险现金流输入接口表
 -- LEFT JOIN IFRS17.HASOURCE_SRDB.HADIM_LRISKPROF s2 -- 长险营利性配置信息
 -- ON s1.N_CDX ='长险'  and s1.N_PRD_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.PLC_RISK_CODE = s4.N_PRDTYPE  and s1.N_CYEAR_D = s4.N_CYEAR_D
 and s3.PROFIT_FLAG   = s4.N_PROFIT_FLAG
 where s1.MEA_YM = cast('${MEA_YM}' as int)