src/loaders/database.py

# from env import config

# from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession, async_sessionmaker
# print(config)
# database_url = f"mysql+aiomysql://{config['db']['user']}:{config['db']['password']}@{config['db']['host']}:{config['db']['port']}/{config['db']['database']}"
# engine = create_async_engine(
#     database_url,
#     pool_size=config['db']['pool_size'],
#     max_overflow=0,
#     pool_recycle=3600,
#     echo=False,
#     future=True,
# )
# SessionLocal = async_sessionmaker(
#     engine, 
#     expire_on_commit=False, 
#     class_=AsyncSession
# )

# def get_db():
#     db = SessionLocal()
#     try:
#         yield db
#     finally:
#         db.close()