12 lines
381 B
Python
12 lines
381 B
Python
from sqlalchemy import select
|
|
|
|
from models import Deal
|
|
from repositories.base import BaseRepository
|
|
|
|
|
|
class DealRepository(BaseRepository):
|
|
async def get_all(self, board_id: int) -> list[Deal]:
|
|
stmt = select(Deal).where(Deal.is_deleted.is_(False), Deal.board_id == board_id)
|
|
result = await self.session.execute(stmt)
|
|
return list(result.scalars().all())
|