Añadir InsertSelectSQL.py

InsertSelectSQL.py

@@ -0,0 +1,62 @@
+import mysql.connector
+from mysql.connector import Error
+
+def insertar_usuario(nombre, edad):
+    conexion = None
+    try:
+        # Conectar a la base de datos
+        conexion = mysql.connector.connect(
+            host="localhost",     
+            user="thread4",    
+            password="sas",  
+            database="thread4"  # Asegúrate de que el nombre de la base de datos sea correcto
+        )
+        
+        if conexion.is_connected():
+            
+            cursor = conexion.cursor()
+            
+            # Consulta SQL para insertar un registro
+            sql = "INSERT INTO usuarios (nombre, edad) VALUES (%s, %s)"
+            valores = (nombre, edad)
+            print("Hola4")
+            cursor.execute(sql, valores)
+            conexion.commit()  # Guardar los cambios en la base de datos
+            print("Registro insertado con éxito")
+
+    except Error as e:
+        print(f"Error al conectar o insertar en MySQL: {e}")
+    finally:
+        if conexion and conexion.is_connected():
+            cursor.close()
+            conexion.close()
+            print("Conexión cerrada")
+
+
+def obtener_usuarios():
+    conexion = None
+    try:
+        conexion = mysql.connector.connect(
+            host="localhost",
+            user="thread4",
+            password="sas",
+            database="thread4"
+        )
+
+        if(conexion.is_connected()):
+
+            cursor = conexion.cursor()
+
+            sql="Select nombre, edad from usuarios"
+            cursor.execute(sql)
+
+            resultado = cursor.fetchall()
+
+            for fila in resultado:
+                nombre, edad = fila
+                print(f"Nombre : {nombre}, Edad : {edad}")
+    except Error as e:
+        print(f"Error al conectar o consultar en MySQL: {e}")
+
+insertar_usuario("kevin","11")
+obtener_usuarios();