需求背景：需要源数据变动，需要对历史表已存的字段值根据源数据进行更新。如果是单字段存值，直接根据映射表关联修改即可。但字段里面若存的值是以逗号分割，比如旧值：‘old1,old2,old3’，要根据映射关系调整为'new1,new2,new3'。

要求：出初始化更新脚本；

一、数据准备

我的历史表为 test_table, 需要对MUTI_VALUE字段进行数据更新

这是映射表 YINSE_TABLE,分别存着新值和旧值

结果为：(old22没有匹配)

二、SQL逻辑编写

第一步：拆分

先将test_table表进行拆分，以下是拆分Sql,将muti_value字段按逗号分隔全部查询出来，以SINGEELEMENT表示被拆分后的旧值。

SELECT t.RULE_ID ,t.RULE_NAME ,TRIM(REGEXP_SUBSTR(t.MUTI_VALUE , '[^,]+', 1, LEVEL)) AS singeElement,t.MUTI_VALUE  
FROM test_table t
CONNECT BY
LEVEL <= REGEXP_COUNT(t.MUTI_VALUE, '[^,]+')
AND PRIOR t.RULE_ID = t.RULE_ID 
AND PRIOR SYS_GUID() IS NOT NULL ;

第二步：映射

将以拆分的查询结果关联映射表；先将以上查询结果做成临时表，即使用with as创建临时表split_value，再将临时表跟映射表YINGSE_TABLE做关联，用singelement关联old_value，得到新值。然后得到rule_id 和 new_value的映射关系

SELECT DISTINCT t.RULE_ID ,t.NEW_VALUE FROM (
WITH split_value AS (
SELECT t.RULE_ID ,t.RULE_NAME ,TRIM(REGEXP_SUBSTR(t.MUTI_VALUE , '[^,]+', 1, LEVEL)) AS singeElement,t.MUTI_VALUE  
FROM test_table t
CONNECT BY
LEVEL <= REGEXP_COUNT(t.MUTI_VALUE, '[^,]+')
AND PRIOR t.RULE_ID = t.RULE_ID 
AND PRIOR SYS_GUID() IS NOT NULL
)
SELECT p.OLD_VALUE ,p.NEW_VALUE ,s.*  FROM split_value s
INNER JOIN YINSE_TALBE p ON s.singeElement = p.OLD_VALUE
) t WHERE t.NEW_VALUE IS NOT NULL ;

第三步：组装合并，更新

将rule_id跟new_value的值再次组装成以逗号分隔的数据，通过rule_id，一次行将历史表的值替换成新值;先组装数据：

SELECT t.RULE_ID , LISTAGG(t.new_value, ',') WITHIN GROUP (ORDER BY t.NEW_VALUE) AS newMutiValue FROM ( 
	SELECT DISTINCT t.RULE_ID ,t.NEW_VALUE FROM (
		WITH split_value AS (
		SELECT t.RULE_ID ,t.RULE_NAME ,TRIM(REGEXP_SUBSTR(t.MUTI_VALUE , '[^,]+', 1, LEVEL)) AS singeElement,t.MUTI_VALUE  
		FROM test_table t
		CONNECT BY
		LEVEL <= REGEXP_COUNT(t.MUTI_VALUE, '[^,]+')
		AND PRIOR t.RULE_ID = t.RULE_ID 
		AND PRIOR SYS_GUID() IS NOT NULL
		)
		SELECT p.OLD_VALUE ,p.NEW_VALUE ,s.*  FROM split_value s
		INNER JOIN YINSE_TALBE p ON s.singeElement = p.OLD_VALUE
	) t WHERE t.NEW_VALUE IS NOT NULL 
) t GROUP BY t.RULE_ID ;

然后根据这个结果更新到test_table表中，使用rule_id进行update；以下是更新语句：

MERGE INTO test_table t
USING (
	SELECT t.RULE_ID , LISTAGG(t.new_value, ',') WITHIN GROUP (ORDER BY t.NEW_VALUE) AS newMutiValue FROM ( 
		SELECT DISTINCT t.RULE_ID ,t.NEW_VALUE FROM (
			WITH split_value AS (
			SELECT t.RULE_ID ,t.RULE_NAME ,TRIM(REGEXP_SUBSTR(t.MUTI_VALUE , '[^,]+', 1, LEVEL)) AS singeElement,t.MUTI_VALUE  
			FROM test_table t
			CONNECT BY
			LEVEL <= REGEXP_COUNT(t.MUTI_VALUE, '[^,]+')
			AND PRIOR t.RULE_ID = t.RULE_ID 
			AND PRIOR SYS_GUID() IS NOT NULL
			)
			SELECT p.OLD_VALUE ,p.NEW_VALUE ,s.*  FROM split_value s
			INNER JOIN YINSE_TALBE p ON s.singeElement = p.OLD_VALUE
		) t WHERE t.NEW_VALUE IS NOT NULL 
	) t GROUP BY t.RULE_ID 
) s ON (t.RULE_ID = s.RULE_ID)
WHEN MATCHED THEN 
	UPDATE SET t.MUTI_VALUE = s.newMutiValue;

最后查询test_table表