from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker, DeclarativeBase from .core.config import settings class Base(DeclarativeBase): pass engine = create_engine(settings.DATABASE_URL, connect_args={"check_same_thread": False} if settings.DATABASE_URL.startswith("sqlite") else {}) SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine) def get_db(): db = SessionLocal() try: yield db finally: db.close()