Upload 3 files

Dockerfile

@@ -0,0 +1,15 @@
+# Usa una imagen base de Python
+FROM python:3.9
+# Establece el directorio de trabajo
+WORKDIR /code
+
+# Copia los archivos necesarios al contenedor
+COPY ./requirements.txt /code/requirements.txt
+RUN pip install --no-cache-dir -r /code/requirements.txt
+
+COPY . .
+
+RUN chmod -R 777 /code
+
+# Comando para ejecutar la aplicación
+CMD ["python", "app.py"]

app.py

@@ -0,0 +1,79 @@
+from pydantic import BaseModel
+from fastapi import FastAPI, HTTPException, Depends
+from fastapi.middleware.cors import CORSMiddleware
+from sqlalchemy import create_engine, text
+from sqlalchemy.orm import sessionmaker, declarative_base
+import uvicorn
+import os
+from dotenv import load_dotenv
+
+load_dotenv()  # Carga las variables de entorno desde el archivo .env
+
+DATABASE_URL = os.getenv("DB_URI")
+
+# Configurar SQLAlchemy
+engine = create_engine(DATABASE_URL)
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+Base = declarative_base()
+
+# CORS
+app = FastAPI()
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+
+# Modelo para recibir consultas SQL
+class SQLQuery(BaseModel):
+    query: str
+
+
+# Dependencia para obtener la sesión de la base de datos
+def get_db():
+    db = SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()
+
+
+@app.post(
+    "/execute",
+    summary="Ejecutar consulta SQL",
+    description="Ejecuta una consulta SQL en la base de datos MySQL",
+)
+def execute_query(sql_query: SQLQuery, db=Depends(get_db)):
+    try:
+        result = db.execute(text(sql_query.query))
+        if result.returns_rows:
+            rows = result.fetchall()
+            columns = result.keys()
+            results = [dict(zip(columns, row)) for row in rows]
+            return {"results": results}
+        db.commit()
+        return {"message": "Consulta ejecutada exitosamente"}
+    except Exception as e:
+        db.rollback()
+        raise HTTPException(status_code=400, detail=str(e))
+
+
+@app.get(
+    "/list_tables",
+    summary="Listar todas las tablas",
+    description="Lista todas las tablas de la base de datos",
+)
+def list_tables(db=Depends(get_db)):
+    try:
+        result = db.execute(text("SHOW TABLES;"))
+        tables = [row[0] for row in result.fetchall()]
+        return {"tables": tables}
+    except Exception as e:
+        raise HTTPException(status_code=400, detail=str(e))
+
+
+if __name__ == "__main__":
+    uvicorn.run(app, host="localhost", port=7860)

requirements.txt

@@ -0,0 +1,5 @@
+fastapi
+uvicorn
+python-dotenv
+mysqlclient
+sqlalchemy