add _ensure_tables_exists back until postgres integration tests compl…

…eted

pyiceberg/catalog/sql.py

@@ -33,7 +33,7 @@
     union,
     update,
 )
-from sqlalchemy.exc import IntegrityError, NoResultFound
+from sqlalchemy.exc import IntegrityError, NoResultFound, OperationalError, ProgrammingError
 from sqlalchemy.orm import (
     DeclarativeBase,
     Mapped,
@@ -129,8 +129,20 @@ def __init__(self, name: str, **properties: str):
         self.engine = create_engine(uri_prop, echo=echo, pool_pre_ping=pool_pre_ping)
 
         if init_catalog_tables:
-            # Only creates tables that do not exist
-            self.create_tables()
+            self._ensure_tables_exist()
+
+    def _ensure_tables_exist(self) -> None:
+        with Session(self.engine) as session:
+            for table in [IcebergTables, IcebergNamespaceProperties]:
+                stmt = select(1).select_from(table)
+                try:
+                    session.scalar(stmt)
+                except (
+                    OperationalError,
+                    ProgrammingError,
+                ):  # sqlalchemy returns OperationalError in case of sqlite and ProgrammingError with postgres.
+                    self.create_tables()
+                    return
 
     def create_tables(self) -> None:
         SqlCatalogBaseTable.metadata.create_all(self.engine)