假設有一張表oldyang_bayern，取其中的10條數據作為參考：

現在需要合并此張表中姓名重復的數據，將符合條件的字段值，合并到重名數據中ID最高的那一條。

要合并的字段分為三種情況：

1. 常規字段(DEPARTMENT/JOBTITLE)：取重名數據中ID最高的非空值，例如“施魏因施泰格”的DEPARTMENT字段合并后，應取值“組織部”；

2. 依據數值大小取值的字段(SALARY)：取重名數據中的最大值；

3. 非常規字段(CITY/DITRICT/ADDRESS/ADDRESSRANK)：這些字段都與地址相關，以ADDRESSRANK最高的那條數據為準（ADDRESSRANK由高到低分別為S|A|B|C|D），然后取此條數據中的CITY/DITRICT/ADDRESS值；如果ADDRESSRANK相同，取ID最高的數據。

依據以上條件，此前的10條數據合并后的結果應如下所示：

我所給出的方法：

處理合并的存儲過程 prc_oldyang_bayern

    create or replace procedure prc_oldyang_bayern(pname varchar2)
is
cursor cur is
　select * from oldyang_bayern
　　where name=pname order by id desc; --NAME相同的數據按id降序排列

 

--申明記錄表info_table，用于存放NAME相同的數據
　type info_table_type is table of oldyang_bayern%ROWTYPE index by binary_integer;
　info_table info_table_type;

 

　info_dest oldyang_bayern%rowtype;
　nCount number(2):=0; --計數變量
　vi number(2); --在更新地址字段時將會用于放入記錄號

 

begin
　open cur;
　　--通過循環計數的方式將重復的記錄放入記錄表
　　loop
　　　nCount:= nCount+1;
　　　fetch cur into info_table(nCount);
　　　exit when cur%notfound;
　　end loop;
　close cur;

 

　nCount := nCount - 1;

 

　--更新常規字段DEPARTMENT/JOBTITLE
　for i in 1..nCount-1 loop
　　if i = 1 then
　　　info_dest.DEPARTMENT:= nvl(info_table(i).DEPARTMENT, info_table(i+1).DEPARTMENT);
　　else
　　　info_dest.DEPARTMENT:= nvl(info_dest.DEPARTMENT, info_table(i+1).DEPARTMENT);
　　end if;
　end loop;

 

　for i in 1..nCount-1 loop
　　if i = 1 then
　　　info_dest.JOBTITLE:= nvl(info_table(i).JOBTITLE, info_table(i+1).JOBTITLE);
　　else
　　　info_dest.JOBTITLE:= nvl(info_dest.JOBTITLE, info_table(i+1).JOBTITLE);
　　end if;
　end loop;

 

　--更新SALARY字段
　for i in 1..nCount-1 loop
　　if i = 1 then
　　　info_dest.SALARY:= greatest(nvl(info_table(i).SALARY,-1), nvl(info_table(i+1).SALARY,-1));
　　else
　　　info_dest.SALARY:= greatest(nvl(info_dest.SALARY,-1), nvl(info_table(i+1).SALARY,-1));
　　end if;
　end loop;
　info_dest.SALARY:= replace(info_dest.SALARY,-1); --處理當SALARY為空值時的狀況

 

　--更新與ADDRESSRANK相關的字段
　--此處引用了一個自定義函數fun_get_ranknum
　--利用這個函數將地址等級S|A|B|C|D轉換成對應的地址等級序號1|2|3|4|5（函數代碼會在后面列出）
　--接著拼接地址等級序號+記錄號，取拼接后最小值
　--此方法用于處理當ADDRESSRANK相同時，取ID最高的那條ADDRESSRANK相關記錄
　--（注：在游標中記錄已按ID降序排列）
　for i in 1..nCount-1 loop
　　if i = 1 then
　　　info_dest.ADDRESSRANK:= least(fun_get_ranknum(info_table(i).ADDRESSRANK)||i, fun_get_ranknum(info_table(i+1).ADDRESSRANK)||i+1);
　　else
　　　info_dest.ADDRESSRANK:= least(info_dest.ADDRESSRANK, 　fun_get_ranknum(info_table(i+1).ADDRESSRANK)||i+1);
　　end if;
　end loop;

 

　vi:= regexp_substr(info_dest.ADDRESSRANK, '\d$'); --使用正則表達式取出拼接值中的記錄號
　info_dest.ADDRESSRANK:=info_table(vi).ADDRESSRANK;
　info_dest.CITY:=info_table(vi).CITY;
　info_dest.DISTRICT:=info_table(vi).DISTRICT;
　info_dest.ADDRESS:=info_table(vi).ADDRESS;

 

　--將篩選后的變量值更新到ID最高的記錄當中
　update oldyang_bayern
　　　set DEPARTMENT=info_dest.DEPARTMENT,
　　　　　JOBTITLE=info_dest.JOBTITLE,
　　　　　SALARY=info_dest.SALARY,
　　　　　CITY=info_dest.CITY,
　　　　　DISTRICT=info_dest.DISTRICT,
　　　　　ADDRESS=info_dest.ADDRESS,
　　　　　ADDRESSRANK=info_dest.ADDRESSRANK
　　where id = info_table(1).id;

 

　--刪除重復的記錄
　delete from oldyang_bayern where name=pname and id != info_table(1).id;

 

　commit;
end ;
  

?

存儲過程中所用到的自定義函數 fun_get_ranknum

    create or replace function fun_get_ranknum(prank in varchar2)
return varchar2
is
　Result varchar(2);
　vcTemp varchar(2);
begin
　vcTemp:=prank;

 

　case
　　when vcTemp = 'S' then
　　　　　vcTemp:= '1';
　　when vcTemp = 'A' then
　　　　　vcTemp:= '2';
　　when vcTemp = 'B' then
　　　　　vcTemp:= '3';
　　when vcTemp = 'C' then
　　　　　vcTemp:= '4';
　　when vcTemp = 'D' then
　　　　　vcTemp:= '5';
　　when vcTemp is null then
　　　　　vcTemp:= '9';
　end case;

 

　Result := vcTemp;
　return(Result);

 

　exception
　　when others then
　　　Result := '9';
　　return result;
end ;
  

?

利用匿名塊傳遞重復姓名到prc_oldyang_bayern，執行合并過程

    declare
cursor cur is select name from oldyang_bayern group by name having count(*)>1;
rec cur%rowtype;
begin
　open cur;
　　loop
　　　fetch cur into rec;
　　   exit when cur%notfound;
　　　prc_oldyang_bayern(rec.name);
　　end loop;
　close cur;
end;
  

?轉自： http://www.oldyang.com/2009/06/23/using_plsql_remove_duplicates/

使用PL/SQL合并重復的數據