Databricks SQL Warehouse中动态SQL用变量创建Delta表求助

你可以通过以下两种正确方式在CREATE TABLE语句中引用已创建的club和environment Widget变量，替换硬编码部分：

方法一：直接使用${变量名}引用Widget #

这种方式适合直接在SQL字符串中替换变量值，注意变量要嵌入到路径的引号内：

%sql
CREATE TABLE customer (
    customer_key BIGINT,
    first_name STRING,
    last_name STRING,
    is_active INT,
    source STRING
)
USING DELTA
PARTITIONED BY (is_active, source)
LOCATION "abfss://${environment}@proemdatalake.dfs.core.windows.net/${club}_dw/customer"

（注：根据你的实际变量对应关系调整路径中的变量位置，比如原路径里的adcuat对应environment，adc_dw对应${club}_dw，按需修改）

方法二：使用参数化标记:变量名 #

这种方式利用Databricks SQL的参数化查询能力，自动绑定Widget变量：

如果变量直接替换路径片段：

%sql
CREATE TABLE customer (
    customer_key BIGINT,
    first_name STRING,
    last_name STRING,
    is_active INT,
    source STRING
)
USING DELTA
PARTITIONED BY (is_active, source)
LOCATION "abfss://:environment@proemdatalake.dfs.core.windows.net/:club_dw/customer"

如果需要变量与固定字符串拼接（比如club加_dw），可以用字符串拼接函数：

%sql
CREATE TABLE customer (
    customer_key BIGINT,
    first_name STRING,
    last_name STRING,
    is_active INT,
    source STRING
)
USING DELTA
PARTITIONED BY (is_active, source)
LOCATION concat("abfss://", :environment, "@proemdatalake.dfs.core.windows.net/", :club, "_dw/customer")

关键注意事项 #

• 确保Widget名称和SQL中引用的完全一致（Databricks Widget大小写敏感）
• 执行前确认Widget已赋值：可以用%sql SHOW WIDGETS命令查看所有已定义的Widget及其当前值
• 路径字符串的引号要完整包裹变量，避免语法错误；如果用字符串拼接，要保证拼接后的路径格式符合ADLS的规范

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