TestSparkUnitTestCaseInsensitivity, TestSparkUnitTestInvalidInput

dbt-labs · Feb 7, 2024 · e67a397 · e67a397
1 parent e62b73d
commit e67a397
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/dbt/include/spark/macros/adapters.sql b/dbt/include/spark/macros/adapters.sql
@@ -146,6 +146,10 @@
 {%- macro spark__create_table_as(temporary, relation, compiled_code, language='sql') -%}
   {%- if language == 'sql' -%}
     {%- if temporary -%}
+      {#-- for SQL model we will create temp view that doesn't have database and schema --#}
+      {%- if language == 'sql'-%}
+        {%- set relation = relation.include(database=false, schema=false) -%}
+      {%- endif -%}
       {{ create_temporary_view(relation, compiled_code) }}
     {%- else -%}
       {% if config.get('file_format', validator=validation.any[basestring]) in ['delta', 'iceberg'] %}

diff --git a/tests/functional/adapter/unit_testing/test_unit_testing.py b/tests/functional/adapter/unit_testing/test_unit_testing.py
@@ -0,0 +1,10 @@
+from dbt.tests.adapter.unit_testing.test_case_insensitivity import BaseUnitTestCaseInsensivity
+from dbt.tests.adapter.unit_testing.test_invalid_input import BaseUnitTestInvalidInput
+
+
+class TestSparkUnitTestCaseInsensitivity(BaseUnitTestCaseInsensivity):
+    pass
+
+
+class TestSparkUnitTestInvalidInput(BaseUnitTestInvalidInput):
+    pass