列名含'.'时如何将列值传入DBT宏

首先要纠正你原来宏的逻辑问题：当前宏是在SQL编译阶段判断传入的参数字符串（比如列名）是否包含utm，而非在数据库运行阶段判断列值是否包含utm，这和你的实际需求不符。

步骤1：修正宏的逻辑 #

改成生成SQL的CASE语句，实现运行时判断列值：

{% macro parse_url_string_format(input_expr) %}
  CASE
    WHEN {{ input_expr }} LIKE '%utm%' THEN {{ input_expr }}
    ELSE ''
  END
{% endmacro %}

步骤2：正确传递带.的列名 #

由于列名my.column.a包含特殊字符，在Jinja中直接写my.column.a会被解析为属性访问而非列引用，需要用以下两种方式处理：

方式一：用adapter.quote()通用包裹列名 #

调用宏时，通过adapter.quote()将列名转换为适配当前数据库的引用格式（比如PostgreSQL用双引号、BigQuery用反引号）：

select {{ parse_url_string_format(adapter.quote('my.column.a')) }} as parsed_a
from table_1

方式二：直接传入带引号的列名（针对特定数据库） #

如果你明确知道数据库的引用规则，也可以直接传入带引号的列名字符串：

-- PostgreSQL/BigQuery等示例，根据数据库调整引号类型
select {{ parse_url_string_format('"my.column.a"') }} as parsed_a
from table_1

为什么原来的调用方式不对？ #

当你写parse_url_string_format(my.column.a)时，Jinja会尝试解析my这个对象的column属性再取a属性，由于不存在这个对象，最终会将整个my.column.a作为字符串传入宏，导致宏编译时处理的是字符串'my.column.a'而非列的实际引用。

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