25 lines
899 B
Python
25 lines
899 B
Python
from sqlalchemy import select
|
|
|
|
from database import new_session, QuestionOrm
|
|
from schemas import SQuestionAdd, SQuestion
|
|
|
|
class QuestionRepository:
|
|
@classmethod
|
|
async def add_one(cls, data: SQuestionAdd) -> int:
|
|
async with new_session() as session:
|
|
question_dict = data.model_dump()
|
|
question = QuestionOrm(**question_dict)
|
|
session.add(question)
|
|
await session.flush()
|
|
await session.commit()
|
|
return question.id
|
|
|
|
@classmethod
|
|
async def find_all(cls) -> list[SQuestion]:
|
|
async with new_session() as session:
|
|
query = select(QuestionOrm)
|
|
result = await session.execute(query)
|
|
question_models = result.scalars().all()
|
|
question_schemas = [SQuestion.model_validate(question_model) for question_model in question_models]
|
|
return question_schemas
|