from sqlalchemy.orm import Session

from app.domain.models.course_students import CourseStudent


class CourseStudentsRepository:
    def __init__(self, db: Session):
        self.db = db

    def get_all(self):
        return self.db.query(CourseStudent).all()

    def get_by_id(self, course_student_id: int):
        return self.db.query(CourseStudent).filter(CourseStudent.id == course_student_id).first()

    def create(self, course_student: CourseStudent):
        self.db.add(course_student)
        self.db.commit()
        self.db.refresh(course_student)
        return course_student

    def update(self, course_student: CourseStudent):
        self.db.merge(course_student)
        self.db.commit()
        self.db.refresh(course_student)
        return course_student

    def delete(self, course_student_id: int):
        course_student = self.db.query(CourseStudent).filter(CourseStudent.id == course_student_id).first()
        if course_student:
            self.db.delete(course_student)
            self.db.commit()
            return course_student

        return None