more updates

Author: jeremyholtzman

learn-dbt/macros/group_by.sql

@@ -0,0 +1,7 @@
+{% macro group_by(n) %}
+  GROUP BY
+   {% for i in range(1, n + 1) %}
+     {{ i }}
+     {% if not loop.last %} , {% endif %}
+   {% endfor %}
+{% endmacro %}

learn-dbt/macros/renaming_segments.sql

@@ -0,0 +1,7 @@
+{% macro rename_segments(column_name) %}
+  CASE
+    WHEN {{column_name}} in ('BUILDING', 'HOUSEHOLD', 'FURNITURE')
+      THEN 'segment_1'
+    ELSE 'segment_2'
+  END
+{% endmacro %}

learn-dbt/macros/suspend_warehouse.sql

@@ -0,0 +1,10 @@
+{% macro suspend(warehouse_name) %}
+
+  {% set sql %}
+    alter warehouse {{warehouse_name}} suspend
+  {% endset %}
+
+  {% set table = run_query(sql) %}
+  {% do table.print_table() %}
+
+{% endmacro %}

learn-dbt/models/example/cumulative_orders_by_date.sql

@@ -1,7 +1,17 @@
+with orders as (
+  SELECT *
+  FROM {{source('sample', 'orders')}}
+
+)
+
 select distinct
     o_orderdate,
     sum(o_totalprice) over (order by o_orderdate) as cumulative_sales
 
-from "SNOWFLAKE_SAMPLE_DATA"."TPCH_SF1"."ORDERS"
+from orders
+
+{% if target.name == 'dev' %}
+where year(o_orderdate) = 1996
+{% endif %}
 
 order by o_orderdate

learn-dbt/models/example/my_first_dbt_model.sql

@@ -1,22 +1,13 @@
 
-/*
-    Welcome to your first dbt model!
-    Did you know that you can also configure models directly within SQL files?
-    This will override configurations stated in dbt_project.yml
-
-    Try changing "table" to "view" below
-*/
-{{ config(materialized='table', alias='first_model') }}
+{{ config(materialized='table', alias='first_model', tags=["nightly", "example"] ) }}
 
 with source_data as (
 
-    select 1 as id, 'NY' as state, '2020-02-01 00:01:00.000'::timestamp as updated_at
+    select 1 as id, 'NJ' as state, '2020-02-01 00:01:00.000'::timestamp as updated_at
     union all
     select null as id, 'CT' as state, '2020-01-01 00:00:00.000'::timestamp as updated_at
     union all
     select 4 as id, 'VT' as state, '2020-01-01 00:00:00.000'::timestamp as updated_at
-    union all
-    select 5 as id, 'NJ' as state, '2020-01-01 00:00:00.000'::timestamp as updated_at
 
 )
 

learn-dbt/models/example/playing_with_tests.sql

@@ -1,2 +1,10 @@
-select *
-from "SNOWFLAKE_SAMPLE_DATA"."TPCH_SF001"."CUSTOMER"
+with sample_customer as (
+  SELECT *
+  FROM {{ source('sample', 'customer') }}
+)
+
+select
+  c_custkey,
+  c_mktsegment,
+  {{rename_segments('c_mktsegment')}} mkt_segment_adjusted
+from sample_customer

learn-dbt/models/example/schema.yml

@@ -46,4 +46,9 @@ sources:
     schema: tpch_sf1
     tables:
       - name: customer
+        columns:
+          - name: c_custkey
+            tests:
+              - unique
+              - not_null
       - name: orders

learn-dbt/models/example/snowflake_customer_purchases.sql

@@ -1,13 +1,20 @@
+with sample_customer as (
+  SELECT *
+  FROM {{ source('sample', 'customer') }}
+),
+
+sample_orders as (
+  SELECT *
+  FROM {{ source('sample', 'orders') }}
+)
+
 SELECT
     c.c_custkey,
     c.c_name,
     c.c_nationkey as nation,
     sum(o.o_totalprice) as total_order_price
-from {{ source('sample', 'customer') }} c
-LEFT JOIN {{ source('sample', 'orders') }} o
+from sample_customer c
+LEFT JOIN sample_orders o
 ON c.c_custkey = o.o_custkey
 
-group by
-    c.c_custkey,
-    c.c_name,
-    c.c_nationkey
+{{group_by(3)}}