counterweight/data-dwh-dbt-project
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

A few field changes in stg

Browse source
This commit is contained in:
Pablo Martin 2024-02-19 16:07:32 +01:00
parent 8549eab863
commit 1cf1214d97
3 changed files with 11 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

8
models/staging/stripe/stg_stripe__balance_transactions.sql
View file

@ -5,10 +5,10 @@ with
stg_stripe__balance_transactions as ( stg_stripe__balance_transactions as (
select select
{{ adapter.quote("id") }}, {{ adapter.quote("id") }},
{{ adapter.quote("fee") }} / 100 as fee, {{ adapter.quote("fee") }},
{{ adapter.quote("net") }} / 100 as net, {{ adapter.quote("net") }},
{{ adapter.quote("type") }}, {{ adapter.quote("type") }},
{{ adapter.quote("amount") }} / 100 as amount, {{ adapter.quote("amount") }},
{{ adapter.quote("object") }}, {{ adapter.quote("object") }},
{{ adapter.quote("source") }}, {{ adapter.quote("source") }},
{{ adapter.quote("status") }}, {{ adapter.quote("status") }},
@ -20,7 +20,7 @@ with
{{ adapter.quote("exchange_rate") }}, {{ adapter.quote("exchange_rate") }},
{{ adapter.quote("sourced_transfers") }}, {{ adapter.quote("sourced_transfers") }},
{{ adapter.quote("reporting_category") }}, {{ adapter.quote("reporting_category") }},
{{ adapter.quote("_airbyte_extracted_at") }} as dwh_loaded_at_date {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_date
from raw_balance_transactions from raw_balance_transactions
) )

8
models/staging/stripe/stg_stripe__charges.sql
View file

@ -6,7 +6,7 @@ with
{{ adapter.quote("card") }}, {{ adapter.quote("card") }},
cast({{ adapter.quote("paid") }} as bool) as is_paid, cast({{ adapter.quote("paid") }} as bool) as is_paid,
{{ adapter.quote("order") }}, {{ adapter.quote("order") }},
{{ adapter.quote("amount") }} / 100 as amount, {{ adapter.quote("amount") }},
{{ adapter.quote("object") }}, {{ adapter.quote("object") }},
{{ adapter.quote("review") }}, {{ adapter.quote("review") }},
{{ adapter.quote("source") }}, {{ adapter.quote("source") }},
@ -39,8 +39,8 @@ with
{{ adapter.quote("payment_method") }}, {{ adapter.quote("payment_method") }},
{{ adapter.quote("receipt_number") }}, {{ adapter.quote("receipt_number") }},
{{ adapter.quote("transfer_group") }}, {{ adapter.quote("transfer_group") }},
{{ adapter.quote("amount_captured") }} / 100 as amount_captured, {{ adapter.quote("amount_captured") }},
{{ adapter.quote("amount_refunded") }} / 100 as amount_refunded, {{ adapter.quote("amount_refunded") }},
{{ adapter.quote("application_fee") }}, {{ adapter.quote("application_fee") }},
{{ adapter.quote("billing_details") }}, {{ adapter.quote("billing_details") }},
{{ adapter.quote("failure_message") }}, {{ adapter.quote("failure_message") }},
@ -53,7 +53,7 @@ with
{{ adapter.quote("failure_balance_transaction") }}, {{ adapter.quote("failure_balance_transaction") }},
{{ adapter.quote("statement_descriptor_suffix") }}, {{ adapter.quote("statement_descriptor_suffix") }},
{{ adapter.quote("calculated_statement_descriptor") }}, {{ adapter.quote("calculated_statement_descriptor") }},
{{ adapter.quote("_airbyte_extracted_at") }} as dwh_loaded_at_date {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_date
from raw_charges from raw_charges
) )

6
models/staging/stripe/stg_stripe__payment_intents.sql
View file

@ -3,7 +3,7 @@ with
stg_stripe__payment_intents as ( stg_stripe__payment_intents as (
select select
{{ adapter.quote("id") }}, {{ adapter.quote("id") }},
{{ adapter.quote("amount") }} / 100 as amount, {{ adapter.quote("amount") }},
{{ adapter.quote("object") }}, {{ adapter.quote("object") }},
{{ adapter.quote("review") }}, {{ adapter.quote("review") }},
{{ adapter.quote("source") }}, {{ adapter.quote("source") }},
@ -31,7 +31,7 @@ with
{{ adapter.quote("capture_method") }}, {{ adapter.quote("capture_method") }},
{{ adapter.quote("payment_method") }}, {{ adapter.quote("payment_method") }},
{{ adapter.quote("transfer_group") }}, {{ adapter.quote("transfer_group") }},
{{ adapter.quote("amount_received") }} / 100 as amount_received, {{ adapter.quote("amount_received") }},
{{ adapter.quote("amount_capturable") }}, {{ adapter.quote("amount_capturable") }},
{{ adapter.quote("last_payment_error") }}, {{ adapter.quote("last_payment_error") }},
{{ adapter.quote("setup_future_usage") }}, {{ adapter.quote("setup_future_usage") }},
@ -45,7 +45,7 @@ with
{{ adapter.quote("automatic_payment_methods") }}, {{ adapter.quote("automatic_payment_methods") }},
{{ adapter.quote("statement_descriptor_suffix") }}, {{ adapter.quote("statement_descriptor_suffix") }},
{{ adapter.quote("payment_method_configuration_details") }}, {{ adapter.quote("payment_method_configuration_details") }},
{{ adapter.quote("_airbyte_extracted_at") }} as dwh_loaded_at_date {{ adapter.quote("_airbyte_extracted_at") }} as dwh_extracted_at_date
from raw_payment_intents from raw_payment_intents
) )