fix: add explicit sqlserver__ dispatch to T-SQL fabric macros (CORE-877)

integration_tests/dbt_project/macros/schema_utils/list_schemas.sql

@@ -41,6 +41,10 @@
     {% do return(schemas) %}
 {% endmacro %}
 
+{% macro sqlserver__edr_list_schemas(database) %}
+    {% do return(fabric__edr_list_schemas(database)) %}
+{% endmacro %}
+
 {% macro clickhouse__edr_list_schemas(database) %}
     {% set results = run_query("SHOW DATABASES") %}
     {% set schemas = [] %}

integration_tests/dbt_project/macros/schema_utils/schema_exists.sql

@@ -49,6 +49,10 @@
     {% do return(result | length > 0) %}
 {% endmacro %}
 
+{% macro sqlserver__edr_schema_exists(database, schema_name) %}
+    {% do return(fabric__edr_schema_exists(database, schema_name)) %}
+{% endmacro %}
+
 {% macro clickhouse__edr_schema_exists(database, schema_name) %}
     {% set safe_schema = schema_name | replace("'", "''") %}
     {% set result = run_query(

macros/edr/data_monitoring/monitors/column_numeric_monitors.sql

@@ -83,6 +83,14 @@
     var(cast({{ column_name }} as {{ elementary.edr_type_float() }}))
 {%- endmacro %}
 
+{% macro sqlserver__standard_deviation(column_name) -%}
+    {{ elementary.fabric__standard_deviation(column_name) }}
+{%- endmacro %}
+
+{% macro sqlserver__variance(column_name) -%}
+    {{ elementary.fabric__variance(column_name) }}
+{%- endmacro %}
+
 {% macro sum(column_name) -%}
     sum(cast({{ column_name }} as {{ elementary.edr_type_float() }}))
 {%- endmacro %}

macros/edr/data_monitoring/monitors/column_string_monitors.sql

@@ -24,6 +24,18 @@
     avg(len({{ column_name }}))
 {%- endmacro %}
 
+{% macro sqlserver__max_length(column_name) -%}
+    {{ elementary.fabric__max_length(column_name) }}
+{%- endmacro %}
+
+{% macro sqlserver__min_length(column_name) -%}
+    {{ elementary.fabric__min_length(column_name) }}
+{%- endmacro %}
+
+{% macro sqlserver__average_length(column_name) -%}
+    {{ elementary.fabric__average_length(column_name) }}
+{%- endmacro %}
+
 {% macro missing_count(column_name) %}
     coalesce(
         sum(

macros/edr/data_monitoring/monitors_query/get_latest_full_refresh.sql

@@ -30,3 +30,7 @@
     {% endset %}
     {% do return(elementary.result_value(query)) %}
 {% endmacro %}
+
+{% macro sqlserver__get_latest_full_refresh(model_node) %}
+    {% do return(elementary.fabric__get_latest_full_refresh(model_node)) %}
+{% endmacro %}

macros/edr/data_monitoring/monitors_query/table_monitoring_query.sql

@@ -406,6 +406,10 @@
     }}
 {% endmacro %}
 
+{% macro sqlserver___bucket_end_freshness_expr() %}
+    {{ elementary.fabric___bucket_end_freshness_expr() }}
+{% endmacro %}
+
 {#-- Helper: final SELECT columns for freshness metric --#}
 {% macro _freshness_final_select(metric) %}
     select
@@ -545,6 +549,10 @@
     where row_num = 1
 {% endmacro %}
 
+{% macro sqlserver__freshness_metric_query(metric, metric_properties) %}
+    {{ elementary.fabric__freshness_metric_query(metric, metric_properties) }}
+{% endmacro %}
+
 {% macro event_freshness_metric_query(metric, metric_properties) %}
     {{
         return(

macros/edr/data_monitoring/schema_changes/get_columns_changes_query.sql

@@ -313,3 +313,13 @@
         on (lower(cs.column_name) = lower(bl.column_name))
     where lower(cs.full_table_name) = lower('{{ full_table_name }}')
 {% endmacro %}
+
+{% macro sqlserver__get_column_changes_from_baseline_cur(
+    model_relation, full_table_name, model_baseline_relation
+) %}
+    {{
+        elementary.fabric__get_column_changes_from_baseline_cur(
+            model_relation, full_table_name, model_baseline_relation
+        )
+    }}
+{% endmacro %}

macros/edr/materializations/test/failed_row_count.sql

@@ -72,3 +72,7 @@
         as {{ elementary.escape_reserved_keywords("count") }}
     from {{ tmp_relation }}
 {% endmacro %}
+
+{% macro sqlserver__get_failed_row_count_calc_query(failed_row_count_calc) %}
+    {{ elementary.fabric__get_failed_row_count_calc_query(failed_row_count_calc) }}
+{% endmacro %}

macros/edr/materializations/test/test.sql

@@ -280,6 +280,16 @@
     {% do return(result) %}
 {% endmacro %}
 
+{% macro sqlserver__query_test_result_rows(
+    sample_limit=none, ignore_passed_tests=false
+) %}
+    {% do return(
+        elementary.fabric__query_test_result_rows(
+            sample_limit, ignore_passed_tests
+        )
+    ) %}
+{% endmacro %}
+
 {% macro get_columns_to_exclude_from_sampling(flattened_test) %}
     {% set columns_to_exclude = [] %}
 

macros/edr/system/system_utils/buckets_cte.sql

@@ -288,6 +288,24 @@
     {{ return(complete_buckets_cte) }}
 {% endmacro %}
 
+{% macro sqlserver__complete_buckets_cte(
+    time_bucket,
+    bucket_end_expr,
+    min_bucket_start_expr,
+    max_bucket_end_expr
+) -%}
+    {{-
+        return(
+            elementary.fabric__complete_buckets_cte(
+                time_bucket,
+                bucket_end_expr,
+                min_bucket_start_expr,
+                max_bucket_end_expr,
+            )
+        )
+    -}}
+{%- endmacro %}
+
 {% macro dremio__complete_buckets_cte(
     time_bucket, bucket_end_expr, min_bucket_start_expr, max_bucket_end_expr
 ) %}

macros/edr/system/system_utils/empty_table.sql

@@ -253,3 +253,7 @@
     } %}
     {{ return(dummy_values) }}
 {% endmacro %}
+
+{% macro sqlserver__dummy_values() %}
+    {% do return(elementary.fabric__dummy_values()) %}
+{% endmacro %}

macros/edr/system/system_utils/full_names.sql

@@ -116,6 +116,10 @@
     cast(replace(parsename(full_table_name, {{ part_index }}), '"', '') as varchar(256)) as {{ part_name }}
 {% endmacro %}
 
+{% macro sqlserver__full_name_split(part_name) %}
+    {{ elementary.fabric__full_name_split(part_name) }}
+{% endmacro %}
+
 {% macro bigquery__full_name_split(part_name) %}
     {%- if part_name == "database_name" -%} {%- set part_index = 0 %}
     {%- elif part_name == "schema_name" -%} {%- set part_index = 1 %}

macros/edr/system/system_utils/get_config_var.sql

@@ -49,6 +49,10 @@
     {% if value %} cast(1 as bit) {% else %} cast(0 as bit){% endif %}
 {% endmacro %}
 
+{% macro sqlserver__edr_boolean_literal(value) %}
+    {{ elementary.fabric__edr_boolean_literal(value) }}
+{% endmacro %}
+
 {# Render a SQL condition as a boolean column value.
    Produces: case when <condition> then TRUE else FALSE end
    On T-SQL, TRUE/FALSE become cast(1/0 as bit).
@@ -70,6 +74,10 @@
 
 {% macro fabric__edr_is_true(expr) %} {{ expr }} = cast(1 as bit) {% endmacro %}
 
+{% macro sqlserver__edr_is_true(expr) %}
+    {{ elementary.fabric__edr_is_true(expr) }}
+{% endmacro %}
+
 {# Compare a SQL expression to FALSE.  Works across all dialects including T-SQL (bit). #}
 {% macro edr_is_false(expr) %}
     {{ return(adapter.dispatch("edr_is_false", "elementary")(expr)) }}
@@ -79,6 +87,10 @@
 
 {% macro fabric__edr_is_false(expr) %} {{ expr }} = cast(0 as bit) {% endmacro %}
 
+{% macro sqlserver__edr_is_false(expr) %}
+    {{ elementary.fabric__edr_is_false(expr) }}
+{% endmacro %}
+
 {# Returns true if the current adapter uses T-SQL dialect (Fabric or SQL Server). #}
 {% macro is_tsql() %}
     {{ return(adapter.dispatch("is_tsql", "elementary")()) }}
@@ -88,6 +100,10 @@
 
 {% macro fabric__is_tsql() %} {{ return(true) }} {% endmacro %}
 
+{% macro sqlserver__is_tsql() %}
+    {% do return(elementary.fabric__is_tsql()) %}
+{% endmacro %}
+
 {% macro get_default_config(var_name) %}
     {{ return(adapter.dispatch("get_default_config", "elementary")()) }}
 {%- endmacro -%}

macros/edr/tests/test_utils/get_anomaly_query.sql

@@ -23,6 +23,10 @@
     -}}
 {%- endmacro -%}
 
+{%- macro sqlserver__get_anomaly_query(flattened_test=none) -%}
+    {%- do return(elementary.fabric__get_anomaly_query(flattened_test)) -%}
+{%- endmacro -%}
+
 {%- macro get_anomaly_query_for_dimension_anomalies(flattened_test=none) -%}
     {{-
         return(
@@ -64,6 +68,14 @@
     -}}
 {%- endmacro -%}
 
+{%- macro sqlserver__get_anomaly_query_for_dimension_anomalies(flattened_test=none) -%}
+    {%- do return(
+        elementary.fabric__get_anomaly_query_for_dimension_anomalies(
+            flattened_test
+        )
+    ) -%}
+{%- endmacro -%}
+
 {% macro get_read_anomaly_scores_query(
     flattened_test=none,
     additional_where=none,

macros/utils/cross_db_utils/concat.sql

@@ -13,3 +13,7 @@
 {% macro fabric__edr_concat(fields) %}
     cast({{ dbt.concat(fields) }} as varchar(4000))
 {% endmacro %}
+
+{% macro sqlserver__edr_concat(fields) %}
+    {{ elementary.fabric__edr_concat(fields) }}
+{% endmacro %}

macros/utils/cross_db_utils/current_timestamp.sql

@@ -92,6 +92,14 @@
     cast(sysutcdatetime() as datetime2(6))
 {%- endmacro -%}
 
+{% macro sqlserver__edr_current_timestamp() -%}
+    {{ elementary.fabric__edr_current_timestamp() }}
+{%- endmacro -%}
+
+{% macro sqlserver__edr_current_timestamp_in_utc() -%}
+    {{ elementary.fabric__edr_current_timestamp_in_utc() }}
+{%- endmacro -%}
+
 {% macro fabricspark__edr_current_timestamp() %}
     {{ return(elementary.spark__edr_current_timestamp()) }}
 {% endmacro %}

macros/utils/cross_db_utils/date_trunc.sql

@@ -24,3 +24,7 @@
 {% macro fabric__edr_date_trunc(datepart, date_expression) %}
     datetrunc({{ datepart }}, {{ date_expression }})
 {% endmacro %}
+
+{% macro sqlserver__edr_date_trunc(datepart, date_expression) %}
+    {{ elementary.fabric__edr_date_trunc(datepart, date_expression) }}
+{% endmacro %}

macros/utils/cross_db_utils/dateadd.sql

@@ -28,6 +28,10 @@
     dateadd({{ datepart }}, {{ interval }}, {{ from_date_or_timestamp }})
 {% endmacro %}
 
+{% macro sqlserver__edr_dateadd(datepart, interval, from_date_or_timestamp) %}
+    {{ elementary.fabric__edr_dateadd(datepart, interval, from_date_or_timestamp) }}
+{% endmacro %}
+
 {% macro dremio__edr_dateadd(datepart, interval, from_date_or_timestamp) %}
     {% set datepart = datepart | lower %}
     {% if datepart == "year" %}

macros/utils/cross_db_utils/datediff.sql

@@ -280,6 +280,10 @@
     datediff({{ date_part }}, {{ first_date }}, {{ second_date }})
 {% endmacro %}
 
+{% macro sqlserver__edr_datediff(first_date, second_date, date_part) %}
+    {{ elementary.fabric__edr_datediff(first_date, second_date, date_part) }}
+{% endmacro %}
+
 {% macro dremio__edr_datediff(first_date, second_date, date_part) %}
     {%- set seconds_diff_expr -%}
         cast(unix_timestamp(substr(cast(({{ second_date }}) as varchar), 1, 19)) - 

macros/utils/cross_db_utils/day_of_week.sql

@@ -71,6 +71,10 @@
     cast(datename(weekday, {{ date_expr }}) as varchar(30))
 {% endmacro %}
 
+{% macro sqlserver__edr_day_of_week_expression(date_expr) %}
+    {{ elementary.fabric__edr_day_of_week_expression(date_expr) }}
+{% endmacro %}
+
 -- fmt: off
 {% macro clickhouse__edr_day_of_week_expression(date_expr) %}
     formatDateTime({{ date_expr }}, '%W')

macros/utils/cross_db_utils/hour_of_day.sql

@@ -32,3 +32,7 @@
 {% macro fabric__edr_hour_of_day_expression(date_expr) %}
     datepart(hour, {{ date_expr }})
 {% endmacro %}
+
+{% macro sqlserver__edr_hour_of_day_expression(date_expr) %}
+    {{ elementary.fabric__edr_hour_of_day_expression(date_expr) }}
+{% endmacro %}

macros/utils/cross_db_utils/hour_of_week.sql

@@ -96,6 +96,10 @@
     )
 {% endmacro %}
 
+{% macro sqlserver__edr_hour_of_week_expression(date_expr) %}
+    {{ elementary.fabric__edr_hour_of_week_expression(date_expr) }}
+{% endmacro %}
+
 {% macro duckdb__edr_hour_of_week_expression(date_expr) %}
     concat(
         cast(dayname({{ date_expr }}) as {{ elementary.edr_type_string() }}),

macros/utils/cross_db_utils/incremental_strategy.sql

@@ -24,6 +24,10 @@
     {% do return("merge") %}
 {% endmacro %}
 
+{%- macro sqlserver__get_default_incremental_strategy() %}
+    {% do return(elementary.fabric__get_default_incremental_strategy()) %}
+{% endmacro %}
+
 {%- macro fabricspark__get_default_incremental_strategy() %}
     {{ return(elementary.spark__get_default_incremental_strategy()) }}
 {% endmacro %}

macros/utils/cross_db_utils/multi_value_in.sql

@@ -53,6 +53,14 @@
     )
 {%- endmacro -%}
 
+{%- macro sqlserver__edr_multi_value_in(source_cols, target_cols, target_table) -%}
+    {{-
+        elementary.fabric__edr_multi_value_in(
+            source_cols, target_cols, target_table
+        )
+    -}}
+{%- endmacro -%}
+
 {%- macro redshift__edr_multi_value_in(source_cols, target_cols, target_table) -%}
     {# Redshift doesn't support multi-column IN subqueries (tuple IN) like:
        (col1, col2) IN (SELECT col1, col2 FROM table)

macros/utils/cross_db_utils/time_trunc.sql

@@ -26,3 +26,7 @@
         cast({{ date_expression }} as {{ elementary.edr_type_timestamp() }})
     )
 {% endmacro %}
+
+{% macro sqlserver__edr_time_trunc(date_part, date_expression) %}
+    {{ elementary.fabric__edr_time_trunc(date_part, date_expression) }}
+{% endmacro %}

macros/utils/cross_db_utils/timeadd.sql

@@ -88,6 +88,10 @@
     )
 {% endmacro %}
 
+{% macro sqlserver__edr_timeadd(date_part, number, timestamp_expression) %}
+    {{ elementary.fabric__edr_timeadd(date_part, number, timestamp_expression) }}
+{% endmacro %}
+
 {% macro dremio__edr_timeadd(date_part, number, timestamp_expression) %}
     timestampadd(
         {{ date_part }},

macros/utils/cross_db_utils/to_char.sql

@@ -34,3 +34,7 @@
     {%- else %}, 120)
     {%- endif %}
 {% endmacro %}
+
+{% macro sqlserver__edr_to_char(column, format) %}
+    {{ elementary.fabric__edr_to_char(column, format) }}
+{% endmacro %}