<?php
/**
 * @Author: printempw
 * @Date:   2016-02-02 21:59:06
 * @Last Modified by:   prpr
 * @Last Modified time: 2016-02-06 23:06:30
 */

class Database
{
    private $connection = null;

    function __construct() {
        $this->connection = self::checkConfig();
    }

    public static function checkConfig() {
        $conn = new mysqli(DB_HOST, DB_USER, DB_PASSWD, DB_NAME);
        if ($conn->connect_error) {
            Utils::raise(-1, "Can not connect to mysql, check if database info correct in config.php. ".
                                $conn->connect_error);
        }
        if (!self::checkTableExist($conn)) {
            Utils::raise(-1, "Looks like that there is no `users` table in your database. ".
                               "Please run `/admin/install.php` first.");
        }
        $dir = dirname(dirname(__FILE__));
        if (!is_dir("$dir/textures/")) {
            Utils::raise(-1, "No `textures` directory exists. Please run `/admin/install.php` ".
                               "or put one manually.");
        }
        return $conn;
    }

    public static function checkTableExist($conn) {
        $sql = "SELECT table_name FROM
                 `INFORMATION_SCHEMA`.`TABLES` WHERE table_name ='users'
                 AND TABLE_SCHEMA='".DB_NAME."'";
        return ($conn->query($sql)->num_rows != 0) ? true : false;
    }

    public function query($sql) {
        $result = $this->connection->query($sql);
        if (!$this->connection->error) {
            return $result;
        }
        Utils::raise(-1, "Database query error: ".$this->connection->error);
    }

    public function fetchArray($sql) {
        return $this->query($sql)->fetch_array();
    }

    public function select($key, $value) {
        return $this->fetchArray("SELECT * FROM users WHERE $key='$value'");
    }

    public function getNumRows($key, $value) {
        $sql = "SELECT * FROM users WHERE $key='$value'";
        return $this->query($sql)->num_rows;
    }

    public function checkRecordExist($key, $value) {
        return ($this->getNumRows($key, $value) != 0) ? true : false;
    }

    public function insert($array) {
        $uname  = $array['uname'];
        $passwd = $array['passwd'];
        $ip = $array['ip'];
        $sql = "INSERT INTO users (username, password, ip, preference)
                             VALUES ('$uname', '$passwd', '$ip', 'default')";
        return $this->query($sql);
    }

    public function update($uname, $key, $value) {
        return $this->query("UPDATE users SET `$key`='$value' WHERE username='$uname'");
    }

    public function delete($uname) {
        return $this->query("DELETE from users WHERE username='$uname'");
    }

}