Oracle表遍历：基于COLUMN_A/COLUMN_B的多路径查询与存储过程方案

一、递归CTE查询方案（推荐） #

递归CTE可以直接处理层级关联+多路径遍历场景，自动跳过已访问记录，直到找到目标数据。

实现代码 #

WITH RECURSIVE traversal AS (
    -- 起始节点：指定COLUMN_A值，标记已访问
    SELECT 
        COLUMN_A, 
        COLUMN_B, 
        COLUMN_C,
        CAST(COLUMN_A AS VARCHAR2(4000)) AS visited -- 记录已访问的COLUMN_A，避免循环
    FROM your_table
    WHERE COLUMN_A = 35108338

    UNION ALL

    -- 递归关联：通过COLUMN_B匹配未访问节点
    SELECT 
        t.COLUMN_A, 
        t.COLUMN_B, 
        t.COLUMN_C,
        CONCAT(tr.visited, ',', t.COLUMN_A) AS visited
    FROM your_table t
    JOIN traversal tr ON t.COLUMN_B = tr.COLUMN_B
    -- 排除已访问节点，防止循环和重复处理
    WHERE NOT INSTR(tr.visited, ',' || t.COLUMN_A || ',') > 0
)
-- 筛选COLUMN_C非空的记录，如需仅返回第一条可加ROWNUM=1
SELECT *
FROM traversal
WHERE COLUMN_C IS NOT NULL
-- AND ROWNUM = 1;

核心说明 #

• 用visited字符串追踪已访问的COLUMN_A，通过INSTR判断是否重复访问，避免循环遍历
• 递归逻辑会自动遍历所有分支路径，无需额外处理多路径场景
• 若仅需最早找到的一条结果，添加ROWNUM=1即可终止后续遍历

二、存储过程方案（适合复杂逻辑扩展） #

如果需要自定义遍历顺序、日志记录等灵活控制，可采用存储过程结合集合实现，解决数组处理多路径的问题。

实现代码 #

CREATE OR REPLACE PROCEDURE find_non_null_column_c(
    p_start_column_a IN NUMBER,
    p_result OUT SYS_REFCURSOR
) AS
    TYPE t_col_a_list IS TABLE OF NUMBER;
    l_visited t_col_a_list := t_col_a_list();
    l_current_batch t_col_a_list := t_col_a_list();
    l_found BOOLEAN := FALSE;
    -- 临时变量用于结果检测
    v_dummy_a NUMBER;
    v_dummy_b VARCHAR2(100);
    v_dummy_c VARCHAR2(100);
BEGIN
    -- 初始化起始节点
    l_visited.EXTEND;
    l_visited(l_visited.COUNT) := p_start_column_a;
    l_current_batch.EXTEND;
    l_current_batch(l_current_batch.COUNT) := p_start_column_a;

    WHILE l_current_batch.COUNT > 0 AND NOT l_found LOOP
        -- 检查当前批次关联节点中是否存在COLUMN_C非空的记录
        OPEN p_result FOR
            SELECT DISTINCT t.COLUMN_A, t.COLUMN_B, t.COLUMN_C
            FROM your_table t
            JOIN TABLE(l_current_batch) cb 
              ON t.COLUMN_B = (SELECT COLUMN_B FROM your_table WHERE COLUMN_A = cb.COLUMN_VALUE)
            WHERE t.COLUMN_A NOT IN (SELECT COLUMN_VALUE FROM TABLE(l_visited))
              AND t.COLUMN_C IS NOT NULL;

        -- 判断是否找到结果
        FETCH p_result INTO v_dummy_a, v_dummy_b, v_dummy_c;
        IF p_result%FOUND THEN
            l_found := TRUE;
            CLOSE p_result;
            -- 重新打开游标返回所有符合条件的结果
            OPEN p_result FOR
                SELECT DISTINCT t.COLUMN_A, t.COLUMN_B, t.COLUMN_C
                FROM your_table t
                JOIN TABLE(l_current_batch) cb 
                  ON t.COLUMN_B = (SELECT COLUMN_B FROM your_table WHERE COLUMN_A = cb.COLUMN_VALUE)
                WHERE t.COLUMN_A NOT IN (SELECT COLUMN_VALUE FROM TABLE(l_visited))
                  AND t.COLUMN_C IS NOT NULL;
        ELSE
            CLOSE p_result;
            -- 获取下一批未访问的节点
            SELECT DISTINCT t.COLUMN_A
            BULK COLLECT INTO l_current_batch
            FROM your_table t
            JOIN TABLE(l_current_batch) cb 
              ON t.COLUMN_B = (SELECT COLUMN_B FROM your_table WHERE COLUMN_A = cb.COLUMN_VALUE)
            WHERE t.COLUMN_A NOT IN (SELECT COLUMN_VALUE FROM TABLE(l_visited));

            -- 将新节点加入已访问集合
            FOR i IN 1..l_current_batch.COUNT LOOP
                l_visited.EXTEND;
                l_visited(l_visited.COUNT) := l_current_batch(i);
            END LOOP;
        END IF;
    END LOOP;

    -- 未找到结果时返回空游标
    IF NOT l_found THEN
        OPEN p_result FOR SELECT NULL AS COLUMN_A, NULL AS COLUMN_B, NULL AS COLUMN_C FROM DUAL WHERE 1=0;
    END IF;
END;
/

核心说明 #

• 用l_visited集合记录已访问节点，彻底避免重复处理
• 采用批次处理模式，每次遍历当前层级的所有节点，天然支持多路径场景
• 每批次优先检查目标记录，找到后立即终止遍历，提升执行效率

三、优化建议 #

• 替换your_table为实际表名
• 给COLUMN_A、COLUMN_B创建索引，大幅提升大表下的遍历速度
• 若递归CTE的visited字符串长度超限，可改用TABLE OF NUMBER集合存储已访问节点，修改递归条件为t.COLUMN_A NOT IN (SELECT COLUMN_VALUE FROM TABLE(tr.visited))

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