Oracle儲存過程請求WebService並解析返回報文

阿新 • • 發佈：2019-01-05

WebService請求報文：

<soapenv:Envelope xmlns:soapenv="" http://schemas.xmlsoap.org/soap/envelope/ "">
	<soap:Header xmlns:soap="" http://schemas.xmlsoap.org/soap/envelope/ ""></soap:Header>
	<soapenv:Body>
		<car:locationReq xmlns:car="" http://www.sxqc.com/osb/Trans/CarTravellingPathLocation "">
			<car:vin>EX027448</car:vin></car:locationReq>
	</soapenv:Body>
</soapenv:Envelope>

WebService響應報文：

<?xml version="1.0" encoding="UTF-8" ?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
	<soap:Header xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"></soap:Header>
	<soapenv:Body>
		<ns2:locationResp xmlns:ns2="http://www.sxqc.com/osb/Trans/CarTravellingPathLocation">
			<ns2:L_RET_STATUS>S</ns2:L_RET_STATUS>
			<ns2:L_RET_MESSAGE/>
			<ns2:L_RET_ERROR_CODE/>
			<ns2:data>
				<ns2:carno/>
				<ns2:state>3</ns2:state>
				<ns2:speed>52.20</ns2:speed>
				<ns2:totalMileage>57631.40</ns2:totalMileage>
				<ns2:locationTime>20171222184105</ns2:locationTime>
				<ns2:address>內蒙古自治區巴彥淖爾市五原縣和勝鄉110國道</ns2:address>
				<ns2:lng>108.337436</ns2:lng>
				<ns2:lat>41.075663</ns2:lat>
				<ns2:dir>299</ns2:dir></ns2:data>
		</ns2:locationResp>
	</soapenv:Body>
</soapenv:Envelope>

Oracle儲存過程：

create or replace procedure TXJ_TO_ZC_TRANS_HIS(p_vin             in varchar2,
                                                r_time            out nocopy varchar2,
                                                r_speed           out nocopy varchar2,
                                                r_mileage         out nocopy varchar2,
                                                r_lt              out nocopy varchar2,
                                                r_lg              out nocopy varchar2,
                                                r_address         out nocopy varchar2,
                                                r_state           out nocopy varchar2,
                                                r_ret_status      out nocopy varchar2,
                                                r_ret_message     out nocopy varchar2,
                                                r_ret_error_code  out nocopy varchar2,
                                                response_xml      out nocopy varchar2) is

  http_req    utl_http.req;
  http_resp   utl_http.resp;
  request_env clob;
  l_replyline varchar2(2000);
  v_sql       varchar2(32767) := '';

  type t_cursor is ref cursor;
  ids_cursor t_cursor;
  id_value   varchar2(32) := '';
  v_flag     number := 0;

  errorException exception;
  errorCode number;
  errorMsg  varchar2(1000);

  l_body_len number;
  l_offset number;
  l_max_buffer_len number := 255;
  l_buffer varchar2(500);

begin

  request_env := '<soapenv:Envelope  xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
                  <soap:Header xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
                  </soap:Header>
                  <soapenv:Body>
                  <car:locationReq xmlns:car="http://www.sxqc.com/osb/Trans/CarTravellingPathLocation">
                  <car:vin>'||p_vin||'</car:vin>
                  </car:locationReq>
                  </soapenv:Body>
                  </soapenv:Envelope>';

  http_req := utl_http.begin_request('http://172.16.8.166:7004/TransportationSB/CarTravellingPath/Txj/ProxyService/TransTxjCarTravellingPathLocationSvcProxy?wsdl',
                                     'POST',
                                     utl_http.HTTP_VERSION_1_1);

  utl_http.set_authentication(http_req, 'zc', 'welcome1');
  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');
  utl_http.set_header(http_req, 'Content-Length',dbms_lob.getlength(request_env));
  l_body_len := dbms_lob.getlength(request_env);

  l_offset := 1;
  l_buffer := NULL;
  WHILE l_offset < l_body_len loop
    dbms_lob.read(lob_loc => request_env
                  ,amount => l_max_buffer_len
                  ,offset => l_offset
                  ,buffer => l_buffer);
    l_offset := l_offset + l_max_buffer_len;
    utl_http.write_text(http_req, l_buffer);
    dbms_output.put_line(l_buffer);
  END LOOP;

  http_resp := utl_http.get_response(http_req);
  utl_http.read_text(http_resp, l_replyline);
  utl_http.end_response(http_resp);
  
  response_xml := l_replyline;
  response_xml := replace(response_xml,'soapenv:','');
  response_xml := replace(response_xml,'soap:','');
  response_xml := replace(response_xml,'ns2:','');
  
  SELECT RET_STATUS,RET_MESSAGE,RET_ERROR_CODE
    INTO r_ret_status,r_ret_message,r_ret_error_code
    FROM XMLTABLE('$B/Envelope/Body/locationResp' PASSING
                   XMLTYPE(response_xml) AS B COLUMNS
                   RET_STATUS VARCHAR2(50) PATH '/locationResp/L_RET_STATUS',
                   RET_MESSAGE VARCHAR2(50) PATH '/locationResp/L_RET_MESSAGE',
                   RET_ERROR_CODE VARCHAR2(50) PATH '/locationResp/L_RET_ERROR_CODE');

  IF r_ret_status = 'S' THEN
    SELECT TXJ_SPEED,TXJ_TOTAL_MILEAGE,TXJ_LOCATION_TIME,TXJ_ADDRESS,TXJ_LNG,TXJ_LAT,TXJ_STATE
      INTO r_speed,r_mileage,r_time,r_address,r_lg,r_lt,r_state
      FROM XMLTABLE('$B/Envelope/Body/locationResp/data' PASSING
                     XMLTYPE(response_xml) AS B COLUMNS
                     TXJ_CARNO VARCHAR2(50) PATH '/data/carno',
                     TXJ_SPEED VARCHAR2(50) PATH '/data/speed',
                     TXJ_TOTAL_MILEAGE VARCHAR2(50) PATH '/data/totalMileage',
                     TXJ_LOCATION_TIME VARCHAR2(50) PATH '/data/locationTime',
                     TXJ_ADDRESS VARCHAR2(50) PATH '/data/address',
                     TXJ_LNG VARCHAR2(50) PATH '/data/lng',
                     TXJ_LAT VARCHAR2(50) PATH '/data/lat',
                     TXJ_STATE VARCHAR2(50) PATH '/data/state');
  END IF;
  response_xml := l_replyline;

EXCEPTION
  when errorException then
    utl_http.end_response(http_resp);
    errorCode    := SQLCODE;
    errorMsg     := SUBSTR(SQLERRM, 1, 200);
    r_ret_status := 'E';
    response_xml := 'l_ret_status=' || r_ret_status || ',errorCode=' ||
                    errorCode || ',errorMsg=' || errorMsg;
  when others then
    utl_http.end_response(http_resp);
    errorCode    := SQLCODE;
    errorMsg     := SUBSTR(SQLERRM, 1, 200);
    r_ret_status := 'E';
    response_xml := 'l_ret_status=' || r_ret_status || ',errorCode=' ||
                    errorCode || ',errorMsg=' || errorMsg;

end TXJ_TO_ZC_TRANS_HIS;

測試結果：

注：Oracle呼叫http需要ACL許可權，https://www.cnblogs.com/Snowfun/p/5577178.html

Oracle儲存過程請求WebService並解析返回報文

WebService請求報文： <soapenv:Envelope xmlns:soapenv="" http://schemas.xmlsoap.org/soap/envelope/ ""> <soap:Header xmlns:soap="" htt

java HttpClient 訪問webservice並解析返回資料

關於webservice的普及就不多說了，直接進入主題吧。 1.導包

mybatis 呼叫oracle儲存過程，傳參、返回遊標的值獲取--示例

1，dao層程式碼 Integer currentlq_fsx = getSqlSession().selectOne("lqMapper.maxscore"); Map<String,Object> map = new HashMap<String,O

oracle儲存過程傳入in引數，返回結果集

create or replace procedure proc_report_TEST(zhxshss in varchar2, pcursor out sys_refcursor) as begi

C#呼叫WebService並解析返回的XML

string title = HttpUtility.UrlEncode(txtTitle.Text); string content = HttpUtility.UrlEncode(content1.Value); str

C#呼叫Oracle儲存過程並返回結果集

1.建立一個儲存過程: createorreplaceprocedure GET_PERSON ( RC1 outsys_refcursor, RC2 outsys_refcursor ) is begin open RC1 for select * from PERSO

Java執行Oracle儲存過程並接收返回值

Java執行Oracle儲存過程並接收多個返回值(集合/數值) Java程式碼： package com.pure.util; import java.sql.Connection; import java.sql.DriverManager; import java.s

C#呼叫ORACLE儲存過程返回結果集

Oracle中scott使用者下建立儲存過程： (注：從9i開始有了sys_refcursor這種型別，在以前的Oracle版本中需要使用REF CURSOR,並且還需放在一個程式包中) create or replace procedure sp_getdept (result

Oracle 儲存過程中傳送郵件，並支援使用者驗證中文標題和內容

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！

oracle 儲存過程傳送WebServie 請求

create or replace procedure CMS_TO_ESB_INTEGRAL is --呼叫ESB積分錯誤是重發介面 http_req utl_http.req; http_resp utl_http.resp; request_env clob; l_re

oracle 儲存過程返回結果集（轉載）

好久沒上來了, 難道今天工作時間稍有空閒, 研究了一下oracle儲存過程返回結果集. 配合oracle臨時表, 使用儲存過程來返回結果集的資料讀取方式可以解決海量資料表與其他表的連線問題. 在儲存過程中先根據過濾條件從海量資料表中選出符合條件的記錄並存放到臨

ORACLE 儲存過程遊標返回多行

1、過程主體 --儲存過程迴圈，SELECT INTO 是隱式遊標只能返回一行 CREATE OR REPLACE PROCEDURE P_LOOP_PR ( P_TIME NUMBER) IS A_OVER NUMBER; A_NAME VARCHAR2(20); BE

通過shell指令碼呼叫oracle儲存過程並加入定時任務

例項檔名：add_tab_partitions.sh #!/bin/sh username='waep' password='czty_waep' sqlplus -S ${username}/

VB呼叫WebService（直接Post方式）並解析返回的XML

Function TodoTaskBySOAP(postURL As String,host As String, n As Integer,FilterItem() As String,OwnerSSICID() As String ,AppID() As String

Oracle儲存過程如何呼叫java程式併發送Http請求

專案中有個需求是資料庫自動定時掃描資料庫，給符合要求的使用者傳送推送訊息，這就需要在儲存過程中自動呼叫傳送推送的程式，由於程式複雜，所以利用orcle 的pl/sql傳送http請求來間接呼叫外部程式。1.首先，在orcle中建立傳送http請求的java程式碼。java s

oracle儲存過程返回值

oracle的儲存過程只要返回的值是指定的型別就行了有的時候我們會看到這種寫法的儲存過程 create or replace function func_add(num1 in number,num2 in number) return number is r numbe

mybatis呼叫Oracle儲存過程返回結果集

在開發中，有時需要關聯幾張表來進行一些複雜的計算，此時可採用建立一張臨時表，將每次的資料計算後先存入臨時表，然後通過Oracle的遊標返回。在mybatis中的呼叫如下： //呼叫語法格式，需要構造一個resultMap，用來接收返回的結果集 <select id

mybatis呼叫oracle儲存過程返回sys_refcursor

Map<String, Object> map = new HashMap<String, Object>(); map.put("id", "0"); mapper.selectPosBy(map); return (List) map

oracle 儲存過程返回結果集 table形式

--sys_refcursor 和 cursor 優缺點比較優點比較優點一：sys_refcursor，可以在儲存過程中作為引數返回一個table格式的結構集（我把他認為是table型別，容易理解，其實是一個遊標集）， cursor 只能用在儲存過程，函式，包等的實現體中，不

使用oracle 儲存過程返回集合

1 所謂返回集合是返回遊標集合可以不使用臨時表,使用oracle自定義型別 2 可以先建一個object的type，再建一個type 型別為table 如：CREATE OR REPLACE TYPE Dis_WGM_dayreport_type as objec

Oracle儲存過程請求WebService並解析返回報文

相關推薦