mv2

app.py

@@ -393,13 +393,46 @@ def execute_sql_query(query, db_connection):
             if len(rows) == 1 and len(rows[0]) == 1:
                 return str(rows[0][0])
                 
-            # Si hay múltiples filas, formatear como tabla
+            # Si hay múltiples filas, formatear como tabla markdown robusta
             try:
-                import pandas as pd
-                df = pd.DataFrame(rows)
-                return df.to_markdown(index=False)
-            except ImportError:
-                # Si pandas no está disponible, usar formato simple
+                # Prefer row mapping if available
+                headers = []
+                try:
+                    headers = list(rows[0]._mapping.keys())  # SQLAlchemy 2.x
+                except Exception:
+                    try:
+                        headers = list(result.keys())  # Fallback
+                    except Exception:
+                        # As last resort, numeric headers
+                        headers = [str(i) for i in range(len(rows[0]))]
+
+                # Build markdown
+                lines = []
+                header_line = "| " + " | ".join(headers) + " |"
+                sep_line = "|" + "|".join([" --- " for _ in headers]) + "|"
+                lines.append(header_line)
+                lines.append(sep_line)
+                for r in rows:
+                    try:
+                        mapping = dict(getattr(r, "_mapping", {}))
+                    except Exception:
+                        mapping = {}
+                    values = []
+                    for h in headers:
+                        if mapping:
+                            v = mapping.get(h, "")
+                        else:
+                            # Tuple-style row
+                            idx = headers.index(h)
+                            try:
+                                v = r[idx]
+                            except Exception:
+                                v = ""
+                        values.append(str(v))
+                    lines.append("| " + " | ".join(values) + " |")
+                return "\n".join(lines)
+            except Exception:
+                # Formato simple si algo falla
                 return "\n".join([str(row) for row in rows])
                 
     except Exception as e:
@@ -677,6 +710,31 @@ async def stream_agent_response(question: str, chat_history: List[List[str]]) ->
                                         if chart_fig is not None:
                                             logger.info("Chart generated from second-pass SQL execution (markdown parse).")
                                             chart_state = {"data": data_list, "x_col": x_col, "y_col": y_col, "title": f"{y_col} por {x_col}", "chart_type": desired_type}
+                                else:
+                                    # If no table, try parsing tuple-like rows shown as lines: ('LABEL', N)
+                                    tuple_lines = [l.strip() for l in str(query_result).split('\n') if l.strip()]
+                                    parsed = []
+                                    for l in tuple_lines:
+                                        m = re.match(r"^\(\'?\s*([^',]+?)\s*\'?,\s*(\d+(?:\.\d+)?)\)$", l)
+                                        if m:
+                                            label = m.group(1).strip()
+                                            try:
+                                                value = float(m.group(2))
+                                            except Exception:
+                                                continue
+                                            parsed.append({"label": label, "value": value})
+                                    if len(parsed) >= 2:
+                                        desired_type = 'pie' if any(k in q_lower for k in ["gráfico circular", "grafico circular", "pie", "pastel"]) else 'bar'
+                                        chart_fig = generate_chart(
+                                            data=parsed,
+                                            chart_type=desired_type,
+                                            x="label",
+                                            y="value",
+                                            title="Distribución"
+                                        )
+                                        if chart_fig is not None:
+                                            logger.info("Chart generated from tuple-like SQL output parse.")
+                                            chart_state = {"data": parsed, "x_col": "label", "y_col": "value", "title": "Distribución", "chart_type": desired_type}
                             else:
                                 logger.info("No DB connection on second pass; skipping.")
                     except Exception as e: