fix/cast-string-literals

CHANGELOG.md

@@ -1,3 +1,9 @@
+# dbt_quickbooks v1.6.3
+[PR #211](https://github.com/fivetran/dbt_quickbooks/pull/211) includes the following updates:
+
+## Bug Fix
+- Fixes Postgres/Redshift unknown datatype errors by explicitly casting string literals in our models as strings.
+
 # dbt_quickbooks v1.6.2
 [PR #207](https://github.com/fivetran/dbt_quickbooks/pull/207) includes the following updates:
 

dbt_project.yml

@@ -1,7 +1,7 @@
 config-version: 2
 name: 'quickbooks'
 
-version: '1.6.2'
+version: '1.6.3'
 
 require-dbt-version: [">=1.3.0", "<3.0.0"]
 

integration_tests/dbt_project.yml

@@ -1,6 +1,6 @@
 name: 'quickbooks_integration_tests'
 
-version: '1.6.2'
+version: '1.6.3'
 
 profile: 'integration_tests'
 config-version: 2

models/double_entry_transactions/int_quickbooks__bill_double_entry.sql

@@ -76,8 +76,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'bill' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('bill' as {{ dbt.type_string() }}) as transaction_source
     from bill_join
 
     union all
@@ -96,8 +96,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'bill' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('bill' as {{ dbt.type_string() }}) as transaction_source
     from bill_join
 )
 

models/double_entry_transactions/int_quickbooks__bill_payment_double_entry.sql

@@ -79,8 +79,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'bill payment' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('bill payment' as {{ dbt.type_string() }}) as transaction_source
     from bill_payment_join
 
     union all
@@ -99,8 +99,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'bill payment' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('bill payment' as {{ dbt.type_string() }}) as transaction_source
     from bill_payment_join
 )
 

models/double_entry_transactions/int_quickbooks__credit_card_pymt_double_entry.sql

@@ -53,8 +53,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'credit card payment' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('credit card payment' as {{ dbt.type_string() }}) as transaction_source
     from credit_card_payment_prep
 
     union all
@@ -73,8 +73,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'credit card payment' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('credit card payment' as {{ dbt.type_string() }}) as transaction_source
     from credit_card_payment_prep
 )
 

models/double_entry_transactions/int_quickbooks__credit_memo_double_entry.sql

@@ -92,8 +92,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'credit_memo' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('credit_memo' as {{ dbt.type_string() }}) as transaction_source
     from credit_memo_join
 
     union all
@@ -112,8 +112,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'credit_memo' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('credit_memo' as {{ dbt.type_string() }}) as transaction_source
     from credit_memo_join
 
     left join df_accounts

models/double_entry_transactions/int_quickbooks__deposit_double_entry.sql

@@ -84,8 +84,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'deposit' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('deposit' as {{ dbt.type_string() }}) as transaction_source
     from deposit_join
 
     union all
@@ -104,8 +104,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'deposit' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('deposit' as {{ dbt.type_string() }}) as transaction_source
     from deposit_join
 )
 

models/double_entry_transactions/int_quickbooks__invoice_double_entry.sql

@@ -221,11 +221,11 @@ invoice_join as (
             then 1
             else coalesce(invoices.exchange_rate, 1) 
         end) as converted_amount,
-        case when invoice_lines.detail_type is not null then invoice_lines.detail_type
+        cast(case when invoice_lines.detail_type is not null then invoice_lines.detail_type
             when coalesce(invoice_bundles.account_id, invoice_lines.account_id, invoice_lines.sales_item_account_id, items.parent_income_account_id, items.income_account_id, bundle_income_accounts.account_id) is not null then 'SalesItemLineDetail'
             when invoice_lines.discount_account_id is not null then 'DiscountLineDetail'
             when coalesce(invoice_bundles.account_id, invoice_lines.account_id, invoice_lines.sales_item_account_id, items.parent_income_account_id, items.income_account_id, bundle_income_accounts.account_id, invoice_lines.discount_account_id) is null then 'NoAccountMapping'
-        end as invoice_line_transaction_type,
+        end as {{ dbt.type_string() }}) as invoice_line_transaction_type,
         coalesce(invoice_bundles.account_id, invoice_lines.account_id, invoice_lines.sales_item_account_id, items.parent_income_account_id, items.income_account_id, bundle_income_accounts.account_id, invoice_lines.discount_account_id) as account_id,
         coalesce(invoice_bundles.class_id, invoice_lines.sales_item_class_id, invoice_lines.discount_class_id, invoices.class_id) as class_id,
 
@@ -238,11 +238,11 @@ invoice_join as (
             then 1
             else coalesce(invoices.exchange_rate, 1) 
         end) as converted_amount, 
-        case when invoice_lines.detail_type is not null then invoice_lines.detail_type
+        cast(case when invoice_lines.detail_type is not null then invoice_lines.detail_type
             when coalesce(invoice_lines.account_id, invoice_lines.sales_item_account_id, items.parent_income_account_id, items.income_account_id) is not null then 'SalesItemLineDetail'
             when invoice_lines.discount_account_id is not null then 'DiscountLineDetail'
             when coalesce(invoice_lines.account_id, invoice_lines.sales_item_account_id, items.parent_income_account_id, items.income_account_id, invoice_lines.discount_account_id) is null then 'NoAccountMapping'
-        end as invoice_line_transaction_type,
+        end as {{ dbt.type_string() }}) as invoice_line_transaction_type,
         coalesce(invoice_lines.account_id, invoice_lines.sales_item_account_id, items.income_account_id, invoice_lines.discount_account_id) as account_id,
         coalesce(invoice_lines.sales_item_class_id, invoice_lines.discount_class_id, invoices.class_id) as class_id,
         {% endif %}
@@ -288,7 +288,7 @@ invoice_join as (
             then 1
             else coalesce(invoices.exchange_rate, 1)
         end) as converted_amount,
-        'TaxLineDetail' as invoice_line_transaction_type,
+        cast('TaxLineDetail' as {{ dbt.type_string() }}) as invoice_line_transaction_type,
         tax_account_join.account_id,
         invoices.class_id,
         invoices.customer_id,
@@ -340,12 +340,12 @@ final as (
         department_id,
         created_at,
         updated_at,
-        case when invoice_line_transaction_type = 'DiscountLineDetail' then 'debit'
-            else 'credit' 
-        end as transaction_type,
-        case when invoice_line_transaction_type = 'DiscountLineDetail' then 'invoice discount'
+        cast(case when invoice_line_transaction_type = 'DiscountLineDetail' then 'debit'
+            else 'credit'
+        end as {{ dbt.type_string() }}) as transaction_type,
+        cast(case when invoice_line_transaction_type = 'DiscountLineDetail' then 'invoice discount'
             else 'invoice'
-        end as transaction_source
+        end as {{ dbt.type_string() }}) as transaction_source
     from invoice_filter
 
     union all
@@ -364,12 +364,12 @@ final as (
         department_id,
         created_at,
         updated_at,
-        case when invoice_line_transaction_type = 'DiscountLineDetail' then 'credit'
-            else 'debit' 
-        end as transaction_type,
-        case when invoice_line_transaction_type = 'DiscountLineDetail' then 'invoice discount'
+        cast(case when invoice_line_transaction_type = 'DiscountLineDetail' then 'credit'
+            else 'debit'
+        end as {{ dbt.type_string() }}) as transaction_type,
+        cast(case when invoice_line_transaction_type = 'DiscountLineDetail' then 'invoice discount'
             else 'invoice'
-        end as transaction_source
+        end as {{ dbt.type_string() }}) as transaction_source
     from invoice_filter
 
     left join ar_accounts

models/double_entry_transactions/int_quickbooks__journal_entry_double_entry.sql

@@ -145,7 +145,7 @@ final as (
         journal_entries.created_at,
         journal_entries.updated_at,
         lower(journal_entry_lines.posting_type) as transaction_type,
-        'journal_entry' as transaction_source
+        cast('journal_entry' as {{ dbt.type_string() }}) as transaction_source
     from journal_entries
 
     inner join journal_entry_lines
@@ -176,7 +176,7 @@ final as (
         journal_entries.created_at,
         journal_entries.updated_at,
         cast(null as {{ dbt.type_string() }}) as transaction_type,
-        'journal_entry' as transaction_source
+        cast('journal_entry' as {{ dbt.type_string() }}) as transaction_source
     from journal_entries
 
     inner join journal_entry_tax_lines

models/double_entry_transactions/int_quickbooks__payment_double_entry.sql

@@ -75,8 +75,8 @@ final as (
         cast(null as {{ dbt.type_string() }}) as department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'payment' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('payment' as {{ dbt.type_string() }}) as transaction_source
     from payment_join
 
     union all
@@ -95,8 +95,8 @@ final as (
         cast(null as {{ dbt.type_string() }}) as department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'payment' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('payment' as {{ dbt.type_string() }}) as transaction_source
     from payment_join
 
     left join ar_accounts

models/double_entry_transactions/int_quickbooks__purchase_double_entry.sql

@@ -54,8 +54,8 @@ purchase_join as (
         end as converted_amount,
         coalesce(purchase_lines.account_expense_account_id, items.parent_expense_account_id, items.expense_account_id) as paid_to_account_id,
         purchases.account_id as paid_from_account_id,
-        case when coalesce(purchases.credit, false) = true then 'debit' else 'credit' end as paid_from_transaction_type,
-        case when coalesce(purchases.credit, false) = true then 'credit' else 'debit' end as paid_to_transaction_type,
+        cast(case when coalesce(purchases.credit, false) = true then 'debit' else 'credit' end as {{ dbt.type_string() }}) as paid_from_transaction_type,
+        cast(case when coalesce(purchases.credit, false) = true then 'credit' else 'debit' end as {{ dbt.type_string() }}) as paid_to_transaction_type,
         purchases.customer_id,
         coalesce(purchase_lines.item_expense_class_id, purchase_lines.account_expense_class_id) as class_id,
         purchases.vendor_id,
@@ -88,8 +88,8 @@ purchase_join as (
         end as converted_amount,
         coalesce(purchase_lines.account_expense_account_id, items.parent_expense_account_id, items.expense_account_id) as paid_to_account_id,
         purchases.account_id as paid_from_account_id,
-        case when coalesce(purchases.credit, false) = true then 'debit' else 'credit' end as paid_from_transaction_type,
-        case when coalesce(purchases.credit, false) = true then 'credit' else 'debit' end as paid_to_transaction_type,
+        cast(case when coalesce(purchases.credit, false) = true then 'debit' else 'credit' end as {{ dbt.type_string() }}) as paid_from_transaction_type,
+        cast(case when coalesce(purchases.credit, false) = true then 'credit' else 'debit' end as {{ dbt.type_string() }}) as paid_to_transaction_type,
         purchases.customer_id,
         coalesce(purchase_lines.item_expense_class_id, purchase_lines.account_expense_class_id) as class_id,
         purchases.vendor_id,
@@ -126,7 +126,7 @@ final as (
         created_at,
         updated_at,
         paid_from_transaction_type as transaction_type,
-        'purchase' as transaction_source
+        cast('purchase' as {{ dbt.type_string() }}) as transaction_source
     from purchase_join
 
     union all
@@ -146,7 +146,7 @@ final as (
         created_at,
         updated_at,
         paid_to_transaction_type as transaction_type,
-        'purchase' as transaction_source
+        cast('purchase' as {{ dbt.type_string() }}) as transaction_source
     from purchase_join
 )
 

models/double_entry_transactions/int_quickbooks__refund_receipt_double_entry.sql

@@ -225,8 +225,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'refund_receipt' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('refund_receipt' as {{ dbt.type_string() }}) as transaction_source
     from refund_receipt_join
 
     union all
@@ -245,8 +245,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'refund_receipt' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('refund_receipt' as {{ dbt.type_string() }}) as transaction_source
     from refund_receipt_join
 )
 

models/double_entry_transactions/int_quickbooks__sales_receipt_double_entry.sql

@@ -230,8 +230,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'sales_receipt' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('sales_receipt' as {{ dbt.type_string() }}) as transaction_source
     from sales_receipt_join
 
     union all
@@ -250,8 +250,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'sales_receipt' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('sales_receipt' as {{ dbt.type_string() }}) as transaction_source
     from sales_receipt_join
 )
 

models/double_entry_transactions/int_quickbooks__transfer_double_entry.sql

@@ -48,8 +48,8 @@ final as (
         cast(null as {{ dbt.type_string() }}) as department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'transfer' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('transfer' as {{ dbt.type_string() }}) as transaction_source
     from transfer_body
 
     union all
@@ -68,8 +68,8 @@ final as (
         cast(null as {{ dbt.type_string() }}) as department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'transfer' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('transfer' as {{ dbt.type_string() }}) as transaction_source
     from transfer_body
 )
 

models/double_entry_transactions/int_quickbooks__vendor_credit_double_entry.sql

@@ -76,8 +76,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'credit' as transaction_type,
-        'vendor_credit' as transaction_source
+        cast('credit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('vendor_credit' as {{ dbt.type_string() }}) as transaction_source
     from vendor_credit_join
 
     union all
@@ -96,8 +96,8 @@ final as (
         department_id,
         created_at,
         updated_at,
-        'debit' as transaction_type,
-        'vendor_credit' as transaction_source
+        cast('debit' as {{ dbt.type_string() }}) as transaction_type,
+        cast('vendor_credit' as {{ dbt.type_string() }}) as transaction_source
     from vendor_credit_join
 )