Oracle Procedure将逗号分隔的字符串动态插入和更新到dest表中

问题描述

编辑1：我能够编译@ radagast81建议的过程，但是它一直在运行。任何帮助，将不胜感激。

我已经收到在前一个线程中拆分逗号分隔字符串的解决方案。 因此，我正在使用以下查询将给定的字符串拆分为目标表。

PUSH_DATA_TEMP列： DISP_PK->主键应该是每个id的唯一递增数字。 每个字符串的PID-> ID col1 ........ col11

insert into push_data_temp (pid,col1,col2,col3,col4,col5,col6,col7,col8,col9,col10,col11,col12)
with rcte (id,data,lvl,result) as (
  select id,1,regexp_substr(data,'("[^"]*"|[^,"]+)',null,1) )
  from disp_data
  union all
  select id,lvl + 1,1) 
  from rcte
  where lvl <= regexp_count(data,"]+)')
)
select *
from (
  select disp_pk,id,replace(result,'""','') as final
  from rcte
)
pivot (max(result) as col for (lvl) in (1,2,3,4,5,6,7,8,9,10,11,12));

但是我现在有其他要求使用pl / sql过程并拆分和插入/更新行（如果已存在），并且都是动态的。

1. 我需要使上面的列动态化，因此字符串可以分成11列或以上的15列。最大数目为30。

所以我需要编写一个过程，该过程可以动态地将字符串拆分并推入列中。

1. 因此，它应该插入行，如果该行已经存在，则应动态更新这两个列。可能带有循环。因此，每行插入和更新的条件是强制性的。 ID / PID是该行的ID。

DB-12C

1. 对于id_pk，它应该是生成的唯一数字，递增1。 ID / PID主要需要作为标识每个字符串的参数传递。

样本数据： PID = 100的第一个字符串将字符串分为11列，PID = 110的第二个字符串将分为12列，依此类推。

create table disp_data(id number,data varchar2(4000));

Insert into disp_data(id,data) values(100,'"Project title as per the outstanding Requirements","The values are,not with respect to the requirement and analysis done by the team. 
Also it is difficult to,prepare a scenario notwithstanding the fact it is difficult. This user story is going to be slightly complex however it is up to the team","Active","Disabled","25 tonnes of fuel","www.examplesites.com/html.asp&net;","","25"');

Insert into disp_data(id,data) values(110,'"Project title afor BYU heads",exactly up to the requirement and analysis done by the team. 
Also it is difficult to,"Apprehension","25","Stable"');

解决方法

您基本上可以使用现有的SELECT，然后将其简单地放入MERGE语句中：

WITH dat(id,DATA) AS (SELECT 110,'"Project title afor BYU heads","The values are,exactly up to the requirement and analysis done by the team. 
Also it is difficult to,prepare a scenario notwithstanding the fact it is difficult. This user story is going to be slightly complex however it is up to the team","Active","Disabled","25 tonnes of fuel","www.examplesites.com/html.asp&net;","Apprehension","","25","Stable"' FROM dual)
MERGE INTO push_data_temp tgt
USING (SELECT * 
         FROM (SELECT id,LEVEL lvl,REPLACE(regexp_substr(data,'("[^"]*"|[^,"]+)',1,level,null,1),'""','') result
                 FROM dat
              CONNECT BY regexp_substr(data,1) IS NOT NULL)
       pivot (max(result) as col for (lvl) in (1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30)) src
  ON (src.id = tgt.pid)
WHEN MATCHED THEN UPDATE
 SET col1 = src."1_COL",...,col30 = src."30_COL"
WHEN NOT MATCHED THEN INSERT (pid,col1,col30)
VALUES (src.id,src."1_COL",src."30_COL")

将此逻辑包装到过程中也很容易：

CREATE OR REPLACE 
PROCEDURE PUSH_DATA(id INTEGER,DAT VARCHAR2) IS
BEGIN
  MERGE INTO push_data_temp tgt
  USING (SELECT * 
           FROM (SELECT id,REPLACE(regexp_substr(dat,'') result
                   FROM dual
                CONNECT BY regexp_substr(dat,1) IS NOT NULL)
         pivot (max(result) as col for (lvl) in (1,30)) src
    ON (src.id = tgt.pid)
  WHEN MATCHED THEN UPDATE
   SET col1 = src."1_COL",col30 = src."30_COL"
  WHEN NOT MATCHED THEN INSERT (pid,col30)
  VALUES (src.id,src."30_COL");
END;

然后可以按以下方式调用它：

BEGIN
  PUSH_DATA(110,"Stable"');
END;