dbt: Start using dbt-cratedb2

crate · Nov 26, 2024 · a714523 · a714523
1 parent 194a310
commit a714523
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 111 deletions.
diff --git a/framework/dbt/basic/macros/catalog.sql b/framework/dbt/basic/macros/catalog.sql
diff --git a/framework/dbt/basic/macros/overrides.sql b/framework/dbt/basic/macros/overrides.sql
@@ -26,15 +26,7 @@
 
 {%- endmacro %}
 
-{% macro postgres__create_schema(relation) -%}
-  {%- call statement('create_schema') -%}
-    /* schemas are not created in CrateDB */
-    DROP TABLE IF EXISTS thisschemadefinitelydoesnotexits.thiswouldnotexist
-    /* but we need to run something to not have just EOF */
-  {% endcall %}
-{% endmacro %}
-
-{% macro postgres__create_table_as(temporary, relation, sql) -%}
+{% macro cratedb__create_table_as(temporary, relation, sql) -%}
   {%- set unlogged = config.get('unlogged', default=false) -%}
   {%- set sql_header = config.get('sql_header', none) -%}
 
@@ -46,27 +38,6 @@
   );
 {%- endmacro %}
 
-{% macro postgres__drop_schema(relation) -%}
-  {% if relation.database -%}
-    {{ adapter.verify_database(relation.database) }}
-  {%- endif -%}
-  {%- call statement('drop_schema') -%}
-    /* schemas are not dropped in CrateDB */
-  {%- endcall -%}
-{% endmacro %}
-
-{% macro default__drop_relation(relation) -%}
-  {% call statement('drop_relation', auto_begin=False) -%}
-    drop {{ relation.type }} if exists "{{ relation.schema }}"."{{ relation.identifier }}"
-  {%- endcall %}
-{% endmacro %}
-
-{% macro default__drop_schema(relation) -%}
-  {%- call statement('drop_schema') -%}
-    /* schemas are not dropped in CrateDB */
-  {% endcall %}
-{% endmacro %}
-
 {% macro default__create_view_as(relation, sql) -%}
   {%- set sql_header = config.get('sql_header', none) -%}
 
@@ -76,7 +47,7 @@
   ;
 {%- endmacro %}
 
-{% macro postgres__rename_relation(from_relation, to_relation) -%}
+{% macro cratedb__rename_relation(from_relation, to_relation) -%}
 	{% do drop_relation(to_relation) %}
 	{% set schema_query = "SELECT table_type FROM information_schema.tables WHERE table_schema = '{}' AND table_name = '{}'".format(from_relation.schema, from_relation.identifier) %}
 	{% set results = run_query(schema_query) %}

diff --git a/framework/dbt/basic/macros/relations.sql b/framework/dbt/basic/macros/relations.sql
diff --git a/framework/dbt/basic/profiles.yml b/framework/dbt/basic/profiles.yml
@@ -1,7 +1,7 @@
 cratedb_localhost:
   outputs:
     dev:
-      type: postgres
+      type: cratedb
       host: localhost
       user: crate
       pass: crate

diff --git a/framework/dbt/basic/requirements.txt b/framework/dbt/basic/requirements.txt
@@ -1,2 +1 @@
-dbt-postgres<1.7
-snowplow-tracker<0.13
+dbt-cratedb2>=0.0.1dev2