Added some examples for dbt materializations and macros

Author: aosingh

dbt_adbs_test_project/macros/hash_arguments.sql

@@ -0,0 +1,6 @@
+{% macro hash_arguments(args) -%}
+    ORA_HASH({%- for arg in args -%}
+        coalesce(cast({{ arg }} as varchar(50) ), '')
+        {% if not loop.last %} || '|' || {% endif %}
+    {%- endfor -%})
+{%- endmacro %}

dbt_adbs_test_project/models/demo/promotion_costs_for_direct_sales_channel.sql

@@ -0,0 +1,17 @@
+{{config(materialized='table')}}
+WITH direct_sales_promo_cost AS (
+    SELECT s.prod_id,
+           s.quantity_sold,
+           s.amount_sold,
+           s.time_id,
+           c.channel_desc,
+           p.promo_name,
+           p.promo_cost
+    FROM {{ source('sh_database', 'sales') }} s,
+         {{ source('sh_database', 'promotions') }} p,
+         {{ source('sh_database', 'channels') }} c
+    WHERE s.channel_id = 3
+    AND s.promo_id = p.promo_id
+    AND s.channel_id = c.channel_id
+)
+SELECT * FROM direct_sales_promo_cost

dbt_adbs_test_project/models/demo/promotion_costs_for_direct_sales_channel_incr_insert.sql

@@ -0,0 +1,20 @@
+{{config(materialized='incremental')}}
+WITH direct_sales_promo_cost AS (
+    SELECT s.prod_id,
+           s.quantity_sold,
+           s.amount_sold,
+           s.time_id,
+           c.channel_desc,
+           p.promo_name,
+           p.promo_cost
+    FROM {{ source('sh_database', 'sales') }} s,
+         {{ source('sh_database', 'promotions') }} p,
+         {{ source('sh_database', 'channels') }} c
+    WHERE s.channel_id = 3
+    AND s.promo_id = p.promo_id
+    AND s.channel_id = c.channel_id
+    {% if is_incremental() %}
+        AND s.time_id > (SELECT MAX(time_id) FROM {{ this }})
+    {% endif %}
+)
+SELECT * FROM direct_sales_promo_cost

dbt_adbs_test_project/models/demo/promotion_costs_for_direct_sales_channel_incr_merge.sql

@@ -0,0 +1,21 @@
+{{config(materialized='incremental', unique_key='group_id')}}
+WITH direct_sales_promo_cost AS (
+    SELECT s.prod_id,
+           s.quantity_sold,
+           s.amount_sold,
+           s.time_id,
+           c.channel_desc,
+           p.promo_name,
+           p.promo_cost,
+           {{ hash_arguments(['s.prod_id', 's.quantity_sold', 's.time_id', 'p.promo_name']) }} AS group_id
+    FROM {{ source('sh_database', 'sales') }} s,
+         {{ source('sh_database', 'promotions') }} p,
+         {{ source('sh_database', 'channels') }} c
+    WHERE s.channel_id = 3
+    AND s.promo_id = p.promo_id
+    AND s.channel_id = c.channel_id
+    {% if is_incremental() %}
+        AND s.time_id > (SELECT MAX(time_id) FROM {{ this }})
+    {% endif %}
+)
+SELECT * FROM direct_sales_promo_cost