如何在Snowflake存储过程中遍历结果集并调用其他存储过程

以下是修改后的Snowflake JavaScript存储过程代码，可实现查询指定表的4列数据、遍历每一行并将列值作为参数调用其他存储过程的逻辑：

CREATE OR REPLACE PROCEDURE SP_MAIN()
RETURNS VARCHAR(16777216)
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS
$$
// 1. 定义查询语句，明确指定需要的4列（推荐不要用*，避免冗余数据）
var query = `SELECT COL1, COL2, COL3, COL4 FROM SNAPSHOT.SNAPSHOT_CONFIG`;

try {
    // 2. 执行查询并获取结果集对象
    var resultSet = snowflake.execute({sqlText: query});
    
    // 3. 遍历结果集的每一行
    while (resultSet.next()) {
        // 4. 提取当前行的4列值（替换为你的实际列名）
        var col1Value = resultSet.getColumnValue('COL1');
        var col2Value = resultSet.getColumnValue('COL2');
        var col3Value = resultSet.getColumnValue('COL3');
        var col4Value = resultSet.getColumnValue('COL4');
        
        // 5. 构造调用目标存储过程的SQL，将列值作为参数传入
        // 注意：字符串参数需用单引号包裹，数值参数可省略；若值含单引号需转义
        var safeCol1 = col1Value ? col1Value.replace(/'/g, "''") : '';
        var safeCol2 = col2Value ? col2Value.replace(/'/g, "''") : '';
        var safeCol3 = col3Value ? col3Value.replace(/'/g, "''") : '';
        var safeCol4 = col4Value ? col4Value.replace(/'/g, "''") : '';
        
        var callSpSql = `CALL SP_OTHER('${safeCol1}', '${safeCol2}', '${safeCol3}', '${safeCol4}')`;
        
        // 6. 执行存储过程调用
        snowflake.execute({sqlText: callSpSql});
    }
    
    return '所有行处理完成';
} catch (err) {
    // 捕获并返回异常信息，便于排查问题
    return '处理失败: ' + err.message;
}
$$;

关键细节说明： #

• 明确指定列：避免使用SELECT *，直接写出需要的4列，减少数据传输量同时提升代码可读性。
• 结果集遍历：通过resultSet.next()移动到下一行，返回true表示仍有未处理的行，以此实现循环遍历。
• 列值提取：使用getColumnValue('列名')获取对应列的值，也可使用索引（如getColumnValue(1)表示第一列），但列名的可读性更强。
• 参数转义：如果列值包含单引号，必须用replace(/'/g, "''")进行转义，否则会触发SQL语法错误，同时避免注入风险。
• 异常处理：加入try-catch块捕获执行过程中的错误，方便快速定位问题。

注意事项： #

• 确保目标存储过程SP_OTHER已存在，且参数的数量、数据类型与传入的列值完全匹配。
• 若列值为数值、日期等非字符串类型，构造CALL语句时需去掉对应参数的单引号。

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