new base model

2026-08-19 04:14:00 +00:00 · 2023-08-06 07:08:46 +00:00
parent 9876184b6f
commit 3af686d875
1 changed files with 52 additions and 0 deletions
@@ -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