From 1e4b895913fd57e1958f527f9f0ab0ea167df4e7 Mon Sep 17 00:00:00 2001 From: Lizandro Guarnizo <77708265+lizandrogd@users.noreply.github.com> Date: Thu, 18 Jun 2026 11:02:56 -0500 Subject: [PATCH] Reorganize queries page: Probador, Constructor with results, Editor tab --- app/routes/queries.py | 554 +++++++++++++----------- app/templates/queries.html | 852 +++++++++++++++++-------------------- 2 files changed, 697 insertions(+), 709 deletions(-) diff --git a/app/routes/queries.py b/app/routes/queries.py index be21ff6..89193a3 100644 --- a/app/routes/queries.py +++ b/app/routes/queries.py @@ -1,220 +1,195 @@ -from fastapi import APIRouter, Request, Form, Depends -from fastapi.responses import RedirectResponse, JSONResponse -from app.database import get_connection -from app.auth import get_current_user -from app.models import QueryCreate - -router = APIRouter(prefix="/queries", tags=["queries"]) - -QUERY_DEFAULTS = [ - { - "name": "Terceros - Datos del paciente", - "query_type": "terceros", - "query_text": """SELECT - p.TIPO_DOCUMENTO as tipo_documento, - p.NUMERO_DOCUMENTO as numero_documento, - p.PRIMER_NOMBRE as primer_nombre, - p.SEGUNDO_NOMBRE as segundo_nombre, - p.PRIMER_APELLIDO as primer_apellido, - p.SEGUNDO_APELLIDO as segundo_apellido, - p.FECHA_NACIMIENTO as fecha_nacimiento, - p.SEXO as cod_sexo, - p.COD_ENTIDAD as cod_entidad, - p.TIPO_USUARIO as tipo_usuario, - p.COD_MUNICIPIO as cod_municipio, - p.ZONA as cod_zona, - p.DIRECCION as direccion -FROM USUAHOS p -WHERE p.NUMERO_DOCUMENTO = :doc_num""", - "description": "Consulta datos maestros del paciente por documento" - }, - { - "name": "Procedimientos por factura", - "query_type": "transaccion", - "query_text": """SELECT - s.CODIGO_CUP as cod_procedimiento, - s.FECHA_ATENCION as fecha_atencion, - s.COD_DIAGNOSTICO as cod_diagnostico, - s.FINALIDAD as finalidad, - s.VIA_INGRESO as via_ingreso, - s.MODALIDAD as modalidad, - s.GRUPO_SERVICIO as grupo_servicio, - s.COD_SERVICIO as cod_servicio, - s.COD_PRESTADOR as cod_prestador, - s.TIPO_DOC_PROFESIONAL as tipo_doc_profesional, - s.NUM_DOC_PROFESIONAL as num_doc_profesional, - s.VR_SERVICIO as vr_servicio, - s.VALOR_PAGO_MODERADOR as valor_pago_moderador, - s.CONCEPTO_RECAUDO as concepto_recaudo, - s.NUM_AUTORIZACION as num_autorizacion -FROM SERVICIOS s -WHERE s.NUM_FACTURA = :factura - AND s.FECHA_ATENCION BETWEEN :fecha_ini AND :fecha_fin""", - "description": "Consulta procedimientos por factura y rango de fechas" - }, - { - "name": "Procedimientos por fecha", - "query_type": "transaccion", - "query_text": """SELECT - s.FACTURA as num_factura, - s.CODIGO_CUP as cod_procedimiento, - s.FECHA_ATENCION as fecha_atencion, - s.COD_DIAGNOSTICO as cod_diagnostico, - s.FINALIDAD as finalidad, - s.VIA_INGRESO as via_ingreso, - s.MODALIDAD as modalidad, - s.GRUPO_SERVICIO as grupo_servicio, - s.COD_SERVICIO as cod_servicio, - s.COD_PRESTADOR as cod_prestador, - s.TIPO_DOC_PROFESIONAL as tipo_doc_profesional, - s.NUM_DOC_PROFESIONAL as num_doc_profesional, - s.VR_SERVICIO as vr_servicio, - p.TIPO_DOCUMENTO as tipo_doc_paciente, - p.NUMERO_DOCUMENTO as num_doc_paciente -FROM SERVICIOS s -JOIN USUAHOS p ON s.COD_PACIENTE = p.COD_PACIENTE -WHERE s.FECHA_ATENCION BETWEEN :fecha_ini AND :fecha_fin""", - "description": "Consulta todos los procedimientos en rango de fechas" - }, -] - - -def ensure_defaults(): - conn = get_connection() - for q in QUERY_DEFAULTS: - exists = conn.execute( - "SELECT id FROM queries WHERE name = ?", (q["name"],) - ).fetchone() - if not exists: - conn.execute( - "INSERT INTO queries (name, query_type, query_text, description) VALUES (?, ?, ?, ?)", - (q["name"], q["query_type"], q["query_text"], q["description"]), - ) - conn.commit() - conn.close() - - -@router.get("") -async def queries_page(request: Request, user: dict = Depends(get_current_user)): - ensure_defaults() - conn = get_connection() - queries = conn.execute("SELECT * FROM queries ORDER BY query_type, name").fetchall() - conn.close() - return request.app.state.templates.TemplateResponse("queries.html", { - "request": request, "user": user, "queries": queries - }) - - -@router.post("/create") -async def query_create( - request: Request, - user: dict = Depends(get_current_user), - name: str = Form(...), - query_type: str = Form(...), - query_text: str = Form(...), - description: str = Form(""), -): - conn = get_connection() - conn.execute( - "INSERT INTO queries (name, query_type, query_text, description) VALUES (?, ?, ?, ?)", - (name, query_type, query_text, description), - ) - conn.commit() - conn.close() - return RedirectResponse("/queries", status_code=302) - - -@router.post("/update/{query_id}") -async def query_update( - query_id: int, - request: Request, - user: dict = Depends(get_current_user), - name: str = Form(...), - query_text: str = Form(...), - description: str = Form(""), -): - conn = get_connection() - conn.execute( - "UPDATE queries SET name = ?, query_text = ?, description = ? WHERE id = ?", - (name, query_text, description, query_id), - ) - conn.commit() - conn.close() - return RedirectResponse("/queries", status_code=302) - - -@router.post("/delete/{query_id}") -async def query_delete(query_id: int, user: dict = Depends(get_current_user)): - conn = get_connection() - conn.execute("DELETE FROM queries WHERE id = ?", (query_id,)) - conn.commit() - conn.close() - return RedirectResponse("/queries", status_code=302) - - -@router.post("/esquema") -async def obtener_esquema(user: dict = Depends(get_current_user)): - from app.services.firebird_service import FirebirdService - conn = get_connection() - configs = {row["key"]: row["value"] for row in conn.execute("SELECT * FROM config").fetchall()} - conn.close() - - fb = FirebirdService() - fb_success, fb_msg = fb.connect( - configs.get("firebird_host", "localhost"), - int(configs.get("firebird_port", 3050)), - configs.get("firebird_database", ""), - configs.get("firebird_user", "SYSDBA"), - configs.get("firebird_password", "masterkey"), - ) - if not fb_success: - return JSONResponse({"error": f"Error Firebird: {fb_msg}"}, status_code=400) - - success, fb_err, tablas = fb.execute_query(""" - SELECT RDB$RELATION_NAME as nombre - FROM RDB$RELATIONS - WHERE RDB$SYSTEM_FLAG = 0 - AND RDB$RELATION_NAME NOT LIKE 'RDB$%' - ORDER BY 1 - """, {}) - - if not success: - fb.disconnect() - return JSONResponse({"error": fb_err}, status_code=400) - - resultado = [] - for t in tablas: - nombre = t["NOMBRE"].strip() - ok, err, cols = fb.execute_query(f""" - SELECT - rf.RDB$FIELD_NAME as COLUMN_NAME, - f.RDB$FIELD_TYPE as FIELD_TYPE, - f.RDB$FIELD_LENGTH as FIELD_LENGTH - FROM RDB$RELATION_FIELDS rf - JOIN RDB$FIELDS f ON rf.RDB$FIELD_SOURCE = f.RDB$FIELD_NAME - WHERE rf.RDB$RELATION_NAME = '{nombre}' - ORDER BY rf.RDB$FIELD_POSITION - """) - columnas = [] - if ok: - for c in cols: - tiponum = c["FIELD_TYPE"] - tipos = {7: "SMALLINT", 8: "INTEGER", 10: "FLOAT", 12: "DATE", 13: "TIME", - 14: "CHAR", 16: "BIGINT", 27: "DOUBLE", 35: "TIMESTAMP", 37: "VARCHAR", - 40: "BLOB", 45: "BLOB_ID", 261: "BLOB"} - columnas.append({ - "nombre": c["COLUMN_NAME"].strip(), - "tipo": tipos.get(tiponum, f"UNKNOWN({tiponum})"), - "longitud": c["FIELD_LENGTH"] - }) - resultado.append({"tabla": nombre, "columnas": columnas}) - - fb.disconnect() - return JSONResponse({"tablas": resultado}) - - -@router.post("/tablas") -async def listar_tablas(user: dict = Depends(get_current_user)): +from fastapi import APIRouter, Request, Form, Depends +from fastapi.responses import RedirectResponse, JSONResponse +from app.database import get_connection +from app.auth import get_current_user +from app.models import QueryCreate + +router = APIRouter(prefix="/queries", tags=["queries"]) + +QUERY_DEFAULTS = [ + { + "name": "Terceros - Datos del paciente", + "query_type": "terceros", + "query_text": """SELECT + p.TIPO_DOCUMENTO as tipo_documento, + p.NUMERO_DOCUMENTO as numero_documento, + p.PRIMER_NOMBRE as primer_nombre, + p.SEGUNDO_NOMBRE as segundo_nombre, + p.PRIMER_APELLIDO as primer_apellido, + p.SEGUNDO_APELLIDO as segundo_apellido, + p.FECHA_NACIMIENTO as fecha_nacimiento, + p.SEXO as cod_sexo, + p.COD_ENTIDAD as cod_entidad, + p.TIPO_USUARIO as tipo_usuario, + p.COD_MUNICIPIO as cod_municipio, + p.ZONA as cod_zona, + p.DIRECCION as direccion +FROM USUAHOS p +WHERE p.NUMERO_DOCUMENTO = :doc_num""", + "description": "Consulta datos maestros del paciente por documento" + }, + { + "name": "Procedimientos por factura", + "query_type": "transaccion", + "query_text": """SELECT + s.CODIGO_CUP as cod_procedimiento, + s.FECHA_ATENCION as fecha_atencion, + s.COD_DIAGNOSTICO as cod_diagnostico, + s.FINALIDAD as finalidad, + s.VIA_INGRESO as via_ingreso, + s.MODALIDAD as modalidad, + s.GRUPO_SERVICIO as grupo_servicio, + s.COD_SERVICIO as cod_servicio, + s.COD_PRESTADOR as cod_prestador, + s.TIPO_DOC_PROFESIONAL as tipo_doc_profesional, + s.NUM_DOC_PROFESIONAL as num_doc_profesional, + s.VR_SERVICIO as vr_servicio, + s.VALOR_PAGO_MODERADOR as valor_pago_moderador, + s.CONCEPTO_RECAUDO as concepto_recaudo, + s.NUM_AUTORIZACION as num_autorizacion +FROM SERVICIOS s +WHERE s.NUM_FACTURA = :factura + AND s.FECHA_ATENCION BETWEEN :fecha_ini AND :fecha_fin""", + "description": "Consulta procedimientos por factura y rango de fechas" + }, + { + "name": "Procedimientos por fecha", + "query_type": "transaccion", + "query_text": """SELECT + s.FACTURA as num_factura, + s.CODIGO_CUP as cod_procedimiento, + s.FECHA_ATENCION as fecha_atencion, + s.COD_DIAGNOSTICO as cod_diagnostico, + s.FINALIDAD as finalidad, + s.VIA_INGRESO as via_ingreso, + s.MODALIDAD as modalidad, + s.GRUPO_SERVICIO as grupo_servicio, + s.COD_SERVICIO as cod_servicio, + s.COD_PRESTADOR as cod_prestador, + s.TIPO_DOC_PROFESIONAL as tipo_doc_profesional, + s.NUM_DOC_PROFESIONAL as num_doc_profesional, + s.VR_SERVICIO as vr_servicio, + p.TIPO_DOCUMENTO as tipo_doc_paciente, + p.NUMERO_DOCUMENTO as num_doc_paciente +FROM SERVICIOS s +JOIN USUAHOS p ON s.COD_PACIENTE = p.COD_PACIENTE +WHERE s.FECHA_ATENCION BETWEEN :fecha_ini AND :fecha_fin""", + "description": "Consulta todos los procedimientos en rango de fechas" + }, +] + + +def ensure_defaults(): + conn = get_connection() + for q in QUERY_DEFAULTS: + exists = conn.execute( + "SELECT id FROM queries WHERE name = ?", (q["name"],) + ).fetchone() + if not exists: + conn.execute( + "INSERT INTO queries (name, query_type, query_text, description) VALUES (?, ?, ?, ?)", + (q["name"], q["query_type"], q["query_text"], q["description"]), + ) + conn.commit() + conn.close() + + +@router.get("") +async def queries_page(request: Request, user: dict = Depends(get_current_user)): + ensure_defaults() + conn = get_connection() + queries = conn.execute("SELECT * FROM queries ORDER BY query_type, name").fetchall() + conn.close() + return request.app.state.templates.TemplateResponse("queries.html", { + "request": request, "user": user, "queries": queries + }) + + +@router.post("/create") +async def query_create( + request: Request, + user: dict = Depends(get_current_user), + name: str = Form(...), + query_type: str = Form(...), + query_text: str = Form(...), + description: str = Form(""), +): + conn = get_connection() + conn.execute( + "INSERT INTO queries (name, query_type, query_text, description) VALUES (?, ?, ?, ?)", + (name, query_type, query_text, description), + ) + conn.commit() + conn.close() + return RedirectResponse("/queries", status_code=302) + + +@router.post("/update/{query_id}") +async def query_update( + query_id: int, + request: Request, + user: dict = Depends(get_current_user), + name: str = Form(...), + query_text: str = Form(...), + description: str = Form(""), +): + conn = get_connection() + conn.execute( + "UPDATE queries SET name = ?, query_text = ?, description = ? WHERE id = ?", + (name, query_text, description, query_id), + ) + conn.commit() + conn.close() + return RedirectResponse("/queries", status_code=302) + + +@router.post("/run-sql") +async def run_sql( + request: Request, + sql: str = Form(...), + user: dict = Depends(get_current_user), +): + from app.services.firebird_service import FirebirdService + conn = get_connection() + configs = {row["key"]: row["value"] for row in conn.execute("SELECT * FROM config").fetchall()} + conn.close() + + fb = FirebirdService() + fb_success, fb_msg = fb.connect( + configs.get("firebird_host", "localhost"), + int(configs.get("firebird_port", 3050)), + configs.get("firebird_database", ""), + configs.get("firebird_user", "SYSDBA"), + configs.get("firebird_password", "masterkey"), + ) + if not fb_success: + return JSONResponse({"error": f"Error Firebird: {fb_msg}"}) + + success, fb_err, rows = fb.execute_query(sql) + fb.disconnect() + + if not success: + return JSONResponse({"error": fb_err}) + + limit = rows[:200] if rows else [] + return JSONResponse({ + "rows": limit, + "total": len(rows), + "columns": list(limit[0].keys()) if limit else [] + }) + + +@router.post("/delete/{query_id}") +async def query_delete(query_id: int, user: dict = Depends(get_current_user)): + conn = get_connection() + conn.execute("DELETE FROM queries WHERE id = ?", (query_id,)) + conn.commit() + conn.close() + return RedirectResponse("/queries", status_code=302) + + +@router.post("/esquema") +async def obtener_esquema(user: dict = Depends(get_current_user)): from app.services.firebird_service import FirebirdService conn = get_connection() configs = {row["key"]: row["value"] for row in conn.execute("SELECT * FROM config").fetchall()} @@ -231,59 +206,120 @@ async def listar_tablas(user: dict = Depends(get_current_user)): if not fb_success: return JSONResponse({"error": f"Error Firebird: {fb_msg}"}, status_code=400) - success, fb_err, rows = fb.execute_query(""" + success, fb_err, tablas = fb.execute_query(""" SELECT RDB$RELATION_NAME as nombre FROM RDB$RELATIONS WHERE RDB$SYSTEM_FLAG = 0 AND RDB$RELATION_NAME NOT LIKE 'RDB$%' ORDER BY 1 """, {}) - fb.disconnect() if not success: + fb.disconnect() return JSONResponse({"error": fb_err}, status_code=400) - return JSONResponse({ - "tablas": [r["NOMBRE"].strip() for r in rows] - }) + resultado = [] + for t in tablas: + nombre = t["NOMBRE"].strip() + ok, err, cols = fb.execute_query(f""" + SELECT + rf.RDB$FIELD_NAME as COLUMN_NAME, + f.RDB$FIELD_TYPE as FIELD_TYPE, + f.RDB$FIELD_LENGTH as FIELD_LENGTH + FROM RDB$RELATION_FIELDS rf + JOIN RDB$FIELDS f ON rf.RDB$FIELD_SOURCE = f.RDB$FIELD_NAME + WHERE rf.RDB$RELATION_NAME = '{nombre}' + ORDER BY rf.RDB$FIELD_POSITION + """) + columnas = [] + if ok: + for c in cols: + tiponum = c["FIELD_TYPE"] + tipos = {7: "SMALLINT", 8: "INTEGER", 10: "FLOAT", 12: "DATE", 13: "TIME", + 14: "CHAR", 16: "BIGINT", 27: "DOUBLE", 35: "TIMESTAMP", 37: "VARCHAR", + 40: "BLOB", 45: "BLOB_ID", 261: "BLOB"} + columnas.append({ + "nombre": c["COLUMN_NAME"].strip(), + "tipo": tipos.get(tiponum, f"UNKNOWN({tiponum})"), + "longitud": c["FIELD_LENGTH"] + }) + resultado.append({"tabla": nombre, "columnas": columnas}) - -@router.post("/test") -async def query_test( - request: Request, - query_id: int = Form(...), - user: dict = Depends(get_current_user), -): - from app.services.firebird_service import FirebirdService - - conn = get_connection() - q = conn.execute("SELECT * FROM queries WHERE id = ?", (query_id,)).fetchone() - configs = {row["key"]: row["value"] for row in conn.execute("SELECT * FROM config").fetchall()} - conn.close() - - if not q: - return JSONResponse({"error": "Consulta no encontrada"}, status_code=404) - - fb = FirebirdService() - fb_success, fb_msg = fb.connect( - configs.get("firebird_host", "localhost"), - int(configs.get("firebird_port", 3050)), - configs.get("firebird_database", ""), - configs.get("firebird_user", "SYSDBA"), - configs.get("firebird_password", "masterkey"), - ) - if not fb_success: - return JSONResponse({"error": f"Error Firebird: {fb_msg}"}, status_code=400) - - success, fb_err, rows = fb.execute_query(q["query_text"], {}) fb.disconnect() + return JSONResponse({"tablas": resultado}) - if not success: - return JSONResponse({"error": fb_err}, status_code=400) - limit = rows[:20] if rows else [] - return JSONResponse({ - "rows": limit, - "total": len(rows), - "columns": list(limit[0].keys()) if limit else [] - }) +@router.post("/tablas") +async def listar_tablas(user: dict = Depends(get_current_user)): + from app.services.firebird_service import FirebirdService + conn = get_connection() + configs = {row["key"]: row["value"] for row in conn.execute("SELECT * FROM config").fetchall()} + conn.close() + + fb = FirebirdService() + fb_success, fb_msg = fb.connect( + configs.get("firebird_host", "localhost"), + int(configs.get("firebird_port", 3050)), + configs.get("firebird_database", ""), + configs.get("firebird_user", "SYSDBA"), + configs.get("firebird_password", "masterkey"), + ) + if not fb_success: + return JSONResponse({"error": f"Error Firebird: {fb_msg}"}, status_code=400) + + success, fb_err, rows = fb.execute_query(""" + SELECT RDB$RELATION_NAME as nombre + FROM RDB$RELATIONS + WHERE RDB$SYSTEM_FLAG = 0 + AND RDB$RELATION_NAME NOT LIKE 'RDB$%' + ORDER BY 1 + """, {}) + fb.disconnect() + + if not success: + return JSONResponse({"error": fb_err}, status_code=400) + + return JSONResponse({ + "tablas": [r["NOMBRE"].strip() for r in rows] + }) + + +@router.post("/test") +async def query_test( + request: Request, + query_id: int = Form(...), + user: dict = Depends(get_current_user), +): + from app.services.firebird_service import FirebirdService + + conn = get_connection() + q = conn.execute("SELECT * FROM queries WHERE id = ?", (query_id,)).fetchone() + configs = {row["key"]: row["value"] for row in conn.execute("SELECT * FROM config").fetchall()} + conn.close() + + if not q: + return JSONResponse({"error": "Consulta no encontrada"}, status_code=404) + + fb = FirebirdService() + fb_success, fb_msg = fb.connect( + configs.get("firebird_host", "localhost"), + int(configs.get("firebird_port", 3050)), + configs.get("firebird_database", ""), + configs.get("firebird_user", "SYSDBA"), + configs.get("firebird_password", "masterkey"), + ) + if not fb_success: + return JSONResponse({"error": f"Error Firebird: {fb_msg}"}, status_code=400) + + success, fb_err, rows = fb.execute_query(q["query_text"], {}) + fb.disconnect() + + if not success: + return JSONResponse({"error": fb_err}, status_code=400) + + limit = rows[:20] if rows else [] + return JSONResponse({ + "rows": limit, + "total": len(rows), + "columns": list(limit[0].keys()) if limit else [] + }) diff --git a/app/templates/queries.html b/app/templates/queries.html index 6cc7236..357feb1 100644 --- a/app/templates/queries.html +++ b/app/templates/queries.html @@ -1,451 +1,403 @@ -{% extends "base.html" %} -{% block title %}Consultas SQL{% endblock %} -{% block header %}Consultas SQL{% endblock %} -{% block content %} - -
- - -
- -
-
-
-
-
-

Mis Consultas

- -
-
- {% for q in queries %} -
-
-
- {{ q.name }} - {{ q.query_type }} -
-

{{ q.description or 'Sin descripción' }}

-
- -
- {% endfor %} -
-
-
- -
-
-
-

Editor SQL

-
-
-
- -
-
- - -
-
- - -
-
-
- - -
-
-
- - -
-
- - -
-
-
-
- -
-

Parámetros disponibles

-

- Usa :doc_num para filtro por documento, - :factura para filtro por factura, - :fecha_ini y :fecha_fin para rango de fechas. -

- - -
-
-
-
- - - - -{% endblock %} + +// ───── PROBADOR ───── +function ejecutarProbador() { + const sql = document.getElementById('probador-sql').value.trim(); + if (!sql) { showToast('Escribí una consulta SQL', 'warning'); return; } + ejecutarSql(sql, 'probador-resultados', 'probador-info'); +} + +function limpiarProbador() { + document.getElementById('probador-sql').value = ''; + document.getElementById('probador-resultados').innerHTML = ''; + document.getElementById('probador-info').innerHTML = ''; +} + +async function ejecutarSql(sql, outputId, infoId) { + const outputDiv = document.getElementById(outputId); + const infoDiv = document.getElementById(infoId); + outputDiv.innerHTML = '
Ejecutando...
'; + if (infoDiv) infoDiv.innerHTML = ''; + try { + const form = new FormData(); + form.append('sql', sql); + const resp = await fetch('/queries/run-sql', { method: 'POST', body: form }); + const data = await resp.json(); + if (data.error) { + outputDiv.innerHTML = `
${data.error}
`; + return; + } + let html = ''; + data.columns.forEach(c => { html += ''; }); + html += ''; + data.rows.slice(0, 200).forEach(r => { + html += ''; + data.columns.forEach(c => { html += ''; }); + html += ''; + }); + html += '
' + c + '
' + (r[c] ?? '') + '
'; + outputDiv.innerHTML = html; + if (infoDiv) infoDiv.innerHTML = `${data.total} registros (mostrando ${Math.min(data.total, 200)})`; + if (data.total > 200) infoDiv.innerHTML += ' - Resultado truncado a 200 filas'; + } catch(e) { + outputDiv.innerHTML = `
Error: ${e.message}
`; + } +} + +// ───── CONSTRUCTOR ───── +async function cargarEsquema() { + const btn = document.querySelector('#panel-constructor .bg-green-600'); + btn.disabled = true; btn.innerHTML = ' Cargando...'; + try { + const resp = await fetch('/queries/esquema', { method: 'POST' }); + const data = await resp.json(); + if (data.error) { showToast(data.error, 'error'); return; } + esquema = data.tablas; + renderizarTablas(); + } catch(e) { showToast('Error: ' + e.message, 'error'); } + finally { btn.disabled = false; btn.innerHTML = ' Cargar esquema'; } +} + +function renderizarTablas() { + const div = document.getElementById('builder-tablas'); + div.innerHTML = ''; + esquema.forEach(t => { + const id = 'tab-' + t.tabla.replace(/[^a-zA-Z0-9]/g, '_'); + const checked = tablasSeleccionadas[t.tabla] ? 'checked' : ''; + const card = document.createElement('div'); + card.className = 'border rounded p-1.5 ' + (checked ? 'border-blue-300 bg-blue-50' : 'border-gray-200 bg-white'); + card.innerHTML = ` + +
${renderizarColumnas(t.tabla, t.columnas)}
`; + div.appendChild(card); + }); + actualizarBuilder(); +} + +function renderizarColumnas(tabla, columnas) { + let html = ''; + columnas.forEach(c => { + const sel = tablasSeleccionadas[tabla]?.columnas?.[c.nombre] ? 'checked' : ''; + html += ``; + }); + return html; +} + +function toggleTabla(tabla, checked) { + if (checked) tablasSeleccionadas[tabla] = { alias: 't' + (++aliasCounter), columnas: {} }; + else delete tablasSeleccionadas[tabla]; + renderizarTablas(); actualizarBuilder(); +} + +function toggleColumna(tabla, columna, checked) { + if (!tablasSeleccionadas[tabla]) return; + if (checked) tablasSeleccionadas[tabla].columnas[columna] = true; + else delete tablasSeleccionadas[tabla].columnas[columna]; + renderizarTablas(); actualizarBuilder(); +} + +function agregarFiltro() { + filtros.push({ campo: '', operador: '=', parametro: '', condicion: 'AND' }); + renderizarFiltros(); actualizarBuilder(); +} + +function renderizarFiltros() { + const div = document.getElementById('builder-where'); + div.innerHTML = ''; + if (!filtros.length) { div.innerHTML = '

Sin filtros

'; return; } + filtros.forEach((f, i) => { + const opts = []; + Object.entries(tablasSeleccionadas).forEach(([t, info]) => { + const tInfo = esquema.find(e => e.tabla === t); + if (tInfo) tInfo.columnas.forEach(c => { + opts.push({ value: `${t}.${c.nombre}`, label: `${info.alias}.${c.nombre}` }); + }); + }); + const row = document.createElement('div'); + row.className = 'flex items-center space-x-1 text-xs'; + row.innerHTML = ` + + + + `; + div.appendChild(row); + if (i < filtros.length - 1) { + const sep = document.createElement('div'); + sep.className = 'ml-1'; + sep.innerHTML = ``; + div.appendChild(sep); + } + }); +} + +function actualizarFiltro(i, prop, val) { + if (!filtros[i]) filtros[i] = { campo: '', operador: '=', parametro: '', condicion: 'AND' }; + filtros[i][prop] = val; + actualizarBuilder(); +} + +function generarSql() { + const tabs = Object.entries(tablasSeleccionadas); + if (!tabs.length) return { sql: '-- Seleccioná al menos una tabla', params: [] }; + const selects = [], froms = [], allParams = new Set(); + tabs.forEach(([tabla, info]) => { + froms.push({ tabla, alias: info.alias }); + Object.keys(info.columnas).forEach(c => selects.push(`${info.alias}.${c}`)); + }); + if (!selects.length) return { sql: '-- Seleccioná al menos una columna', params: [] }; + let sql = 'SELECT\n ' + selects.join(',\n ') + '\nFROM '; + sql += froms.map((f, i) => i === 0 ? `${f.tabla} ${f.alias}` : `JOIN ${f.tabla} ${f.alias} ON 1=1`).join('\n'); + const wheres = []; + filtros.forEach(f => { + if (f.campo && f.parametro) { + const [t, c] = f.campo.split('.'); + const info = tablasSeleccionadas[t]; + if (info) { wheres.push(`${info.alias}.${c} ${f.operador} ${f.parametro}`); if (f.parametro.startsWith(':')) allParams.add(f.parametro); } + } + }); + if (wheres.length) sql += '\nWHERE ' + wheres.join(' '); + sql += '\nROWS 200'; + return { sql, params: Array.from(allParams) }; +} + +function actualizarBuilder() { + const { sql, params } = generarSql(); + document.getElementById('builder-sql').value = sql; + document.getElementById('builder-params').textContent = params.length ? 'Params: ' + params.join(', ') : ''; + + const tabs = Object.entries(tablasSeleccionadas); + const div = document.getElementById('builder-columnas'); + if (!tabs.length) { div.innerHTML = '

Seleccioná una tabla

'; return; } + let html = ''; + tabs.forEach(([tabla, info]) => { + const cols = Object.keys(info.columnas); + if (cols.length) html += `
${info.alias}. ${cols.map(c => `${c}`).join(' ')}
`; + }); + div.innerHTML = html || '

Seleccioná columnas

'; +} + +function ejecutarBuilder() { + const sql = document.getElementById('builder-sql').value; + if (!sql || sql.startsWith('--')) { showToast('No hay SQL generado', 'warning'); return; } + ejecutarSql(sql, 'builder-resultados', null); +} + +function usarSqlEditor() { + const sql = document.getElementById('builder-sql').value; + if (!sql || sql.startsWith('--')) { showToast('No hay SQL generado', 'warning'); return; } + document.getElementById('q_text').value = sql; + document.getElementById('probador-sql').value = sql; + cambiarTab('probador'); + showToast('SQL enviado al Probador'); +} + +// ───── CONSULTAS GUARDADAS ───── +function cargarConsulta(id, name, type, text) { + document.getElementById('query_id').value = id; + document.getElementById('q_name').value = name; + document.getElementById('q_type').value = type; + document.getElementById('q_text').value = text; + document.getElementById('q_desc').value = ''; + document.getElementById('probador-sql').value = text; + document.getElementById('btn-cancel').classList.remove('hidden'); + document.querySelector('#panel-editor form').action = '/queries/update/' + id; + cambiarTab('probador'); +} + +function cancelEdit() { + document.getElementById('query_id').value = ''; + document.getElementById('q_name').value = ''; + document.getElementById('q_text').value = ''; + document.getElementById('q_desc').value = ''; + document.getElementById('btn-cancel').classList.add('hidden'); + document.querySelector('#panel-editor form').action = '/queries/create'; +} + +async function ejecutarConsultaId(id) { + const form = new FormData(); form.append('sql', ''); + const resp = await fetch('/queries/test', { method: 'POST', body: (()=>{const f=new FormData();f.append('query_id',id);return f;})() }); + const data = await resp.json(); + if (data.error) { showToast(data.error, 'error'); return; } + let html = ''; + data.columns.forEach(c => { html += ''; }); + html += ''; + data.rows.slice(0,200).forEach(r => { + html += ''; + data.columns.forEach(c => { html += ''; }); + html += ''; + }); + html += '
' + c + '
' + (r[c] ?? '') + '
'; + const modal = document.createElement('div'); + modal.className = 'fixed inset-0 z-50 flex items-center justify-center bg-black bg-opacity-50'; + modal.innerHTML = '

Resultado

' + html + '

Total: ' + data.total + ' registros (mostrando ' + Math.min(data.total, 200) + ')

'; + document.body.appendChild(modal); +} + +{% endblock %}