Snowflake中变量为空时跳过表查询的实现方案

方案一：使用动态SQL拼接查询语句 #

这种方法会逐个检查变量是否非空，只将有效表名对应的查询语句拼接到最终SQL中，从根源上避免空变量引发的解析错误。

示例代码：

DECLARE
  -- 从combine表提取表名并赋值变量（根据实际逻辑调整查询）
  prod_table_1 STRING DEFAULT (SELECT table_full_name FROM combine WHERE seq = 1);
  prod_table_2 STRING DEFAULT (SELECT table_full_name FROM combine WHERE seq = 2);
  prod_table_3 STRING DEFAULT (SELECT table_full_name FROM combine WHERE seq = 3);
  -- ... 依次定义prod_table_4至prod_table_15
  final_sql STRING DEFAULT '';
BEGIN
  -- 拼接非空变量对应的查询分支
  IF(prod_table_1 IS NOT NULL AND prod_table_1 != '') THEN
    final_sql := final_sql || 'SELECT * FROM TABLE($prod_table_1) UNION ALL ';
  END IF;
  IF(prod_table_2 IS NOT NULL AND prod_table_2 != '') THEN
    final_sql := final_sql || 'SELECT * FROM TABLE($prod_table_2) UNION ALL ';
  END IF;
  -- ... 重复上述IF逻辑到prod_table_15

  -- 处理最终SQL的收尾：移除末尾多余的UNION ALL，或设置兜底空结果集
  IF(LENGTH(final_sql) > 0) THEN
    final_sql := LEFT(final_sql, LENGTH(final_sql) - 11); -- 11是' UNION ALL '的字符长度
  ELSE
    -- 所有变量为空时，返回与目标表结构一致的空结果集（需替换为实际表的列定义）
    final_sql := 'SELECT NULL::VARCHAR AS col1, NULL::INT AS col2, NULL::DATE AS col3 FROM DUAL WHERE 1=0';
  END IF;

  -- 执行动态SQL并传入变量
  EXECUTE IMMEDIATE final_sql USING prod_table_1, prod_table_2, ..., prod_table_15;
END;

关键注意事项 #

• 表结构一致性：所有要合并的表必须拥有完全相同的列数、列名和数据类型，否则UNION ALL会抛出类型不匹配错误。
• 变量空值判断：同时检查IS NOT NULL和!= ''，避免变量为空白字符串的情况。
• 兜底空结果集：当所有变量都为空时，必须构造一个结构匹配的空结果集，防止EXECUTE IMMEDIATE执行空字符串报错。

原方案报错原因 #

当变量为空时，SELECT * FROM TABLE($prod_table_n)会先尝试解析空字符串为表对象，Snowflake无法识别空字符串对应的合法表，因此直接抛出对象不存在的错误——WHERE条件无法提前拦截这种解析阶段的错误，动态SQL是最可靠的解决方式。

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