from sqlalchemy.orm import Session
from app.models import House

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

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

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

    def create(self, house: House):
        self.db.add(house)
        self.db.commit()
        self.db.refresh(house)
        return house

    def update(self, house: House):
        self.db.merge(house)
        self.db.commit()
        return house

    def delete(self, house_id: int):
        house = self.db.query(House).filter(House.id == house_id).first()
        if house:
            self.db.delete(house)
            self.db.commit()
        return house