<?php

namespace model;

use PDO;

/*
 * PDO Database Class
 * Connect to database
 * Create prepared statements
 * Bind Values
 * Return rows and results
 */

include './config/config.php';

class Database
{
    private $host = DB_HOST;
    private $user = DB_USER;
    private $pass = DB_PASS;
    private $databaseName = DB_NAME;

    private $databaseHandler;
    private $statement;
    private $error;
    private $dsn;


    public function __construct()
    {
        // set DSN
        $this->dsn = 'mysql:host=' . $this->host . ';dbname=' . $this->databaseName;
        // TODO : check for more usefull options
        $options = array(
            PDO::ATTR_PERSISTENT => true, // Persistent connection -increase preformance
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // Handle errors
        );

        $this->createNewPDO();
    }

    private function createNewPDO()
    {
        try {
            $this->databaseHandler = new PDO($this->dsn, $this->user, $this->pass);
        } catch (PDOExeption $error) {
            $this->error = $error->getMessage();
            echo $this->error;
        }
    }

    // Prepare statement with query
    public function query($sql)
    {
        $this->statement = $this->databaseHandler->prepare($sql);
    }

    // Bind values & check which type is passed in
    public function bind($param, $value, $type = null)
    {
        if (is_null($type)) {
            switch (true) {
                case is_int($value):
                    $type = PDO::PARAM_INT;
                    break;
                case is_bool($value):
                    $type = PDO::PARAM_BOOL;
                    break;
                case is_null($value):
                    $type = PDO::PARAM_NULL;
                    break;
                default:
                    $type = PDO::PARAM_STR;
            }
        }
        $this->statement->bindValue($param, $value, $type);
    }

    // Execute the prepared statment
    public function execute()
    {
        return $this->statement->execute();
    }

    // Get single record as object
    public function single()
    {
        $this->execute();
        return $this->statement->fetch(PDO::FETCH_OBJ);
    }

    // Get row count
    public function rowCount()
    {
        return $this->statement->rowCount();
    }
}