add staging models

Author: Student

models/staging/gsheets/stg_gsheets__franchise_actives.sql

@@ -0,0 +1,31 @@
+with
+
+source_table as (
+    select * from {{ source('franchises', 'actives') }}
+),
+
+final as (
+
+    select 
+        TEAM_ID::int as team_id,
+        FRANCHISE_ID::int as franchise_id,
+        FRANCHISE_NAME as franchise_name,
+        URL as url,
+        "start"::int as year_started,
+        "end"::int as year_ended,
+        YEARS::int as years_active,
+        GP::int as games_played,
+        WINS::int as wins,
+        LOSSES::int as losses,
+        WIN::numeric / 100 as winning_percentage,
+        PO::int as playoffs_made,
+        DIV__TITLES::int as division_titles,
+        CONF__TITLES::int as conference_titles,
+        LEAGUE_TITLES::int as league_titles,
+        "end" is null as is_current
+
+    from source_table
+
+)
+
+select * from final

models/staging/gsheets/stg_gsheets__franchise_general_managers.sql

@@ -0,0 +1,32 @@
+with
+
+source_table as (
+    select * from {{ source('franchises', 'general_managers') }}
+),
+
+final as (
+
+    select 
+        ID as general_manager_id, 
+        TEAM as team_name, 
+        COLLEGE as college_name, 
+        DIVISION as division, 
+        CONFERENCE as conference, 
+        
+        case 
+            when GENERAL_MANAGER = 'Vacant' 
+            then null
+            else GENERAL_MANAGER
+        end as general_manager, 
+        
+        PROFESSIONAL_CAREER as professional_career,
+        YEAR_HIRED::int as year_hired, 
+        AS_OF_DATE::date as as_of_date,
+        
+        date_part('year', AS_OF_DATE::date) - YEAR_HIRED::int as years_active
+
+    from source_table
+
+)
+
+select * from final

models/staging/gsheets/stg_gsheets__franchise_head_coaches.sql

@@ -0,0 +1,23 @@
+with
+
+source_table as (
+    select * from {{ source('franchises', 'head_coaches') }}
+),
+
+final as (
+
+    select 
+        ID as head_coach_id,
+        HEAD_COACH as head_coach,
+        TEAM as team_name,
+        DIVISION as division,
+        CONFERENCE as conference,
+        START_DATE::date as start_date,
+        AS_OF_DATE::date as as_of_date,
+        date_part('year', AS_OF_DATE::date) - date_part('year', START_DATE::date) as years_active
+
+    from source_table
+
+)
+
+select * from final

models/staging/nba/stg_nba__games.sql

@@ -0,0 +1,78 @@
+with
+
+source_table as (
+    select * from {{ source('nba', 'games') }}
+),
+
+final as (
+
+    select
+        id::integer as game_id,
+        date::timestamp as game_at,
+        date::date as game_date,
+        time::time as game_time,
+
+        -- teams
+        (teams::jsonb->'away'->>'id')::integer as away_team_id,
+        teams::jsonb->'away'->>'name' as away_team_name,
+        (teams::jsonb->'home'->>'id')::integer as home_team_id,
+        teams::jsonb->'home'->>'name' as home_team_name,
+
+        -- league & season
+        (league::jsonb->'id')::integer as league_id,
+        replace((league::jsonb->'name')::text, '"','') as league_name,
+        replace((league::jsonb->'season')::text, '"','') as season,
+
+        -- away team scoring
+        (scores::jsonb->'away'->>'total')::integer as away_team_score_total,
+        (scores::jsonb->'away'->>'quarter_1')::integer as away_team_score_quarter_1,
+        (scores::jsonb->'away'->>'quarter_2')::integer as away_team_score_quarter_2,
+        (scores::jsonb->'away'->>'quarter_3')::integer as away_team_score_quarter_3,
+        (scores::jsonb->'away'->>'quarter_4')::integer as away_team_score_quarter_4,
+        (coalesce(scores::jsonb->'away'->>'over_time', '0'))::integer as away_team_score_overtime,
+
+        -- home team scoring
+        (scores::jsonb->'home'->>'total')::integer as home_team_score_total,
+        (scores::jsonb->'home'->>'quarter_1')::integer as home_team_score_quarter_1,
+        (scores::jsonb->'home'->>'quarter_2')::integer as home_team_score_quarter_2,
+        (scores::jsonb->'home'->>'quarter_3')::integer as home_team_score_quarter_3,
+        (scores::jsonb->'home'->>'quarter_4')::integer as home_team_score_quarter_4,
+        (coalesce(scores::jsonb->'home'->>'over_time', '0'))::integer as home_team_score_overtime,
+
+
+        -- Custom Metrics
+        case
+            when (scores::jsonb->'home'->>'total')::integer > (scores::jsonb->'away'->>'total')::integer
+                then true
+            else false
+        end as is_home_team_win,
+
+        case
+            when (scores::jsonb->'home'->>'total')::integer < (scores::jsonb->'away'->>'total')::integer
+                then true
+            else false
+        end as is_away_team_win,
+
+        abs((scores::jsonb->'home'->>'total')::integer 
+            - (scores::jsonb->'away'->>'total')::integer) as point_differential,
+
+
+        -- status
+        replace((status::jsonb->'long')::text, '"','') as status_long,
+        replace((status::jsonb->'short')::text, '"','') as status_short,
+            
+        -- country
+        (country::jsonb->'id')::integer as country_id,
+        replace((country::jsonb->'code')::text, '"','') as country_code,
+        replace((country::jsonb->'name')::text, '"','') as country_name,
+            
+        timezone,
+        to_timestamp(timestamp) as created_at,
+
+        row_number() over (partition by id order by _airbyte_emitted_at desc) = 1 is_latest
+
+    from source_table
+
+)
+
+select * from final where is_latest

models/staging/nba/stg_nba__teams.sql

@@ -0,0 +1,26 @@
+with
+
+source_table as (
+    select * from {{ source('nba', 'teams') }}
+),
+
+final as (
+
+    select
+        id::integer as team_id,
+        name as team_name,
+        logo as team_logo_url,
+
+        case
+            when name = 'Toronto Raptors'
+                then 'Canada'
+            else 'USA'
+        end as country_name,
+  
+        row_number() over (partition by id order by _airbyte_emitted_at desc) = 1 is_latest
+
+    from source_table
+
+)
+
+select * from final where is_latest