From a08fd5f98b726dee011d3520b80da72e2ebd5744 Mon Sep 17 00:00:00 2001
From: Gabriel Amaral <gabrieldutraamaral@gmail.com>
Date: Thu, 30 Nov 2023 20:15:30 -0300
Subject: [PATCH] '-'

---
 main.py | 20 +++++++++++++++++++-
 sql.py  | 11 ++++-------
 2 files changed, 23 insertions(+), 8 deletions(-)

diff --git a/main.py b/main.py
index dfd548c..c86e894 100644
--- a/main.py
+++ b/main.py
@@ -3,6 +3,7 @@ import os
 from table import Table
 from sql import SQL
 import mysql.connector
+from mysql.connector import Error
 
 def main():
     print("Bem-vindo!")
@@ -40,7 +41,24 @@ def main():
             print()
 
     elif escolha == "BD":
-        print("BD")
+        try:
+            connection = mysql.connector.connect(host='localhost',
+                                         database='employees',
+                                         user='employeesdb',
+                                         password='Employees1!')
+            
+            if connection.is_connected():
+                print("Conectado ao employees-db")
+                cursor = connection.cursor()
+
+        except Error as e:
+            print("Error while connecting to MySQL", e)
+        finally:
+            if connection.is_connected():
+                cursor.close()
+                connection.close()
+                print("MySQL connection is closed")
+
     else:
         print("Fora do intervalo!")
 
diff --git a/sql.py b/sql.py
index 1ba7528..5bce18c 100644
--- a/sql.py
+++ b/sql.py
@@ -1,13 +1,8 @@
-from table import Table
-
 class SQL:
     def __init__(self, tables: dict, query: str) -> None:
         self.tables = tables
         self.query = query.replace(";", "")
 
-    def __str__(self) -> str:
-        pass
-
     # ISCOLHE * DE tabela
     def execute(self):
         query_parts = self.query.split(" ")
@@ -17,7 +12,8 @@ class SQL:
         else:
             pass
 
-    # ISCOLHE * DE tabela AJUNTAR tabela2 coluna DONDE coluna = valor
+    # ISCOLHE * DE tabela AJUNTAR tabela2 EM coluna;
+    # ISCOLHE * DE tabela DONDE coluna = valor;
     def select(self, query_parts: list) -> None:
         where_filter = None
         join_stmt = None
@@ -25,7 +21,8 @@ class SQL:
         if "AJUNTAR" in query_parts:
             index = query_parts.index("AJUNTAR")
             join_table = query_parts[index + 1]
-            join_column = query_parts[index + 2]
+            join_operator = query_parts[index + 2] # EM -> estetico
+            join_column = query_parts[index + 3]
             join_stmt = [self.tables[join_table], join_column]
 
         if "DONDE" in query_parts: