DEQUEUE_ARRAY无法出队？批量取出20条Oracle AQ消息失败

你的批量出队代码返回0且未移除消息，核心问题在于数组类型不匹配和数组未初始化，以下是具体原因和修正方案：

关键错误点 #

1. 自定义payload数组类型不兼容
   你自行定义了RAW_ARRAY作为DEQUEUE_ARRAY的payload_array参数，但Oracle AQ针对RAW类型消息预定义了DBMS_AQ.raw_array_t类型，自定义类型与AQ内部期望的类型不匹配，导致无法接收消息。

2. 数组未初始化
   payload_array和msgid_array均未初始化，AQ无法将出队的消息写入未初始化的数组容器中。

修正后的出队代码 #

SET SERVEROUTPUT on
DECLARE
  v_dequeue_options       DBMS_AQ.dequeue_options_t;
  msg_prop_array          DBMS_AQ.message_properties_array_t := DBMS_AQ.message_properties_array_t();
  payload_array           DBMS_AQ.raw_array_t := DBMS_AQ.raw_array_t(); -- 使用预定义RAW数组类型并初始化
  msgid_array             DBMS_AQ.msgid_array_t := DBMS_AQ.msgid_array_t(); -- 初始化msgid数组
  retval                  PLS_INTEGER;
BEGIN
  -- 可选：设置立即可见，出队后直接移除消息（无需等待COMMIT）
  v_dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
  
  retval := DBMS_AQ.DEQUEUE_ARRAY( 
              queue_name               => 'my_queue',
              dequeue_options          => v_dequeue_options,
              array_size               => 20,
              message_properties_array => msg_prop_array,
              payload_array            => payload_array,
              msgid_array              => msgid_array);
  
  DBMS_OUTPUT.PUT_LINE('Number of messages dequeued: ' || retval);
  
  -- 可选：打印取出的消息内容
  IF retval > 0 THEN
    FOR i IN 1..retval LOOP
      DBMS_OUTPUT.PUT_LINE('Message ' || i || ': ' || UTL_RAW.CAST_TO_VARCHAR2(payload_array(i)));
    END LOOP;
  END IF;
  
  -- 若使用默认的ON_COMMIT可见性，需执行COMMIT才能永久移除消息
  -- COMMIT;
END;
/

额外验证建议 #

检查队列的payload类型是否与代码匹配，执行以下SQL确认：

SELECT qt.queue_payload_type
FROM dba_queue_tables qt
JOIN dba_queues q ON q.queue_table = qt.queue_table
WHERE q.queue_name = 'MY_QUEUE';

若结果不是RAW，需重新创建基于RAW类型的队列表和队列。

内容的提问来源于stack exchange，提问作者Diskdrive