当前位置: 开发笔记 > 数据库 > 正文

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

作者：壹滒_918 | 来源：互联网 | 2017-05-12 15:44

摘要：最近项目中用到了存储过程，触发器，Function，由于以前没怎么用过，所以查资料，请教同事，最后总算是把问题解决了，问题是这样的，数据库中有三张表一张是存放从远程服务器获取数据的MBINMSGS表，这个表里面有个Clob字段，里面存放的是xml式的字符串

摘要：最近项目中用到了存储过程，触发器，Function，由于以前没怎么用过，所以查资料，请教同事，最后总算是把问题解决了，问题是这样的，数据库中有三张表一张是存放从远程服务器获取数据的MBINMSGS表，这个表里面有个Clob字段，里面存放的是xml&＃26684;式的字符串，我们要把这个表里面的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 &＃39;&＃39;;
   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, &＃39;RENO&＃39;);
   AIRLINE := GetXmlNodeValue (xmlStr, &＃39;AIRLINE&＃39;);
   FFID := GetXmlNodeValue (xmlStr, &＃39;FFID&＃39;);

   ABNS := GetXmlNodeValue (xmlStr, &＃39;ABNS&＃39;);
   ACFT := GetXmlNodeValue (xmlStr, &＃39;ACFT&＃39;);
   CHDT := GetXmlNodeValue (xmlStr, &＃39;CHDT&＃39;);
   EIBT := GetXmlNodeValue (xmlStr, &＃39;EIBT&＃39;);
   FATA := GetXmlNodeValue (xmlStr, &＃39;FATA&＃39;);
   FETA := GetXmlNodeValue (xmlStr, &＃39;FETA&＃39;);
   FFID := GetXmlNodeValue (xmlStr, &＃39;FFID&＃39;);
   FSTA := GetXmlNodeValue (xmlStr, &＃39;FSTA&＃39;);
   LMDT := GetXmlNodeValue (xmlStr, &＃39;LMDT&＃39;);
   LMUR := GetXmlNodeValue (xmlStr, &＃39;LMUR&＃39;);
   PSTM := GetXmlNodeValue (xmlStr, &＃39;PSTM&＃39;);
   RWAY := GetXmlNodeValue (xmlStr, &＃39;RWAY&＃39;);
   SPOT := GetXmlNodeValue (xmlStr, &＃39;SPOT&＃39;);
   STND := GetXmlNodeValue (xmlStr, &＃39;STND&＃39;);


   A_TOBT := GetXmlNodeValue (xmlStr, &＃39;A_TOBT&＃39;);
   A_WEATHER := GetXmlNodeValue (xmlStr, &＃39;A_WEATHER&＃39;);
   --ABNS := GetXmlNodeValue (xmlStr, &＃39;ABNS&＃39;);
   --ACFT := GetXmlNodeValue (xmlStr, &＃39;ACFT&＃39;);
   ASAT := GetXmlNodeValue (xmlStr, &＃39;ASAT&＃39;);
   BCTM := GetXmlNodeValue (xmlStr, &＃39;BCTM&＃39;);
   BOTM := GetXmlNodeValue (xmlStr, &＃39;BOTM&＃39;);
   BSTM := GetXmlNodeValue (xmlStr, &＃39;BSTM&＃39;);
   C_TOBT := GetXmlNodeValue (xmlStr, &＃39;C_TOBT&＃39;);
   COBT := GetXmlNodeValue (xmlStr, &＃39;COBT&＃39;);
   CTOT := GetXmlNodeValue (xmlStr, &＃39;CTOT&＃39;);

   DINT := GetXmlNodeValue (xmlStr, &＃39;DINT&＃39;);
   DLAB := GetXmlNodeValue (xmlStr, &＃39;DLAB&＃39;);
   DOUT := GetXmlNodeValue (xmlStr, &＃39;DOUT&＃39;);
   EDDI := GetXmlNodeValue (xmlStr, &＃39;EDDI&＃39;);
   EOBT := GetXmlNodeValue (xmlStr, &＃39;EOBT&＃39;);
   EPGT := GetXmlNodeValue (xmlStr, &＃39;EPGT&＃39;);
   EPOT := GetXmlNodeValue (xmlStr, &＃39;EPOT&＃39;);
   FATD := GetXmlNodeValue (xmlStr, &＃39;FATD&＃39;);
   FSTD := GetXmlNodeValue (xmlStr, &＃39;FSTD&＃39;);
   --LMDT := GetXmlNodeValue (xmlStr, &＃39;LMDT&＃39;);
   --LMUR := GetXmlNodeValue (xmlStr, &＃39;LMUR&＃39;);
   OFTM := GetXmlNodeValue (xmlStr, &＃39;OFTM&＃39;);
   STDI := GetXmlNodeValue (xmlStr, &＃39;STDI&＃39;);
   TSAT := GetXmlNodeValue (xmlStr, &＃39;TSAT&＃39;);
   

   IF INSTR(FFID,&＃39;-D-&＃39;) > 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字符串插入到对应的数据表中。

推荐阅读

sql
掌握Java EE的全面指南

探讨如何真正掌握Java EE，包括所需技能、工具和实践经验。资深软件教学总监李刚分享了对毕业生简历中常见问题的看法，并提供了详尽的标准。 ... [详细]

蜡笔小新 2024-12-25 13:38:29
sql
Tomcat配置80端口时常见问题及解决方案

本文探讨了在Windows Server 2008环境下配置Tomcat使用80端口时遇到的问题，包括端口被占用、多项目访问失败等，并提供详细的解决方法和配置建议。 ... [详细]

蜡笔小新 2024-12-24 19:21:28
insert
Windows服务与数据库交互问题解析

本文探讨了在Windows 10（64位）环境下开发的Windows服务，旨在定期向本地MS SQL Server (v.11)插入记录。尽管服务已成功安装并运行，但记录并未正确插入。我们将详细分析可能的原因及解决方案。 ... [详细]

蜡笔小新 2024-12-28 10:30:14
insert
PHP检测AJAX请求的有效方法

本文详细介绍了如何使用PHP检测AJAX请求，通过分析预定义服务器变量来判断请求是否来自XMLHttpRequest。此方法简单实用，适用于各种Web开发场景。 ... [详细]

蜡笔小新 2024-12-27 21:20:10
sql
新浪笔试题

1:有如下一段程序：packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]

蜡笔小新 2024-12-27 19:32:17
insert
深入理解 SQL 视图、存储过程与事务

本文详细介绍了SQL中的视图、存储过程和事务的概念及应用。视图为用户提供了一种灵活的数据查询方式，存储过程则封装了复杂的SQL逻辑，而事务确保了数据库操作的完整性和一致性。 ... [详细]

蜡笔小新 2024-12-27 17:40:42
json
RESTful API 与传统接口的主要区别

本文探讨了 RESTful API 和传统接口之间的关键差异，解释了为什么 RESTful API 在设计和实现上具有独特的优势。 ... [详细]

蜡笔小新 2024-12-27 15:33:42
json
Java面试题解析

本文详细介绍了Java编程语言中的核心概念和常见面试问题，包括集合类、数据结构、线程处理、Java虚拟机（JVM）、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题，帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]

蜡笔小新 2024-12-27 13:55:14
sql
MyBatis：深入解析与应用

在当前众多持久层框架中，MyBatis（前身为iBatis）凭借其轻量级、易用性和对SQL的直接支持，成为许多开发者的首选。本文将详细探讨MyBatis的核心概念、设计理念及其优势。 ... [详细]

蜡笔小新 2024-12-27 12:17:16
memcached
MySQL缓存机制深度解析

本文详细探讨了MySQL的缓存机制，包括主从复制、读写分离以及缓存同步策略等内容。通过理解这些概念和技术，读者可以更好地优化数据库性能。 ... [详细]

蜡笔小新 2024-12-26 15:15:06
sql
MySQL 数据库迁移指南：从本地到远程及磁盘间迁移

本文详细介绍了如何在不同场景下进行 MySQL 数据库的迁移，包括从一个硬盘迁移到另一个硬盘、从一台计算机迁移到另一台计算机，以及解决迁移过程中可能遇到的问题。 ... [详细]

蜡笔小新 2024-12-26 13:21:38
insert
MySQL LAST_INSERT_ID() 函数深入解析

本文详细介绍了 MySQL 中 LAST_INSERT_ID() 函数的使用方法及其工作原理，包括如何获取最后一个插入记录的自增 ID、多行插入时的行为以及在不同客户端环境下的表现。 ... [详细]

蜡笔小新 2024-12-25 22:04:04
insert
深入理解Java Web中的过滤器机制

本文详细介绍了Java Web应用程序中的过滤器（Filter）功能，包括其作用、实现方式及配置方法。过滤器可以在请求到达目标资源之前对其进行预处理，并在响应返回给客户端之前进行后处理。 ... [详细]

蜡笔小新 2024-12-24 17:57:57
insert
JavaScript 实战与基础案例解析

本文介绍了多个关于JavaScript的书籍资源、实用工具和编程实例，涵盖从入门到进阶的各个阶段，帮助读者全面提升JavaScript编程能力。 ... [详细]

蜡笔小新 2024-12-24 16:36:52
insert
分组获取最大N条记录的优化方案及新年祝福

探讨如何从数据库中按分组获取最大N条记录的方法，并分享新年祝福。本文提供多种解决方案，适用于不同数据库系统，如MySQL、Oracle等。 ... [详细]

蜡笔小新 2024-12-24 12:30:56

壹滒_918

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章