v1.8.1

- oracledb python driver upgraded to 2.3.0
- Added support for BLOB column type in dbt model contracts
- Fixed method signature for create schema

Author: aosingh

Makefile

@@ -1,5 +1,5 @@
 # Configuration variables
-VERSION=1.8.0
+VERSION=1.8.1
 PROJ_DIR?=$(shell pwd)
 VENV_DIR?=${PROJ_DIR}/.bldenv
 BUILD_DIR=${PROJ_DIR}/build

dbt/include/oracle/macros/adapters.sql

@@ -42,6 +42,8 @@
       {%- endif -%}
       {%- if col['data_type'] | lower == 'clob' -%}
       empty_clob() as {{ col['name'] }}{{ ", " if not loop.last }}
+      {%- elif col['data_type'] | lower == 'blob' -%}
+      empty_blob() as {{ col['name'] }}{{ ", " if not loop.last }}
       {%- else -%}
       cast(null as {{ col['data_type'] }}) as {{ col['name'] }}{{ ", " if not loop.last }}
      {%- endif -%}
@@ -63,7 +65,7 @@
     ) model_subq
 {%- endmacro %}
 
-{% macro oracle__create_schema(relation, schema_name) -%}
+{% macro oracle__create_schema(relation) -%}
   {% if relation.database -%}
     {{ adapter.verify_database(relation.database) }}
   {%- endif -%}

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

@@ -215,7 +215,7 @@
   {% endif %}
 
   {% if not adapter.check_schema_exists(model_database, model.schema) %}
-    {% do create_schema(model_database, model.schema) %}
+    {% do create_schema(model.schema) %}
   {% endif %}
 
   {% set target_relation_exists, target_relation = get_or_create_relation(

dbt_adbs_test_project/dbt_project.yml

@@ -21,6 +21,7 @@ seeds:
         kafka_message:
           +column_types:
             message: CLOB
+            blob_message: BLOB
         seed_with_empty_col:
           +column_types:
             id: number

dbt_adbs_test_project/models/kafka.sql

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

dbt_adbs_test_project/models/promotion_costs.sql

@@ -13,7 +13,7 @@
   See the License for the specific language governing permissions and
   limitations under the License.
 #}
-{{ config(materialized='table')}}
+{{ config(materialized='table', grants = {'select': ['dbt_test_1']})}}
 with all_promo_costs as(
     select * from {{ source('sh_database', 'promotions') }}
 )

dbt_adbs_test_project/models/schema.yml

@@ -43,6 +43,11 @@ models:
         data_type: CLOB
         constraints:
           - type: not_null
+      - name: blob_message
+        description: Kafka message
+        data_type: BLOB
+        constraints:
+          - type: not_null
 
 
   - name: people

dbt_adbs_test_project/profiles.yml

@@ -9,7 +9,7 @@ dbt_test:
          host: "{{ env_var('DBT_ORACLE_HOST') }}"
          port: 1522
          service: "{{ env_var('DBT_ORACLE_SERVICE') }}"
-#         database: "{{ env_var('DBT_ORACLE_DATABASE') }}"
+         database: "{{ env_var('DBT_ORACLE_DATABASE') }}"
          schema: "{{ env_var('DBT_ORACLE_SCHEMA') }}"
          oml_cloud_service_url: "{{ env_var('DBT_ORACLE_OML_CLOUD_SERVICE_URL')}}"
          session_info:

dbt_adbs_test_project/seeds/kafka_message.csv

@@ -1,5 +1,5 @@
-message
-Jack-Hunter
-Jack-Hunter
-Jack-HunterJackHunter
-Jack-Hunter
+message,blob_message
+Jack-Hunter,1234
+Jack-Hunter,123124
+Jack-HunterJackHunter,123123
+Jack-Hunter,123143

setup.cfg

@@ -1,6 +1,6 @@
 [metadata]
 name = dbt-oracle
-version = 1.8.0
+version = 1.8.1
 description = dbt (data build tool) adapter for Oracle Autonomous Database
 long_description = file: README.md
 long_description_content_type = text/markdown
@@ -36,7 +36,7 @@ install_requires =
     dbt-common>=1.1.0,<2.0
     dbt-adapters>=1.2.1,<2.0
     dbt-core~=1.8,<1.9
-    oracledb==2.2.1
+    oracledb==2.3.0
 test_suite=tests
 test_requires =
     dbt-tests-adapter~=1.8,<1.9