如何将多个Drop表语句传递到DBT中的循环？

Question

我想在雪花上放多个桌子。我没有将多个命令添加到我的DBT作业中，而只需传递表名称，而是在数据库的Information_Schema下使用了表视图，并找到了一种从那里构造我的Drop语句的方法。

这是我用来构建我的下降语句的语句：

SELECT
    CONCAT('"DROP TABLE IF EXISTS ', CONCAT(CONCAT_WS('.', TABLE_CATALOG, TABLE_SCHEMA, TABLE_NAME), '"'))
FROM "{{ var('db_name') }}"."INFORMATION_SCHEMA"."TABLES"
WHERE table_owner = '{{ var("table_owner") }}'
AND table_schema = '{{ var("schema_name") }}'
AND table_name LIKE '{{ var("table_name") }}'

我的第一种方法（我也发布了一个问题）是将上述语句的结果放到一个字符串中，然后将其传递到变量，然后将该变量传递给我的post_hook。但是显然，post_hook仅接受字符串值。请参阅此 post。

我的下一个方法是将结果列表传递给带有run_query命令的for loop而不是将结果列表传递给一个字符串。

这是我的整个代码：

{%- set generate_drop_table_statement -%}
SELECT
    CONCAT('"DROP TABLE IF EXISTS ', CONCAT(CONCAT_WS('.', TABLE_CATALOG, TABLE_SCHEMA, TABLE_NAME), '"'))
FROM "{{ var('db_name') }}"."INFORMATION_SCHEMA"."TABLES"
WHERE table_owner = '{{ var("table_owner") }}'
AND table_schema = '{{ var("schema_name") }}'
AND table_name LIKE '{{ var("table_name") }}'
{%- endset -%}

{%- set get_drop_statements = run_query(generate_drop_table_statement) -%}

{%- if execute -%}
{%- set drop_statements = get_drop_statements.columns[0].values() -%}

{%- set exec_query -%}
    {{ log(drop_statements, info=True) }}
    
    {% for drop_statement in drop_statements %}
        {{ log(drop_statement, info=True) }}
        {%- do run_query(drop_statement) -%}
    {% endfor %}
{%- endset -%}

{%- else -%}
{%- set drop_statements = [] -%}
{%- endif -%}

{{ config (
alias='DROP_STATEMENTS_TABLE',
materialized='table',
post_hook='{{ exec_query }}'
) }}

with statements as (
SELECT
    1 as id
)

SELECT *
FROM statements

从日志中我可以看到，由于以下行，查询已经传递：{log（drop_statement，info = true）}}}，但是在显示第一个语句后，它失败了到run_query部分。

这是我遇到的错误：

Tried to run an empty query on model 'model.learn_dbt.drop_table'. If you are conditionally running
sql, eg. in a model hook, make sure your `else` clause contains valid sql!

Provided SQL:
/* {"app": "dbt", "dbt_version": "1.1.0", "profile_name": "eric-snowflake-dbt", "target_name": "dev", "node_id": "model.learn_dbt.drop_table"} */

"DROP TABLE IF EXISTS ANALYTICS.DBT.TEST_X_TABLE"

如何解决这个问题？

提前致谢。

Update

我刚刚更新了我的声明：

SELECT
    CONCAT('DROP TABLE IF EXISTS ', CONCAT_WS('.', TABLE_CATALOG, TABLE_SCHEMA, TABLE_NAME))
FROM "{{ var('db_name') }}"."INFORMATION_SCHEMA"."TABLES"
WHERE table_owner = '{{ var("table_owner") }}'
AND table_schema = '{{ var("schema_name") }}'
AND table_name LIKE '{{ var("table_name") }}'

我在示例中注意到，我发现传递给run_query的语句已包含在 single quotes ，引号。那解决了我的问题。

希望这将来将来刚刚开始学习DBT的人。