Functional tests for except macro

tests/functional/cross_db_utils/fixture_except.py

@@ -1,36 +1,65 @@
 
-
 # except
 
-# TODO - implement expected results here
-seeds__data_except_csv = """todo,result
-TODO,1
+seeds__data_except_a_csv = """id
+1
+2
+3
 """
 
+seeds__data_except_b_csv = """id
+3
+4
+5
+"""
 
-models__test_except_sql = """
-with data as (
+seeds__data_except_a_minus_b_csv = """id
+1
+2
+"""
+
+seeds__data_except_b_minus_a_csv = """id
+4
+5
+"""
 
-    select * from {{ ref('data_except') }}
+models__data_except_empty_sql = """
+select * from {{ ref('data_except_a') }}
+where 0=1
+"""
 
-)
+models__test_except_a_minus_b_sql = """
+select * from {{ ref('data_except_a') }}
+{{ dbt_utils.except() }}
+select * from {{ ref('data_except_b') }}
+"""
 
-# TODO - implement actual logic here
-select
+models__test_except_b_minus_a_sql = """
+select * from {{ ref('data_except_b') }}
+{{ dbt_utils.except() }}
+select * from {{ ref('data_except_a') }}
+"""
 
-    1 actual,
-    result as expected
+models__test_except_a_minus_a_sql = """
+select * from {{ ref('data_except_a') }}
+{{ dbt_utils.except() }}
+select * from {{ ref('data_except_a') }}
+"""
 
-from data
+models__test_except_a_minus_empty_sql = """
+select * from {{ ref('data_except_a') }}
+{{ dbt_utils.except() }}
+select * from {{ ref('data_except_empty') }}
 """
 
+models__test_except_empty_minus_a_sql = """
+select * from {{ ref('data_except_empty') }}
+{{ dbt_utils.except() }}
+select * from {{ ref('data_except_a') }}
+"""
 
-models__test_except_yml = """
-version: 2
-models:
-  - name: test_except
-    tests:
-      - assert_equal:
-          actual: actual
-          expected: expected
+models__test_except_empty_minus_empty_sql = """
+select * from {{ ref('data_except_empty') }}
+{{ dbt_utils.except() }}
+select * from {{ ref('data_except_empty') }}
 """

tests/functional/cross_db_utils/test_except.py

@@ -1,25 +1,70 @@
 import pytest
+from dbt.tests.util import run_dbt, check_relations_equal
 from tests.functional.cross_db_utils.base_cross_db_macro import BaseCrossDbMacro
 from tests.functional.cross_db_utils.fixture_except import (
-    seeds__data_except_csv,
-    models__test_except_sql,
-    models__test_except_yml,
+    seeds__data_except_a_csv,
+    seeds__data_except_b_csv,
+    seeds__data_except_a_minus_b_csv,
+    seeds__data_except_b_minus_a_csv,
+    models__data_except_empty_sql,
+    models__test_except_a_minus_b_sql,
+    models__test_except_b_minus_a_sql,
+    models__test_except_a_minus_a_sql,
+    models__test_except_a_minus_empty_sql,
+    models__test_except_empty_minus_a_sql,
+    models__test_except_empty_minus_empty_sql,
 )
 
 
 class BaseExcept(BaseCrossDbMacro):
     @pytest.fixture(scope="class")
     def seeds(self):
-        return {"data_except.csv": seeds__data_except_csv}
+        return {
+            "data_except_a.csv": seeds__data_except_a_csv,
+            "data_except_b.csv": seeds__data_except_b_csv,
+            "data_except_a_minus_b.csv": seeds__data_except_a_minus_b_csv,
+            "data_except_b_minus_a.csv": seeds__data_except_b_minus_a_csv,
+        }
 
     @pytest.fixture(scope="class")
     def models(self):
         return {
-            "test_except.yml": models__test_except_yml,
-            "test_except.sql": models__test_except_sql,
+            "data_except_empty.sql": models__data_except_empty_sql,
+            "test_except_a_minus_b.sql": models__test_except_a_minus_b_sql,
+            "test_except_b_minus_a.sql": models__test_except_b_minus_a_sql,
+            "test_except_a_minus_a.sql": models__test_except_a_minus_a_sql,
+            "test_except_a_minus_empty.sql": models__test_except_a_minus_empty_sql,
+            "test_except_empty_minus_a.sql": models__test_except_empty_minus_a_sql,
+            "test_except_empty_minus_empty.sql": models__test_except_empty_minus_empty_sql,
         }
 
 
-@pytest.mark.skip(reason="TODO - implement this test")
 class TestExcept(BaseExcept):
-    pass
+    def test_build_assert_equal(self, project):
+        run_dbt(['deps'])
+        run_dbt(['build'])
+
+        check_relations_equal(
+            project.adapter,
+            ["test_except_a_minus_b", "data_except_a_minus_b"],
+        )
+        check_relations_equal(
+            project.adapter,
+            ["test_except_b_minus_a", "data_except_b_minus_a"],
+        )
+        check_relations_equal(
+            project.adapter,
+            ["test_except_a_minus_a", "data_except_empty"],
+        )
+        check_relations_equal(
+            project.adapter,
+            ["test_except_a_minus_empty", "data_except_a"],
+        )
+        check_relations_equal(
+            project.adapter,
+            ["test_except_empty_minus_a", "data_except_empty"],
+        )
+        check_relations_equal(
+            project.adapter,
+            ["test_except_empty_minus_empty", "data_except_empty"],
+        )