Update app.py

app.py

@@ -154,19 +154,21 @@ def import_sql_dump_to_sqlite(db_path: str, sql_text: str) -> None:
     """
     Convertidor avanzado MySQL → SQLite.
     Limpia, reordena y ejecuta el schema de forma segura en SQLite.
+    Si al final no se crea ninguna tabla, lanza ValueError.
     """
 
     # ======================================================
     # 1) Limpieza inicial del dump
     # ======================================================
 
-    # Remover comentarios estilo MySQL
+    # Remover comentarios estilo MySQL/PostgreSQL
     sql_text = re.sub(r"/\*![\s\S]*?\*/;", "", sql_text)
     sql_text = re.sub(r"/\*[\s\S]*?\*/", "", sql_text)
     sql_text = re.sub(r"--.*?\n", "", sql_text)
 
-    # Remover `DELIMITER` (no existe en SQLite)
+    # Remover DELIMITER y statements SET típicos
     sql_text = re.sub(r"DELIMITER\s+.+", "", sql_text)
+    sql_text = re.sub(r"SET\s+[^;]+;", "", sql_text)
 
     # Quitar ENGINE, ROW_FORMAT, AUTO_INCREMENT
     sql_text = re.sub(r"ENGINE=\w+", "", sql_text)
@@ -178,7 +180,11 @@ def import_sql_dump_to_sqlite(db_path: str, sql_text: str) -> None:
     sql_text = re.sub(r"CHARACTER SET \w+", "", sql_text)
     sql_text = re.sub(r"COLLATE \w+", "", sql_text)
 
-    # Reemplazar backticks por comillas
+    # Quitar dominios y tipos personalizados (PostgreSQL)
+    sql_text = re.sub(r"CREATE\s+DOMAIN[\s\S]+?;", "", sql_text, flags=re.IGNORECASE)
+    sql_text = re.sub(r"CREATE\s+TYPE[\s\S]+?;", "", sql_text, flags=re.IGNORECASE)
+
+    # Reemplazar backticks por nada (MySQL → SQLite)
     sql_text = sql_text.replace("`", "")
 
     # ======================================================
@@ -279,8 +285,21 @@ def import_sql_dump_to_sqlite(db_path: str, sql_text: str) -> None:
 
     cur.execute("PRAGMA foreign_keys = ON;")
     conn.commit()
+
+    # ======================================================
+    # 6) Validar que realmente se crearon tablas
+    # ======================================================
+    cur.execute("SELECT COUNT(*) FROM sqlite_master WHERE type='table';")
+    n_tables = cur.fetchone()[0]
     conn.close()
 
+    if n_tables == 0:
+        raise ValueError(
+            "No se creó ninguna tabla desde el dump SQL. "
+            "Probablemente es un dump de otro motor (por ejemplo PostgreSQL) "
+            "o usa sintaxis no compatible con SQLite."
+        )
+
 
 def extract_table_name(create_stmt: str) -> str:
     m = re.search(r"CREATE TABLE\s+(\w+)", create_stmt, re.IGNORECASE)
@@ -754,7 +773,7 @@ async def upload_database(db_file: UploadFile = File(...)):
     Subida universal de BD.
     El usuario puede subir:
       - .sqlite / .db → se usa tal cual
-      - .sql → dump MySQL/PostgreSQL/SQLite → se importa a SQLite
+      - .sql → dump MySQL/SQLite (best effort → convertido a SQLite)
       - .csv → se crea una BD SQLite y una tabla
       - .zip → puede contener .sqlite/.db, .sql o .csv (se detecta automáticamente)
     """
@@ -782,8 +801,28 @@ async def upload_database(db_file: UploadFile = File(...)):
         conn_id = create_empty_sqlite_db(label=filename)
         db_path = DB_REGISTRY[conn_id]["db_path"]
         sql_text = contents.decode("utf-8", errors="ignore")
-        import_sql_dump_to_sqlite(db_path, sql_text)
-        note = "SQL dump imported into SQLite (best effort)."
+
+        try:
+            import_sql_dump_to_sqlite(db_path, sql_text)
+            note = "SQL dump imported into SQLite (best effort)."
+        except Exception as e:
+            # Limpiar registro porque la BD quedó inútil
+            try:
+                if os.path.exists(db_path):
+                    os.remove(db_path)
+            except Exception:
+                pass
+            DB_REGISTRY.pop(conn_id, None)
+
+            raise HTTPException(
+                status_code=400,
+                detail=(
+                    "No se pudo convertir este archivo .sql a una base de datos SQLite utilizable. "
+                    "Es probable que sea un dump de otro motor (por ejemplo PostgreSQL) "
+                    "o que contenga sintaxis avanzada no compatible con SQLite.\n"
+                    f"Detalle técnico: {e}"
+                ),
+            )
 
     # Caso 3: CSV simple
     elif fname_lower.endswith(".csv"):
@@ -832,8 +871,27 @@ async def upload_database(db_file: UploadFile = File(...)):
                                 parts.append(f.read().decode("utf-8", errors="ignore"))
                         sql_text = "\n\n".join(parts)
 
-                    import_sql_dump_to_sqlite(db_path, sql_text)
-                    note = "SQL dump(s) from ZIP imported into SQLite."
+                    try:
+                        import_sql_dump_to_sqlite(db_path, sql_text)
+                        note = "SQL dump(s) from ZIP imported into SQLite."
+                    except Exception as e:
+                        try:
+                            if os.path.exists(db_path):
+                                os.remove(db_path)
+                        except Exception:
+                            pass
+                        DB_REGISTRY.pop(conn_id, None)
+
+                        raise HTTPException(
+                            status_code=400,
+                            detail=(
+                                "No se pudo convertir los archivos .sql dentro del ZIP "
+                                "a una base de datos SQLite utilizable. "
+                                "Es probable que sean dumps de otro motor (por ejemplo PostgreSQL) "
+                                "o que contengan sintaxis avanzada no compatible con SQLite.\n"
+                                f"Detalle técnico: {e}"
+                            ),
+                        )
 
                 # 4.3: solo CSVs
                 elif csv_names: