Revert "mv2"

This reverts commit 926fb907f79cc2c960cb8f0597255501680e3603.

app.py

@@ -355,22 +355,6 @@ 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:
@@ -380,7 +364,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(sanitize_sql_query_text(query)))
+                result = connection.execute(sa_text(query))
             else:
                 result = connection.execute(query)
             rows = result.fetchall()
@@ -561,7 +545,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(sanitize_sql_query_text(sql_query), db_connection)
+                    query_result = execute_sql_query(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}"
@@ -648,7 +632,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(sanitize_sql_query_text(sql_query2), db_connection)
+                                query_result = execute_sql_query(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