Update app.py

app.py

@@ -212,7 +212,7 @@ class PostgresManager:
         - Reescribe public./pagila. -> schema_name.
         - Respeta funciones con $$...$$ (no corta por ';' internos).
         - Ignora statements peligrosos via _should_skip_statement().
-        - Ignora bloques CREATE DOMAIN ... multi-línea sin usar regex agresivos.
+        - Ignora bloques CREATE DOMAIN ... multi-línea.
         """
 
         in_copy = False
@@ -223,7 +223,7 @@ class PostgresManager:
         in_dollar = False    # estamos dentro de $$...$$ ?
         dollar_tag = ""      # por ej. "$func$"
 
-        in_domain_block = False  # 👈 estamos dentro de un bloque CREATE DOMAIN ?
+        in_domain_block = False  # estamos dentro de un bloque CREATE DOMAIN ?
 
         def flush_statement():
             nonlocal buffer
@@ -275,40 +275,23 @@ class PostgresManager:
 
             # Detectar inicio de bloque DOMAIN
             if stripped.upper().startswith("CREATE DOMAIN"):
-                # Entramos en bloque DOMAIN y lo ignoramos hasta el ';'
                 in_domain_block = True
                 continue
 
-            # Detectar inicio de COPY
-            if (
-                # Primero reescribimos la línea según el schema
-                line = self._rewrite_line_for_schema(line, schema_name)
-                stripped = line.strip()
-                
-                # SOLO después detectamos COPY
-                if stripped.upper().startswith("COPY ") and "FROM stdin" in stripped.upper():
-                    flush_statement()
-                    in_copy = True
-                    copy_sql = stripped
-                    copy_lines = []
-                    continue
-            ):
-                # Ejecutar lo que haya pendiente antes del COPY
+            # 👉 Primero reescribimos la línea según el schema de sesión
+            line = self._rewrite_line_for_schema(line, schema_name)
+            if not line.strip():
+                continue
+            stripped = line.strip()
+
+            # Detectar inicio de COPY (YA con la línea reescrita)
+            if stripped.upper().startswith("COPY ") and "FROM stdin" in stripped.upper():
                 flush_statement()
                 in_copy = True
-                # Reescribimos también el encabezado COPY
-                copy_sql = (
-                    self._rewrite_line_for_schema(stripped, schema_name)
-                    .strip()
-                )
+                copy_sql = stripped
                 copy_lines = []
                 continue
 
-            # Reescribir la línea según el schema de sesión
-            line = self._rewrite_line_for_schema(line, schema_name)
-            if not line.strip():
-                continue
-
             # Escanear la línea caracter a caracter para detectar $tag$ y ';'
             i = 0
             start_seg = 0
@@ -321,9 +304,7 @@ class PostgresManager:
                 if ch == "$":
                     # ¿Inicio o fin de bloque dollar-quoted?
                     j = i + 1
-                    while j < length and (
-                        line[j].isalnum() or line[j] == "_"
-                    ):
+                    while j < length and (line[j].isalnum() or line[j] == "_"):
                         j += 1
                     if j < length and line[j] == "$":
                         tag = line[i : j + 1]  # incluye ambos '$'