Joomla 3.1 Templates by FatCow Coupon

Работа с внешним приложением по SOAP протоколу в ORACLE .Работа с XML в Oracle.

Категория: Блог Опубликовано 23.05.2017

создании данного материала неоценимую помощь мне оказал мой коллега
Доброквашин Михаил.

В этом материале будут разобраны следующие моменты:
Работа с XML в Oracle (формирование XML, хранение XML в базе, извлечение и парсинг XML документа)
Придача XML документа по HTTP протоколу, ожидание ответа, авторизация на HTTP сервере, получение ответа.
Работа с данными тип LOB.


Для примеров может быть использован сервер Oracle не ниже 9 ой версии, с поддержкой XML TYPE.

Введение

Многочисленные приложения сейчас используют в качестве обмена информацией формат XML. Протокол SOAP так же используется многими web сервисами и приложениями , такими как ozon , google, yandex. В протоколе soap XML документ передается по http get другому приложению или web службе, которая в свою очередь возвращает ответ так же в XML формате.

Рассмотрим ситуацию, когда нам необходимо с помощью средств oracle разработать приложения для взаимодействия с внешним Веб-сервисом с использованием SOAP протоколу.


Общая схема работы приложения

Итак, наша система работает по следующему алгоритму:
Приложение СУБД Oracle формирует XML документ заданного формата
Приложение СУБД Oracle внешнему веб-сервису сформированный XML
Ожидает ответа со стороны веб - сервиса и
Трансформирует ответ из XML в курсор Oracle и передает его далее во внешнее приложение
Формирование XML

Рассмотрим различные методы для формирования XML в Oracle

Преобразование данных из строки в формат XML:
Для создания XML создается соответствующий XML в формате VARCHAR2
Затем переменная VARCHAR2 преобразуется в CLOB , далее происходит непосредственно преобразование в XML.
Подобное преобразование необходимо для того что тип varchar2 ограничивается 32 килобайтами, а предаваемые xml могут большего объема.
Итак, при работе с XML oracle в процессе преобразований целесообразно использовать тип CLOB.
Стандартные методы работы с XML в Oracle


Сохраняем XML в базу данных
Сохранение XML происходит в поле CLOB

Function AddXML(tXML IN sys.xmltype, RETURN NUMBER
is
  tId NUMBER;
  PRAGMA AUTONOMOUS_TRANSACTION;
begin
begin
 SELECT LOG.nextval into tID from dual; 
  insert into
   logg
   (
   logid,
   xmldoc_in,
   logdate,
   )
  values
  ( 
   retId
  , tXMLDOC
  , sysdate
  );
  commit;
  return tId;
exception
  when others then raise_application_error(SQLCODE, 'Ошибка записи в Лог файл' );
end;  
end AddLogInf;




Создание XML
Создание XML в ORACLE удобнее всего преобразованием символьной переменной следующим образом:

xxml := '<Header><En xmlns:env="http://schemas.xmlsoap.org/soap/" en="http://orasource.code.ru/">  
</Header>   <Body>  <gets>         <id>'|| IDN  || '</id>'
||'<xml_start>' || T_START ||'</xml_start>'
||'<xml_stop>' || T_STOP || '</xml_stop>'
||' </gets>' ||'</Body> </En>';



Формируем XML  из типа varchar32 выполняем преобразование в axml sysxml.type
axml := xmltype.createxml(xXml);


итак , мы получаем готовый xml

<Header>
<En xmlns:env="http://schemas.xmlsoap.org/soap/" en="http://orasource.code.ru/">  
<Header/>  
<Body> 
  <gets>  
     <id>1</id>
     <xml_start>start</xml_start>
     <xml_stop>stop</xml_stop>
 </gets>
</Body>
</En>;





Расшифровка XML ответа
После того как внешнее приложение или веб сервис вернул нам ответ нам необходимо преобразовать его к курсору или единичному значению.
Посмотрим, как это сделать:
Для преобразования XML используется тип XMLSEQUENCE и команда EXTRACT
Единичное значение

<?xml version="1.0" encoding="UTF-8"?>
<Env xmlns:S="http://schemas.xmlsoap.org/soap/envelope/">
<Body><getxml xmlns http://www.orasource.ru/">
   <result>
     1
   </result>
   </getxml >
   </Body>
</Env>

 FOR cr_result IN
    (
     select -- Value(p)
     extract(Value(p), '/result/text()').getStringVal()  returnvalue
     from
     Table(XMLSEQUENCE(EXTRACT(xRetXml,'//result '))) p
    )
   LOOP    
      xRet := to_number(cr_result.returnvalue);
    END LOOP;


Курсор

Исходный XML

<?xml version="1.0" encoding="UTF-8"?>
<Env xmlns:S="http://schemas.xmlsoap.org/soap/envelope/">

<Body><getxml xmlns http://www.orasource.ru/">
   <return>
     <id>1</id>
     <id1>1</id1>
     <id2>1</id2>
  </return>
  <return>
     <id>2</id>
     <id1>2</id1>
     <id2>2</id2>
   </return>
   <return>
     <id>3</id>
     <id1>3</id1>
     <id2>3</id2>
   </return>
   </ getxml >
   </Body></Env>




open tmp_ref_cursor for
     select
        extract(Value(p), 'return/id /text()').getStringVal()                                id
     ,  cast(extract(Value(p), 'return/id_1 /text()').getStringVal() as NUMBER)           id_1
     ,  cast(extract(Value(p), 'return/id_2/text()').getStringVal() as NUMBER)               id_2      
    ,  cast(REPLACE(extract(Value(p), 'return/id/text()').getStringVal(),'.',',') as NUMBER)  balance
    ,  cast(extract(Value(p), 'return/id_3/text()').getStringVal() as NUMBER)               id_3
       From
Table(XMLSEQUENCE(EXTRACT(xXmlReturn,'//return'))) p;
    --Table(XMLSEQUENCE(EXTRACT(xRetXml,'/S_Envelope/S_Body/ns2_getBalancesListResponse/*'))) p;
    Table(XMLSEQUENCE(EXTRACT(xRetXml,'//return'))) p;


Обработка курсора внешним приложением 
Передача данных внешнему приложению
Url - адрес вызова
aXML - сформированный XML документ
Передача данных внешнему приложению осуществляется следующим образом

-- создаем временный LOB

  DBMS_LOB.createtemporary(XML, FALSE);


-- устанавливем кодировку http пакета

  utl_http.set_body_charset('UTF-8');
  HTTP_REQ := utl_http.begin_request(aURL, 'POST', 'HTTP/1.1');
  utl_http.set_header(HTTP_REQ, 'Content-Type', 'text/xml');



-- задаем дляну http пакета
-- следует обратить внимание, что длину пакета следует устанавливать с учетом кодировки
-- для utf8 устанавливается одна длина пакета , для другой кодировки будет другая
  utl_http.set_header(HTTP_REQ, 'Content-Length', LENGTHB(UNISTR(aENV))); --длина в ЮНИКОДЕ
-- проходми авторизацию на веб серевере
-- auser apassword пароль и имя пользователя на сервере
  utl_http.set_authentication(HTTP_REQ, v_USER, v_PASSWORD);
    loop
        buf := SUBSTR(aENV,i, 200);
        if buf is not null then
           utl_http.write_text(HTTP_REQ, buf);
           i:=i + 200;
        else
          exit;  
        end if;
    end loop;



-- отравляем пакет на веб сервер по частям, в 2000 байт



Итак, мы создаем временную переменную типа LOB в которую в дальнейшем будем принимать данные из внешнего приложения
Задаем кодировку и длину HTTP пакета
Прием данных из внешнего приложения или веб службы.
Прием данных из внешнего приложения или веб службы осуществляется следующим образом: 

HTTP_RESP := utl_http.get_response(HTTP_REQ); 
begin
   loop
     -- последовательно считываем текст XML документа
     -- в переменную env типа clob
     utl_http.read_text(HTTP_RESP, l_text, 32767);
     DBMS_LOB.writeappend (ENV, LENGTH(l_text), l_text); 
   end loop;                                        
  EXCEPTION
      WHEN THEN
-- здесь произвольная обработка исключений
  end;



  utl_http.end_response(HTTP_RESP); 

  --dbms_output.put_line(SUBSTR(ENV,1,250));   

  RESP:=ENV;

 

Просмотров: 1051