在 DBT 中旋转带有撇号的列答案

【问题标题】：Pivoting a column with an apostrophe in DBT在 DBT 中旋转带有撇号的列
【发布时间】：2020-09-16 22:53:26
【问题描述】：

我正在尝试使用撇号旋转一列，但这在 DBT 中非常困难。有任何想法吗？我尝试了双引号，但 dbt 没有选择这个，我不能在数据透视中使用 like 语句。

 {% set pvt_details=[
      ('General liability cover_rated_premium' , 'gl_premium')
    , ('Contractors' errors and omissions cover_rated_premium','eo_premium') ] %}
 WITH filtered AS (
     SELECT
     quote_id
    , target
    , premium_after_amount
 from {{ source('acdc', 'chopin_quote_rating_steps') }} cqrs
 WHERE target IN ({% for column in pvt_details %} '{{column[0]}}' {%- if not loop.last -%} 
, {%- endif %}
  {% endfor %})
    AND action = 'initial_premium'
  )
  select *
  from filtered
  pivot(sum(premium_after_amount)
   for target in ({% for column in pvt_details %} '{{column[0]}}' {%- if not loop.last -%} , 
{%- endif %}
{% endfor %}))
  as p (quote_id,
        {% for column in pvt_details %} {{column[1]}} {%- if not loop.last -%} , {%- endif 
%}
        {% endfor %})

【问题讨论】：

您已将此标记为 SQL - 您可以指定其他信息，例如发行版 + 版本吗？即 Postgres 11.8、SQL Server 2017 等
如果这是 Postgres，您可能会发现以下内容很有帮助：stackoverflow.com/a/9170637/3073340，“双引号以转义它们”。只是一个想法 - 对情况了解不够，无法提供更多见解。

标签： sql dbt

【解决方案1】：

在 DBT 宏中试试这个链接。有一个仅用于枢轴的宏。

https://github.com/fishtown-analytics/dbt-utils/blob/master/macros/sql/pivot.sql

将值从行转到列。

例子：

Input: `public.test`

| size | color |
|------+-------|
| S    | red   |
| S    | blue  |
| S    | red   |
| M    | red   |

select
  size,
  {{ dbt_utils.pivot('color', dbt_utils.get_column_values('public.test',
                                                          'color')) }}
from public.test
group by size

Output:

| size | red | blue |
|------+-----+------|
| S    | 2   | 1    |
| M    | 1   | 0    |

dbt_utils.pivot()

参数：

列：列名，必填

values：需要转换为列的行值列表

alias：是否创建列别名，默认为True

agg：SQL聚合函数，默认为sum

cmp：SQL值比较，默认为=

prefix：列别名前缀，默认为空

后缀：列别名后缀，默认为空

then_value：比较成功时使用的值，默认为1

else_value：比较失败时使用的值，默认为0

quote_identifiers：列别名是否用双引号括起来，默认为true

{% macro pivot(column,
               values,
               alias=True,
               agg='sum',
               cmp='=',
               prefix='',
               suffix='',
               then_value=1,
               else_value=0,
               quote_identifiers=True) %}
  {% for v in values %}
    {{ agg }}(
      case
      when {{ column }} {{ cmp }} '{{ v }}'
        then {{ then_value }}
      else {{ else_value }}
      end
    )
    {% if alias %}
      {% if quote_identifiers %}
            as {{ adapter.quote(prefix ~ v ~ suffix) }}
      {% else %}
        as {{prefix ~ v ~ suffix }}
      {% endif %}
    {% endif %}
    {% if not loop.last %},{% endif %}
  {% endfor %}
{% endmacro %}

【讨论】：

您是否愿意发布一个答案，除非您提供根本不同的方法，例如multiple answers by the same user are not acceptable。还请确保它是well formatted，特别是要确保代码可读。

【解决方案2】：

{% set pvt_details=[
('General liability cover_rated_premium', 'gl_premium'),
("Contractor\\\'s errors and omissions cover_rated_premium", 'eo_premium') 
] %}

select
  concat_ws(' :: ',
    {% for column in pvt_details %} 
        '{{ column[0] }}'
    {%- if not loop.last -%},  {%- endif %}
    {% endfor %}
) as column_selection
from {{ ref('reference_model') }}
limit 1

Collapse

来自 DBT 的 Christine。 Jinja2 似乎在以许多其他语言处理它的方式进行引用时存在问题 =/。

【讨论】：

【解决方案3】：

如果他们想坚持自己的查询，我怀疑换掉

“承包商的错误和遗漏cover_rated_premium”

与 “承包商的错误和遗漏cover_rated_premium”在您使用“

而不是 ' 可能会解决它？但不是 100% 确定这里是否还有其他问题。我确实认为 utils 的 pivot 宏应该很好用！只是不确定它是否能很好地处理 ' （我认为应该）。他们也无法在与枢轴相同的步骤中重命名列（我认为这里正在发生这种情况），但他们可以轻松使用枢轴函数，然后在后续 CTE 中重命名列

来自 DBT 的安德鲁

【讨论】：