Oracle
 sql >> Base de données >  >> RDS >> Oracle

Est-il possible de sortir de la file d'attente de capture synchrone ANYDATA à l'aide de JDBC ?

Vous pouvez écrire une procédure stockée et retirer le message en PL/SQL et le convertir en texte XML et le renvoyer en tant que CLOB. Ensuite, vous pouvez appeler la procédure stockée à partir de Java avec JDBC. J'ai déjà utilisé une solution de contournement similaire lorsqu'il manquait une fonctionnalité à l'API AQ ordinaire.

Exemple :

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;

Cela fonctionne lorsque je l'appelle depuis PL/SQL avec la file d'attente et le consommateur appropriés :

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;

Faites simplement l'appel depuis Java avec un CallableStatement avec un clob comme paramètre de sortie et vous devriez être prêt à partir !