reorganize and add new models

models/marts/dim_customers.sql

@@ -0,0 +1,44 @@
+with customers as (
+
+    select * from {{ ref('stg_jaffle_shop__customers') }}
+
+),
+
+orders as (
+
+    select * from {{ ref('stg_jaffle_shop__orders') }}
+
+),
+
+customer_orders as (
+
+    select
+        customer_id,
+
+        min(order_date) as first_order_date,
+        max(order_date) as most_recent_order_date,
+        count(order_id) as number_of_orders
+
+    from orders
+
+    group by 1
+
+),
+
+final as (
+
+    select
+        customers.customer_id,
+        customers.first_name,
+        customers.last_name,
+        customer_orders.first_order_date,
+        customer_orders.most_recent_order_date,
+        coalesce(customer_orders.number_of_orders, 0) as number_of_orders
+
+    from customers
+
+    left join customer_orders using (customer_id)
+
+)
+
+select * from final

analysis/snowplow/fct_page_views.sql → models/marts/fct_page_views.sql

@@ -1,5 +1,5 @@
 with events as (
-    select * from {# {{ ref('stg_snowplow__events') }} #}
+    select * from {{ ref('stg_snowplow__events') }}
 ),
 page_views as (
     select * from events

models/staging/jaffle_shop/_schema_jaffle_shop.yml

@@ -0,0 +1,31 @@
+models:
+  - name: stg_jaffle_shop__customers
+    columns:
+      - name: customer_id
+        tests:
+          - unique
+          - not_null             
+  - name: stg_jaffle_shop__orders
+    columns:
+      - name: order_id
+        tests:
+          - unique
+          - not_null
+      - name: status
+        tests:
+          - accepted_values:
+              values:
+                - "returned"
+                - "completed"
+                - "pending"
+                - "placed"
+                - "shipped"
+  - name: stg_jaffle_shop__products
+    columns:
+      - name: sku
+        tests:
+          - unique:
+              config:
+                where: "product_type = 'jaffle'"
+
+          - not_null

models/staging/jaffle_shop/_jaffle_shop__source.yml → models/staging/jaffle_shop/_source_jaffle_shop.yml

@@ -5,6 +5,6 @@ sources:
     database: raw
     schema: jaffle_shop
     tables:
-      - name: customers
+      - name: customers 
       - name: orders
       - name: products

models/staging/jaffle_shop/stg_jaffle_shop__customers.sql

@@ -0,0 +1,20 @@
+with 
+
+source as (
+
+    select * from {{ source('jaffle_shop', 'customers') }}
+
+),
+
+renamed as (
+
+    select
+        id as customer_id,
+        first_name,
+        last_name
+
+    from source
+
+)
+
+select * from renamed

models/staging/jaffle_shop/stg_jaffle_shop__orders.sql

@@ -0,0 +1,22 @@
+with 
+
+source as (
+
+    select * from {{ source('jaffle_shop', 'orders') }}
+
+),
+
+renamed as (
+
+    select
+        id as order_id,
+        user_id as customer_id,
+        order_date,
+        status,
+        _etl_loaded_at
+
+    from source
+
+)
+
+select * from renamed

models/staging/jaffle_shop/stg_jaffle_shop__products.sql

@@ -0,0 +1,22 @@
+with 
+
+source as (
+
+    select * from {{ source('jaffle_shop', 'products') }}
+
+),
+
+renamed as (
+
+    select
+        sku,
+        name as product_name,
+        type as product_type,
+        description,
+        price
+
+    from source
+
+)
+
+select * from renamed

analysis/stripe/_stripe_sources.yml → models/staging/stripe/_stripe__source.yml

@@ -3,5 +3,6 @@ version: 2
 sources:
   - name: stripe
     database: raw
+    schema: stripe
     tables:
       - name: payment

models/staging/stripe/stg_stripe__payment.sql

@@ -0,0 +1,25 @@
+with 
+
+source as (
+
+    select * from {{ source('stripe', 'payment') }}
+
+),
+
+renamed as (
+
+    select
+        amount,
+        created,
+        id,
+        orderid,
+        paymentmethod,
+        status,
+        _batched_at
+
+
+    from source
+
+)
+
+select * from renamed