fix: third-party test

.circleci/config.yml

@@ -94,22 +94,22 @@ workflows:
         ################################
         - Postgres:
             name: Third Party Test - Postgres | v3.10 | Linux
-            filters:
-              branches:
-                only: 
-                  - master
-                  - staging
+            # filters:
+            #   branches:
+            #     only: 
+            #       - master
+            #       - staging
         ################################
         ### THIRD PARTY: Staging, Master
         ################################
         ################################
         - MySQL:
             name: Third Party Test - MySQL | v3.10 | Linux
-            filters:
-              branches:
-                only: 
-                  - master
-                  - staging
+            # filters:
+            #   branches:
+            #     only: 
+            #       - master
+            #       - staging
         ################################
         ### NOTEBOOKS: Staging, Master
         ################################

evadb/storage/native_storage_engine.py

@@ -31,6 +31,9 @@ def __init__(self, db: EvaDBDatabase):
     def write(self, table: TableCatalogEntry, rows: Batch):
         pass
 
+    def create(self, table: TableCatalogEntry):
+        pass
+
     def read(self, table: TableCatalogEntry) -> Iterator[Batch]:
         try:
             db_catalog_entry = self.db.catalog().get_database_catalog_entry(

evadb/third_party/databases/interface.py

@@ -16,6 +16,8 @@
 import os
 from contextlib import contextmanager
 
+from evadb.executor.executor_utils import ExecutorError
+
 
 def _get_database_handler(engine: str, **kwargs):
     """
@@ -48,10 +50,10 @@ def _get_database_handler(engine: str, **kwargs):
 def get_database_handler(engine: str, **kwargs):
     handler = _get_database_handler(engine, **kwargs)
     try:
-        handler.connect()
+        resp = handler.connect()
+        if not resp.status:
+            raise ExecutorError(f"Cannot establish connection due to {resp.error}")
         yield handler
-    except Exception as e:
-        raise Exception(f"Error connecting to the database: {str(e)}")
     finally:
         handler.disconnect()
 

test/third_party_tests/test_native_executor.py

@@ -38,7 +38,7 @@ def _create_table_in_native_database(self):
             """USE test_data_source {
                 CREATE TABLE test_table (
                     name VARCHAR(10),
-                    Age INT,
+                    age INT,
                     comment VARCHAR (100)
                 )
             }""",
@@ -49,7 +49,7 @@ def _insert_value_into_native_database(self, col1, col2, col3):
             self.evadb,
             f"""USE test_data_source {{
                 INSERT INTO test_table (
-                    name, Age, comment
+                    name, age, comment
                 ) VALUES (
                     '{col1}', {col2}, '{col3}'
                 )
@@ -67,7 +67,7 @@ def _drop_table_in_native_database(self):
     def _create_evadb_table_using_select_query(self):
         execute_query_fetch_all(
             self.evadb,
-            """CREATE TABLE eva_table AS SELECT name, Age FROM test_data_source.test_table;""",
+            """CREATE TABLE eva_table AS SELECT name, age FROM test_data_source.test_table;""",
         )
 
         # check if the create table is successful