Amazon Redshift游标使用与表关联更新实现技术咨询

需求梳理 #

你的需求是遍历test2_view_table的每一条记录，检查其中的pnr（作为唯一ID）是否存在于sdh_ticket_test2_update表中，满足指定条件时执行更新操作，未匹配或不满足条件时输出对应的结果。

完整可运行代码示例 #

我把你给出的代码片段补全为完整可执行的PL/SQL块，包含匹配逻辑、更新操作和结果输出：

DECLARE
    -- 游标c1：读取第一张表的核心字段
    CURSOR c1 IS 
        SELECT pnr, agrnumber, pnrcreatedate 
        FROM test2_view_table;
    r1 c1%ROWTYPE;
    
    -- 游标c2：读取第二张表用于匹配的字段
    CURSOR c2 IS 
        SELECT pnr, ano, pcdt 
        FROM sdh_ticket_test2_update;
    r2 c2%ROWTYPE;
    
    v_match_found BOOLEAN := FALSE;
BEGIN
    -- 遍历第一张表的每一行数据
    FOR r1 IN c1 LOOP
        v_match_found := FALSE;
        -- 遍历第二张表寻找匹配的pnr
        FOR r2 IN c2 LOOP
            -- 这里补充完整你的匹配条件（示例中保留你提到的pnr相等+第二张表对应字段为空）
            IF (r1.pnr = r2.pnr AND r2.pcdt IS NULL) THEN
                -- 执行更新操作：用第一张表的字段更新第二张表
                UPDATE sdh_ticket_test2_update
                SET ano = r1.agrnumber, pcdt = r1.pnrcreatedate
                WHERE pnr = r2.pnr;
                
                v_match_found := TRUE;
                DBMS_OUTPUT.PUT_LINE('成功更新pnr: ' || r1.pnr);
                EXIT; -- 找到匹配项后退出内层循环，避免重复处理
            END IF;
        END LOOP;
        
        -- 未找到匹配项时输出提示
        IF NOT v_match_found THEN
            DBMS_OUTPUT.PUT_LINE('未找到匹配的pnr记录: ' || r1.pnr);
        END IF;
    END LOOP;
    
    COMMIT; -- 提交所有更新操作
EXCEPTION
    WHEN OTHERS THEN
        ROLLBACK; -- 发生异常时回滚事务
        DBMS_OUTPUT.PUT_LINE('执行过程出错: ' || SQLERRM);
END;
/

重要性能优化建议 #

你当前用的嵌套游标循环方式，在数据量较大的场景下性能会非常差——因为每处理外层表的一条记录，就要全量扫描一次内层表。更高效的做法是直接利用数据库的关联查询来完成更新，避免游标嵌套：

-- 直接关联两张表完成更新，性能远高于游标循环
UPDATE sdh_ticket_test2_update t2
SET ano = t1.agrnumber, pcdt = t1.pnrcreatedate
FROM test2_view_table t1
WHERE t2.pnr = t1.pnr AND t2.pcdt IS NULL;

-- 同时可以单独查询未匹配的pnr记录
SELECT pnr AS 未匹配的PNR FROM test2_view_table
WHERE pnr NOT IN (SELECT pnr FROM sdh_ticket_test2_update);

这种方式会让数据库优化器自动选择最优的关联方式，大幅提升执行效率。

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