Oracle
 sql >> база данни >  >> RDS >> Oracle

Възможно ли е да излезете от опашката за синхронно улавяне на ANYDATA с помощта на JDBC?

Можете да напишете съхранена процедура и да премахнете съобщението от опашката в PL/SQL и да го конвертирате в XML текст и да го върнете като CLOB. След това можете да извикате съхранената процедура от Java с JDBC. Използвал съм подобно решение преди, когато обикновеният AQ API нямаше функция.

Пример:

create or replace procedure dequeue_lcr(
    p_queue_name   varchar2,
    p_consumer     varchar2,
    p_wait_seconds number,
    p_lcr          out clob) as
  deq_lcr     anydata;
  deq_xml     xmltype;
  msgid       raw(16); 
  deqopt      dbms_aq.dequeue_options_t; 
  mprop       dbms_aq.message_properties_t;
  no_messages exception; 
  pragma exception_init (no_messages, -25228);
begin
  deqopt.consumer_name := p_consumer;
  deqopt.wait := p_wait_seconds;
  deqopt.navigation := dbms_aq.first_message;
  deqopt.dequeue_mode  := dbms_aq.remove;
  begin
    dbms_aq.dequeue( 
      queue_name         =>  p_queue_name,
      dequeue_options    =>  deqopt,
      message_properties =>  mprop,
      payload            =>  deq_lcr,
      msgid              =>  msgid);
     deq_xml := dbms_streams.convert_lcr_to_xml(deq_lcr);
     p_lcr := deq_xml.getclobval();    
     commit;
  exception
    when no_messages then
      p_lcr := null;
  end;
end;

Това работи, когато го извикам от PL/SQL с правилната опашка и потребител:

declare
  v_clob clob;
begin
  dequeue_lcr('aqtest.hcb_queue_any', 'LOCAL_AGENT', 5, v_clob);
  if (v_clob is not null) then
    dbms_output.put_line('Data: ' || v_clob);
  else
    dbms_output.put_line('No messages');  
  end if;
end;

Просто направете повикването от Java с CallableStatement с clob като изходен параметър и трябва да сте готови!




  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Как да направите обвивка, която да връща нещо различно от референтен курсор

  2. Инсталирайте драйвери на Oracle Attunity в Visual Studio 2017

  3. получаване на грешка, аргументът '0' е извън диапазона

  4. Експортиране на sql заявка в csv вместо данни от таблица

  5. Как да отделя дял от таблица и да го прикача към друг в oracle?