Set delimited idenitifier conditional for database and schema columns

brooklyn-data · Sep 20, 2024 · 7110f29 · 7110f29
1 parent d07ce33
commit 7110f29
Showing 1 changed file with 21 additions and 11 deletions.
diff --git a/macros/upload_results/get_column_name_lists.sql b/macros/upload_results/get_column_name_lists.sql
@@ -63,7 +63,9 @@
             {% if target.type == "bigquery" %} bytes_processed,
             {% endif %}
             materialization,
-            "schema",
+            {% if target.type == "sqlserver" %} "schema",
+            {% else %} schema,
+            {% endif %}
             name,
             alias,
             message,
@@ -76,8 +78,9 @@
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
+            {% if target.type == "sqlserver" %} "database", "schema",
+            {% else %} database, schema,
+            {% endif %}
             name,
             depends_on_nodes,
             package_name,
@@ -104,7 +107,9 @@
             total_node_runtime,
             rows_affected,
             materialization,
-            "schema",
+            {% if target.type == "sqlserver" %} "schema",
+            {% else %} schema,
+            {% endif %}
             name,
             alias,
             message,
@@ -117,8 +122,9 @@
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
+            {% if target.type == "sqlserver" %} "database", "schema",
+            {% else %} database, schema,
+            {% endif %}
             name,
             package_name,
             path,
@@ -142,7 +148,9 @@
             total_node_runtime,
             rows_affected,
             materialization,
-            "schema",
+            {% if target.type == "sqlserver" %} "schema",
+            {% else %} schema,
+            {% endif %}
             name,
             alias,
             message,
@@ -155,8 +163,9 @@
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
+            {% if target.type == "sqlserver" %} "database", "schema",
+            {% else %} database, schema,
+            {% endif %}
             name,
             depends_on_nodes,
             package_name,
@@ -174,8 +183,9 @@
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
+            {% if target.type == "sqlserver" %} "database", "schema",
+            {% else %} database, schema,
+            {% endif %}
             source_name,
             loader,
             name,