Oracle中通过：触发器，存储过程，Function调用实现解析Clob字段
function
oracle
儲存
觸發器
調
過程
透過
摘要：最近项目中用到了存储过程，触发器，Function，由于以前没怎么用过，所以查资料，请教同事，最后总算是把问题解决了，问题是这样的，数据库中有三张表一张是存放从远程服务器获取数据的MBINMSGS表，这个表里面有个Clob字段，里面存放的是xml式的字符串
摘要：最近项目中用到了存储过程，触发器，Function，由于以前没怎么用过，所以查资料，请教同事，最后总算是把问题解决了，问题是这样的，数据库中有三张表一张是存放从远程服务器获取数据的MBINMSGS表，这个表里面有个Clob字段，里面存放的是xml格式的字符串，我们要把这个表里面的xml字符串通过Oracle解析出来，然后再把解析出来的数据插入对应的数据表：TB_CMS_FLGTINFO_A表和TB_CMS_FLGTINFO_D表，以上就是问题的描述，下面我把我的代码贴出了，以供大家参考：
一：数据表结构SQL
CREATE TABLE MIP.MBINMSGS ( ID NUMBER(30) NOT NULL, MBINMSGS_CLOB_MSG CLOB, MBINMSGS_DATE_RECEIVED DATE, MBINMSGS_DATE_PROCESSED DATE, MBINMSGS_SUBSYSTEM_NAME VARCHAR2(100 BYTE), MBINMSGS_SUBSYSTEM_DATE_SENT DATE, SERVICENAME VARCHAR2(30 BYTE) NOT NULL )
登入後複製
CREATE TABLE MIP.TB_CMS_FLGTINFO_A ( ID NUMBER(10) NOT NULL, ABNS VARCHAR2(64 BYTE), ACFT VARCHAR2(64 BYTE), AIRLINE VARCHAR2(64 BYTE), ALAP VARCHAR2(64 BYTE), BETM VARCHAR2(64 BYTE), CHDT VARCHAR2(64 BYTE), EIBT VARCHAR2(64 BYTE), FATA VARCHAR2(64 BYTE), FETA VARCHAR2(64 BYTE), FFID VARCHAR2(64 BYTE), FSTA VARCHAR2(64 BYTE), LMDT VARCHAR2(64 BYTE), LMUR VARCHAR2(64 BYTE), PSTM VARCHAR2(64 BYTE), RENO VARCHAR2(64 BYTE), RWAY VARCHAR2(64 BYTE), SPOT VARCHAR2(64 BYTE), STND VARCHAR2(64 BYTE) )
登入後複製
CREATE TABLE MIP.TB_CMS_FLGTINFO_D ( ID NUMBER(10) NOT NULL, A_TOBT VARCHAR2(64 BYTE), A_WEATHER VARCHAR2(64 BYTE), ABNS VARCHAR2(64 BYTE), ACFT VARCHAR2(64 BYTE), AIRLINE VARCHAR2(64 BYTE), ASAT VARCHAR2(64 BYTE), BCTM VARCHAR2(64 BYTE), BOTM VARCHAR2(64 BYTE), BSTM VARCHAR2(64 BYTE), C_TOBT VARCHAR2(64 BYTE), COBT VARCHAR2(64 BYTE), CTOT VARCHAR2(64 BYTE), DINT VARCHAR2(64 BYTE), DLAB VARCHAR2(64 BYTE), DNAP VARCHAR2(64 BYTE), DOUT VARCHAR2(64 BYTE), EDDI VARCHAR2(64 BYTE), EOBT VARCHAR2(64 BYTE), EPGT VARCHAR2(64 BYTE), EPOT VARCHAR2(64 BYTE), FATD VARCHAR2(64 BYTE), FFID VARCHAR2(64 BYTE), FSTD VARCHAR2(64 BYTE), LMDT VARCHAR2(64 BYTE), LMUR VARCHAR2(64 BYTE), OFTM VARCHAR2(64 BYTE), RENO VARCHAR2(64 BYTE), RWAY VARCHAR2(64 BYTE), STDI VARCHAR2(64 BYTE), STND VARCHAR2(64 BYTE), TSAT VARCHAR2(64 BYTE) )
登入後複製
二：Function.SQL
CREATE OR REPLACE FUNCTION MIP.GetXmlNodeValue (xmlStr CLOB, nodeName VARCHAR2)
RETURN VARCHAR2
IS
--创建xml解析器实例xmlparser.Parser
xmlPar xmlparser.Parser := xmlparser.newParser;
--定义DOM文档
xDoc xmldom.DOMDocument;
--定义item子节点数目变量
lenItme INTEGER;
--定义节点列表，存放item节点们
itemNodes xmldom.DOMNodeList;
--定义节点，存放单个item节点
itemNode xmldom.DOMNode;
ValueReturn VARCHAR2 (100);
BEGIN
--解析xmlStr中xml字符串，并存放到xmlPar中
xmlparser.parseClob (xmlPar, xmlStr);
--将xmlPar中的数据转存到dom文档中
xDoc := xmlparser.getDocument (xmlPar);
xmlparser.freeParser (xmlPar); --释放解析器实例
--获取所有item节点
itemNodes := xmldom.getElementsByTagName (xDoc, nodeName);
--获取item节点的个数
lenItme := xmldom.getLength (itemNodes);
IF lenItme = 0
THEN
RETURN '';
END IF;
--获取节点列表中的第1个item节点
itemNode := xmldom.item (itemNodes, 0);
--获取所有子节点的值
ValueReturn := xmldom.getNodeValue (xmldom.getFirstChild (itemNode));
RETURN ValueReturn;
END GetXmlNodeValue;
/
登入後複製
三：存储过程.SQL
CREATE OR REPLACE PROCEDURE MIP.MIP_PARSE (xmlStr IN CLOB)
IS
RENO VARCHAR2 (100);
AIRLINE VARCHAR2 (100);
FFID VARCHAR2 (100);
FFID_A VARCHAR2 (100);
FFID_D VARCHAR2 (100);
ABNS VARCHAR2 (100);
ACFT VARCHAR2 (100);
CHDT VARCHAR2 (100);
EIBT VARCHAR2 (100);
FATA VARCHAR2 (100);
FETA VARCHAR2 (100);
--FFID VARCHAR2 (100);
FSTA VARCHAR2 (100);
LMDT VARCHAR2 (100);
LMUR VARCHAR2 (100);
PSTM VARCHAR2 (100);
RWAY VARCHAR2 (100);
SPOT VARCHAR2 (100);
STND VARCHAR2 (100);
A_TOBT VARCHAR2 (100);
A_WEATHER VARCHAR2 (100);
--ABNS VARCHAR2 (100);
--ACFT VARCHAR2 (100);
ASAT VARCHAR2 (100);
BCTM VARCHAR2 (100);
BOTM VARCHAR2 (100);
BSTM VARCHAR2 (100);
C_TOBT VARCHAR2 (100);
COBT VARCHAR2 (100);
CTOT VARCHAR2 (100);
DINT VARCHAR2 (100);
DLAB VARCHAR2 (100);
DOUT VARCHAR2 (100);
EDDI VARCHAR2 (100);
EOBT VARCHAR2 (100);
EPGT VARCHAR2 (100);
EPOT VARCHAR2 (100);
FATD VARCHAR2 (100);
--FFID VARCHAR2 (100);
FSTD VARCHAR2 (100);
--LMDT VARCHAR2 (100);
--LMUR VARCHAR2 (100);
OFTM VARCHAR2 (100);
--RENO VARCHAR2 (100);
--RWAY VARCHAR2 (100);
STDI VARCHAR2 (100);
--STND VARCHAR2 (100);
TSAT VARCHAR2 (100);
BEGIN
RENO := GetXmlNodeValue (xmlStr, 'RENO');
AIRLINE := GetXmlNodeValue (xmlStr, 'AIRLINE');
FFID := GetXmlNodeValue (xmlStr, 'FFID');
ABNS := GetXmlNodeValue (xmlStr, 'ABNS');
ACFT := GetXmlNodeValue (xmlStr, 'ACFT');
CHDT := GetXmlNodeValue (xmlStr, 'CHDT');
EIBT := GetXmlNodeValue (xmlStr, 'EIBT');
FATA := GetXmlNodeValue (xmlStr, 'FATA');
FETA := GetXmlNodeValue (xmlStr, 'FETA');
FFID := GetXmlNodeValue (xmlStr, 'FFID');
FSTA := GetXmlNodeValue (xmlStr, 'FSTA');
LMDT := GetXmlNodeValue (xmlStr, 'LMDT');
LMUR := GetXmlNodeValue (xmlStr, 'LMUR');
PSTM := GetXmlNodeValue (xmlStr, 'PSTM');
RWAY := GetXmlNodeValue (xmlStr, 'RWAY');
SPOT := GetXmlNodeValue (xmlStr, 'SPOT');
STND := GetXmlNodeValue (xmlStr, 'STND');
A_TOBT := GetXmlNodeValue (xmlStr, 'A_TOBT');
A_WEATHER := GetXmlNodeValue (xmlStr, 'A_WEATHER');
--ABNS := GetXmlNodeValue (xmlStr, 'ABNS');
--ACFT := GetXmlNodeValue (xmlStr, 'ACFT');
ASAT := GetXmlNodeValue (xmlStr, 'ASAT');
BCTM := GetXmlNodeValue (xmlStr, 'BCTM');
BOTM := GetXmlNodeValue (xmlStr, 'BOTM');
BSTM := GetXmlNodeValue (xmlStr, 'BSTM');
C_TOBT := GetXmlNodeValue (xmlStr, 'C_TOBT');
COBT := GetXmlNodeValue (xmlStr, 'COBT');
CTOT := GetXmlNodeValue (xmlStr, 'CTOT');
DINT := GetXmlNodeValue (xmlStr, 'DINT');
DLAB := GetXmlNodeValue (xmlStr, 'DLAB');
DOUT := GetXmlNodeValue (xmlStr, 'DOUT');
EDDI := GetXmlNodeValue (xmlStr, 'EDDI');
EOBT := GetXmlNodeValue (xmlStr, 'EOBT');
EPGT := GetXmlNodeValue (xmlStr, 'EPGT');
EPOT := GetXmlNodeValue (xmlStr, 'EPOT');
FATD := GetXmlNodeValue (xmlStr, 'FATD');
FSTD := GetXmlNodeValue (xmlStr, 'FSTD');
--LMDT := GetXmlNodeValue (xmlStr, 'LMDT');
--LMUR := GetXmlNodeValue (xmlStr, 'LMUR');
OFTM := GetXmlNodeValue (xmlStr, 'OFTM');
STDI := GetXmlNodeValue (xmlStr, 'STDI');
TSAT := GetXmlNodeValue (xmlStr, 'TSAT');
IF INSTR(FFID,'-D-') > 0 THEN
FFID_D := FFID;
INSERT INTO TB_CMS_FLGTINFO_D (ID,A_TOBT,A_WEATHER,ABNS,ACFT,AIRLINE,ASAT,BCTM,BOTM,BSTM,C_TOBT,COBT,CTOT,DINT,DLAB,DOUT,EDDI,EOBT,EPGT,EPOT,FATD,FFID,FSTD,LMDT,LMUR,OFTM,RENO,RWAY,STDI,STND,TSAT)
VALUES (FLGTINFO_D_SEQ.NEXTVAL,
A_TOBT,
A_WEATHER,
ABNS,
ACFT,
AIRLINE,
ASAT,
BCTM,
BOTM,
BSTM,
C_TOBT,
COBT,
CTOT,
DINT,
DLAB,
DOUT,
EDDI,
EOBT,
EPGT,
EPOT,
FATD,
FFID_D,
FSTD,
LMDT,
LMUR,
OFTM,
RENO,
RWAY,
STDI,
STND,
TSAT);
ELSE
FFID_A := FFID;
INSERT INTO TB_CMS_FLGTINFO_A (ID,ABNS,ACFT,AIRLINE,CHDT,FFID,RENO,EIBT,FATA,FETA,FSTA,LMDT,LMUR,PSTM,RWAY,SPOT,STND)
VALUES (FLGTINFO_A_SEQ.NEXTVAL,
ABNS,
ACFT,
AIRLINE,
CHDT,
FFID_A,
RENO,
EIBT,
FATA,
FETA,
FSTA,
LMDT,
LMUR,
PSTM,
RWAY,
SPOT,
STND);
END IF;
COMMIT;
EXCEPTION
WHEN OTHERS
THEN
DBMS_OUTPUT.PUT_LINE (SQLERRM);
END MIP_PARSE;
/
登入後複製
四：触发器.SQL
DROP TRIGGER MIP.COPY_MIPDATA_TRIGGER; CREATE OR REPLACE TRIGGER MIP.COPY_MIPDATA_TRIGGER AFTER INSERT ON MIP.MBINMSGS FOR EACH ROW DECLARE -- LOCAL VARIABLES HERE BEGIN MIP_PARSE (:NEW.MBINMSGS_CLOB_MSG); END COPY_MIPDATA_TRIGGER; /
登入後複製
五：最后把所有的Function，存储过程，触发器都编译一下，就可以执行了，执行过程是：给表MBINMSGS中每插入一条数据，触发器就触发存储过程，存储过程再调用Function，最后把解析出来的xml字符串插入到对应的数据表中。
本網站聲明
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
如何修復KB5055612無法在Windows 10中安裝？
4 週前
By DDD
<🎜>：種植花園 - 完整的突變指南
3 週前
By DDD
<🎜>：泡泡膠模擬器無窮大 - 如何獲取和使用皇家鑰匙
3 週前
By 尊渡假赌尊渡假赌尊渡假赌
北端：融合系統，解釋
4 週前
By 尊渡假赌尊渡假赌尊渡假赌
Mandragora：巫婆樹的耳語 - 如何解鎖抓鉤
3 週前
By 尊渡假赌尊渡假赌尊渡假赌
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發環境
Dreamweaver CS6
視覺化網頁開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
oracle打不開怎麼辦
Apr 11, 2025 pm 10:06 PM
Oracle 打不開的解決辦法包括：1. 啟動數據庫服務；2. 啟動監聽器；3. 檢查端口衝突；4. 正確設置環境變量；5. 確保防火牆或防病毒軟件未阻止連接；6. 檢查服務器是否已關閉；7. 使用 RMAN 恢復損壞的文件；8. 檢查 TNS 服務名稱是否正確；9. 檢查網絡連接；10. 重新安裝 Oracle 軟件。
oracle游標關閉怎麼解決
Apr 11, 2025 pm 10:18 PM
解決 Oracle 游標關閉問題的方法包括：使用 CLOSE 語句顯式關閉游標。在 FOR UPDATE 子句中聲明游標，使其在作用域結束後自動關閉。在 USING 子句中聲明游標，使其在關聯的 PL/SQL 變量關閉時自動關閉。使用異常處理確保在任何異常情況下關閉游標。使用連接池自動關閉游標。禁用自動提交，延遲游標關閉。
oracle怎麼循環創建游標
Apr 12, 2025 am 06:18 AM
Oracle 中，FOR LOOP 循環可動態創建游標， 步驟為：1. 定義游標類型；2. 創建循環；3. 動態創建游標；4. 執行游標；5. 關閉游標。示例：可循環創建游標，顯示前 10 名員工姓名和工資。
oracle視圖怎麼導出
Apr 12, 2025 am 06:15 AM
可以通過 EXP 實用程序導出 Oracle 視圖：登錄 Oracle 數據庫。啟動 EXP 實用程序，指定視圖名稱和導出目錄。輸入導出參數，包括目標模式、文件格式和表空間。開始導出。使用 impdp 實用程序驗證導出。
oracle日誌寫滿怎麼辦
Apr 12, 2025 am 06:09 AM
Oracle 日誌文件寫滿時，可採用以下解決方案：1）清理舊日誌文件；2）增加日誌文件大小；3）增加日誌文件組；4）設置自動日誌管理；5）重新初始化數據庫。在實施任何解決方案前，建議備份數據庫以防數據丟失。
甲骨文在商業世界中的作用
Apr 23, 2025 am 12:01 AM
Oracle不僅是數據庫公司，還是雲計算和ERP系統的領導者。 1.Oracle提供從數據庫到雲服務和ERP系統的全面解決方案。 2.OracleCloud挑戰AWS和Azure，提供IaaS、PaaS和SaaS服務。 3.Oracle的ERP系統如E-BusinessSuite和FusionApplications幫助企業優化運營。
HDFS配置CentOS需要哪些步驟
Apr 14, 2025 pm 06:42 PM
在CentOS系統上搭建Hadoop分佈式文件系統（HDFS）需要多個步驟，本文提供一個簡要的配置指南。一、前期準備安裝JDK:在所有節點上安裝JavaDevelopmentKit(JDK)，版本需與Hadoop兼容。可從Oracle官網下載安裝包。環境變量配置:編輯/etc/profile文件，設置Java和Hadoop的環境變量，使系統能夠找到JDK和Hadoop的安裝路徑。二、安全配置：SSH免密登錄生成SSH密鑰:在每個節點上使用ssh-keygen命令
oracle數據庫怎麼停止
Apr 12, 2025 am 06:12 AM
要停止 Oracle 數據庫，請執行以下步驟：1. 連接到數據庫；2. 優雅關機數據庫（shutdown immediate）；3. 完全關機數據庫（shutdown abort）。
