db uses async operations

app/core/database.py

@@ -1,15 +1,19 @@
 import os
 
 from dotenv import load_dotenv
-from sqlalchemy import create_engine
+from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy.orm import sessionmaker
 
 load_dotenv(override=True)
 
+ASYNC_POSTGRES_URL = os.getenv("POSTGRES_SERVER").replace(
+    "postgresql://", "postgresql+asyncpg://"
+)
+
 # Create engine with connection pooling and best practices
-engine = create_engine(
-    os.getenv("POSTGRES_SERVER"),
+engine = create_async_engine(
+    ASYNC_POSTGRES_URL,
     pool_size=10,  # Initial number of connections in the pool
     max_overflow=10,  # Maximum number of connections beyond pool_size
     pool_timeout=30,  # Timeout in seconds for getting a connection from the pool
@@ -19,15 +23,15 @@
 )
 
 # Create session factory
-SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+AsyncSessionLocal = sessionmaker(engine, class_=AsyncSession, expire_on_commit=False, autocommit=False, autoflush=False, bind=engine)
 
 # Base class for all ORM models
 Base = declarative_base()
 
 
 # Dependency to be used in routes
-def get_db():
-    db = SessionLocal()
+async def get_db():
+    db = AsyncSessionLocal()
     try:
         yield db
     finally: