Update app.py

app.py

@@ -1,37 +1,66 @@
-# uvicorn app:app --host localhost --port 7860 --reload
-from library.librerias import *
-from routers.routers import *
-
-app = FastAPI(
-    title="API de la Academia Stephen Hawking",
-    description="Esta es la API de la academia Stephen Hawking, dedicada a la preparación preuniversitaria. Aquí se pueden realizar operaciones CRUD para gestionar estudiantes, profesores, cursos y más.",
-    version="1.0.0",
-    openapi_url="/stephen-hawking-openapi.json",
-    docs_url="/stephen-hawking-docs",
-    redoc_url="/stephen-hawking-redoc",
-    contact={
-        "name": "Academia Stephen Hawking",
-        "url": "https://www.academiashawking.com",
-        "email": "contacto@academiashawking.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 academia Stephen Hawking"}
-
-
-# Routers
-
-app.router.include_router(api.router)
+# uvicorn app:app --host localhost --port 7860 --reload
+from library.librerias import *
+from routers.routers import *
+
+app = FastAPI(
+    title="API de la Academia Stephen Hawking",
+    description="Esta es la API de la academia Stephen Hawking, dedicada a la preparación preuniversitaria. Aquí se pueden realizar operaciones CRUD para gestionar estudiantes, profesores, cursos y más.",
+    version="1.0.0",
+    openapi_url="/stephen-hawking-openapi.json",
+    docs_url="/stephen-hawking-docs",
+    redoc_url="/stephen-hawking-redoc",
+    contact={
+        "name": "Academia Stephen Hawking",
+        "url": "https://www.academiashawking.com",
+        "email": "contacto@academiashawking.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 academia Stephen Hawking"}
+
+# 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/academia.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:
+        # Limpiar la consulta para eliminar '\nObservation' y reemplazar comillas escapadas
+        cleaned_query = sql_query.query.replace("\nObservation", "").replace("\\'", "'")
+        print("Solicitud POST completa:", sql_query.json())
+        print("Consulta recibida en el servidor:", cleaned_query)
+        
+        cursor = conn.cursor()
+        cursor.execute(cleaned_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(api.router)