distinguish errors

core/src/datayoga_core/blocks/relational/write/block.py

@@ -173,16 +173,19 @@ def execute(self, statement: Any, records: List[Dict[str, Any]]):
             statement = text(statement)
 
         logger.debug(f"Executing {statement} on {records}")
+        connected = False
         try:
             with self.engine.connect() as connection:
+                connected = True
                 try:
                     connection.execute(statement, records)
                     if not connection._is_autocommit_isolation():
                         connection.commit()
                 except Exception:
                     raise
         except Exception as e:
-            raise ConnectionError(e) from e
+            if not connected:
+                raise ConnectionError(e) from e
 
     def execute_upsert(self, records: List[Dict[str, Any]]):
         """Upserts records into the table."""