from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker, declarative_base
from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession

from community_qa_bot.settings import DEFAULT_DB_URL, DEFAULT_DB_ASYNC_URL

Base = declarative_base()


engine = create_engine(DEFAULT_DB_URL, pool_pre_ping=True)
Session = sessionmaker(bind=engine, expire_on_commit=False)


async_engine = create_async_engine(DEFAULT_DB_ASYNC_URL, pool_pre_ping=True)
AsyncSession = sessionmaker(bind=async_engine, expire_on_commit=False, class_=AsyncSession)