Database.php

Go to the documentation of this file.

<?php

namespace Combu;

class Database {

    protected $_dbType;
    protected $_dbServer;
    protected $_dbPort;
    protected $_dbName;
    protected $_dbUser;
    protected $_dbPass;

    protected $_connection;

    public function __construct($dbType, $dbServer, $dbPort, $dbName, $dbUser, $dbPass) {
        $this->_dbType = $dbType;
        $this->_dbServer = $dbServer;
        $this->_dbPort = $dbPort;
        $this->_dbName = $dbName;
        $this->_dbUser = $dbUser;
        $this->_dbPass = $dbPass;
        $this->_setConnection();
    }

    public function GetConnection() {
        return $this->_connection;
    }

    protected function _setConnection() {
        $this->_connection = mysqli_connect($this->_dbServer, $this->_dbUser, $this->_dbPass, $this->_dbName);
        if ($this->_connection) {
            $this->_selectDatabase();
        } else {
            $this->_connection = false;
        }
    }

    protected function _selectDatabase() {
        mysqli_select_db($this->_connection, $this->_dbName);
        //$this->Query("SET NAMES 'UTF8'");
    }

    public function CloseConnection() {
        if ($this->_connection) {
            mysqli_close($this->_connection);
            $this->_connection = null;
        }
    }
    
    public function TestConnection() {
        if ($this->_connection) {
            return mysqli_ping($this->_connection);
        }
        return FALSE;
    }

    public function Query($query) {
        if ($this->_connection && $query) {
            return mysqli_query($this->_connection, $query);
        }
        return FALSE;
    }

    public function InsertedId($name = NULL) {
        if ($this->_connection) {
            return mysqli_insert_id($this->_connection);
        }
        return 0;
    }

    public function AffectedRows() {
        return intval(mysqli_affected_rows($this->_connection));
    }
    
    private function _Fetch($result, $result_type) {
        if ($result) {
            return mysqli_fetch_array($result, $result_type);
        }
        return NULL;
    }

    public function FetchAssoc($result) {
        return $this->_Fetch($result, MYSQLI_ASSOC);
    }

    public function FetchNum($result) {
        return $this->_Fetch($result, MYSQLI_NUM);
    }

    public function Escape($text) {
        return mysqli_real_escape_string($this->_connection, $text);
    }

    public function EscapeDate($text) {
        if (!$text || $text == '') {
            return "NULL";
        }
        if (strpos($text, ":") === false) {
            return "'" . date("Y-m-d", Utils::GetTimestamp($text)) . "'";
        }
        return "'" . date("Y-m-d H:i:s", Utils::GetTimestamp($text)) . "'";
    }

    public function RecordExists($query) {
        if ($this->_connection && $query) {
            $res = $this->Query($query);
            $row = $this->FetchAssoc($res);
            if ($row) {
                return TRUE;
            }
        }
        return FALSE;
    }

    public function TransactionStart() {
        if ($this->_connection) {
            return mysqli_begin_transaction($this->_connection);
        }
        return FALSE;
    }

    public function TransactionCommit() {
        if ($this->_connection) {
            return mysqli_commit($this->_connection);
        }
        return FALSE;
    }

    public function TransactionRollback() {
        if ($this->_connection) {
            return mysqli_rollback($this->_connection);
        }
        return false;
    }

    public function GetError() {
        return mysqli_error($this->_connection);
    }

    public function GetErrorNo() {
        return mysqli_errno($this->_connection);
    }

}