diff --git a/models/staging/exchange/base/base_exchange__account_statements.sql b/models/staging/exchange/base/base_exchange__account_statements.sql new file mode 100644 index 0000000..fd1850d --- /dev/null +++ b/models/staging/exchange/base/base_exchange__account_statements.sql @@ -0,0 +1,52 @@ +-- IMPORTS +WITH source AS ( + SELECT * FROM {{ source('src_exchange_mysql', 'account_statements') }} + +), + +-- LOGIC +account_statements_rename as ( + + SELECT + id AS account_statement_id, + statement_account_id, + date(date_from) AS account_statement_from_date, + date(date_to) AS account_statement_to_date, + total_amount AS total_value, + begin_balance AS starting_balance, + end_balance AS closing_balance, + created_at AS created_datetime, + updated_at AS updated_datetime, + '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime + + FROM source +), + +-- FINAL +final__base_exchange__account_statements AS ( + + SELECT + -- ids + account_statement_id, + statement_account_id, + + -- dimensions + starting_balance, + closing_balance, + + -- measures + total_value, + + -- date/times + account_statement_from_date, + account_statement_to_date, + created_datetime, + updated_datetime, + + -- metadata + _dbt_ran_datetime + + FROM account_statements_rename +) + +SELECT * FROM final__base_exchange__account_statements