Snowflake JS存储过程适配特殊字符列及LOAD_DATE优化求助

Snowflake中处理包含空格、特殊字符（如<>#）的列名，必须用**双引号(")**包裹，否则会解析失败。针对你的存储过程，需做两处核心修改：

1. 统一用双引号包裹列名
   从SQL Server获取列名后，在构建SELECT、MERGE等SQL语句时，对所有列名添加双引号包裹。示例代码片段：

   // 假设cols是从SQL Server读取的列名数组（含特殊字符/空格）
   const quotedCols = cols.map(col => `"${col}"`);
   // 用于拼接SELECT或INSERT子句
   const selectClause = quotedCols.join(', ');
   

2. 目标表列名匹配
   Snowflake目标表需提前创建带双引号的列（如"Column With Space"、"Col#ID"），或在存储过程动态建表时，用双引号定义列名，确保与源表列名完全匹配。

修改后的MERGE更新子句示例：

// 原代码可能直接拼接列名，现在改为带双引号的版本
const mergeUpdate = cols.map(col => `"${col}" = s."${col}"`).join(', ');

通过MERGE语句的分支逻辑，仅在插入新记录或更新已有变更记录时修改LOAD_DATE，避免全量更新：

1. 插入新记录时设置LOAD_DATE
   在WHEN NOT MATCHED分支中，将LOAD_DATE设为当前时间戳：

   WHEN NOT MATCHED THEN INSERT ("LOAD_DATE", ${quotedCols.join(', ')})
   VALUES (CURRENT_TIMESTAMP(), ${quotedCols.map(col => `s."${col}"`).join(', ')})
   

2. 更新变更记录时更新LOAD_DATE
   在WHEN MATCHED分支中，先判断源表与目标表的字段是否有差异，仅当字段变化时更新LOAD_DATE（如果不需要差异判断，直接更新也可，MERGE只会处理匹配到的记录）：

   WHEN MATCHED AND (${cols.map(col => `t."${col}" != s."${col}"`).join(' OR ')}) THEN
   UPDATE SET
       ${mergeUpdate},
       "LOAD_DATE" = CURRENT_TIMESTAMP()
   

完整嵌入JS存储过程的MERGE语句示例：

const mergeSql = `
MERGE INTO ${targetTable} t
USING (SELECT * FROM @stage/${fileName}) s
ON t."PRIMARY_KEY_COL" = s."PRIMARY_KEY_COL" -- 替换为你的主键匹配条件
WHEN MATCHED AND (${cols.map(col => `t."${col}" != s."${col}"`).join(' OR ')}) THEN
UPDATE SET
    ${cols.map(col => `t."${col}" = s."${col}"`).join(', ')},
    t."LOAD_DATE" = CURRENT_TIMESTAMP()
WHEN NOT MATCHED THEN
INSERT ("LOAD_DATE", ${cols.map(col => `"${col}"`).join(', ')})
VALUES (CURRENT_TIMESTAMP(), ${cols.map(col => `s."${col}"`).join(', ')})
`;
// 执行SQL
snowflake.execute({sqlText: mergeSql});

• 用双引号包裹列名后，Snowflake会区分大小写，需确保源表与目标表的列名大小写完全一致。
• MERGE的匹配条件（ON子句）必须使用主键或唯一键，避免重复匹配导致执行错误。
• 目标表的LOAD_DATE字段需允许为NULL或设置默认值（我们在插入/更新时主动赋值，无需依赖默认值）。

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