diff --git a/dbt_project.yml b/dbt_project.yml index 574044b..112ea64 100644 --- a/dbt_project.yml +++ b/dbt_project.yml @@ -38,3 +38,6 @@ models: staging: +materialized: table +schema: staging + working: + +materialized: view + +schema: working diff --git a/models/staging/stg_core_superhog_user.sql b/models/staging/stg_core_superhog_user.sql index 541622a..2153332 100644 --- a/models/staging/stg_core_superhog_user.sql +++ b/models/staging/stg_core_superhog_user.sql @@ -7,7 +7,7 @@ select updateddate as updated_date_utc, verifieddate as verified_date_utc, flagasproblem as flag_as_problem, - superhoguserid as id_superhoguser, + cast(superhoguserid as uuid) as id_superhoguser, numberofproperties as number_of_properties, superhogverifiedsetid as id_superhog_verified_set, platformcommsrecipient as platform_comms_recipient, diff --git a/models/staging/stg_core_user.sql b/models/staging/stg_core_user.sql index ee7b1a9..a928140 100644 --- a/models/staging/stg_core_user.sql +++ b/models/staging/stg_core_user.sql @@ -1,6 +1,6 @@ with raw_user as (select * from {{ source("core", "user") }}) select - "Id" as id_user, + cast("Id" as uuid) as id_user, code as user_code, "Name" as name, email as email, diff --git a/models/working/wkg_core_unified_user.sql b/models/working/wkg_core_unified_user.sql new file mode 100644 index 0000000..4f55d8a --- /dev/null +++ b/models/working/wkg_core_unified_user.sql @@ -0,0 +1,38 @@ +with + stg_core_user as (select * from {{ ref("stg_core_user") }}), + stg_core_superhog_user as (select * from {{ ref("stg_core_superhog_user") }}) +select + id_user, + user_code, + name, + email, + title, + id_deal, + is_deleted, + join_date_utc, + username, + code_prefix, + billing_town, + company_name, + is_email_confirmed, + is_lockout_enabled, + billing_postcode, + id_billing_country, + is_twofactor_enabled, + access_failed_count, + lockout_end_date_utc, + billing_country_name, + avatar, + id_airbnb, + airbnb_url, + created_date_utc, + updated_date_utc, + verified_date_utc, + flag_as_problem, + number_of_properties, + id_superhog_verified_set, + platform_comms_recipient, + other_sharing_platform_url, + id_user_verification_status +from stg_core_user as u +inner join stg_core_superhog_user as su on u.id_user = su.id_superhoguser