staging model

This commit is contained in:
Pablo Martin 2024-06-20 14:31:12 +02:00
parent cd9c797f02
commit 79d69a9286

View file

@ -0,0 +1,38 @@
with
raw_bank_transactions as (select * from {{ source("xero", "bank_transactions") }}),
stg_xero__bank_transactions as (
select
{{ adapter.quote("BankTransactionID") }} as id_bank_transaction,
{{ adapter.quote("PrepaymentID") }} as id_prepayment,
{{ adapter.quote("OverpaymentID") }} as id_overpayment,
{{ adapter.quote("Reference") }} as reference,
{{ adapter.quote("Type") }} as transaction_type,
{{ adapter.quote("Status") }} as transaction_status,
{{ adapter.quote("Date") }} as transaction_at_utc,
{{ adapter.quote("DateString") }} as date_string,
{{ adapter.quote("Total") }} as total_amount_local_curr,
{{ adapter.quote("SubTotal") }} as subtotal_local_curr,
{{ adapter.quote("TotalTax") }} as total_tax_local_curr,
{{ adapter.quote("CurrencyCode") }} as transaction_currency_iso_4217,
1 / {{ adapter.quote("CurrencyRate") }} as exchange_rate_to_gbp,
{{ adapter.quote("LineAmountTypes") }} as line_amount_tax_inclusiveness,
{{ adapter.quote("Contact") }} as full_contact_details,
{{ adapter.quote("LineItems") }} as line_items,
{{ adapter.quote("BankAccount") }} as bank_account,
{{ adapter.quote("IsReconciled") }} as is_reconciled,
{{ adapter.quote("HasAttachments") }} as has_attachments,
{{ adapter.quote("Url") }} as url,
{{ adapter.quote("ExternalLinkProviderName") }}
as external_link_provider_name,
{{ adapter.quote("UpdatedDateUTC") }} as updated_at_utc,
cast({{ adapter.quote("UpdatedDateUTC") }} as date) as updated_date_utc,
{{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_utc
from raw_bank_transactions
)
select *
from stg_xero__bank_transactions