Snowpark参数化创建表失败：存储过程执行后无表生成求助

你的代码核心问题是Snowpark的查询是惰性执行的——调用session.sql()只是定义了查询逻辑，不会立刻在Snowflake上执行。原代码里的CREATE TABLE语句没有触发执行，所以目标表根本没被创建，自然SHOW TABLES返回0。

具体修复步骤 #

• 执行DDL语句（比如CREATE TABLE）时，必须调用.execute()方法触发实际执行，否则SQL只会停留在语法解析阶段，不会真正运行。
• SHOW TABLES LIKE语句中，匹配的表名需要用单引号包裹，否则Snowflake会把{TARGET_TABLE}当成标识符而非字符串匹配条件，导致无法正确找到表。
• 可选优化：已经通过session.use_database()和session.use_schema()切换了当前上下文，创建表时可以省略全限定名，让代码更简洁。

修改后的完整代码 #

CREATE OR REPLACE PROCEDURE table_merge(DB varchar,SCHEMA varchar,TARGET_TABLE varchar, SRC_TABLE varchar)
  RETURNS STRING
  LANGUAGE PYTHON
  RUNTIME_VERSION = '3.8'
  PACKAGES = ('snowflake-snowpark-python')
  HANDLER = 'table_merge'
AS
$$
def table_merge(session, DB, SCHEMA, TARGET_TABLE, SRC_TABLE ):
  session.use_database(DB)
  session.use_schema(SCHEMA)
  # 触发CREATE TABLE语句执行
  session.sql(f"CREATE TABLE {TARGET_TABLE} LIKE {SRC_TABLE}").execute()
  # SHOW TABLES LIKE需要用单引号包裹表名
  table_count = session.sql(f"SHOW TABLES LIKE '{TARGET_TABLE}'")
  return str(table_count.count())
$$; 

额外说明 #

• 如果你的表名包含特殊字符（比如空格、连字符），还需要用双引号把表名包裹起来，比如f"CREATE TABLE \"{TARGET_TABLE}\" LIKE \"{SRC_TABLE}\""，避免标识符解析错误。
• 执行存储过程后，可以直接在对应的数据库和schema下查看表是否存在，或者在存储过程里添加session.sql("SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = ?", params=[TARGET_TABLE]).collect()来验证表的创建状态。

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