feat: implement database pool

Author: fiqrikm18

.env.example

@@ -2,6 +2,10 @@ APP_NAME=Todo Modulith API
 APP_ENV=production
 
 DATABASE_URL=postgresql+asyncpg://postgres:postgres@127.0.0.1:5432/todo_db
+DATABASE_POOL_SIZE=20
+DATABASE_MAX_OVERFLOW=10
+DATABASE_POOL_TIMEOUT=30
+DATABASE_POOL_RECYCLE=3600
 
 REDIS_URL=redis://:password@127.0.0.1:6379/0
 

src/core/config/setting.py

@@ -53,6 +53,10 @@ class Settings(BaseSettings):
     MAX_REQUEST_SIZE_MB: int = Field(
         alias="MAX_REQUEST_SIZE_MB", default=5 * 1024 * 1024
     )
+    DATABASE_POOL_SIZE: int = Field(alias="DATABASE_POOL_SIZE", default=20)
+    DATABASE_MAX_OVERFLOW: int = Field(alias="DATABASE_MAX_OVERFLOW", default=10)
+    DATABASE_POOL_TIMEOUT: int = Field(alias="DATABASE_POOL_TIMEOUT", default=30)
+    DATABASE_POOL_RECYCLE: int = Field(alias="DATABASE_POOL_RECYCLE", default=3600)
 
     @property
     def is_production(self) -> bool:

src/core/database/postgres/session.py

@@ -2,14 +2,25 @@
 
 from fastapi import Depends
 from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
+from sqlalchemy.pool import QueuePool
 
 from src.core.config.setting import get_settings
 from src.shared.database.unit_of_work import SQLAlchemyUnitOfWork
 from src.shared.unit_of_work import UnitOfWork
 
 settings = get_settings()
 
-engine = create_async_engine(settings.DATABASE_URL, echo=False, future=True)
+engine = create_async_engine(
+    settings.DATABASE_URL,
+    echo=False,
+    future=True,
+    poolclass=QueuePool,
+    pool_size=settings.DATABASE_POOL_SIZE,
+    max_overflow=settings.DATABASE_MAX_OVERFLOW,
+    pool_pre_ping=True,
+    pool_timeout=settings.DATABASE_POOL_TIMEOUT,
+    pool_recycle=settings.DATABASE_POOL_RECYCLE,
+)
 AsyncSessionLocal = async_sessionmaker(
     engine, class_=AsyncSession, expire_on_commit=False, autoflush=False
 )