cief/data-management
1
0
Fork 0
mirror of https://gitlab.com/cief-data/data-management.git synced 2026-08-19 04:13:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fully ELT

Browse Source
This commit is contained in:
Yam ZhengLim
2022-10-28 15:40:00 +08:00
parent cb08e5b561
commit 5d30c6c505
1 changed files with 36 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
edmond.sql
+36
View File
@@ -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)