/*
*@Author: quocvuongdn
*@Twitter: quocvuongdn
*@Site: quocvuongdn.com
*/
class MySQL{
	protected $db_name = '';
	protected $db_user = '';
	protected $db_pass = '';
	protected $db_host = '';
	protected $connection;

	function __construct(){
		$this->connect();
	}

	public function connect() {
		$this->connection = mysql_connect($this->db_host, $this->db_user, $this->db_pass);
		mysql_select_db($this->db_name);

		return true;
	}

	public function processRowSet($rowSet, $singleRow=false)
	{
		$resultArray = array();
		while($row = mysql_fetch_assoc($rowSet))
		{
			array_push($resultArray, $row);
		}

		if($singleRow === true)
			return $resultArray[0];

		return $resultArray;
	}

	public function select($table, $where) {
		$sql = "SELECT * FROM $table WHERE $where";
		//echo $sql;
		$result = mysql_query($sql);
		if(mysql_num_rows($result) == 1)
			return $this->processRowSet($result, true);
		return $this->processRowSet($result);
	}

	public function update($data, $table, $where) {
		foreach ($data as $column => $value) {
			$sql = "UPDATE $table SET $column = $value WHERE $where";
			//echo $sql;
			mysql_query($sql) or die(mysql_error());
		}
		return true;
	}

	public function insert($data, $table) {

		$columns = "";
		$values = "";

		foreach ($data as $column => $value) {
			$columns .= ($columns == "") ? "" : ", ";
			$columns .= $column;
			$values .= ($values == "") ? "" : ", ";
			$values .= $value;
		}

		$sql = "insert into $table ($columns) values ($values)";
		echo $sql;
		mysql_query($sql) or die(mysql_error());

		//return the ID of the user in the database.
		return mysql_insert_id();

	}

	public function close(){
		mysql_close($this->connection);
	}
}