Skip to content
Snippets Groups Projects
Select Git revision
  • a28bddd9951f8f527ca83b914db67c64a4eec371
  • master default
  • v2.21.0
  • v2.20.1
  • v2.20.0
  • v2.19.0
  • v2.18.1
  • v2.18.0
  • v2.17.0
  • v2.16.0
  • v2.15.0
  • v2.14.0
  • v2.13.1
  • v2.13.0
  • v2.12.0
  • v2.11.0
  • v2.10.0
  • v2.9.0
  • v2.8.0
  • v2.7.0
  • v2.6.0
  • v2.5.0
22 results

Crud.py

Blame
  • Crud.py 1.08 KiB
    from sqlalchemy.orm import Session
    
    from logic.databaseNew import Models, Schemas
    
    
    def get_devices(db: Session, skip: int = 0, limit: int = 100):
        return db.query(Models.Device).offset(skip).limit(limit).all()
    
    
    def get_device(db: Session, deviceId: int):
        return db.query(Models.Device).filter(Models.Device.id == deviceId).first()
    
    
    def get_device_by_name(db: Session, name: str):
        return db.query(Models.Device).filter(Models.Device.name == name).first()
    
    
    def create_device(db: Session, device: Schemas.DeviceCreate):
        dbDevice = Models.Device(name=device.name)
        db.add(dbDevice)
        db.commit()
        db.refresh(dbDevice)
        return dbDevice
    
    
    def delete_device(db: Session, device: Schemas.Device):
        db.delete(device)
        db.commit()
    
    
    def get_sensors(db: Session, skip: int = 0, limit: int = 100):
        return db.query(Models.Sensor).offset(skip).limit(limit).all()
    
    
    def create_sensor(db: Session, item: Schemas.SensorCreate, deviceId: int):
        dbSensor = Models.Sensor(**item.dict(), deviceId=deviceId)
        db.add(dbSensor)
        db.commit()
        db.refresh(dbSensor)
        return dbSensor