一、背景 在數據開發中,有時你需要合併兩個動態游標sys_refcursor。 開發一個存儲過程PROC_A,這個過程業務邏輯相當複雜,代碼篇幅較長。一段時間後要開發一個PROC_B,要用PROC_A同樣的邏輯,而且在這個過程中,還要迴圈調用PROC_A這個過程。擺在你面前的有兩個選擇。 打開PL/ ...
一、背景
在數據開發中,有時你需要合併兩個動態游標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
二、思路
經過搜索查詢,找到以下可行的方案
- 序列化sys_refcursor為xml文檔,ORACLE對xml支持還不錯,12C已經有JSON格式了
- 使用ORACLE xml解析的方法,對序列化的xml文檔,添加、刪除、修改
- 轉換為記憶體表,通過游標返回查詢的結果
為此你需要掌握的知識有
- 使用 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_cur
和ref_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中也有良好的支持。所以,對於基於語言之上的知識,各個語言實現方式基本相識。基礎終究是重要的。