diff --git a/jaffle_shop/models/customer_total_spend.sql b/jaffle_shop/models/customer_total_spend.sql new file mode 100644 index 0000000..c5ae23e --- /dev/null +++ b/jaffle_shop/models/customer_total_spend.sql @@ -0,0 +1,29 @@ +{{ config(materialized='table') }} + +with orders as ( + select * from {{ ref('stg_orders') }} +), + +customer_spend as ( + select + customer_id, + sum(order_amount) as total_amount_spent + from orders + group by customer_id +), + +customers as ( + select * from {{ ref('stg_customers') }} +), + +final as ( + select + c.customer_id, + c.first_name, + c.last_name, + coalesce(cs.total_amount_spent, 0) as total_amount_spent + from customers c + left join customer_spend cs using (customer_id) +) + +select * from final \ No newline at end of file