34 lines
885 B
Python
34 lines
885 B
Python
from sqlalchemy.orm import Session
|
|
|
|
from . import models
|
|
|
|
|
|
def get_sonde(db: Session, identifiant: str):
|
|
q = db.query(models.Sonde)
|
|
q = q.filter(models.Sonde.identifiant == identifiant)
|
|
return q.first()
|
|
|
|
|
|
def create_sonde(db: Session, identifiant: str, nom: str):
|
|
db_sonde = models.Sonde(identifiant=identifiant, nom=nom)
|
|
db.add(db_sonde)
|
|
db.commit()
|
|
db.refresh(db_sonde)
|
|
return db_sonde
|
|
|
|
|
|
def create_mesure(db: Session, sonde_id: int, content: dict):
|
|
db_mesure = models.Mesure(sonde_id=sonde_id, content=content)
|
|
db.add(db_mesure)
|
|
db.commit()
|
|
db.refresh(db_mesure)
|
|
return db_mesure
|
|
|
|
|
|
def get_mesure(db: Session, sonde_id: int, only_last=False):
|
|
q = db.query(models.Mesure).filter(models.Mesure.sonde_id == sonde_id)
|
|
if not only_last:
|
|
return q.all()
|
|
else:
|
|
return [q.all()[-1]] # order by id desc limit 1
|