inc.db.php

<?php
require_once("inc.config.php");

class MySQLDB
{
	private $link = NULL;
	public $data = array();
	private $error_msg = "";

	function __construct()
	{
		$link = NULL;
		$data = array();
		$error_msg = "";
	}

	function connect($db_host = DB_HOST, $db_user = DB_USER, $db_passwd = DB_PASSWD, $db_name = DB_NAME, $db_cpage = DB_CPAGE)
	{
		$this->link = mysqli_connect($db_host, $db_user, $db_passwd, $db_name);
		if(!$this->link)
		{
			$this->error(mysqli_connect_error());
			return NULL;
		}

		if(!mysqli_set_charset($this->link, $db_cpage))
		{
			$this->error(mysqli_error($this->link));
			mysqli_close($this->link);
			$this->link = NULL;
			return NULL;
		}

		return $this->link;
	}

	public function __destruct()
	{
		$this->data = array();
		$this->disconnect();
	}

	public function select_db($db_name)
	{
		return mysqli_select_db($this->link, $db_name);
	}

	public function select($query)
	{
		$this->data = array();

		if(!$this->link)
		{
			return FALSE;
		}

		$res = mysqli_query($this->link, $query);
		if(!$res)
		{
			$this->error(mysqli_error($this->link));
			return FALSE;
		}

		if(mysqli_num_rows($res) <= 0)
		{
			return FALSE;
		}

		while($row = mysqli_fetch_row($res))
		{
			$this->data[] = $row;
		}

		mysqli_free_result($res);

		return TRUE;
	}

	public function select_assoc($query)
	{
		$this->data = array();

		if(!$this->link)
		{
			return FALSE;
		}

		$res = mysqli_query($this->link, $query);
		if(!$res)
		{
			$this->error(mysqli_error($this->link));
			return FALSE;
		}

		if(mysqli_num_rows($res) <= 0)
		{
			return FALSE;
		}

		while($row = mysqli_fetch_assoc($res))
		{
			$this->data[] = $row;
		}

		mysqli_free_result($res);

		return TRUE;
	}

	public function put($query)
	{
		if(!$this->link)
		{
			return FALSE;
		}

		$res = mysqli_query($this->link, $query);
		if(!$res)
		{
			$this->error(mysqli_error($this->link));
			return FALSE;
		}

		//return mysqli_affected_rows($this->link);
		return TRUE;
	}

	public function last_id()
	{
		return mysqli_insert_id($this->link);
	}

	public function disconnect()
	{
		//$this->data = FALSE;
		$this->error_msg = "";

		if($this->link)
		{
			mysqli_close($this->link);
			$this->link = NULL;
		}
	}

	public function get_last_error()
	{
		return $this->error_msg;
	}

	private function error($str)
	{
		$this->error_msg = $str;
		//throw new Exception(__CLASS__.": ".$str);
	}
}