Added delimited identifier conditional for sql server

models/dim_dbt__models.sql

@@ -7,9 +7,13 @@ with
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
             name,
+            {% if target.type == "sqlserver" %} "database"
+            {% else %} database
+            {% endif %},
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             depends_on_nodes,
             package_name,
             path,

models/dim_dbt__seeds.sql

@@ -7,9 +7,13 @@ with
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
             name,
+            {% if target.type == "sqlserver" %} "database"
+            {% else %} database
+            {% endif %},
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             package_name,
             path,
             checksum,

models/dim_dbt__snapshots.sql

@@ -7,9 +7,13 @@ with
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
             name,
+            {% if target.type == "sqlserver" %} "database"
+            {% else %} database
+            {% endif %},
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             depends_on_nodes,
             package_name,
             path,

models/dim_dbt__sources.sql

@@ -7,8 +7,12 @@ with
             command_invocation_id,
             node_id,
             run_started_at,
-            "database",
-            "schema",
+            {% if target.type == "sqlserver" %} "database"
+            {% else %} database
+            {% endif %},
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             source_name,
             loader,
             name,

models/fct_dbt__model_executions.sql

@@ -16,7 +16,9 @@ with
             rows_affected
             {% if target.type == "bigquery" %}, bytes_processed {% endif %},
             materialization,
-            "schema",  -- noqa
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             name,
             alias,
             message

models/fct_dbt__seed_executions.sql

@@ -15,7 +15,9 @@ with
             total_node_runtime,
             rows_affected,
             materialization,
-            "schema",
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             name,
             alias,
             message

models/fct_dbt__snapshot_executions.sql

@@ -15,7 +15,9 @@ with
             total_node_runtime,
             rows_affected,
             materialization,
-            "schema",
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
             name,
             alias,
             message

models/fct_dbt__test_executions.sql

@@ -1,29 +1,25 @@
 with
-    base as (
-
-        select *
-        from {{ ref('stg_dbt__test_executions') }}
-
-    )
-
-    , test_executions as (
+    base as (select * from {{ ref("stg_dbt__test_executions") }}),
+    test_executions as (
 
         select
-            test_execution_id
-            , command_invocation_id
-            , node_id
-            , run_started_at
-            , was_full_refresh
-            , thread_id
-            , status
-            , compile_started_at
-            , query_completed_at
-            , total_node_runtime
-            , rows_affected
-            , failures
-            , message
+            test_execution_id,
+            command_invocation_id,
+            node_id,
+            run_started_at,
+            was_full_refresh,
+            thread_id,
+            status,
+            compile_started_at,
+            query_completed_at,
+            total_node_runtime,
+            rows_affected,
+            failures,
+            message
         from base
 
     )
 
-select * from test_executions
+select *
+from test_executions
+

models/sources/model_executions.sql

@@ -11,7 +11,7 @@ select
     cast(null as {{ type_timestamp() }}) as compile_started_at,
     cast(null as {{ type_timestamp() }}) as query_completed_at,
     cast(null as {{ type_float() }}) as total_node_runtime,
-    cast(null as {{ type_int() }}) as rows_affected
+    cast(null as {{ type_int() }}) as rows_affected,
     {% if target.type == "bigquery" %}
         , cast(null as {{ type_int() }}) as bytes_processed
     {% endif %},

models/sources/snapshots.sql

@@ -4,13 +4,13 @@ with dummy_cte as (select 1 as foo)
 select
     cast(null as {{ type_string() }}) as command_invocation_id,
     cast(null as {{ type_string() }}) as node_id,
-    cast(null as {{ type_timestamp() }}) as run_started_at
+    cast(null as {{ type_timestamp() }}) as run_started_at,
     cast(null as {{ type_string() }}) as {% if target.type == "sqlserver" %} "database"
     {% else %} database
     {% endif %},
     cast(null as {{ type_string() }}) as {% if target.type == "sqlserver" %} "schema"
     {% else %} schema
-    {% endif %},,
+    {% endif %},
     cast(null as {{ type_string() }}) as name,
     cast(null as {{ type_array() }}) as depends_on_nodes,
     cast(null as {{ type_string() }}) as package_name,

models/staging/stg_dbt__model_executions.sql

@@ -1,36 +1,33 @@
 with
-    base as (
-
-        select *
-        from {{ ref('model_executions') }}
-
-    )
-
-    , enhanced as (
+    base as (select * from {{ ref("model_executions") }}),
+    enhanced as (
 
         select
-            {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as model_execution_id
-            , command_invocation_id
-            , node_id
-            , run_started_at
-            , was_full_refresh
-            , {{ split_part('thread_id', "'-'", 2) }} as thread_id
-            , status
-            , compile_started_at
-            , query_completed_at
-            , total_node_runtime
-            , rows_affected
-            {% if target.type == 'bigquery' %}
-            , bytes_processed
-            {% endif %}
-            , materialization
-            , "schema" -- noqa
-            , name
-            , alias
-            , message
-            , adapter_response
+            {{ dbt_artifacts.generate_surrogate_key(["command_invocation_id", "node_id"]) }}
+            as model_execution_id,
+            command_invocation_id,
+            node_id,
+            run_started_at,
+            was_full_refresh,
+            {{ split_part("thread_id", "'-'", 2) }} as thread_id,
+            status,
+            compile_started_at,
+            query_completed_at,
+            total_node_runtime,
+            rows_affected
+            {% if target.type == "bigquery" %}, bytes_processed {% endif %},
+            materialization,
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},  -- noqa
+            name,
+            alias,
+            message,
+            adapter_response
         from base
 
     )
 
-select * from enhanced
+select *
+from enhanced
+

models/staging/stg_dbt__models.sql

@@ -1,31 +1,32 @@
 with
-    base as (
-
-        select *
-        from {{ ref('models') }}
-
-    )
-
-    , enhanced as (
+    base as (select * from {{ ref("models") }}),
+    enhanced as (
 
         select
-            {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as model_execution_id
-            , command_invocation_id
-            , node_id
-            , run_started_at
-            , "database"
-            , "schema"
-            , name
-            , depends_on_nodes
-            , package_name
-            , path
-            , checksum
-            , materialization
-            , tags
-            , meta
-            , alias
+            {{ dbt_artifacts.generate_surrogate_key(["command_invocation_id", "node_id"]) }}
+            as model_execution_id,
+            command_invocation_id,
+            node_id,
+            run_started_at,
+            {% if target.type == "sqlserver" %} "database"
+            {% else %} database
+            {% endif %},
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},  -- noqa
+            name,
+            depends_on_nodes,
+            package_name,
+            path,
+            checksum,
+            materialization,
+            tags,
+            meta,
+            alias
         from base
 
     )
 
-select * from enhanced
+select *
+from enhanced
+

models/staging/stg_dbt__seed_executions.sql

@@ -1,33 +1,32 @@
 with
-    base as (
-
-        select *
-        from {{ ref('seed_executions') }}
-
-    )
-
-    , enhanced as (
+    base as (select * from {{ ref("seed_executions") }}),
+    enhanced as (
 
         select
-            {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as seed_execution_id
-            , command_invocation_id
-            , node_id
-            , run_started_at
-            , was_full_refresh
-            , {{ split_part('thread_id', "'-'", 2) }} as thread_id
-            , status
-            , compile_started_at
-            , query_completed_at
-            , total_node_runtime
-            , rows_affected
-            , materialization
-            , "schema" -- noqa
-            , name
-            , alias
-            , message
-            , adapter_response
+            {{ dbt_artifacts.generate_surrogate_key(["command_invocation_id", "node_id"]) }}
+            as seed_execution_id,
+            command_invocation_id,
+            node_id,
+            run_started_at,
+            was_full_refresh,
+            {{ split_part("thread_id", "'-'", 2) }} as thread_id,
+            status,
+            compile_started_at,
+            query_completed_at,
+            total_node_runtime,
+            rows_affected,
+            materialization,
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},  -- noqa
+            name,
+            alias,
+            message,
+            adapter_response
         from base
 
     )
 
-select * from enhanced
+select *
+from enhanced
+

models/staging/stg_dbt__seeds.sql

@@ -1,28 +1,29 @@
 with
-    base as (
-
-        select *
-        from {{ ref('seeds') }}
-
-    )
-
-    , enhanced as (
+    base as (select * from {{ ref("seeds") }}),
+    enhanced as (
 
         select
-            {{ dbt_artifacts.generate_surrogate_key(['command_invocation_id', 'node_id']) }} as seed_execution_id
-            , command_invocation_id
-            , node_id
-            , run_started_at
-            , "database"
-            , "schema"
-            , name
-            , package_name
-            , path
-            , checksum
-            , meta
-            , alias
+            {{ dbt_artifacts.generate_surrogate_key(["command_invocation_id", "node_id"]) }}
+            as seed_execution_id,
+            command_invocation_id,
+            node_id,
+            run_started_at,
+            {% if target.type == "sqlserver" %} "database"
+            {% else %} database
+            {% endif %},
+            {% if target.type == "sqlserver" %} "schema"
+            {% else %} schema
+            {% endif %},
+            name,
+            package_name,
+            path,
+            checksum,
+            meta,
+            alias
         from base
 
     )
 
-select * from enhanced
+select *
+from enhanced
+