Merge pull request #251 from dbt-msft/fix-unique-incremental-array

fix incremental unique array

dbt/include/sqlserver/macros/materializations/models/incremental/merge.sql

@@ -10,7 +10,39 @@
 {% endmacro %}
 
 {% macro sqlserver__get_delete_insert_merge_sql(target, source, unique_key, dest_columns) %}
-  {{ default__get_delete_insert_merge_sql(target, source, unique_key, dest_columns) }};
+
+      {%- set dest_cols_csv = get_quoted_csv(dest_columns | map(attribute="name")) -%}
+
+      {% if unique_key %}
+      {% if unique_key is sequence and unique_key is not string %}
+      delete from {{ target }}
+          where exists (
+                SELECT NULL
+                FROM
+                  {{ source }}
+                WHERE
+                {% for key in unique_key %}
+                    {{ source }}.{{ key }} = {{ target }}.{{ key }}
+                    {{ "and " if not loop.last }}
+                {% endfor %}
+            );
+      {% else %}
+      delete from {{ target }}
+          where (
+                {{ unique_key }}) in (
+      select ({{ unique_key }})
+      from {{ source }}
+          );
+
+      {% endif %}
+      {% endif %}
+
+      insert into {{ target }} ({{ dest_cols_csv }})
+          (
+      select {{ dest_cols_csv }}
+      from {{ source }}
+          )
+
 {% endmacro %}
 
 {% macro sqlserver__get_insert_overwrite_merge_sql(target, source, dest_columns, predicates, include_sql_header) %}

tests/functional/adapter/test_incremental.py

@@ -0,0 +1,5 @@
+from dbt.tests.adapter.incremental.test_incremental_unique_id import BaseIncrementalUniqueKey
+
+
+class TestBaseIncrementalUniqueKeySQLServer(BaseIncrementalUniqueKey):
+    pass