"""fichier_model.py — Accès aux données pour l'entité "fichier"."""


def insert(db, nom_original, nom_stocke, mime_type, taille_octets, uploader_sub):
    query = (
        "INSERT INTO fichiers (nom_original, nom_stocke, mime_type, taille_octets, uploader_sub) "
        "VALUES (%s, %s, %s, %s, %s)"
    )
    return db.execute(query, (nom_original, nom_stocke, mime_type, taille_octets, uploader_sub))


def fetch_all(db):
    query = (
        "SELECT id, nom_original, nom_stocke, mime_type, taille_octets, uploader_sub, created_at "
        "FROM fichiers ORDER BY created_at DESC"
    )
    return db.fetch_all(query)


def get(db, fichier_id):
    query = (
        "SELECT id, nom_original, nom_stocke, mime_type, taille_octets, uploader_sub, created_at "
        "FROM fichiers WHERE id = %s"
    )
    return db.fetch_one(query, (fichier_id,))


def delete(db, fichier_id):
    query = "DELETE FROM fichiers WHERE id = %s"
    with db.cursor(commit=True) as cur:
        cur.execute(query, (fichier_id,))
        return cur.rowcount