如何从Snowflake SQL连接获取带绑定参数的SQL语句

Snowflake Node.js连接器的stmt.getSqlText()方法只会返回包含占位符?的原始SQL语句，并不会自动替换绑定参数。要生成实际执行的带参数的SQL，你可以手动实现占位符替换逻辑，结合Statement对象的getBindValues()方法获取绑定值。

方法1：手动替换占位符 #

编写工具函数处理不同数据类型的参数格式化，将原始SQL中的?依次替换为对应绑定值：

function getExecutedSql(sqlText, bindValues) {
  let sql = sqlText;
  bindValues.forEach(value => {
    let formattedValue;
    if (typeof value === 'string') {
      // 字符串类型加单引号，转义内部单引号避免语法错误
      formattedValue = `'${value.replace(/'/g, "''")}'`;
    } else if (value instanceof Date) {
      // 日期格式化为Snowflake兼容的ISO字符串
      formattedValue = `'${value.toISOString()}'`;
    } else if (value === null || value === undefined) {
      formattedValue = 'NULL';
    } else {
      // 数字、布尔等类型直接转字符串
      formattedValue = String(value);
    }
    // 替换第一个匹配的占位符
    sql = sql.replace('?', formattedValue);
  });
  return sql;
}

在错误回调中调用该函数输出带参数的SQL：

snowflake.execute({
    sqlText: 'SELECT * FROM TBL_A WHERE A = ?',
    binds: [12],
    fetchAsString: ['NUMBER'],
    complete: function (err, stmt, rows) {
      if (err) {
          const executedSql = getExecutedSql(stmt.getSqlText(), stmt.getBindValues());
          console.error('执行失败，实际SQL语句：' + executedSql);
      }
      else {
        // 业务逻辑处理
      }
    }
  })

方法2：通过Snowflake查询历史获取（可选） #

若你有权限访问Snowflake系统视图，可事后通过查询历史获取实际执行的SQL，适合离线排查：

SELECT QUERY_TEXT
FROM TABLE(INFORMATION_SCHEMA.QUERY_HISTORY())
WHERE QUERY_ID = '<你的查询ID>'

注意：手动替换生成的SQL与Snowflake内部实际执行的SQL可能存在细微格式差异，但完全满足调试错误场景的需求。

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