Small cleanups.

[Project_webapp.git] / lib / db.php

<?php

/**
 * [CustomDB description]
 */
class CustomDB
{
    private $connection;
    public $connected;
    private $current_pquery;
    private $current_stmt;
    private $current_result;

    /**
     * [__construct description]
     * @param [type] $host     [description]
     * @param [type] $username [description]
     * @param [type] $password [description]
     * @param [type] $dbname   [description]
     */
    public function __construct($host, $username, $password, $dbname)
    {
        $this->connection = new mysqli($host, $username, $password, $dbname);

        if (!$this->connection->connect_errno) {
            $this->connected = true;
        } else {
            die('Fail to connect to the RDBMS.');
        }

        return $this->connection;
    }

    /* public function __destruct()
    {
        $this->close();
    } */

    /**
     * [close description]
     * @return [type] [description]
     */
    public function close()
    {
        if ($this->connected && $this->connection->close()) {
            $this->connected = false;
        } else {
            die('Fail to close the connection to the RDBMS.');
        }
    }

    /**
     * [query description]
     * @param  [type] $sql_query [description]
     * @return [type]            [description]
     */
    public function query($sql_query)
    {
        if ($this->connected && !($this->current_result = $this->connection->query($sql_query))) {
            echo "Fail to execute the SQL query : " . $sql_query . "<br>";
        }
        return $this->current_result;
    }

    /**
     * [prepare_query description]
     * @param  [type] $prepared_query [description]
     * @return [type]                 [description]
     */
    public function prepare_query($prepared_query)
    {
        $this->current_pquery = $prepared_query;
        if ($this->connected && !($this->current_stmt = $this->connection->prepare($this->current_pquery))) {
            // Empty the currently stored prepared query in the failure case
            $this->current_pquery = "";
            echo "Fail to prepare SQL query : (" . $this->connection->errno . ") " . $this->connection->error . " - " . $this->current_pquery . "<br>";
        }
        return $this->current_stmt;
    }

    /**
     * [prepared_query_bind_param description]
     * @param  [type] $params [description]
     * @return [type]         [description]
     */
    public function prepared_query_bind_param($types, $params)
    {
        $rt_val = $this->current_stmt->bind_param($types, ...$params);
        if (!$rt_val) {
            echo "Fail to link parameters to SQL query : (" . $this->current_stmt->errno . ") " . $this->current_stmt->error . " - " . $this->current_pquery . "<br>";
        }
        return $rt_val;
    }

    /**
     * [run_prepared_query description]
     * @return [type] [description]
     */
    public function run_prepared_query()
    {
        $rt_val = $this->current_stmt->execute();
        if (!$rt_val) {
            echo "Fail to execute SQL query : (" . $this->current_stmt->errno . ") " . $this->current_stmt->error . " - " . $this->current_pquery . "<br>";
        }
        return $rt_val;
    }

    public function get_pquery_result()
    {
        $rt_val = $this->current_result = $this->current_stmt->get_result();
        if (!$rt_val) {
            echo "Fail to fill SQL query result : (" . $this->current_stmt->errno . ") " . $this->current_stmt->error . " - " . $this->current_pquery . "<br>";
        }
        return $rt_val;
    }

    public function get_result_array()
    {
        $rt_val = $this->current_result->fetch_array();
        if (!$rt_val) {
            echo "Fail to build SQL query result array : (" . $this->current_stmt->errno . ") " . $this->current_stmt->error . " - " . $this->current_pquery . "<br>";
        }
        return $rt_val;
    }

    /**
     * [close_prepared_query description]
     * @return [type] [description]
     */
    public function close_prepared_query()
    {
        $rt_val = $this->current_stmt->close();
        if (!$rt_val) {
            echo "Fail to close SQL query : (" . $this->current_stmt->errno . ") " . $this->current_stmt->error . " - " . $this->current_pquery . "<br>";
        }
        return $rt_val;
    }
}
?>