如何将JS函数查询Snowflake的结果插入Snowflake表？

你的add函数无法正常工作，核心是两个问题：

• 错误的字符串引用逻辑：用双引号"${result}"包裹DDL结果，在Snowflake中双引号用于标识对象名（如列、表），而非字符串值，这会导致数据库把result当成列名而非实际的DDL字符串。
• SQL语法破坏风险：直接拼接DDL结果到SQL语句中，DDL通常包含单引号、换行等特殊字符，会直接打乱SQL语法结构，同时存在SQL注入隐患。

另外，原objectGet函数也可以做安全性和可读性优化，以下是完整的修正方案：

修正后的objectGet函数 #

function objectGet(objectType, db, schema, objectName) {
    // 使用绑定变量替代字符串拼接，避免语法错误与注入风险
    const stmt = snowflake.createStatement({
        sqlText: `SELECT GET_DDL(:1, :2) AS result`,
        binds: [objectType, `"${db}"."${schema}"."${objectName}"`]
    });
    const res = stmt.execute();
    // 规范取值方式，无结果时返回null
    return res.next() ? res.getColumnValue('result') : null;
}

修正后的add函数 #

function add(x) {
    const ddlResult = objectGet(x.view, x.db, x.schema, x.object);
    // 处理DDL获取失败的情况
    if (!ddlResult) {
        throw new Error('无法获取指定对象的DDL');
    }
    // 用绑定变量插入数据，彻底规避特殊字符与注入问题
    const insertStmt = snowflake.createStatement({
        sqlText: `INSERT INTO "Base"."Schema"."Example" (col) VALUES (:1)`,
        binds: [ddlResult]
    });
    insertStmt.execute();
    // 可选：返回插入行数作为反馈
    return insertStmt.getRowCount() + ' 行数据已插入';
}

关键优化点说明 #

• 绑定变量的使用：通过:1占位符和binds数组传递参数，Snowflake会自动处理字符串中的特殊字符（如单引号），同时杜绝SQL注入。
• 规范结果取值：用getColumnValue('result')替代直接访问res.result，这是Snowflake JS API中更标准的结果集取值方式。
• 空值防护：增加DDL结果为空的判断，避免插入无效数据或抛出意外错误。
• 语义化参数命名：将objectGet的view参数改为objectType，更贴合GET_DDL第一个参数是对象类型（如'VIEW'、'TABLE'）的语义。

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