Oracle 11g APPS ERP中，如何基于VARRAY行的ORG_ID条件执行DBMS_AQ出队？

直接用l_dequeue_options.deq_condition := 'tab.user_data.line_varray.org_id=99';是行不通的哦——因为line_varray是VARRAY类型的集合，Oracle没办法直接在DEQUEUE的条件里直接引用集合内部元素的字段，得用专门的集合处理方式来实现。

正确的DEQUEUE过滤条件（针对含目标行的整个消息） #

如果你需要的是只要消息里存在至少一行org_id=82的销售订单行，就出队整个消息，可以用EXISTS子查询结合TABLE()函数来展开VARRAY，把集合转成可查询的行结构：

l_dequeue_options.deq_condition := 'EXISTS (
    SELECT 1 
    FROM TABLE(tab.user_data.line_varray) lines
    WHERE lines.org_id = 82
)';

这里的TABLE()函数会把line_varray这个VARRAY拆分成一条条的行记录，然后我们在子查询里检查这些行中是否有符合org_id=82的记录，只要存在就满足出队条件。

如果需要仅保留符合条件的行（而非整个消息） #

如果你的需求是只提取消息中org_id=82的行，丢弃其他行，那单纯靠DEQUEUE的过滤条件是做不到的——因为AQ的DEQUEUE操作是针对整个消息的：要么完整出队整个消息，要么不出队。这种情况下，你需要先出队整个消息，再在PL/SQL代码里手动过滤行：

-- 先出队整个消息到变量l_message（类型为SYSTEM.ASO_Order_Feedback_Type）
DBMS_AQ.DEQUEUE(
    queue_name        => 'YOUR_QUEUE_NAME', -- 替换成你的队列名
    dequeue_options   => l_dequeue_options,
    message_properties=> l_msg_properties,
    payload           => l_message,
    msgid             => l_msgid
);

-- 初始化过滤后的行集合
l_filtered_lines ASO_Line_Var_Type := ASO_Line_Var_Type();

-- 遍历原行集合，筛选出org_id=82的行
FOR i IN 1..l_message.line_varray.COUNT LOOP
    IF l_message.line_varray(i).org_id = 82 THEN
        l_filtered_lines.EXTEND;
        l_filtered_lines(l_filtered_lines.COUNT) := l_message.line_varray(i);
    END IF;
END LOOP;

-- 后续业务逻辑就用l_filtered_lines来处理即可

补充说明 #

在Oracle 11g中，使用TABLE()函数处理VARRAY时，确保你的用户有访问相关类型和函数的权限（APPS场景下通常已经配置好，但如果遇到权限问题可以检查EXECUTE权限）。

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