关于XML文件内容插入Oracle数据库的应用

首先我们建立一个存储过程domsample,并且在oracle数据库中建立一个表people,另外新建一个people.xml文件及people.dtd文件,

新建表的SQL语句如下:

CREATE TABLE PEOPLE

(

ID VARCHAR2(10) PRIMARY KEY,

NAME VARCHAR2(20),

ADDRESS VARCHAR2(60),

TEL VARCHAR2(20),

FAX VARCHAR2(20),

EMAIL VARCHAR2(40)

);

people.xml文件内容如下:

<?xml version="1.0"?>
<!DOCTYPE PEOPLE SYSTEM "people.dtd">
<PEOPLE>
<PERSON ID="E01">
  <NAME>Tony Blair</NAME>
  <ADDRESS>10 Downing Street, London, UK</ADDRESS>
  <TEL>(061) 98765</TEL>
  <FAX>(061) 98768</FAX>
  <EMAIL>blair@everywhere.com</EMAIL>
</PERSON>
<PERSON ID="E02">
  <NAME>Bill Clinton</NAME>
  <ADDRESS>White House, USA</ADDRESS>
  <TEL>(001) 6400 98765</TEL>
  <FAX>(001) 6400 98769</FAX>
  <EMAIL>bill@everywhere.com</EMAIL>
</PERSON>
<PERSON ID="E03">
  <NAME>Tom Cruise</NAME>
  <ADDRESS>57 Jumbo Street, New York, USA</ADDRESS>
  <TEL>(001) 4500 67859</TEL>
  <FAX>(001) 4500 67895</FAX>
  <EMAIL>cruise@everywhere.com</EMAIL>
</PERSON>
<PERSON ID="E04">
  <NAME>Linda Goodman</NAME>
  <ADDRESS>78 Crax Lane, London, UK</ADDRESS>
  <TEL>(061) 54 56789</TEL>
  <FAX>(061) 54 56772</FAX>
  <EMAIL>linda@everywhere.com</EMAIL>
</PERSON>
</PEOPLE>

people.dtd文件内容如下:

<?xml version="1.0" encoding="UTF-8"?>
<!ELEMENT ADDRESS (#PCDATA)>
<!ELEMENT EMAIL (#PCDATA)>
<!ELEMENT FAX (#PCDATA)>
<!ELEMENT NAME (#PCDATA)>
<!ELEMENT PEOPLE (PERSON+)>
<!ELEMENT PERSON (NAME, ADDRESS, TEL, FAX, EMAIL)>
<!ATTLIST PERSON
ID CDATA #REQUIRED
>
<!ELEMENT TEL (#PCDATA)>

存储过程语句如下:

create or replace procedure domsample(dir varchar2, inpfile varchar2,
errfile varchar2) is
-- 参数说明：
-- dir 基本目录，如 'd:\xml\plsql'
-- inpfile 输入文件名，不含路径，如 'people.xml'
-- errfile 错误日志文件，保存解析错误信息，如 'err.log'

p xmlparser.parser;
doc xmldom.DOMDocument;

procedure xmlinserttable(doc xmldom.DOMDocument) is
nl xmldom.DOMNodeList;
len number;
len2 number;
n xmldom.DOMNode;
nnm xmldom.DOMNamedNodeMap;
attrname varchar2(100);
attrval varchar2(100);
strSQL varchar2(20000);
attn xmldom.DOMNode;
nl2 xmldom.DOMNodeList;
begin
nl := xmldom.getElementsByTagName(doc, 'PERSON'); -- 读取 PERSON 元素
len := xmldom.getLength(nl);
-- 遍历元素
for i in 0..len-1 loop
   strSQL := 'INSERT INTO PEOPLE VALUES ('; -- 构造动态 SQL 语句
   n := xmldom.item(nl, i);
   if xmldom.getNodeName(n)='PERSON' then
      nnm := xmldom.getAttributes(n); -- 读取 ID 属性
      attn := xmldom.item(nnm, 0);
      strSQL := strSQL || '''' || xmldom.getNodeValue(attn) || '''';
   end if;
   -- 读取 PERSON 的子节点
   nl2 := xmldom.getChildNodes(n);
   len2 := xmldom.getLength(nl2);
   -- 处理 NAME, ADDRESS, ... 等节点
   for j in 0..len2-1 loop
      n := xmldom.item(nl2, j);
      strSQL := strSQL || ', ''' || xmldom.getNodeValue(xmldom.getFirstChild(n)) || '''';
   end loop;
   strSQL := strSQL || ')';   -- 完成动态 SQL 语句的构造
   -- 执行插入记录的 SQL 语句
   execute immediate(strSQL); -- 执行动态 SQL
end loop;
commit; -- 提交插入
end xmlinserttable;

begin
-- 新建解析器实例
p := xmlparser.newParser;

-- 设置解析器特性
   xmlparser.setValidationMode(p, TRUE); -- 是否使用文档指定的DTD验证文档合法性
   xmlparser.setErrorLog(p, dir || '\' || errfile); -- 设置错误日志文件
   xmlparser.setBaseDir(p, dir);   -- 设置基本目录

-- 解析输入的xml文件
xmlparser.parse(p, dir || '\' || inpfile);

-- 获取解析后的文档对象
doc := xmlparser.getDocument(p);

-- 释放解析器实例
   xmlparser.freeParser(p);

   dbms_output.put_line('插入数据中...');
   xmlinserttable(doc);

-- 释放文档对象
xmldom.freeDocument(doc);

-- 处理异常
exception
when xmldom.INDEX_SIZE_ERR then
     raise_application_error(-20120, 'Index Size error');
when xmldom.DOMSTRING_SIZE_ERR then
     raise_application_error(-20120, 'String Size error');
when xmldom.HIERARCHY_REQUEST_ERR then
     raise_application_error(-20120, 'Hierarchy request error');
when xmldom.WRONG_DOCUMENT_ERR then
     raise_application_error(-20120, 'Wrong doc error');
when xmldom.INVALID_CHARACTER_ERR then
     raise_application_error(-20120, 'Invalid Char error');
when xmldom.NO_DATA_ALLOWED_ERR then
     raise_application_error(-20120, 'Nod data allowed error');
when xmldom.NO_MODIFICATION_ALLOWED_ERR then
     raise_application_error(-20120, 'No mod allowed error');
when xmldom.NOT_FOUND_ERR then
     raise_application_error(-20120, 'Not found error');
when xmldom.NOT_SUPPORTED_ERR then
     raise_application_error(-20120, 'Not supported error');
when xmldom.INUSE_ATTRIBUTE_ERR then
     raise_application_error(-20120, 'In use attr error');
end domsample;

最后我们就可以调用存储过程了.可以在PLSQL Developer用以下方法调用:

exec domsample('d:\xml\plsql','people.xml','err.log');

必须注意的是:在d:\xml\plsql目录下必须有people.xml文件及people.dtd文件.

希望这篇文章能对初学者有所帮助!!!

Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=1639655