psycopg3

py_backend/alembic/env.py

@@ -48,7 +48,7 @@ def run_migrations_offline() -> None:
 
 def run_migrations_online() -> None:
     url = _get_db_url()
-    engine = create_engine(url, poolclass=pool.NullPool, future=True)
+    engine = create_engine(url, poolclass=pool.NullPool)
     with engine.connect() as connection:
         context.configure(
             connection=connection,

py_backend/app/database.py

@@ -11,24 +11,25 @@ raw_db_url = settings.DATABASE_URL
 if raw_db_url.startswith("psql '") and raw_db_url.endswith("'"):
     raw_db_url = raw_db_url[6:-1]
 
+# Convert postgresql:// to postgresql+psycopg:// for psycopg v3
+if raw_db_url.startswith("postgresql://") and not raw_db_url.startswith("postgresql+psycopg://"):
+    raw_db_url = raw_db_url.replace("postgresql://", "postgresql+psycopg://")
+
 if "sslmode=" not in raw_db_url and "localhost" not in raw_db_url and "127.0.0.1" not in raw_db_url:
     raw_db_url = f"{raw_db_url}{'&' if '?' in raw_db_url else '?'}sslmode=require"
 
-    print(f"database url: {raw_db_url}")  
+print(f"database url: {raw_db_url}")  
 
 engine = create_engine(
     raw_db_url,            
     pool_pre_ping=True,
     pool_recycle=300,        
-                  
-    future=True,
 )
 
 SessionLocal = sessionmaker(
     autocommit=False,
     autoflush=False,
     bind=engine,
-    future=True,
 )
 
 Base = declarative_base()

py_backend/requirements.txt

@@ -1,8 +1,8 @@
 fastapi
 uvicorn[standard]
 orjson
-sqlalchemy
-alembic
+sqlalchemy>=2.0.0
+alembic>=1.12.0
 psycopg[binary,pool]
 boto3
 python-dotenv