""" SQLAlchemy engine & session factory. """ from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker, DeclarativeBase from app.config import settings connect_args = {} if settings.DATABASE_URL.startswith("sqlite"): connect_args = {"check_same_thread": False} engine = create_engine( settings.DATABASE_URL, connect_args=connect_args, echo=settings.DEBUG, pool_pre_ping=True, ) SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine) class Base(DeclarativeBase): pass def get_db(): db = SessionLocal() try: yield db finally: db.close()