fix create table as macro

Create table as cannot insert into relation due to missmatch column order between the result of sql
vertica · Aug 10, 2022 · ff52378 · ff52378
1 parent d75d0ba
commit ff52378
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 6 deletions.
diff --git a/dbt/include/vertica/macros/materializations/models/incremental/merge.sql b/dbt/include/vertica/macros/materializations/models/incremental/merge.sql
@@ -15,11 +15,17 @@
 
   on HASH( {{ get_qouted_csv_with_prefix("DBT_INTERNAL_DEST", unique_key) }} ) = HASH({{ get_qouted_csv_with_prefix("DBT_INTERNAL_SOURCE", unique_key) }})
 
-  when matched then update set
-  {% for column_name in merge_update_columns -%}
-    {{ adapter.quote(column_name) }} = DBT_INTERNAL_SOURCE.{{ adapter.quote(column_name) }}
-    {%- if not loop.last %}, {% endif %}
-  {%- endfor %}
+  {%- if merge_update_columns is string %}
+    {%- set merge_update_columns = merge_update_columns.split(',') %}
+  {% endif %}
+
+  {%- if merge_update_columns | length > 0 %}
+    when matched then update set
+    {% for column_name in merge_update_columns -%}
+      {{ adapter.quote(column_name) }} = DBT_INTERNAL_SOURCE.{{ adapter.quote(column_name) }}
+      {%- if not loop.last %}, {% endif %}
+    {%- endfor %}
+  {%- endif %}
 
   when not matched then insert
     ({{ dest_columns_csv }})

diff --git a/dbt/include/vertica/macros/materializations/models/table/create_table_as.sql b/dbt/include/vertica/macros/materializations/models/table/create_table_as.sql
@@ -28,7 +28,9 @@
 
       insert into {{ relation }} ({{ dest_cols_csv }})
       (
-          {{ sql }}
+        select {{ dest_cols_csv }} from (
+          select * from {{ sql }}
+        ) as DBT_MASKED_TARGET
       );
 
 {% endmacro %}