From 5d30c6c505b6f3c46af00094a3421ba37780c5d9 Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Fri, 28 Oct 2022 15:40:00 +0800 Subject: [PATCH] Fully ELT --- edmond.sql | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 edmond.sql diff --git a/edmond.sql b/edmond.sql new file mode 100644 index 0000000..d3be7a1 --- /dev/null +++ b/edmond.sql @@ -0,0 +1,36 @@ +use database RAW; +use schema EDMOND_DEV; +use warehouse CIEF_DW_DEV; + +SELECT + bookings.id AS booking_id, + bookings.status AS booking_status, + bookings.company_id AS booking_company_id, + bookings.service_id AS booking_service_id, + bookings.fix_currency_id AS booking_fix_currency_id, + bookings.fix_amount AS booking_fix_booking_amount, + dim_currency_rate_logs.CURRENCY_RATE_LOGS_SELLING_RATE AS booking_base_to_quote_convertion_rate, + bookings.conversion_currency_id AS booking_base_currency_id, + IF (bookings.fix-currency-id == conversion(base)-curr-id THEN fix-amount ELSE fix-amount/CURRENCY_RATE_LOGS_SELLING_RATE) + -- bookings.idk AS booking_base_booking_amount + bookings.convertible_currency_id AS booking_quote_currency_id, + IF (fix-currency-id == convertible(quote)-curr-id THEN fix-amount ELSE fix-amount*CURRENCY_RATE_LOGS_SELLING_RATE) AS FSFSDFDSFDSF, + -- bookings.idk AS booking_quote_booking_amount + ++ IF(base-currency = MYR THEN base -- bookings_amount_MYR + bookings.created_at, AS booking_created_at, + -- bookings.idk AS booking_expired_at + -- bookings.idk AS booking_is_expired + -- bookings.idk AS booking_approved_at + -- bookings.idk AS booking_is_approved + -- bookings.idk AS booking_completed_at + +FROM RAW.EXCHANGE_MYSQL.BOOKINGS as bookings + +LEFT JOIN RAW.DBT_ZYAM_EXCHANGE_WAREHOUSE.DIM_CURRENCY_RATE_LOGS__EXCHANGE as dim_currency_rate_logs +ON (bookings.created_at > dim_currency_rate_logs .CURRENCY_RATE_LOGS_CREATED_DATE_FROM) +AND (bookings.created_at <= dim_currency_rate_logs .CURRENCY_RATE_LOGS_CREATED_DATE_TO) +AND (bookings.service_id = dim_currency_rate_logs .CURRENCY_RATE_LOGS_SERVICE_ID) +limit 1 + + +IFF(bookings.fix_currency_id = bookings.base_currency_id, bookings.fix_amount, bookings.fix_amount * dim_currency_rate_logs.CURRENCY_RATE_LOGS_SELLING_RATE) \ No newline at end of file