Update app.py

app.py

@@ -1,79 +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)
+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="0.0.0.0", port=7860)