album.dao.php

Aller à la documentation de ce fichier.

<?php
class AlbumDAO
{
    private ?PDO $pdo;
 
    public function __construct(?PDO $pdo = null)
    {
        $this->pdo = $pdo;
    }
 
    public function findAll(): array
    {
        $sql = "SELECT * FROM album";
        $pdoStatement = $this->pdo->prepare($sql);
        $pdoStatement->execute();
        $pdoStatement->setFetchMode(PDO::FETCH_ASSOC);
        $tableau = $pdoStatement->fetchAll();
        $album = $this->hydrateMany($tableau);
        return $album;
    }
 
    public function rechercher(string $term): array
    {
        $sql = "SELECT a.*, u.pseudoUtilisateur, 
                   (SELECT SUM(nbEcouteChanson) FROM chanson WHERE albumChanson = a.idAlbum) as totalEcoutes
            FROM album a
            JOIN utilisateur u ON a.artisteAlbum = u.emailUtilisateur
            WHERE a.nomAlbum LIKE :term
            ORDER BY totalEcoutes DESC 
            LIMIT 3"; 
            
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute([':term' => '%' . $term . '%']);
    
        $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
        $albums = [];
        foreach ($results as $row) {
            $album = $this->hydrate($row);
            if (isset($row['pseudoUtilisateur'])) {
                $album->setPseudoArtiste($row['pseudoUtilisateur']);
            }
            $albums[] = $album;
        }
        return $albums;
    }
 
    public function find(int $id): ?Album 
    {
        $sql = "SELECT a.*, u.pseudoUtilisateur 
                FROM album a
                JOIN utilisateur u ON a.artisteAlbum = u.emailUtilisateur
                WHERE a.idAlbum = :id";
        $pdoStatement = $this->pdo->prepare($sql);
        $pdoStatement->execute([':id' => $id]);
 
        $pdoStatement->setFetchMode(PDO::FETCH_ASSOC);
        $tableau = $pdoStatement->fetch();
        
        if (!$tableau) {
            return null;
        }
 
        $album = $this->hydrate($tableau);
        if (isset($tableau['pseudoUtilisateur'])) {
            $album->setPseudoArtiste($tableau['pseudoUtilisateur']);
        }
        return $album;
    }
 
    public function findByArtiste(string $artistePseudo): array
    {
        $sql = "SELECT a.* FROM album a
                JOIN utilisateur u ON a.artisteAlbum = u.emailUtilisateur -- CORRECTION : Jointure sur l'email
                WHERE u.pseudoUtilisateur = :artistePseudo 
                ORDER BY a.dateSortieAlbum DESC";
        $pdoStatement = $this->pdo->prepare($sql);
        $pdoStatement->execute([':artistePseudo' => $artistePseudo]);
        $pdoStatement->setFetchMode(PDO::FETCH_ASSOC);
        $tableau = $pdoStatement->fetchAll();
        $albums = $this->hydrateMany($tableau);
        return $albums;
    }
 
    public function findAllByArtistEmail(string $email): array
    {
        $sql = "SELECT a.* FROM album a
                JOIN utilisateur u ON a.artisteAlbum = u.emailUtilisateur -- CORRECTION : Jointure sur l'email (était sur u.pseudoUtilisateur)
                WHERE u.emailUtilisateur = :email
                ORDER BY a.dateSortieAlbum DESC";
        $pdoStatement = $this->pdo->prepare($sql);
        $pdoStatement->execute([':email' => $email]);
        $pdoStatement->setFetchMode(PDO::FETCH_ASSOC);
        $tableau = $pdoStatement->fetchAll();
        $albums = $this->hydrateMany($tableau);
        return $albums;
    }
 
    public function create(Album $album): int
    {
        $sql = "INSERT INTO album (nomAlbum, dateSortieAlbum, urlPochetteAlbum, artisteAlbum) VALUES (:nomAlbum, :dateSortie, :pochette, :artiste)";
        $pdoStatement = $this->pdo->prepare($sql);
        $pdoStatement->execute([
            ':nomAlbum' => $album->getTitreAlbum(),
            ':dateSortie' => $album->getDateSortieAlbum(),
            ':pochette' => $album->geturlPochetteAlbum(),
            ':artiste' => $album->getArtisteAlbum()
        ]);
 
        return (int)$this->pdo->lastInsertId();
    }
 
    public function hydrate(array $tableaAssoc): Album
    {
        $album = new Album();
        $album->setIdAlbum(isset($tableaAssoc['idAlbum']) ? (int)$tableaAssoc['idAlbum'] : null);
        $album->setTitreAlbum($tableaAssoc['nomAlbum'] ?? null);
        $album->setDateSortieAlbum($tableaAssoc['dateSortieAlbum'] ?? null);
        $album->seturlPochetteAlbum($tableaAssoc['urlPochetteAlbum'] ?? null);
        $album->setArtisteAlbum($tableaAssoc['artisteAlbum'] ?? null);
        return $album;
    }
 
    public function hydrateMany(array $tableauxAssoc): array
    {
        $albums = [];
        foreach ($tableauxAssoc as $tableauAssoc) {
            $albums[] = $this->hydrate($tableauAssoc);
        }
        return $albums;
    }
 
    public function findMostListened(int $limit = 8): array
    {
        // Cette requête calcule la somme des écoutes de toutes les chansons d'un album
        // pour déterminer la popularité de cet album.
        $sql = "SELECT 
                    a.*,
                    u.pseudoUtilisateur,
                    SUM(c.nbEcouteChanson) as totalEcoutes
                FROM album a
                JOIN chanson c ON a.idAlbum = c.albumChanson
                JOIN utilisateur u ON a.artisteAlbum = u.emailUtilisateur -- CORRECTION : Jointure sur l'email (était sur u.pseudoUtilisateur)
                GROUP BY a.idAlbum
                ORDER BY totalEcoutes DESC
                LIMIT :limit";
 
        try {
            $stmt = $this->pdo->prepare($sql);
            $stmt->bindValue(':limit', $limit, PDO::PARAM_INT);
            $stmt->execute();
 
            $results = $stmt->fetchAll(PDO::FETCH_ASSOC);
            $albums = [];
 
            foreach ($results as $row) {
                $album = $this->hydrate($row);
                // Le setter setPseudoArtiste doit exister dans votre classe Album
                $album->setPseudoArtiste($row['pseudoUtilisateur']);
                $albums[] = $album;
            }
            return $albums;
        } catch (PDOException $e) {
            error_log('Erreur DAO lors de la récupération des albums les plus écoutés : ' . $e->getMessage());
            return [];
        }
    }
 
 
    public function getPdo(): ?PDO
    {
        return $this->pdo;
    }
 
    public function setPdo(?PDO $pdo): void
    {
        $this->pdo = $pdo;
    }
}