编写PL/SQL块：按Contract_ID补全Line_Num空值为连续序列

首先明确你的需求：针对GECM_OKC_CON_PART_DETAILS表（对应示例中的tx表），每个contract_id下有一个初始非空的column46（对应示例的line_num），其余为NULL，需要把这些空值更新为从该组最大column46开始的连续递增数，最终每个合同的行号是1、2、3...这样的连续序列。

完整的PL/SQL解决方案 #

DECLARE
    -- 游标：获取所有符合GE-Power条件的合同ID及其当前最大行号
    CURSOR c_target_contracts IS
        SELECT gocpd.contract_id, MAX(gocpd.column46) AS current_max_line
        FROM gecm_okc_con_part_details gocpd
        JOIN okc_rep_contracts_all orca 
            ON gocpd.contract_id = orca.contract_id
        WHERE orca.attribute12 = 'GE-Power'
        GROUP BY gocpd.contract_id;
    
    v_contract_id gecm_okc_con_part_details.contract_id%TYPE;
    v_current_max gecm_okc_con_part_details.column46%TYPE;
BEGIN
    -- 遍历每个符合条件的合同
    FOR contract_rec IN c_target_contracts LOOP
        v_contract_id := contract_rec.contract_id;
        v_current_max := contract_rec.current_max_line;
        
        -- 更新当前合同下的空行号，生成连续递增序列
        UPDATE gecm_okc_con_part_details gocpd
        SET column46 = v_current_max + ROW_NUMBER() OVER (ORDER BY ROWID)
        WHERE contract_id = v_contract_id
          AND column46 IS NULL; -- 注意：判断空值必须用IS NULL，不能用=NULL
    END LOOP;
    
    COMMIT;
    DBMS_OUTPUT.PUT_LINE('所有符合条件的空行号已成功更新为连续递增序列！');
EXCEPTION
    WHEN OTHERS THEN
        ROLLBACK;
        DBMS_OUTPUT.PUT_LINE('更新失败，错误详情：' || SQLERRM);
        RAISE; -- 重新抛出异常，便于上层处理
END;
/

代码关键点说明 #

• 游标批量处理：通过游标获取所有attribute12 = 'GE-Power'的合同ID及其最大行号，确保批量处理所有符合条件的合同，而非单个硬编码的ID。
• 窗口函数生成连续序列：使用ROW_NUMBER() OVER (ORDER BY ROWID)为每个空值记录生成从1开始的序号，加上当前合同的最大行号，就能得到连续的递增值。如果你的业务有特定排序规则（比如按创建时间排序），可以把ROWID换成对应的字段。
• 正确的空值判断：SQL中NULL不等于任何值（包括它自己），所以必须用IS NULL来匹配空值记录，原代码中的= NULL是无效的。
• 异常处理：添加了事务回滚和错误信息输出，避免更新失败时出现数据不一致的情况。

原代码的问题分析 #

1. 变量作用域错误：你定义的var1在第一个BEGIN...END块内，第二个BEGIN...END块无法访问这个变量，会直接编译报错。
2. 硬编码单个合同ID：原代码只处理了contract_id = 525215，无法批量处理所有符合GE-Power条件的合同。
3. 空值判断错误：使用gocpd.column46 = NULL无法匹配任何空值记录，永远不会执行更新。
4. 更新逻辑缺陷：原代码会把所有空值都设置为var1 + 1，导致同一个合同下的空值都变成同一个数，无法实现连续递增的效果。

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