Merge pull request #14 from bachng2017/drop_database

Drop database

dbt/adapters/mindsdb/connections.py

@@ -56,7 +56,8 @@ def open(cls, connection):
                 port=credentials.port,
                 username=credentials.username,
                 password=credentials.password,
-                database=credentials.database
+                database=credentials.database,
+                buffered=True
             )
             connection.state = 'open'
             connection.handle = handle

dbt/adapters/mindsdb/relation.py

@@ -0,0 +1,20 @@
+from dataclasses import dataclass
+
+from dbt.adapters.base.relation import BaseRelation, Policy
+from dbt.contracts.relation import ComponentName
+
+
+@dataclass
+class MindsdbQuotePolicy(Policy):
+    database: bool = False
+    schema: bool = False
+    identifier: bool = False
+
+
+@dataclass(frozen=True, eq=False, repr=False)
+class MindsdbRelation(BaseRelation):
+    quote_policy: MindsdbQuotePolicy = MindsdbQuotePolicy()
+
+    # Overridden as Mindsdb converts relation identifiers to lowercase
+    def _is_exactish_match(self, field: ComponentName, value: str) -> bool:
+       return self.path.get_lowered_part(field) == value.lower()

dbt/include/mindsdb/macros/materialization/database.sql

@@ -5,7 +5,10 @@
 
   -- build model
   {%- call statement('main') -%}
-    DROP DATABASE IF EXISTS {{ database }};
+    CREATE DATABASE {{ database }}
+  {%- endcall -%}
+  {%- call statement('main') -%}
+    DROP DATABASE IF EXISTS {{ database }}
   {%- endcall -%}
 
 

dbt/include/mindsdb/macros/schema.sql

@@ -0,0 +1,12 @@
+{% macro mindsdb__create_schema(relation) -%}
+  {%- call statement('create_schema') -%}
+  SELECT 1
+  {% endcall %}
+{% endmacro %}
+
+
+{% macro mindsdb__drop_schema(relation) -%}
+  {%- call statement('drop_schema') -%}
+    drop database if exists {{ relation.without_identifier() }}
+  {% endcall %}
+{% endmacro %}