Update app.py

app.py

@@ -1,52 +1,80 @@
-# uvicorn app:app --host localhost --port 7860 --reload
-from library.librerias import *
-from routers.routers import *
-
-
-app = FastAPI(
-    title="API de la heladería Anhelados",
-    description="Esta es la API de la microempresa Anhelados, la cual se dedica a la venta de helados y postres. Aquí se pueden realizar operaciones CRUD para los recursos de la empresa.",
-    version="2.8.7",
-    openapi_url="/anhelados-openapi.json",
-    docs_url="/anhelados-docs",
-    redoc_url="/anhelados-redoc",
-    contact={
-        "name": "Anhelados",
-        "url": "https://www.anhelados.com",
-        "email": "contacto@anhelados.com",
-    },
-    license_info={"name": "MIT", "url": "https://opensource.org/licenses/MIT"},
-)
-
-# CORS
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-
-# saludo
-@app.get("/", summary="Saludo", description="Saludo de la API")
-def read_root():
-    return {"message": "Bienvenido a la API de la heladeria"}
-
-
-# Routers
-
-app.router.include_router(almacen.router)
-app.router.include_router(clientes.router)
-app.router.include_router(detalle_pedidos.router)
-app.router.include_router(detalle_ventas.router)
-app.router.include_router(empleados.router)
-app.router.include_router(gastos_imprevistos.router)
-app.router.include_router(gastos.router)
-app.router.include_router(insumos.router)
-app.router.include_router(maquinas.router)
-app.router.include_router(pedidos_proveedor.router)
-app.router.include_router(produccion.router)
-app.router.include_router(productos.router)
-app.router.include_router(registro_energetico.router)
-app.router.include_router(ventas.router)
+# uvicorn app:app --host localhost --port 7860 --reload
+from library.librerias import *
+from routers.routers import *
+from pydantic import BaseModel
+import sqlite3
+
+app = FastAPI(
+    title="API de la heladería Anhelados",
+    description="Esta es la API de la microempresa Anhelados, la cual se dedica a la venta de helados y postres. Aquí se pueden realizar operaciones CRUD para los recursos de la empresa.",
+    version="2.8.7",
+    openapi_url="/anhelados-openapi.json",
+    docs_url="/anhelados-docs",
+    redoc_url="/anhelados-redoc",
+    contact={
+        "name": "Anhelados",
+        "url": "https://www.anhelados.com",
+        "email": "contacto@anhelados.com",
+    },
+    license_info={"name": "MIT", "url": "https://opensource.org/licenses/MIT"},
+)
+
+# CORS
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+
+# saludo
+@app.get("/", summary="Saludo", description="Saludo de la API")
+def read_root():
+    return {"message": "Bienvenido a la API de la heladeria"}
+
+# Modelo para recibir consultas SQL
+class SQLQuery(BaseModel):
+    query: str
+
+# Conexión a la base de datos SQLite
+def get_db_connection():
+    conn = sqlite3.connect('database/anhelados.db')
+    conn.row_factory = sqlite3.Row
+    return conn
+
+@app.post("/execute", summary="Ejecutar consulta SQL", description="Ejecuta una consulta SQL en la base de datos SQLite")
+def execute_query(sql_query: SQLQuery):
+    conn = get_db_connection()
+    try:
+        cursor = conn.cursor()
+        cursor.execute(sql_query.query)
+        conn.commit()
+        if cursor.description:  # Verifica si la consulta tiene resultados
+            results = cursor.fetchall()
+            return {"results": [dict(row) for row in results]}
+        return {"message": "Consulta ejecutada exitosamente"}
+    except sqlite3.Error as e:
+        raise HTTPException(status_code=400, detail=str(e))
+    finally:
+        conn.close()
+
+# Routers
+
+app.router.include_router(almacen.router)
+app.router.include_router(clientes.router)
+app.router.include_router(detalle_pedidos.router)
+app.router.include_router(detalle_ventas.router)
+app.router.include_router(empleados.router)
+app.router.include_router(gastos_imprevistos.router)
+app.router.include_router(gastos.router)
+app.router.include_router(insumos.router)
+app.router.include_router(maquinas.router)
+app.router.include_router(pedidos_proveedor.router)
+app.router.include_router(produccion.router)
+app.router.include_router(productos.router)
+app.router.include_router(registro_energetico.router)
+app.router.include_router(ventas.router)
+
+