added logs + get_session as session

Author: MaxNumerique

src/opengeodeweb_microservice/database/connection.py

@@ -16,14 +16,19 @@ def init_database(db_path: str = DATABASE_FILENAME) -> None:
 
     if engine is None:
         engine = create_engine(
-            f"sqlite:///{db_path}", connect_args={"check_same_thread": False}
+            f"sqlite:///{db_path}",
+            connect_args={"check_same_thread": False},
         )
+        print(f"Database engine created for {db_path}", flush=True)
         session_factory = sessionmaker(bind=engine)
         scoped_session_registry = scoped_session(session_factory)
         Base.metadata.create_all(engine)
+        print(f"Database engine created DONE for {db_path}")
+    else:
+        print(f"Database engine already exists for {db_path}, reusing", flush=True)
 
 
 def get_session() -> scoped_session[Session]:
     if scoped_session_registry is None:
         raise RuntimeError()
-    return scoped_session_registry
+    return scoped_session_registry()

tests/conftest.py

@@ -30,11 +30,12 @@ def _cleanup_database(db_path: str):
 
 @pytest.fixture(autouse=True)
 def clean_database():
-    session = get_session()
-    session.query(Data).delete()
-    session.commit()
-    yield
-    try:
-        session.rollback()
-    except Exception:
-        pass
+    with get_session() as session:
+        session = get_session()
+        session.query(Data).delete()
+        session.commit()
+        yield
+        try:
+            session.rollback()
+        except Exception:
+            pass