Classe DATABASE

                               

                            
/*---------------------------------------------------------------*/
/*
    Titre : Classe DATABASE                                                                                               
                                                                                                                          
    URL   : https://phpsources.net/code_s.php?id=142
    Auteur           : Eric Potvin                                                                                        
    Date édition     : 27 Sept 2005                                                                                      
    Date mise a jour : 15 Fev 2026
                                                                                       
    Rapport de la maj:                                                                                                    
    - amélioration du code                                                                                             
    - fonctionnement du code vérifié                                                                                
    - refactoring du code en PHP 8                                                                                        
*/
/*---------------------------------------------------------------*/

declare(strict_types=1);

class Database
{
    private ?PDO $connection = null;
    private ?PDOStatement $statement = null;
    private int $rowCount = 0;
    private string $lastError = '';
    private int $lastErrorCode = 0;

    /**
     * Constructeur avec promoted properties
     */
    public function __construct(
        private readonly string $host = 'localhost',
        private readonly string $user = 'web',
        private readonly string $password = 'web',
        private readonly string $database = 'database',
        private readonly string $charset = 'utf8mb4',
        private readonly int $port = 3306
    ) {
        $this->connect();
    }

    /**
     * Établit la connexion à la base de données
     */
    private function connect(): void
    {
        // Validation : empêcher l'accès à la base système MySQL
        if (strtolower($this->database) === 'mysql') {
            throw new InvalidArgumentException(
                
"Connexion à la base de données système 'mysql' refusée pour des raisons" .
" de sécurité"
            );
        }

        try {
            $dsn = sprintf(
                'mysql:host=%s;port=%d;dbname=%s;charset=%s',
                $this->host,
                $this->port,
                $this->database,
                $this->charset
            );

            $options = [
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                PDO::ATTR_EMULATE_PREPARES => false,
                PDO::ATTR_PERSISTENT => false,
                PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES {$this->charset}"
            ];

            $this->connection = new PDO($dsn, $this->user, $this->password, 
$options);

        } catch (PDOException $e) {
            $this->lastErrorCode = (int) $e->getCode();
            $this->lastError = $e->getMessage();
            
            throw new RuntimeException(
                "Erreur de connexion à la base de données: " . $e->getMessage(
),
                (int) $e->getCode(),
                $e
            );
        }
    }

    /**
     * Exécute une requête SQL simple (sans paramètres)
     * 
     * @deprecated Utilisez queryPrepared() pour plus de sécurité
     */
    public function query(string $sql): array|false
    {
        if (empty($sql)) {
            return false;
        }

        try {
            $this->statement = $this->connection->query($sql);
            $this->rowCount = $this->statement->rowCount();
            
            return $this->statement->fetchAll();

        } catch (PDOException $e) {
            $this->lastErrorCode = (int) $e->getCode();
            $this->lastError = $e->getMessage();
            return false;
        }
    }

    /**
     * Exécute une requête préparée (RECOMMANDÉ)
     * 
     * @param array<string, mixed> $params Paramètres de la requête
     */
    public function queryPrepared(string $sql, array $params = []): array|false
    {
        if (empty($sql)) {
            return false;
        }

        try {
            $this->statement = $this->connection->prepare($sql);
            $this->statement->execute($params);
            $this->rowCount = $this->statement->rowCount();
            
            return $this->statement->fetchAll();

        } catch (PDOException $e) {
            $this->lastErrorCode = (int) $e->getCode();
            $this->lastError = $e->getMessage();
            return false;
        }
    }

    /**
     * Exécute une requête INSERT/UPDATE/DELETE
     * 
     * @param array<string, mixed> $params
     */
    public function execute(string $sql, array $params = []): bool
    {
        try {
            $this->statement = $this->connection->prepare($sql);
            $result = $this->statement->execute($params);
            $this->rowCount = $this->statement->rowCount();
            
            return $result;

        } catch (PDOException $e) {
            $this->lastErrorCode = (int) $e->getCode();
            $this->lastError = $e->getMessage();
            return false;
        }
    }

    /**
     * Échappe une chaîne pour utilisation SQL
     * 
     * @deprecated Utilisez les requêtes préparées à la place
     */
    public function getEscaped(string $text): string
    {
        // Retire les guillemets ajoutés par PDO::quote()
        return trim($this->connection->quote($text), "'");
    }

    /**
     * Retourne le dernier ID inséré
     */
    public function getLastId(): int
    {
        return (int) $this->connection->lastInsertId();
    }

    /**
     * Retourne le nombre de lignes affectées
     */
    public function getNumRows(): int
    {
        return $this->rowCount;
    }

    /**
     * Retourne le code d'erreur
     */
    public function getErrorNum(): int
    {
        return $this->lastErrorCode;
    }

    /**
     * Retourne le message d'erreur
     */
    public function getErrorMsg(): string
    {
        return $this->lastError;
    }

    /**
     * Retourne la version de MySQL
     */
    public function getVersion(): string
    {
        return $this->connection->getAttribute(PDO::ATTR_SERVER_VERSION);
    }

    /**
     * Ferme la connexion
     */
    public function close(): void
    {
        $this->statement = null;
        $this->connection = null;
    }

    /**
     * Démarre une transaction
     */
    public function beginTransaction(): bool
    {
        return $this->connection->beginTransaction();
    }

    /**
     * Valide une transaction
     */
    public function commit(): bool
    {
        return $this->connection->commit();
    }

    /**
     * Annule une transaction
     */
    public function rollback(): bool
    {
        return $this->connection->rollBack();
    }

    /**
     * Vérifie si une transaction est active
     */
    public function inTransaction(): bool
    {
        return $this->connection->inTransaction();
    }

    /**
     * Retourne la connexion PDO pour usage avancé
     */
    public function getConnection(): PDO
    {
        return $this->connection;
    }

    /**
     * Destructeur : ferme automatiquement la connexion
     */
    public function __destruct()
    {
        $this->close();
    }
}
?>