Bases de Datos con SQLAlchemy en Flask

¿Qué es Flask-SQLAlchemy?

Flask-SQLAlchemy es una extensión que simplifica el uso del ORM (Mapeador Relacional de Objetos) SQLAlchemy dentro de aplicaciones Flask. Permite mapear clases de Python a tablas de la base de datos SQL sin escribir SQL manual.

instalar_sqlalchemy.sh

BASH

1pip install flask-sqlalchemy

Conexión a distintas Bases de Datos

La gran ventaja de Flask-SQLAlchemy es que la lógica del modelo no cambia; solo cambia la cadena de conexión SQLALCHEMY_DATABASE_URI en app.config.

SQLite (Local): sqlite:///mi_base.db (ideal para pruebas rápidas).
MySQL: mysql+pymysql://usuario:password@localhost:3306/nombre_bd
Supabase (Postgres): postgresql://postgres.[ref]:[password]@aws-0-[region].pooler.supabase.com:6543/postgres

1. CRUD en Flask con MySQL

Para conectar Flask a un servidor **MySQL**, primero instalamos el driver pymysql:

instalar_mysql.sh

BASH

1pip install flask-sqlalchemy pymysql cryptography

Luego configuramos la URI de conexión y ejecutamos las operaciones CRUD:

flask_mysql_crud.py

PYTHON

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
 
app = Flask(__name__)
 
# Configuración de conexión a MySQL local o servidor remoto
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:secreto123@localhost:3306/tienda_db'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
 
db = SQLAlchemy(app)
 
 
# Modelo de datos en MySQL
class Producto(db.Model):
    __tablename__ = 'productos'
    id = db.Column(db.Integer, primary_key=True)
    nombre = db.Column(db.String(100), nullable=False)
    precio = db.Column(db.Float, nullable=False)
    stock = db.Column(db.Integer, default=0)
 
 
# CRUD Completo en MySQL
def crud_mysql():
    with app.app_context():
        db.create_all()  # Crea la tabla en MySQL si no existe
 
        # --- CREATE ---
        nuevo = Producto(nombre='Laptop Pro 15', precio=1200.00, stock=10)
        db.session.add(nuevo)
        db.session.commit()
 
        # --- READ ---
        productos = Producto.query.all()
        item = Producto.query.filter_by(nombre='Laptop Pro 15').first()
 
        # --- UPDATE ---
        if item:
            item.precio = 1150.00
            db.session.commit()
 
        # --- DELETE ---
        if item:
            db.session.delete(item)
            db.session.commit()

2. CRUD en Flask con Supabase

Supabase es una alternativa Open Source a Firebase basada en PostgreSQL. Puedes conectar Flask a Supabase de dos formas: mediante **SQLAlchemy ORM (PostgreSQL)** o mediante la **Librería Oficial Supabase Python SDK**.

Opción A: Vía Flask-SQLAlchemy (PostgreSQL Connection String)

instalar_postgres.sh

BASH

1pip install flask-sqlalchemy psycopg2-binary

config_supabase_orm.py

PYTHON

# URI de conexión directa a PostgreSQL de Supabase
app.config['SQLALCHEMY_DATABASE_URI'] = 'postgresql://postgres.xxx:tu_password@aws-0-sa-east-1.pooler.supabase.com:6543/postgres'
 
# El código del modelo y las consultas db.session en SQLAlchemy se mantienen idénticos.

Opción B: Vía Supabase Python SDK (Client Directo)

Si deseas interactuar con las APIs automáticas, Row Level Security (RLS) y autenticación de Supabase desde Flask:

instalar_supabase_sdk.sh

BASH

1pip install supabase

flask_supabase_sdk_crud.py

PYTHON

import os
from flask import Flask, jsonify, request
from supabase import create_client, Client
 
app = Flask(__name__)
 
SUPABASE_URL = "https://tu-proyecto.supabase.co"
SUPABASE_KEY = "tu-anon-key-o-service-role-key"
 
supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
 
 
# CRUD con el cliente de Supabase en Flask
@app.route('/api/supabase/productos', methods=['GET'])
def listar_productos_supabase():
    # --- READ ---
    response = supabase.table('productos').select('*').execute()
    return jsonify(response.data)
 
 
@app.route('/api/supabase/productos', methods=['POST'])
def crear_producto_supabase():
    data = request.get_json()
    # --- CREATE ---
    response = supabase.table('productos').insert({
        'nombre': data['nombre'],
        'precio': data['precio'],
        'stock': data.get('stock', 0)
    }).execute()
    return jsonify(response.data), 201
 
 
@app.route('/api/supabase/productos/<int:id>', methods=['PUT'])
def actualizar_producto_supabase(id):
    data = request.get_json()
    # --- UPDATE ---
    response = supabase.table('productos').update({
        'precio': data['precio']
    }).eq('id', id).execute()
    return jsonify(response.data)
 
 
@app.route('/api/supabase/productos/<int:id>', methods=['DELETE'])
def eliminar_producto_supabase(id):
    # --- DELETE ---
    response = supabase.table('productos').delete().eq('id', id).execute()
    return jsonify({'mensaje': 'Eliminado', 'data': response.data})

Ponte a prueba

Verifica si comprendes la integración de bases de datos con SQLAlchemy en Flask.

Contenido

📚 Cursos de Café y Código

5. Bases de Datos con SQLAlchemy

¿Qué es Flask-SQLAlchemy?

Conexión a distintas Bases de Datos

1. CRUD en Flask con MySQL

2. CRUD en Flask con Supabase

Opción A: Vía Flask-SQLAlchemy (PostgreSQL Connection String)

Opción B: Vía Supabase Python SDK (Client Directo)

Ponte a prueba

¡Hecho con mucho cariño! ☕