1. 程式人生 > >oracle 合並多個sys_refcursor

oracle 合並多個sys_refcursor

== eat from 它的 pac sin gin 打印 lan

oracle 合並多個sys_refcursor

一、背景

在數據開發中,有時你需要合並兩個動態遊標sys_refcursor

開發一個存儲過程PROC_A,這個過程業務邏輯相當復雜,代碼篇幅較長。一段時間後要開發一個PROC_B,要用PROC_A同樣的邏輯,而且在這個過程中,還要循環調用PROC_A這個過程。擺在你面前的有兩個選擇。

  • 打開PL/SQL,仔細的讀PROC_A這個過程,一直到明白了所有的邏輯,然後在自己的過程中重寫這個邏輯 。
  • 直接復制PROC_A這個過的代碼過來,多寫極端。還是業界標準大法好
  • 針對循環調用的,建立一個臨時表,循環插入數據到臨時表(但這裏還有一個問題,每次返回的遊標可能列都不相同,建立臨時表就顯得復雜了)

好吧,這個新的過程是完成了,可是看上去,它更復雜了,代碼量更大了。完全不能接受,必須改改!
這時,已經默默打開了ORACLE官方幫助文檔 https://docs.oracle.com/cd/B19306_01/index.htm,尋找一個可行的辦法,最終目標標是要解析,整合,合並 遊標 sys_refcursor

二、思路

經過搜索查詢,找到以下可行的方案

  1. 序列化sys_refcursor為xml文檔,ORACLE對xml支持還不錯,12C已經有JSON格式了
  2. 使用ORACLE xml解析的方法,對序列化的xml文檔,添加、刪除、修改
  3. 轉換為內存表,通過遊標返回查詢的結果

為此你需要掌握的知識有

  • 使用 Dbms_Lob 個package操作clob類型數據,因為解析後的遊標可能用varchar2是裝不下的,幫助地址 https://docs.oracle.com/cd/E11882_01/timesten.112/e21645/d_lob.htm#TTPLP600。
  • 重點掌握Oracle類型xmltype如何使用 https://docs.oracle.com/cd/B19306_01/appdev.102/b14258/t_xml.htm#BABHCHHJ

三、實現

從上邊的幫助文檔中,知道xmltype的構造函數中可以直接傳入遊標xmltype(refcursor)

從而得到一個xmltype,調用xmltype的getClobVal方法,可得到序列化的結果,所以它的結構是這樣的

1 <?xml version="1.0"?>
2 <ROWSET>
3 <ROW>
4 <COLUMNNAME1></COLUMNNAME1>
5 <COLUMNNAME2></COLUMNNAME2>
6 <...>...</...>
7 </ROW>
8 ....
9 </ROWSET>

所以,如果需要合並兩個數據列相同遊標,只需要提取DOM中的ROW節點數據保存到定義的clob字段中去。

提取dom中片段,采用標準的xpath語法,/ROWSET/ROW這裏提取ROW信息

 1 Declare
 2 x xmltype;
 3 rowxml clob;
 4 mergeXml clob;
 5 ref_cur Sys_Refcursor;
 6 ref_cur2 Sys_Refcursor;
 7 ref_cur3 Sys_Refcursor;
 8 begin
 9   open ref_cur for
10    select F_USERNAME, F_USERCODE, F_USERID
11    from Tb_System_User
12    where F_userid = 1;
13  Dbms_Lob.createtemporary(mergeXml, true);
14  Dbms_Lob.writeappend(mergeXml, 8, <ROWSET>);
15  x := xmltype(ref_cur);
16  Dbms_Output.put_line(=====完整的REFCURSOR結構=====);
17  Dbms_Output.put_line(x.getClobVal());
18  Dbms_Output.put_line(=====只提取行信息=====);
19  rowxml := x.extract(/ROWSET/ROW).getClobVal(0, 0);
20  Dbms_Output.put_line(rowxml);
21  Dbms_Lob.append(mergeXml, rowxml);ROWSET
22  open ref_cur2 for
23   select F_USERNAME, F_USERCODE, F_USERID
24   from Tb_System_User
25   where F_userid = 1000;
26  x := xmltype(ref_cur2);
27  rowxml := x.extract(/ROWSET/ROW).getClobVal(0, 0);
28  Dbms_Lob.append(mergeXml, rowxml);
29  Dbms_Lob.writeappend(mergeXml, 9, </ROWSET>);
30  Dbms_Output.put_line(=====合並後的信息=====);
31  Dbms_Output.put_line(mergeXml);
32 end;

執行這段代碼輸出的結果是這樣的

 1 =====完整的REFCURSOR結構=====
 2 <?xml version="1.0"?>
 3 <ROWSET>
 4 <ROW>
 5 <F_USERNAME>系統管理員</F_USERNAME>
 6 <F_USERCODE>admin</F_USERCODE>
 7 <F_USERID>1</F_USERID>
 8 </ROW>
 9 </ROWSET>
10 
11 =====只提取行信息=====
12 <ROW>
13 <F_USERNAME>系統管理員</F_USERNAME>
14 <F_USERCODE>admin</F_USERCODE>
15 <F_USERID>1</F_USERID>
16 </ROW>
17 
18 =====合並後的信息=====
19 <ROWSET><ROW>
20 <F_USERNAME>系統管理員</F_USERNAME>
21 <F_USERCODE>admin</F_USERCODE>
22 <F_USERID>1</F_USERID>
23 </ROW>
24 <ROW>
25 <F_USERNAME>黃燕</F_USERNAME>
26 <F_USERCODE>HUANGYAN</F_USERCODE>
27 <F_USERID>1000</F_USERID>
28 </ROW>
29 </ROWSET>

從上邊打印的結果看,我們已經成功的將兩個遊標 ref_curref_cur2中我們需要的列信息合並到了一個xml文檔中。那麽接下了,我們就需要通過解析這個xml並返回一個新的sys_refcursor,這裏你有必要了解以下oracle xmltable的用法(https://docs.oracle.com/cd/B19306_01/server.102/b14200/functions228.htm)接上邊代碼

1 Dbms_Output.put_line(mergeXml);
2 open ref_cur3 for
3   select *
4   from xmltable(/ROWSET/ROW Passing xmltype(mergeXml) Columns
5         F_USERNAME varchar2(100) path F_USERNAME,
6         F_USERCODE varchar2(100) path F_USERCODE);

簡單說明下xmltable構造函數

  • 聲明xpath,指明你需要解析的dom在哪裏,比如從根找到ROW /ROWSET/ROW
  • 指明你要查詢的xmltype
  • 定義轉換列,比如把ROW下邊的F_USERNAME這個節點值,映射到遊標列F_USERNAME 這個列中

四、總結

xml作為早期數據傳輸,序列化和反序列化的文件格式,在oracle中也有良好的支持。所以,對於基於語言之上的知識,各個語言實現方式基本相識。基礎終究是重要的。

oracle 合並多個sys_refcursor