postgres integration

docs/postgres_setup.md

@@ -0,0 +1,25 @@
+## INSTRUCTIONS TO SET UP POSTGRES DATABASE
+
+These were the steps followed on a Mac system to install postgres and configure it:
+
+1. Install postgres
+   ``` brew install postgresql```
+2. Start PostgresSQL:
+```brew services start postgressql```
+3. Create a user and database: 
+
+   Username: evadb
+
+   Password: password
+
+   - ```psql postgres``` 
+   - ```CREATE ROLE evadb WITH LOGIN PASSWORD 'password';```
+   - ```ALTER ROLE evadb CREATEDB;```
+   - ```\q```
+4. Login as your new user
+
+    ``` psql -d postgres -U evadb```
+5. create the database evadb
+
+    ```CREATE DATABASE evadb;```
+6. ```pip install psycopg2```

evadb/catalog/sql_config.py

@@ -71,11 +71,14 @@ def __init__(self, uri):
         # set echo=True to log SQL
 
         # Default to SQLite.
-        connect_args = {"timeout": 1000}
-        self.engine = create_engine(
-            self.worker_uri,
-            connect_args=connect_args,
-        )
+        # connect_args = {"timeout": 1000}
+        # self.engine = create_engine(
+        #     self.worker_uri,
+        #     connect_args=connect_args,
+        # )
+
+        # Postgres version
+        self.engine = create_engine(self.worker_uri)
 
         if self.engine.url.get_backend_name() == "sqlite":
             # enforce foreign key constraint and wal logging for sqlite

evadb/database.py

@@ -41,10 +41,23 @@ def catalog(self) -> "CatalogManager":
         return self.catalog_func(self.catalog_uri)
 
 
-def get_default_db_uri(evadb_dir: Path):
+def get_default_db_uri_sqlite(evadb_dir: Path):
     # Default to sqlite.
     return f"sqlite:///{evadb_dir.resolve()}/{DB_DEFAULT_NAME}"
 
+def get_default_db_uri(evadb_dir: Path):
+    """
+        Generates a PostgreSQL connection URI for the local database.
+
+        Returns:
+        str: A PostgreSQL connection URI.
+        """
+    user = "evadb"
+    password = "password"
+    host = "localhost"
+    port = 5432  # Default PostgreSQL port
+    db_name = "evadb"
+    return f"postgresql://{user}:{password}@{host}:{port}/{db_name}"
 
 def init_evadb_instance(
     db_dir: str, host: str = None, port: int = None, custom_db_uri: str = None