■ はじめに

https://dk521123.hatenablog.com/entry/2023/11/29/003751

の続き。

小ネタ。
DBTにおいて、各DWH（DB）により、処理を切り替える方法を記載する

【１】adapter object

https://docs.getdbt.com/reference/dbt-jinja-functions/adapter

{{ adapter.<method name> }}

１）dispach メソッド

* macroの呼び出す際に、対象DWHごとに処理を切り替えたい場合に使用

https://docs.getdbt.com/reference/dbt-jinja-functions/dispatch

DWH	[DWH]__[マクロ名(my_macro)]
Postgres	postgres__my_macro
Redshift	redshift__my_macro
Snowflake	snowflake__my_macro
BigQuery	bigquery__my_macro
OtherAdapter	otheradapter__my_macro
default	default__my_macro

【２】サンプル

例１：Hello world

{% macro concat(fields) -%}
    {{ return(adapter.dispatch('concat')(fields)) }} -- ★呼び出し★
{%- endmacro %}

-- <DWH>__<マクロ名>で定義

-- デフォルト
{% macro default__concat(fields) -%}
    concat({{ fields|join(', ') }})
{%- endmacro %}

-- RedShift用
{% macro redshift__concat(fields) %}
    {{ fields|join(' || ') }}
{% endmacro %}

-- Snowflake用
{% macro snowflake__concat(fields) %}
    {{ fields|join(' || ') }}
{% endmacro %}