Pasted

/*@Author: quocvuongdn
*@Twitter: quocvuongdn
*@Site: quocvuongdn.com
*/
 
class DBmysqli{
    protected $db_name = '';
    protected $db_user = '';
    protected $db_pass = '';
    protected $db_host = '';
    protected $db;
 
    function __construct(){
        $this->connect();
 
    }
 
    public function connect(){
        $this->db = new mysqli($this->db_host, $this->db_user, $this->db_pass, $this->db_name);
        if(!$this->db){
            echo mysqli_connect_error();
        }
        $this->db->set_charset("utf8");
    }
 
    public function executeNonParams($prcName){
            $result = $this->db->query('call '.$prcName.'()');
            if($result->num_rows == 1)
                return $this->processRowSet($result, true);
            return $this->processRowSet($result);
    }
 
    public function executeParams($prcName, $arrParams){
            $sql = 'call '.$prcName.' (';
            for($i= 0;$i< count($arrParams);$i++){
                    if($i== count($arrParams)-1){
                        if(is_string($arrParams[$i])){
                            $sql .= '"'.$arrParams[$i].'");';
                        }else{
                            $sql .= $arrParams[$i].')';
                        }
                    }else{
                        if(is_string($arrParams[$i])){
                            $sql .= '"'.$arrParams[$i].'", ';
                        }else{
                            $sql .= $arrParams[$i].', ';
                        }
                    }
            }
            $result = $this->db->query($sql);
            if($result->num_rows == 1){
                return $this->processRowSet($result, true);
            }
            return $this->processRowSet($result);
    }
 
    public function processRowSet($result, $singleRow = false){
            $resultArray = array();
            while ($row = $result->fetch_assoc()) {
                    array_push($resultArray, $row);
            }
            $result->close();
            $this->db->next_result();
            if($singleRow == true)
                return $this->json($resultArray[0]);
            return $this->json($resultArray);
    }
 
    public function json($resultArray){
            if(is_array($resultArray))
                    return json_encode($resultArray);
            return $resultArray;
    }
 
    public function close(){
        $this->db->close();
    }
}