<?php


class database {

	private $mysqli;
	
	public function __construct()  
    {  
		$this->mysqli = new mysqli(DB_HOST, DB_USER, DB_PASS, DB_NAME);
		if ($this->mysqli->connect_errno) {
			echo "Failed to connect to MySQL: (" . $this->mysqli->connect_errno . ") " . $this->mysqli->connect_error;
			die();				
		}
		
		$this->mysqli->set_charset("utf8");

    } 
	
	public function __destruct()  
    {  
		$this->mysqli->close();
    } 
	
	private function my_query($query_string){

		global $db_prefix;	

		$result = $this->mysqli->query($query_string);
		
		//echo "<br>------<br>".$query_string."<br>------<br>";
		
		return $result;
	
	}
	
	public function select($query_string, $top1=null){
		$query_string="SELECT ".$query_string;
		$recordset=$this->my_query($query_string);
		
		$result=array();
		
		if ($recordset && $recordset->num_rows>0){
			while ($obj=$recordset->fetch_object()){
				array_push($result, $obj);
			}
			if (isset($top1)) return $result[0]; 
			else return $result; 
		} 
		else {
			return false;
		}
	}

	public function insert($query_string){
		$query_string="INSERT ".$query_string;
		$result=$this->my_query($query_string);
		return $result; 
	}
	
	public function update($query_string){
		$query_string="UPDATE ".$query_string;
		$result=$this->my_query($query_string);
		return $result; 
	}


	public function delete($query_string){
		$query_string="DELETE ".$query_string;
		$result=$this->my_query($query_string);
		return $result; 
	}

	public function affected_rows() {
		return $this->mysqli->affected_rows;
	}

	public function get_num_rows($query_string) {
		$query_string="SELECT ".$query_string;
		$result = $this->mysqli->query($query_string);
		
		return $result->num_rows;
	}	
	
	public function insert_id() {
		return $this->mysqli->insert_id;
	}
	
	public function strip($string) {
		$string = $this->mysqli->real_escape_string($string);
		return $string;
	}
	
	public function strip_array(&$item, $key) {
		$item = $this->mysqli->real_escape_string($item);
	}
}

?>