<?php
include "config.php";


/**
 * @return mysqli
 */


function getConnection()
{
    $connection = mysqli_connect(HOST, USER, PASSWORD, DB);
    if (false === $connection) {
        die('Erreur de connexion (' . mysqli_connect_errno() . ') '
            . mysqli_connect_error());
    }
    return $connection;
}


/**
 * @param mysqli $connection
 * @param string $sql
 * @return bool|mysqli_result
 */


function execSql($connection, $sql)
{
    $results = mysqli_query($connection, $sql);
    if (false === $results) {
        die('Erreur de requête (' . mysqli_errno($connection) . ') '
            . mysqli_error($connection));
    }
    return $results;
}


/**
 * @param mysqli $connection
 * @param string $table
 * @return bool|mysqli_result
 */


function getAllRows($connection, $table)
{
    $sql = "select * from $table";
    return execSql($connection, $sql);
}


/**
 * @param mysqli $connection
 * @param string $table
 * @param array $fields
 * @return bool|mysqli_result
 */


function insertRow($connection, $table, $fields)
{
    $titre      = $fields["titre"];
    $contenu    = $fields["contenu"];
    $auteur     = $fields["auteur"];

    $sql = "insert into $table values (null, '$titre', '$contenu', '$auteur')";
    return execSql($connection, $sql);
}


/**
 * @param mysqli $connection
 * @param string $table
 * @param int $id
 * @return array|null
 */


function getRow($connection, $table, $id)
{
    $sql = "select * from $table where id=$id";
    $result = execSql($connection, $sql);
    return mysqli_fetch_assoc($result);

}

/**
 * @param mysqli $connection
 * @param string $table
 * @param array $fields
 * @return bool|mysqli_result
 */

function updateRow($connection, $table, $fields)
{

    $titre      = $fields["titre"];
    $contenu    = $fields["contenu"];
    $auteur     = $fields["auteur"];
    $id         = $fields["id"];

    $sql = "update $table set titre='$titre',
                              contenu='$contenu',
                              auteur='$auteur'
                          where id=$id";
    return execSql($connection, $sql);
}