v1.7.2: kafka

dbt/include/oracle/macros/adapters.sql

@@ -40,7 +40,11 @@
       {%- if col['data_type'] is not defined -%}
         {{ col_err.append(col['name']) }}
       {%- endif -%}
-      cast(null as {{ col['data_type'] }}) as {{ col['name'] }}{{ ", " if not loop.last }}
+      {%- if col['data_type'] | lower == 'clob' -%}
+        empty_clob() as {{ col['name'] }}{{ ", " if not loop.last }}
+      {%- else -%}
+        cast(null as {{ col['data_type'] }}) as {{ col['name'] }}{{ ", " if not loop.last }}
+      {%- endif -%}
     {%- endfor -%}
     {# Override for Oracle #}
      from dual
@@ -268,7 +272,7 @@
       {% set comment = column_dict[column_name]['description'] %}
       {% set escaped_comment = oracle_escape_comment(comment) %}
       {% call statement('alter _column comment', fetch_result=False) -%}
-        comment on column {{ relation }}.{{ column_name }} is {{ escaped_comment }}
+        comment on column {{ relation }}.{{ adapter.check_and_quote_identifier(column_name, model.columns) }} is {{ escaped_comment }}
       {%- endcall %}
     {% endfor %}
   {% endif %}
@@ -384,7 +388,7 @@
            else 'BASE TABLE'
          end table_type
        from sys.all_tables
-       where upper(table_name) not in (select upper(mview_name) from sys.all_mviews)
+       where upper(table_name) not in (select upper(mview_name) from sys.all_mviews where upper(owner) = upper('{{ schema_relation.schema }}'))
        union all
        select SYS_CONTEXT('userenv', 'DB_NAME'),
          owner,

dbt_adbs_test_project/dbt_project.yml

@@ -18,6 +18,9 @@ quoting:
 seeds:
     dbt_adbs_test_project:
         quote_columns: false
+        kafka_message:
+          +column_types:
+            message: CLOB
         seed_with_empty_col:
           +column_types:
             id: number

dbt_adbs_test_project/models/kafka.sql

@@ -0,0 +1 @@
+select * from {{ ref('kafka_message') }}

dbt_adbs_test_project/models/schema.yml

@@ -18,6 +18,25 @@ sources:
       - name: costs
 
 models:
+  - name: kafka
+    description: kafka_description
+    config:
+      materialized: incremental
+      incremental_strategy: append
+      on_schema_change: fail
+      full_refresh: false
+      contract:
+        enforced: true
+      constraints:
+        - type: not_null
+          columns: [message]
+    columns:
+      - name: message
+        description: Kafka message
+        data_type: CLOB
+        constraints:
+          - type: not_null
+
   - name: people
     columns:
       - name: id

dbt_adbs_test_project/seeds/kafka_message.csv

@@ -0,0 +1,5 @@
+message
+Jack-Hunter
+Jack-Hunter
+Jack-HunterJackHunter
+Jack-Hunter