oracle发送HTTP请求参考例子
2016-07-20 13:43
453 查看
//------------------oracle发送HTTP请求参考例子------------
function fnSqlHttpRequest(
pi_URL in varchar2, --发送的Http URL
pi_Content in varchar2, --发送的报文内容
po_ReMsg out varchar2, --错误内容
po_xmltype out xmltype --响应报文内容
) return boolean
as
obj_http_req UTL_HTTP.REQ; --http请求对象
obj_http_resp UTL_HTTP.RESP; --http响应对象
v_req_clob varchar2(32767); --请求报文
v_resp_clob clob; --响应报文
v_buffer_text varchar2(32767); --缓存
v_resp_text varchar2(32767);
TIMEOUT INTEGER DEFAULT 3600;
--v_length int;
begin
v_req_clob:=pi_Content;
--DBMS_OUTPUT.PUT_LINE('pi_Content = ' || pi_Content);
--v_length:=length(pi_Content);
-- DBMS_OUTPUT.PUT_LINE('v_req_clob = ' || v_req_clob);
-- 初始化晌应CLOB.
DBMS_LOB.createtemporary(v_resp_clob, FALSE);
v_resp_text:='';
-- 初始化HTTP请求参数.
UTL_HTTP.SET_TRANSFER_TIMEOUT(TIMEOUT);
obj_http_req := UTL_HTTP.BEGIN_REQUEST (pi_URL, 'POST');
UTL_HTTP.SET_HEADER (obj_http_req,'Content-Type','text/xml');
UTL_HTTP.SET_HEADER (obj_http_req,'Content-Length',lengthb(v_req_clob));
UTL_HTTP.SET_BODY_CHARSET(obj_http_req,'UTF-8');
--发送HTTP请求
UTL_HTTP.WRITE_TEXT (obj_http_req,v_req_clob);
--接收响应
obj_http_resp := UTL_HTTP.GET_RESPONSE(obj_http_req);
/*
if (obj_http_resp.status_code <> 100) then
utl_http.end_response(obj_http_resp);
raise_application_error(20000, 'Request rejected');
end if;*/
BEGIN
LOOP
UTL_HTTP.READ_TEXT(obj_http_resp, v_buffer_text, 30000);
-- v_resp_text:=v_resp_text||v_buffer_text;
DBMS_LOB.WRITEAPPEND(v_resp_clob, length(v_buffer_text), v_buffer_text);
END LOOP;
--关闭HTTP连接
UTL_HTTP.END_RESPONSE(obj_http_resp);
EXCEPTION
WHEN UTL_HTTP.REQUEST_FAILED THEN --The HTTP request failed
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'HTTP请求失败:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
RETURN FALSE;
WHEN UTL_HTTP.TRANSFER_TIMEOUT THEN
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'HTTP请求超时失败:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
RETURN FALSE;
WHEN UTL_HTTP.END_OF_BODY THEN--
UTL_HTTP.END_RESPONSE(obj_http_resp);
WHEN OTHERS THEN
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'HTTP请求错误:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
RETURN FALSE;
END;
--DBMS_OUTPUT.PUT_LINE('v_resp_clob = ' || v_resp_clob);
--创建XMLTYPE对象
po_xmltype:=sys.XMLTYPE(v_resp_clob);
--释放clob
DBMS_LOB.freetemporary(v_resp_clob);
RETURN TRUE;
EXCEPTION
WHEN OTHERS THEN
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'XML内容错误:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
return false;
end sqlsendhttpreq;
function fnSqlHttpRequest(
pi_URL in varchar2, --发送的Http URL
pi_Content in varchar2, --发送的报文内容
po_ReMsg out varchar2, --错误内容
po_xmltype out xmltype --响应报文内容
) return boolean
as
obj_http_req UTL_HTTP.REQ; --http请求对象
obj_http_resp UTL_HTTP.RESP; --http响应对象
v_req_clob varchar2(32767); --请求报文
v_resp_clob clob; --响应报文
v_buffer_text varchar2(32767); --缓存
v_resp_text varchar2(32767);
TIMEOUT INTEGER DEFAULT 3600;
--v_length int;
begin
v_req_clob:=pi_Content;
--DBMS_OUTPUT.PUT_LINE('pi_Content = ' || pi_Content);
--v_length:=length(pi_Content);
-- DBMS_OUTPUT.PUT_LINE('v_req_clob = ' || v_req_clob);
-- 初始化晌应CLOB.
DBMS_LOB.createtemporary(v_resp_clob, FALSE);
v_resp_text:='';
-- 初始化HTTP请求参数.
UTL_HTTP.SET_TRANSFER_TIMEOUT(TIMEOUT);
obj_http_req := UTL_HTTP.BEGIN_REQUEST (pi_URL, 'POST');
UTL_HTTP.SET_HEADER (obj_http_req,'Content-Type','text/xml');
UTL_HTTP.SET_HEADER (obj_http_req,'Content-Length',lengthb(v_req_clob));
UTL_HTTP.SET_BODY_CHARSET(obj_http_req,'UTF-8');
--发送HTTP请求
UTL_HTTP.WRITE_TEXT (obj_http_req,v_req_clob);
--接收响应
obj_http_resp := UTL_HTTP.GET_RESPONSE(obj_http_req);
/*
if (obj_http_resp.status_code <> 100) then
utl_http.end_response(obj_http_resp);
raise_application_error(20000, 'Request rejected');
end if;*/
BEGIN
LOOP
UTL_HTTP.READ_TEXT(obj_http_resp, v_buffer_text, 30000);
-- v_resp_text:=v_resp_text||v_buffer_text;
DBMS_LOB.WRITEAPPEND(v_resp_clob, length(v_buffer_text), v_buffer_text);
END LOOP;
--关闭HTTP连接
UTL_HTTP.END_RESPONSE(obj_http_resp);
EXCEPTION
WHEN UTL_HTTP.REQUEST_FAILED THEN --The HTTP request failed
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'HTTP请求失败:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
RETURN FALSE;
WHEN UTL_HTTP.TRANSFER_TIMEOUT THEN
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'HTTP请求超时失败:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
RETURN FALSE;
WHEN UTL_HTTP.END_OF_BODY THEN--
UTL_HTTP.END_RESPONSE(obj_http_resp);
WHEN OTHERS THEN
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'HTTP请求错误:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
RETURN FALSE;
END;
--DBMS_OUTPUT.PUT_LINE('v_resp_clob = ' || v_resp_clob);
--创建XMLTYPE对象
po_xmltype:=sys.XMLTYPE(v_resp_clob);
--释放clob
DBMS_LOB.freetemporary(v_resp_clob);
RETURN TRUE;
EXCEPTION
WHEN OTHERS THEN
UTL_HTTP.END_RESPONSE(obj_http_resp);
DBMS_LOB.freetemporary(v_resp_clob);
po_ReMsg := 'XML内容错误:' || 'DBS' || to_char(SQLCODE) || ':' || substr(SQLERRM,1,128);
pkgSystem.prAddErrLog('fnHttpSqlRequest',SQLCODE, SQLERRM);
return false;
end sqlsendhttpreq;
相关文章推荐
- 基于 Red Hat 的发行版 Oracle Linux 正式发布Oracle Linux 7.1
- Oracle Containers for J2EE远程安全漏洞(CVE-2014-0413)
- Oracle 10g R2不能使用EM的问题
- 表空间操作
- PreparedStatement中in子句的处理
- VMware下RedHat4.8_64位安装Oracle 10g RAC--简略脚本
- oracle sql日期比较
- 基于 Red Hat 的发行版 Oracle Linux 正式发布Oracle Linux 7.1
- OS block size和Oracle block size,查找OS Blocksize的方法
- oracle中创建数据库和表空间的几点总结
- 数据库自动备份脚本
- oracle的nvl函数的使用介绍
- 解决oracle用户连接失败的解决方法
- oracle的一些tips技巧
- Oracle 下的开发日积月累
- Oracle存储过程之数据库中获取数据实例
- Windows下ORACLE 10g完全卸载的方法分析
- Oracle 函数大全[字符串函数,数学函数,日期函数]第1/4页
- ORACLE LATERAL-SQL-INJECTION 个人见解