搜尋
首頁資料庫mysql教程Oracle中通过：触发器，存储过程，Function调用实现解析Clob字段

Oracle中通过：触发器，存储过程，Function调用实现解析Clob字段

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB
WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB
Jun 07, 2016 pm 03:32 PM
functionoracle儲存觸發器調過程透過

摘要：最近项目中用到了存储过程，触发器，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
相關文章
說明InnoDB重做日誌和撤消日誌的作用。說明InnoDB重做日誌和撤消日誌的作用。Apr 15, 2025 am 12:16 AM

InnoDB使用redologs和undologs確保數據一致性和可靠性。 1.redologs記錄數據頁修改，確保崩潰恢復和事務持久性。 2.undologs記錄數據原始值，支持事務回滾和MVCC。

在解釋輸出（類型，鍵，行，額外）中要查找的關鍵指標是什麼？在解釋輸出（類型，鍵，行，額外）中要查找的關鍵指標是什麼？Apr 15, 2025 am 12:15 AM

EXPLAIN命令的關鍵指標包括type、key、rows和Extra。 1）type反映查詢的訪問類型，值越高效率越高，如const優於ALL。 2）key顯示使用的索引，NULL表示無索引。 3）rows預估掃描行數，影響查詢性能。 4）Extra提供額外信息，如Usingfilesort提示需要優化。

在解釋中使用臨時狀態以及如何避免它是什麼？在解釋中使用臨時狀態以及如何避免它是什麼？Apr 15, 2025 am 12:14 AM

Usingtemporary在MySQL查詢中表示需要創建臨時表，常見於使用DISTINCT、GROUPBY或非索引列的ORDERBY。可以通過優化索引和重寫查詢避免其出現，提升查詢性能。具體來說，Usingtemporary出現在EXPLAIN輸出中時，意味著MySQL需要創建臨時表來處理查詢。這通常發生在以下情況：1)使用DISTINCT或GROUPBY時進行去重或分組；2)ORDERBY包含非索引列時進行排序；3)使用複雜的子查詢或聯接操作。優化方法包括：1)為ORDERBY和GROUPB

描述不同的SQL交易隔離級別（讀取未讀取，讀取，可重複的讀取，可序列化）及其在MySQL/InnoDB中的含義。描述不同的SQL交易隔離級別（讀取未讀取，讀取，可重複的讀取，可序列化）及其在MySQL/InnoDB中的含義。Apr 15, 2025 am 12:11 AM

MySQL/InnoDB支持四種事務隔離級別：ReadUncommitted、ReadCommitted、RepeatableRead和Serializable。 1.ReadUncommitted允許讀取未提交數據，可能導致臟讀。 2.ReadCommitted避免臟讀，但可能發生不可重複讀。 3.RepeatableRead是默認級別，避免臟讀和不可重複讀，但可能發生幻讀。 4.Serializable避免所有並發問題，但降低並發性。選擇合適的隔離級別需平衡數據一致性和性能需求。

MySQL與其他數據庫：比較選項MySQL與其他數據庫：比較選項Apr 15, 2025 am 12:08 AM

MySQL適合Web應用和內容管理系統，因其開源、高性能和易用性而受歡迎。 1)與PostgreSQL相比，MySQL在簡單查詢和高並發讀操作上表現更好。 2)相較Oracle，MySQL因開源和低成本更受中小企業青睞。 3)對比MicrosoftSQLServer，MySQL更適合跨平台應用。 4)與MongoDB不同，MySQL更適用於結構化數據和事務處理。

MySQL索引基數如何影響查詢性能？MySQL索引基數如何影響查詢性能？Apr 14, 2025 am 12:18 AM

MySQL索引基数对查询性能有显著影响：1.高基数索引能更有效地缩小数据范围，提高查询效率；2.低基数索引可能导致全表扫描，降低查询性能；3.在联合索引中，应将高基数列放在前面以优化查询。

MySQL：新用戶的資源和教程MySQL：新用戶的資源和教程Apr 14, 2025 am 12:16 AM

MySQL學習路徑包括基礎知識、核心概念、使用示例和優化技巧。 1)了解表、行、列、SQL查詢等基礎概念。 2)學習MySQL的定義、工作原理和優勢。 3)掌握基本CRUD操作和高級用法，如索引和存儲過程。 4)熟悉常見錯誤調試和性能優化建議，如合理使用索引和優化查詢。通過這些步驟，你將全面掌握MySQL的使用和優化。

現實世界Mysql：示例和用例現實世界Mysql：示例和用例Apr 14, 2025 am 12:15 AM

MySQL在現實世界的應用包括基礎數據庫設計和復雜查詢優化。 1)基本用法：用於存儲和管理用戶數據，如插入、查詢、更新和刪除用戶信息。 2)高級用法：處理複雜業務邏輯，如電子商務平台的訂單和庫存管理。 3)性能優化：通過合理使用索引、分區表和查詢緩存來提升性能。

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序，用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

顯示更多

熱門文章

R.E.P.O.能量晶體解釋及其做什麼（黃色晶體）
4 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
4 週前By尊渡假赌尊渡假赌尊渡假赌
刺客信條陰影：貝殼謎語解決方案
2 週前ByDDD
R.E.P.O.如果您聽不到任何人，如何修復音頻
4 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25：如何解鎖Myrise中的所有內容
1 個月前By尊渡假赌尊渡假赌尊渡假赌
顯示更多

熱工具

VSCode Windows 64位元 下載

VSCode Windows 64位元 下載

微軟推出的免費、功能強大的一款IDE編輯器

EditPlus 中文破解版

EditPlus 中文破解版

體積小，語法高亮，不支援程式碼提示功能

SublimeText3 Linux新版

SublimeText3 Linux新版

SublimeText3 Linux最新版

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

DVWA

DVWA

Damn Vulnerable Web App (DVWA) 是一個PHP/MySQL的Web應用程序，非常容易受到攻擊。它的主要目標是成為安全專業人員在合法環境中測試自己的技能和工具的輔助工具，幫助Web開發人員更好地理解保護網路應用程式的過程，並幫助教師/學生在課堂環境中教授/學習Web應用程式安全性。 DVWA的目標是透過簡單直接的介面練習一些最常見的Web漏洞，難度各不相同。請注意，該軟體中

顯示更多

熱門話題

gmail信箱登陸入口在哪裡
7508
15
CakePHP 教程
1378
52
steam的賬戶名稱是什麼格式
78
11
win11激活密鑰永久
52
19
NYT連接提示和答案
19
58
顯示更多