Upload app.py

app.py

@@ -1,4 +1,4 @@
-from fastapi import FastAPI, HTTPException
+from fastapi import FastAPI, HTTPException, Request
 from pydantic import BaseModel
 from transformers import pipeline
 import mysql.connector 
@@ -67,12 +67,20 @@ def get_database_schema():
 def home():
     return {"message": "SQL Generation Server is running"}
 
-@app.post("/query")
-def handle_query(request: QueryRequest):
+@app.api_route("/query", methods=["GET", "POST"])
+async def handle_query(request: Request):
     try:
-        print("Received query:", request.query)  # Debugging: Print the received query
-        text = request.query
+        if request.method == "POST":
+            request_data = await request.json()
+            text = request_data.get("query", "")
+        elif request.method == "GET":
+            text = request.query_params.get("query", "")
         
+        print("Received query:", text)  # Debugging: Print the received query
+
+        if not text:
+            raise ValueError("No query provided.")
+
         # Fetch the database schema
         schema = get_database_schema()
         schema_str = json.dumps(schema, indent=4)
@@ -85,19 +93,19 @@ def handle_query(request: QueryRequest):
         {schema_str}
          When creating your answers, consider the following:
 
-    1. If a query involves a column or value that is not present in the provided database schema, correct it and mention the correction in the summary. If a column or value is missing, provide an explanation of the issue and adjust the query accordingly.
-    2. If there is a spelling mistake in the column name or value, attempt to correct it by matching the closest possible column or value from the schema. Mention this correction in the summary to clarify any changes made.
-    3. Ensure that the correct columns and values are used based on the schema provided. Verify the query against the schema to confirm accuracy.
-    4. Include column name headers in the query results for clarity.
+        1. If a query involves a column or value that is not present in the provided database schema, correct it and mention the correction in the summary. If a column or value is missing, provide an explanation of the issue and adjust the query accordingly.
+        2. If there is a spelling mistake in the column name or value, attempt to correct it by matching the closest possible column or value from the schema. Mention this correction in the summary to clarify any changes made.
+        3. Ensure that the correct columns and values are used based on the schema provided. Verify the query against the schema to confirm accuracy.
+        4. Include column name headers in the query results for clarity.
 
-    Always provide your answer in the JSON format below:
+        Always provide your answer in the JSON format below:
 
-    {{ "summary": "your-summary", "query":  "your-query" }}
-    
-    Output ONLY JSON.
-    In the preceding JSON response, substitute "your-query" with a MariaDB query to retrieve the requested data.
-    In the preceding JSON response, substitute "your-summary" with a summary of the query and any corrections or clarifications made.
-    Always include all columns in the table.
+        {{ "summary": "your-summary", "query":  "your-query" }}
+        
+        Output ONLY JSON.
+        In the preceding JSON response, substitute "your-query" with a MariaDB query to retrieve the requested data.
+        In the preceding JSON response, substitute "your-summary" with a summary of the query and any corrections or clarifications made.
+        Always include all columns in the table.
         """
 
         prompt = f"{system_message}\n\nUser request:\n\n{text}\n\nSQL query:"
@@ -123,7 +131,6 @@ def handle_query(request: QueryRequest):
         print("Error occurred:", str(e))  # Debugging: Print the error
         raise HTTPException(status_code=500, detail=str(e))
 
-
 if __name__ == "__main__":
     import uvicorn
     uvicorn.run(app, host="0.0.0.0", port=7860)