diff --git a/code_thingies/dbtlearn/models/dim/dim_hosts_cleansed.sql b/code_thingies/dbtlearn/models/dim/dim_hosts_cleansed.sql index 2a1f43d..c489d1b 100644 --- a/code_thingies/dbtlearn/models/dim/dim_hosts_cleansed.sql +++ b/code_thingies/dbtlearn/models/dim/dim_hosts_cleansed.sql @@ -11,6 +11,8 @@ SELECT CASE WHEN flag_is_superhost = 't' THEN true WHEN flag_is_superhost = 'f' THEN false - END::bool AS flag_is_superhost + END::bool AS flag_is_superhost, + created_at, + updated_at FROM src_hosts \ No newline at end of file diff --git a/code_thingies/dbtlearn/models/dim/dim_listings_with_hosts.sql b/code_thingies/dbtlearn/models/dim/dim_listings_with_hosts.sql new file mode 100644 index 0000000..ee05cc2 --- /dev/null +++ b/code_thingies/dbtlearn/models/dim/dim_listings_with_hosts.sql @@ -0,0 +1,25 @@ +WITH + listings AS ( + SELECT * + FROM + {{ ref('dim_listings_cleansed') }} + ), + hosts AS ( + SELECT * + FROM + {{ ref('dim_hosts_cleansed') }} + ) +SELECT + listings.listing_id, + listings.listing_name, + listings.room_type, + listings.mininum_nights, + listings.price, + listings.host_id, + hosts.host_name, + hosts.flag_is_superhost, + listings.created_at, + GREATEST(listings.updated_at, hosts.updated_at) AS updated_at +FROM + listings +LEFT JOIN hosts ON (listings.host_id = hosts.host_id) \ No newline at end of file diff --git a/code_thingies/dbtlearn/models/src/src_hosts.sql b/code_thingies/dbtlearn/models/src/src_hosts.sql index a39842a..b33b25d 100644 --- a/code_thingies/dbtlearn/models/src/src_hosts.sql +++ b/code_thingies/dbtlearn/models/src/src_hosts.sql @@ -5,6 +5,8 @@ WITH raw_hosts AS ( SELECT id as host_id, name as host_name, - is_superhost as flag_is_superhost + is_superhost as flag_is_superhost, + created_at, + updated_at FROM raw_hosts \ No newline at end of file