diff --git a/models/staging/core/stg_core__price_plan_charged_by_type.sql b/models/staging/core/stg_core__price_plan_charged_by_type.sql new file mode 100644 index 0000000..1e94cf1 --- /dev/null +++ b/models/staging/core/stg_core__price_plan_charged_by_type.sql @@ -0,0 +1,14 @@ +with + raw_price_plan_charged_by_type as ( + select * from {{ source("core", "PricePlanChargedByType") }} + ), + stg_core__price_plan_charged_by_type as ( + select + {{ adapter.quote("Id") }} as id_price_plan_charged_by_type, + {{ adapter.quote("Name") }} as price_plan_charged_by_type, + {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_utc + + from raw_price_plan_charged_by_type + ) +select * +from stg_core__price_plan_charged_by_type diff --git a/models/staging/core/stg_core__price_plan_to_user.sql b/models/staging/core/stg_core__price_plan_to_user.sql new file mode 100644 index 0000000..5ea2258 --- /dev/null +++ b/models/staging/core/stg_core__price_plan_to_user.sql @@ -0,0 +1,28 @@ +with + raw_price_plan_to_user as (select * from {{ source("core", "PricePlanToUser") }}), + stg_core__price_plan_to_user as ( + select + {{ adapter.quote("Id") }} as id_price_plan, + {{ adapter.quote("SuperhogUserId") }} as id_user_host, + {{ adapter.quote("PricePlanChargedByTypeId") }} + as id_price_plan_charged_by_type, + {{ adapter.quote("StartDate") }} as start_at_utc, + cast({{ adapter.quote("StartDate") }} as date) as start_date_utc, + {{ adapter.quote("EndDate") }} as end_at_utc, + cast({{ adapter.quote("EndDate") }} as date) end_date_utc, + {{ adapter.quote("BookingFeeNet") }} as booking_fee, + {{ adapter.quote("ListingFeeNet") }} as listing_fee, + {{ adapter.quote("SupportFeeNet") }} as support_fee, + {{ adapter.quote("TaxPercentage") }} as tax_percentage, + {{ adapter.quote("MinBillableListings") }} as minimum_billable_listings, + {{ adapter.quote("MinMonthlyListingFee") }} as minimum_monthly_listing_fee, + {{ adapter.quote("CreatedDate") }} as created_at_utc, + cast({{ adapter.quote("CreatedDate") }} as date) as created_date_utc, + {{ adapter.quote("UpdatedDate") }} as updated_at_utc, + {{ adapter.quote("UpdatedDate") }} as updated_date_utc, + {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_utc + + from raw_price_plan_to_user + ) +select * +from stg_core__price_plan_to_user