Added unit test cases for materialized view

Author: aosingh

dbt/include/oracle/macros/materializations/materialized_view/materialized_view.sql

@@ -9,7 +9,7 @@
 {%- endmacro %}
 
 {% macro oracle__get_replace_materialized_view_as_sql(relation, sql, existing_relation, backup_relation, intermediate_relation) %}
-    {{ oracle__drop_relation(relation) }}
+    {{ oracle__drop_relation(existing_relation) }}
     {{ oracle__get_create_materialized_view_as_sql(relation, sql) }}
 {% endmacro %}
 

tests/functional/adapter/materialized_view/__init__.py

@@ -0,0 +1,84 @@
+"""
+Copyright (c) 2022, Oracle and/or its affiliates.
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+     https://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+"""
+from typing import Optional, Tuple
+
+import pytest
+
+from dbt.adapters.base.relation import BaseRelation
+
+from dbt.tests.adapter.materialized_view.basic import MaterializedViewBasic
+from dbt.tests.util import (
+    assert_message_in_logs,
+    get_model_file,
+    run_dbt,
+    run_dbt_and_capture,
+    set_model_file,
+)
+from tests.functional.adapter.materialized_view.utils import query_relation_type
+
+
+class TestOracleMaterializedViewBasic(MaterializedViewBasic):
+
+    @staticmethod
+    def insert_record(project, table: BaseRelation, record: Tuple[int, int]):
+        my_id, value = record
+        project.run_sql(f"insert into {table} (id, value) values ({my_id}, {value})")
+
+    @staticmethod
+    def refresh_materialized_view(project, materialized_view: BaseRelation):
+        sql = f"""
+            BEGIN
+             DBMS_MVIEW.REFRESH('{materialized_view}');
+            END;
+        """
+        project.run_sql(sql)
+
+    @staticmethod
+    def query_row_count(project, relation: BaseRelation) -> int:
+        sql = f"select count(*) from {relation}"
+        return project.run_sql(sql, fetch="one")[0]
+
+    @staticmethod
+    def query_relation_type(project, relation: BaseRelation) -> Optional[str]:
+        return query_relation_type(project, relation)
+
+    @pytest.fixture(scope="function", autouse=True)
+    def setup(self, project, my_materialized_view):
+
+        run_dbt(["seed"])
+        run_dbt(["run", "--models", my_materialized_view.identifier, "--full-refresh"])
+
+        # the tests touch these files, store their contents in memory
+        initial_model = get_model_file(project, my_materialized_view)
+
+        yield
+
+        # and then reset them after the test runs
+        set_model_file(project, my_materialized_view, initial_model)
+        run_dbt(["run-operation", "drop_schema", "--args", f"relation: {my_materialized_view.schema}"])
+
+    @pytest.mark.skip(
+        "The current implementation does not support overwriting materialized views with tables."
+    )
+    def test_table_replaces_materialized_view(self, project, my_materialized_view):
+        super().test_table_replaces_materialized_view(project, my_materialized_view)
+
+    @pytest.mark.skip(
+        "The current implementation does not support overwriting materialized views with views."
+    )
+    def test_view_replaces_materialized_view(self, project, my_materialized_view):
+        super().test_view_replaces_materialized_view(project, my_materialized_view)
+

tests/functional/adapter/materialized_view/test_materialized_view.py

@@ -0,0 +1,55 @@
+from typing import List, Optional
+
+from dbt.adapters.base.relation import BaseRelation
+from dbt.adapters.oracle.relation import OracleRelation
+
+
+def query_relation_type(project, relation: BaseRelation) -> Optional[str]:
+    assert isinstance(relation, OracleRelation)
+
+    sql = f"""
+        with tables as
+      (select SYS_CONTEXT('userenv', 'DB_NAME') table_catalog,
+         owner table_schema,
+         table_name,
+         case
+           when iot_type = 'Y'
+           then 'IOT'
+           when temporary = 'Y'
+           then 'TEMP'
+           else 'BASE TABLE'
+         end table_type
+       from sys.all_tables
+       where upper(table_name) not in (select upper(mview_name) from sys.all_mviews)
+       union all
+       select SYS_CONTEXT('userenv', 'DB_NAME'),
+         owner,
+         view_name,
+         'VIEW'
+       from sys.all_views
+       union all
+       select SYS_CONTEXT('userenv', 'DB_NAME'),
+        owner,
+        mview_name,
+        'MATERIALIZED VIEW'
+        from sys.all_mviews
+  )
+  select case table_type
+      when 'BASE TABLE' then 'table'
+      when 'VIEW' then 'view'
+      when 'MATERIALIZED VIEW' then 'materialized_view'
+    end as "relation_type"
+  from tables
+  where table_type in ('BASE TABLE', 'VIEW', 'MATERIALIZED VIEW')
+    and upper(table_schema) = upper('{relation.schema}')
+    and upper(table_name) = upper('{relation.identifier}') 
+    """
+
+    results = project.run_sql(sql, fetch="all")
+    if len(results) == 0:
+        return None
+    elif len(results) > 1:
+        raise ValueError(f"More than one instance of {relation.identifier} found!")
+    else:
+        return results[0][0]
+