62 lines
1.8 KiB
Python
62 lines
1.8 KiB
Python
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(); |