Snowflake DB：加载至目标表前如何动态将源表空字符串转为NULL

1. 查询/INSERT场景的动态SQL实现 #

源表全为VARCHAR类型，要批量将所有列的空字符串转为NULL后插入目标表，可以通过系统视图动态生成处理语句，不用手动逐列编写：

-- 替换成你的源表和目标表
SET src_table = '你的源表架构.源表名';
SET tgt_table = '你的目标表架构.目标表名';

-- 生成带NULLIF处理的列列表
SET processed_cols = (
    SELECT LISTAGG('NULLIF(' || COLUMN_NAME || ', '''''') AS ' || COLUMN_NAME, ', ')
    FROM INFORMATION_SCHEMA.COLUMNS
    WHERE TABLE_SCHEMA = SPLIT_PART($src_table, '.', 1)
      AND TABLE_NAME = SPLIT_PART($src_table, '.', 2)
);

-- 生成并执行INSERT语句
SET insert_stmt = 'INSERT INTO ' || $tgt_table || ' SELECT ' || $processed_cols || ' FROM ' || $src_table;
EXECUTE IMMEDIATE $insert_stmt;

• NULLIF(col, '')会把列中等于空字符串的值转为NULL，其他值保持原样
• 利用INFORMATION_SCHEMA.COLUMNS自动获取所有列名，适配表结构变更
• LISTAGG负责拼接所有列的处理表达式，最终生成完整的INSERT语句

2. 批量加载（COPY INTO）场景的处理 #

如果是从外部存储加载数据到目标表，可直接在COPY INTO中配置转换规则：

针对CSV/TSV等文本文件 #

COPY INTO 你的目标表架构.目标表名
FROM @你的存储阶段/数据路径
FILE_FORMAT = (
    TYPE = CSV
    FIELD_OPTIONALLY_ENCLOSED_BY = '"'
    EMPTY_FIELD_AS_NULL = TRUE -- 自动将空字段转为NULL
);

针对JSON等半结构化数据 #

COPY INTO 你的目标表架构.目标表名
FROM (
    SELECT 
        NULLIF(parse_json($1):列1::VARCHAR, '')::INT,
        NULLIF(parse_json($1):列2::VARCHAR, '')::DATE,
        -- 其他列按目标表数据类型依次处理
    FROM @你的存储阶段/数据路径
)
FILE_FORMAT = (TYPE = JSON);

3. 转换验证 #

执行处理后，用以下语句确认空字符串已转为NULL：

SELECT 
    COLUMN_NAME,
    COUNT(*) AS 总行数,
    COUNT(CASE WHEN "'||COLUMN_NAME||'" = '' THEN 1 END) AS 空字符串数量,
    COUNT(CASE WHEN "'||COLUMN_NAME||'" IS NULL THEN 1 END) AS NULL数量
FROM 你的源表架构.源表名
GROUP BY COLUMN_NAME;

对比目标表的NULL统计，确保转换生效。

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