base model

2026-08-19 12:24:04 +00:00 · 2023-08-06 07:17:10 +00:00
parent 0ea657fcdc
commit ac6c297da2
1 changed files with 68 additions and 0 deletions
@@ -0,0 +1,68 @@
+-- IMPORTS
+WITH source AS (
+    SELECT * FROM {{ source('src_exchange_mysql', 'statement_transactions') }}
+
+),
+
+-- LOGIC
+statement_transactions_rename as (
+
+    SELECT
+        id                              AS statement_transaction_id,
+        account_statement_id,
+        transaction_date                AS transaction_datetime,
+        posting_date                    AS posting_datetime,
+        transaction_description,
+        transaction_description_2,
+        transaction_description_3,
+        transaction_description_4,
+        transaction_description_5,
+        transaction_ref                 AS transaction_reference,
+        amount,
+        teller_id,
+        branch_channel                  AS branch_channel_id,
+        transaction_code,
+        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__statement_transactions AS (
+
+    SELECT
+        -- ids
+        statement_transaction_id,
+        account_statement_id,
+        branch_channel_id,
+
+        -- dimensions
+        transaction_description,
+        transaction_description_2,
+        transaction_description_3,
+        transaction_description_4,
+        transaction_description_5,
+        transaction_reference,
+        transaction_code,
+        amount,
+        closing_balance,
+             
+        -- measures
+
+        -- date/times
+        transaction_datetime,
+        posting_datetime,
+        created_datetime,
+        updated_datetime,
+
+        -- metadata
+        _dbt_ran_datetime
+
+    FROM statement_transactions_rename
+)
+
+SELECT * FROM final__base_exchange__statement_transactions