mv2

app.py

@@ -355,6 +355,22 @@ def extract_sql_query(text):
 
     return None
 
+def sanitize_sql_query_text(query: str) -> str:
+    """Normalize LLM-produced SQL text to be executable by MariaDB/MySQL.
+
+    - Converts literal escape sequences ("\\n", "\\t") to spaces
+    - Collapses excessive whitespace
+    - Strips surrounding code block backticks if any
+    """
+    if not isinstance(query, str):
+        return query
+    q = query.strip().strip('`')
+    # Replace escaped newlines/tabs that sometimes appear in model outputs
+    q = q.replace("\\n", " ").replace("\\t", " ")
+    # Collapse whitespace to single spaces
+    q = re.sub(r"\s+", " ", q)
+    return q
+
 def execute_sql_query(query, db_connection):
     """Ejecuta una consulta SQL y devuelve los resultados como una cadena."""
     if not db_connection:
@@ -364,7 +380,7 @@ def execute_sql_query(query, db_connection):
         with db_connection._engine.connect() as connection:
             # Ensure SQLAlchemy receives a SQL expression
             if sa_text is not None and isinstance(query, str):
-                result = connection.execute(sa_text(query))
+                result = connection.execute(sa_text(sanitize_sql_query_text(query)))
             else:
                 result = connection.execute(query)
             rows = result.fetchall()
@@ -545,7 +561,7 @@ async def stream_agent_response(question: str, chat_history: List[List[str]]) ->
                 logger.info(f"Detected SQL query: {sql_query}")
                 db_connection, _ = setup_database_connection()
                 if db_connection:
-                    query_result = execute_sql_query(sql_query, db_connection)
+                    query_result = execute_sql_query(sanitize_sql_query_text(sql_query), db_connection)
                     
                     # Add the query and its result to the response
                     response_text += f"\n\n### 🔍 Resultado de la consulta:\n```sql\n{sql_query}\n```\n\n{query_result}"
@@ -632,7 +648,7 @@ async def stream_agent_response(question: str, chat_history: List[List[str]]) ->
                             logger.info(f"Second pass SQL detected: {sql_query2}")
                             db_connection, _ = setup_database_connection()
                             if db_connection:
-                                query_result = execute_sql_query(sql_query2, db_connection)
+                                query_result = execute_sql_query(sanitize_sql_query_text(sql_query2), db_connection)
                                 # Append query and result to response_text for transparency
                                 response_text += f"\n\n### 🔍 Resultado de la consulta (2ª pasada):\n```sql\n{sql_query2}\n```\n\n{query_result}"
                                 # Try robust markdown table parse