Python habla con
la base de datos

pip install mysql-connector-python

import mysql.connector
from mysql.connector import Error

CREATE DATABASE tienda;
USE tienda;

CREATE TABLE productos (
    id     INT AUTO_INCREMENT PRIMARY KEY,
    nombre VARCHAR(100) NOT NULL,
    precio DECIMAL(10,2) NOT NULL
);

INSERT INTO productos (nombre, precio) VALUES
    ('Remera negra', 25000),
    ('Buzo gris',    48000),
    ('Gorra',        12000);

import mysql.connector

conexion = mysql.connector.connect(
    host="localhost",
    port=3306,
    user="root",
    password="",
    database="tienda"
)

print(conexion)
conexion.close()

import mysql.connector
from mysql.connector import Error

try:
    conexion = mysql.connector.connect(
        host="localhost",
        user="root",
        password="",
        database="tienda"
    )
    print("Conexión exitosa")
    conexion.close()

except Error as e:
    print(f"Error de conexión: {e}")

cursor = conexion.cursor()

cursor.execute("SELECT * FROM productos")

resultados = cursor.fetchall()

print(resultados)

cursor.close()
conexion.close()

[(1, 'Remera negra', Decimal('25000.00')),
 (2, 'Buzo gris',    Decimal('48000.00')),
 (3, 'Gorra',        Decimal('12000.00'))]

for fila in resultados:
    print(fila[1], "-> $", fila[2])

Nombre a buscar:  ' OR '1'='1

cursor.execute("SELECT id, nombre, precio FROM productos")
productos = cursor.fetchall()

cursor.execute(
    "INSERT INTO productos (nombre, precio) VALUES (%s, %s)",
    (nombre, precio)
)

conexion.commit()

cursor.execute(
    "UPDATE productos SET precio = %s WHERE id = %s",
    (precio, id_producto)
)

conexion.commit()

cursor.execute(
    "DELETE FROM productos WHERE id = %s",
    (id_producto,)
)

conexion.commit()

def ver_productos():
    conexion = mysql.connector.connect(host="localhost", user="root", password="", database="tienda")
    cursor = conexion.cursor()
    cursor.execute("SELECT * FROM productos")
    datos = cursor.fetchall()
    cursor.close()
    conexion.close()
    return datos

def agregar_producto(nombre, precio):
    conexion = mysql.connector.connect(host="localhost", user="root", password="", database="tienda")
    cursor = conexion.cursor()
    cursor.execute("INSERT INTO productos (nombre, precio) VALUES (%s, %s)", (nombre, precio))
    conexion.commit()
    cursor.close()
    conexion.close()

def borrar_producto(id_producto):
    conexion = mysql.connector.connect(host="localhost", user="root", password="", database="tienda")
    cursor = conexion.cursor()
    cursor.execute("DELETE FROM productos WHERE id = %s", (id_producto,))
    conexion.commit()
    cursor.close()
    conexion.close()

class BasededatosControlador:
    pass

import mysql.connector
from mysql.connector import Error


class BasededatosControlador:

    def connect():
        try:
            return mysql.connector.connect(
                host="localhost",
                port=3306,
                database="tienda",
                user="root",
                password=""
            )
        except Error as e:
            print(f"Error de conexión: {e}")
            return None

    @staticmethod
    def ejecutar_query(query, params=None, fetchone=False, commit=False):
        connection = BasededatosControlador.connect()

        if connection:
            try:
                with connection.cursor() as cursor:
                    cursor.execute(query, params)

                    if commit:
                        connection.commit()
                        return True

                    return cursor.fetchone() if fetchone else cursor.fetchall()

            except Error as e:
                print(f"Error en la consulta: {e}")

            finally:
                connection.close()

        return None if fetchone else []

    @staticmethod
    def traer_productos():
        query = "SELECT id, nombre, precio FROM productos"
        return BasededatosControlador.ejecutar_query(query)

    @staticmethod
    def buscar_producto(nombre):
        query = """
            SELECT id, nombre, precio
            FROM productos
            WHERE nombre = %s
        """
        return BasededatosControlador.ejecutar_query(
            query,
            (nombre,),
            fetchone=True
        )

    @staticmethod
    def agregar_producto(nombre, precio):
        query = "INSERT INTO productos (nombre, precio) VALUES (%s, %s)"
        return BasededatosControlador.ejecutar_query(
            query,
            (nombre, precio),
            commit=True
        )

password="123456"

import os

usuario  = os.getenv("DB_USER")
password = os.getenv("DB_PASSWORD")

host = os.getenv("DB_HOST", "localhost")
port = int(os.getenv("DB_PORT", "3306"))

DB_HOST=localhost
DB_PORT=3306
DB_NAME=tienda
DB_USER=root
DB_PASSWORD=mi_clave_secreta

import os
import mysql.connector
from mysql.connector import Error
from dotenv import load_dotenv

load_dotenv()


class BasededatosControlador:

    @staticmethod
    def connect():
        try:
            return mysql.connector.connect(
                host=os.getenv('DB_HOST', 'localhost'),
                port=int(os.getenv('DB_PORT', '3306')),
                database=os.getenv('DB_NAME', 'tienda'),
                user=os.getenv('DB_USER', 'root'),
                password=os.getenv('DB_PASSWORD', '')
            )
        except Error as e:
            print(f"Error de conexión: {e}")
            return None

===== PRODUCTOS =====

1. Ver productos
2. Buscar producto
3. Agregar producto
4. Modificar producto
5. Eliminar producto
6. Salir

Opción: _

from base_de_datos import BasededatosControlador


def mostrar_menu():
    print("\n===== PRODUCTOS =====")
    print("1. Ver productos")
    print("2. Buscar producto")
    print("3. Agregar producto")
    print("4. Modificar producto")
    print("5. Eliminar producto")
    print("6. Salir")


def ver_productos():
    productos = BasededatosControlador.traer_productos()

    if not productos:
        print("No hay productos cargados.")
        return

    for id_p, nombre, precio in productos:
        print(f"[{id_p}] {nombre} — ${precio}")


def agregar_producto():
    nombre = input("Nombre: ")
    precio = input("Precio: ")

    if BasededatosControlador.agregar_producto(nombre, precio):
        print("Producto agregado.")
    else:
        print("No se pudo agregar.")


# TODO: buscar_producto(), modificar_producto(), eliminar_producto()


while True:
    mostrar_menu()
    opcion = input("\nOpción: ")

    if opcion == "1":
        ver_productos()
    elif opcion == "3":
        agregar_producto()
    elif opcion == "6":
        print("Hasta luego.")
        break
    else:
        print("Opción inválida.")

   Buscar producto

Nombre: [ gorra________ ]

        [  BUSCAR  ]

        ↓

   Gorra
   $12.000