""" Database configuration and session management """ from sqlalchemy import create_engine from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import sessionmaker from .config import get_settings settings = get_settings() # Create database engine # Handle SQLite vs PostgreSQL if settings.database_url.startswith("sqlite"): engine = create_engine( settings.database_url, connect_args={"check_same_thread": False} ) else: engine = create_engine( settings.database_url, pool_pre_ping=True, pool_size=10, max_overflow=20 ) # Session factory SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine) # Base class for models Base = declarative_base() def get_db(): """Dependency to get database session""" db = SessionLocal() try: yield db finally: db.close() def init_db(): """Initialize database tables""" Base.metadata.create_all(bind=engine)