ORACLE存储过程调用Web Service--Java学习网
1. 概述
最近在ESB项目中,客户在各个系统之间的服务调用大多都是在oracle存储过程中进行的,本文就oracle存储过程调用web service来进行说明。其他主流 数据库 ,比如mysql和sql service,调用web service的方法这里就不做介绍了,本文主要用来介绍oracle存储过程调用Web Service的方法。
众所周知,在Web Service通过HTTP协议发送请求和接收结果时,发送的请求内容和结果内容都采用XML格式封装,并增加了一些特定的HTTP消息头,以说明HTTP消息的内容格式,这些特定的HTTP消息头和XML内容格式就是SOAP协议。SOAP协议是基于HTTP协议的,两者的关系就好比高速公路是基于普通公路改造的,在一条公路上加上隔离栏后就成了高速公路。
同理,在oracle的存储过程中能不能也通过创建XML格式的报文+HTTP协议来调用Web Service呢?答案是肯定的,在ORACLE中有一个名叫UTL_HTTP的工具包,我们可以通过这个工具包来实现存储过程调用Web Service。
上文提到的AEAI ESB是数通畅联的核心产品之一,可以实现WEB服务开发和WEB服务注册等功能,本文的接口样例,本考虑使用ESB创建的WEB服务,但是由于涉及到的需要介绍的内容和本文主题太远,所以采用了AEAI DP开发平台自带的Web服务样例来说明。有对AEAI ESB感兴趣的读者可以通过本文最后的相关链接查找了解。
2. 预期读者
- 数通畅联新员工
- 广大技术爱好者
3. 环境信息
操作系统:Windows7
Oracle: 版本为oracle11g
Mysql:版本为mysql5.1
Jdk: jdk1.6.0_10
4. 名词解释
AEAI ESB:应用集成平台主要作为企业信息系统的“龙骨”来集成各业务系统,一般称之为企业服务总线(Enterprise Service BUS,ESB),在数通畅联软件的产品家族中应用集成平台命名为AEAI ESB。
AEAI DP:AEAI DP应用开发平台专门用于开发MIS类的Java Web应用,也称Miscdp(Misc Develope Platform)综合应用开发平台。AEAI DP应用开发平台在数通畅联软件产品家族中也作为扩展开发的支撑工具,比如:为AEAI Portal门户平台扩展开发Portlet组件、Web Service和Http Service;为AEAI BPM流程集成平台扩展开发业务流程表单及功能等。
存储过程:大型数据库系统中,一组为了完成特定功能的SQL 语句集,存储在数据库中,经过第一次编译后再次调用不需要再次编译,用户通过指定存储过程的名字并给出参数(如果该存储过程带有参数)来执行它。
UTL_HTTP:oracle中自带的HTTP协议工具包,可以用来发送post请求。
PL/SQL Developer:一个集成开发环境,由Allround Automations公司开发,专门面向Oracle 数据库存储 的程序单元的开发
5. 操作步骤
5.1 创建样例接口
使用AEAI DP开发平台,创建自带WS服务的应用,如下图:
选择数据库信息
部署应用后,查看刚刚创建的应用自带的WS服务
5.2 创建存储过程
5.2.1 基本语法
以下为创建存储过程的基本语法
CREATE OR REPLACE PROCEDURE存储过程名 ( --定义参数 )IS定义变量BEGIN开始PL/SQL体END说明PL/SQL体结束 |
---|
5.2.2 创建步骤
1、打开PL/SQL,并打开一个sql窗口
2、将创建存储过程的语句放入其中并执行
这样一个调用web service的存储过程样例就创建了,以下为详细的样例sql体
--创建存储过程,定义四个参数,入参:userid,code,name;出参:resmark
CREATE OR REPLACE PROCEDURE pro_test_ws(name in varchar2,resmark out varchar2) IS
--定义四个变量,http请求,http返回,请求报文,返回报文
http_req UTL_HTTP.REQ;
http_Resp UTL_HTTP.RESP;
request_env VARCHAR2(32767);
l_Replyline VARCHAR2(1000);
BEGIN
--开始pl/sql体
request_env := '
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:demo="http://demo.service.wstest.agileai.com/">
<soapenv:Header/>
<soapenv:Body>
<demo:sayHi>
<!--Optional:-->
<theGirlName>'|| name ||'</theGirlName>
</demo:sayHi>
</soapenv:Body>
</soapenv:Envelope>
--打印请求报文
dbms_output.put_line(request_env);
--请求WS地址
http_req := UTL_HTTP.
begin_request('http://localhost:6060/cam/services/UserSync?wsdl',
'POST',
UTL_HTTP.http_version_1_1);
-- 保持连接状态
Utl_Http.Set_Persistent_Conn_Support(http_req, TRUE);
--设置编码
Utl_Http.Set_Header(http_req, 'Content-Type', 'text/xml;charset=utf-8');
Utl_Http.Set_Header(http_req, 'SOAPAction', '');
--设置字符集
Utl_Http.Set_Body_Charset(http_req, 'utf-8');
--该参数代表我发送的POST报文多长,不可少
Utl_Http.Set_Header(http_req, 'Content-Length', Lengthb(request_env));
Utl_Http.Write_Line(http_req, request_env);
--赋值http返回
http_Resp := Utl_Http.Get_Response(http_req);
--将请求报文赋值给 l_Replyline
Utl_Http.Read_Text(http_Resp, l_Replyline);
dbms_output.put_line(l_Replyline);