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脱衣机
AI Hentai Generator
免费生成ai无尽的。
热门文章
R.E.P.O.能量晶体解释及其做什么（黄色晶体）
2 周前
By 尊渡假赌尊渡假赌尊渡假赌
仓库：如何复兴队友
4 周前
By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险：如何获得巨型种子
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
击败分裂小说需要多长时间？
3 周前
By DDD
R.E.P.O.保存文件位置：在哪里以及如何保护它？
3 周前
By DDD
热工具
记事本++7.3.1
好用且免费的代码编辑器
SublimeText3汉化版
中文版，非常好用
禅工作室 13.0.1
功能强大的PHP集成开发环境
Dreamweaver CS6
视觉化网页开发工具
SublimeText3 Mac版
神级代码编辑软件(SublimeText3)
oracle中计算两个日期之间天数的函数
May 08, 2024 pm 07:45 PM
Oracle 中计算两个日期之间天数的函数是 DATEDIFF()。具体用法如下：指定时间间隔单位：interval（如 day、month、year）指定两个日期值：date1 和 date2DATEDIFF(interval, date1, date2) 返回天数差
oracle数据库日志会保存多久
May 10, 2024 am 03:27 AM
Oracle 数据库日志的保留期限取决于日志类型和配置，包括：重做日志：由 "LOG_ARCHIVE_DEST" 参数配置的最大大小决定。归档重做日志：由 "DB_RECOVERY_FILE_DEST_SIZE" 参数配置的最大大小决定。在线重做日志：不归档，在数据库重启时丢失，保留期限与实例运行时间一致。审计日志：由 "AUDIT_TRAIL" 参数配置，默认保留 30 天。
oracle数据库启动步骤顺序为
May 10, 2024 am 01:48 AM
Oracle 数据库启动顺序为：1. 检查前置条件；2. 启动监听器；3. 启动数据库实例；4. 等待数据库打开；5. 连接到数据库；6. 验证数据库状态；7. 启用服务（如果需要）；8. 测试连接。
oracle中interval的用法
May 08, 2024 pm 07:54 PM
Oracle 中的 INTERVAL 数据类型用于表示时间间隔，语法为 INTERVAL <精度> <单位>，可使用加减乘除运算操作 INTERVAL，适用于存储时间数据、计算日期差值等场景。
oracle中某个字符出现的次数怎么看出来
May 09, 2024 pm 09:33 PM
要在 Oracle 中查找字符出现的次数，执行以下步骤：获取字符串的总长度；获取字符所在子字符串的长度；计算字符出现的次数：用总长度减去子字符串长度。
oracle数据库服务器硬件配置要求
May 10, 2024 am 04:00 AM
Oracle 数据库服务器硬件配置要求：处理器：多核，主频至少 2.5 GHz，大型数据库建议 32 核以上。内存：小型数据库至少 8GB，中等规模 16-64GB，大型数据库或高负载工作负载高达 512GB 或更多。存储：SSD 或 NVMe 磁盘，RAID 阵列提高冗余和性能。网络：高速网络（10GbE 或更高），专用网卡，低延迟网络。其他：稳定电源、冗余组件、兼容操作系统和软件、散热和冷却系统。
oracle需要多少内存
May 10, 2024 am 04:12 AM
Oracle 所需内存量取决于数据库大小、活动水平和所需性能水平：用于存储数据缓冲区、索引缓冲区、执行 SQL 语句和管理数据字典缓存。具体数量受数据库大小、活动水平和所需性能水平影响。最佳实践包括设置适当的 SGA 大小、调整 SGA 组件大小、使用 AMM 和监控内存使用情况。
oracle中替换字符串的方法
May 08, 2024 pm 07:24 PM
Oracle 中替换字符串的方法是使用 REPLACE 函数，该函数的语法为：REPLACE(string, search_string, replace_string)。使用步骤：1. 识别要替换的子字符串；2. 确定替换子字符串的新字符串；3. 使用 REPLACE 函数进行替换。高级用法包括：多个替换、大小写敏感、特殊字符替换等。
