Merge pull request #9 from Ritik574-coder/dbt_branch

Implement domain-driven intermediate layer and project restructuring

Author: Ritik574-coder

dbt_project.yml

@@ -25,14 +25,17 @@ vars:
 
 models:
   dbt_analytics_engineering:
+
     staging:
-      +materialized: table
+      +materialized: view
       +tags: ["staging", "bronze"]
+
     intermediate:
       +materialized: table
       +tags: ["intermediate", "silver"]
+
     marts:
-      +materialized: view
+      +materialized: table
       +tags: ["marts", "gold"]
 
 seeds:

models/intermediate/Customers/int_customer_location.sql

@@ -0,0 +1,10 @@
+SELECT 
+    customer_id,
+    address,
+    city,
+    state_abbr,
+    state,
+    zip_code,
+    country,
+    region
+FROM {{ ref('stg_customers') }} ;

models/intermediate/Customers/int_customer_profile.sql

@@ -0,0 +1,8 @@
+SELECT
+    customer_id,
+    title,
+    first_name,
+    last_name,
+    gender,
+    date_of_birth
+FROM {{ ref('stg_customers') }} ;

models/intermediate/Customers/int_customer_segmentation.sql

@@ -0,0 +1,9 @@
+SELECT
+    customer_id,
+    customer_segment,
+    loyalty_points,
+    annual_income_usd,
+    company,
+    is_active,
+    account_created_date
+FROM {{ ref('stg_customers') }} ;

models/intermediate/Customers/int_customers_contact.sql

@@ -0,0 +1,6 @@
+SELECT
+    customer_id,
+    email,
+    phone,
+    preferred_channel
+FROM {{ ref('stg_customers') }} ;

models/intermediate/Employees/int_employee_employment.sql

@@ -0,0 +1,14 @@
+SELECT
+    employee_id,
+    job_title,
+    department,
+    store_id,
+    store_name,
+    store_city,
+    annual_salary_usd,
+    commission_rate_pct,
+    performance_rating,
+    years_employed,
+    manager_id,
+    is_active
+FROM {{ ref('stg_employees') }} ;

models/intermediate/Employees/int_employee_profile.sql

@@ -0,0 +1,6 @@
+SELECT 
+    employee_id,
+    first_name,
+    last_name,
+    hire_date
+FROM {{ ref('stg_employees') }} ;

models/intermediate/Employees/int_employees_contact.sql

@@ -0,0 +1,5 @@
+SELECT 
+    employee_id,
+    email,
+    phone
+FROM {{ ref('stg_employees') }} ;

models/intermediate/Inventory/int_inventory_product.sql

@@ -0,0 +1,7 @@
+SELECT 
+    snapshot_date,
+    product_id,
+    product_name,
+    sku,
+    category
+FROM {{ ref('stg_inventory') }} ;

models/intermediate/Inventory/int_inventory_stock.sql

@@ -0,0 +1,8 @@
+SELECT 
+    snapshot_date,
+    product_id,
+    stock_on_hand,
+    stock_reserved,
+    stock_available,
+    reorder_level
+FROM {{ ref('stg_inventory') }} ;