<?php
 
 
if(!defined('IN')) die('Access denied');
 
require(ROOT_PATH.'include/config.inc.php');
 
class db_op
{
	protected $link;
	protected $dbhost,$dbuser,$dbpwd,$dbname;
 
	public function db_op($host="",$user="",$pwd="",$name="")
	{
		$this->__construct($host,$user,$pwd,$name);
	}
 
	public function __construct($host="",$user="",$pwd="",$name="")
	{
		$this->link = false;
		$this->dbhost = $host;
		$this->dbuser = $user;
		$this->dbpwd = $pwd;
		$this->dbname = $name;
	}
 
	//建立数据库连接，如果带参数，则以参数为最优先，其次为类中参数，最后为config参数
	public function createConnection($host="",$user="",$pwd="",$name="")
	{
		if($host!=""||$user!=""||$pwd!=""||$name!="")
		{
			$this->connectWithInParameter($host,$user,$pwd,$name);
		}
		else if ($this->dbhost!=""&&$this->dbuser!=""&&$this->dbpwd!=""&&$this->dbname!="")
		{
			$this->connectWithClass();
		}
		else
		{
			$this->connectWithConfig();
		}
	}
 
	//由获取的参数建立连接
	protected function connectWithInParameter($host,$user,$pwd,$name)
	{
		if($host!=""||$user!=""||pwd!=""||$name!="")
		{
			$this->halt("连接数据库参数错误");
		}
		else
		{
			$this->link = @mysql_connect($host,$user,$pwd) or die("Can not connect DateBase!");
			@mysql_select_db($name,$this->link) or die("Can not found DataBase!");
			$gb="set names utf8";
			mysql_query($gb);
		}
	}
 
	//由类中参数连接数据库
	protected function connectWithClass()
	{
		$this->link = @mysql_connect($this->dbhost,$this->dbuser,$this->dbpwd) or die("Can not connect DateBase!");
		@mysql_select_db($this->dbname,$this->link) or die("Can not found DataBase!");
		$gb="set names utf8";
		mysql_query($gb);
	}
 
	//由config文件中的数据建立连接
	protected function connectWithConfig()
	{
		$this->link=@mysql_connect(DB_HOST,DB_USER,DB_PW) or die('Can not connect DateBase!');
		@mysql_select_db(DB_NAME,$this->link) or die('Can Not found the DateBase');
		$gb="set names utf8";
		mysql_query($gb);
	}
 
	public function query($sql)
	{
			return mysql_query($sql);
	}
 
	//取得单个记录	
	public function ExecuteScalar($sql)
	{
		$query = $this->query($sql);
		$rs = mysql_fetch_array($query);
		return $rs[0];
	}
 
	//获取全部记录
	public function get_all($sql)
	{
		try 
		{
			$query = $this->query($sql);
			$result=array();
			while ($rs=mysql_fetch_array($query))
			{
				$result[] = $rs;
			}
			return  $result;
		}
		catch (Exception $e)
		{
			$this->halt($e->getMessage());	
		}
	}
 
	public function fetch_array($sql)
	{
		try 
		{
			$query = $this->query($sql);
			return  mysql_fetch_array($query);
		}
		catch (Exception  $e)
		{
			$this->halt($e->getMessage());
		}
 
	}
 
	public function select($table,$keys,$where='',$order='ASC',$start='',$end='')
	{
		$sql = "SELECT ";
		$keys_temp = '';
		$first_key='';
		foreach ($keys as $k=>$v)
		{
				$keys_temp.='`'.addslashes(trim($v)).'`,';
				if ($first_key=='')
				{
					$first_key = addslashes(trim($k));
				}
		}
 
		$keys_temp = substr($keys_temp,0,-1);
		$sql.=' '.$keys_temp.' FROM `'.$table.'` ';
		if ($where!='')
		{
			$sql.=' WHERE '.$where.' ';	
		}
		if($order=='ASC')
		{
			$sql.=' ORDER BY `'.addslashes(trim($keys[$first_key])).'` ';
		}
		else 
		{
			$sql.=' ORDER BY `'.addslashes(trim($keys[$first_key])).'` DESC ';
		}
		if($start!='')
		{
			$sql.=' LIMIT '.$start;
		}
		if($end!='')
		{
			$sql.=','.$end;
		}
 
		//echo $sql;
		return  $this->get_all($sql);
	}
 
	public function insert($table,$insert)
	{
		if (is_array($insert[0]))
		{
			$i=0;
			while (isset($insert[$i]))
			{
				$this->insert($table,$insert[$i]);
				$i++;	
			}
			//echo $i;
		}
 
		$sql = 'INSERT INTO `'.$table.'` (';
		$keys = '';
		$values = '';
 
		foreach ($insert as $k=>$v)
		{
			$keys.='`'.addslashes(trim($k)).'`,';
			$values.='\''.addslashes(trim($v)).'\',';
		}
		$keys = substr($keys,0,-1);
		$values =  substr($values,0,-1);
		$sql.=$keys.') VALUES (';
		$sql.=$values.')';
 
		try
		{
			$this->query($sql);
			$affected_rows = mysql_affected_rows();
 
		    return $affected_rows;
		}
		catch (Exception $e)
		{
			$this->halt($e->getMessage());
		}
		return 0;
	}
 
	public function delete($table,$where)
	{
		$sql="DELETE FROM $table WHERE $where";
		$this->query($sql);
		return $this->affected_rows();
	}
 
	public function update($table,$update,$where='')
	{
		$sql = 'UPDATE `'.$table.'` SET ';
		foreach ($update as $k=>$v)
		{
			$sql.='`'.$k.'`=\''.addslashes(trim($v)).'\',';
		}
		$sql = substr($sql,0,-1);
		if ($where!='') 
		{
			$sql.=' WHERE '.$where;	
		}
 
	    try 
	    {
	    	//echo $sql;
	    	$this->query($sql);
	   		return $this->affected_rows();
	    }
	    catch (Exception $e)
	    {
	    	echo $e->getMessage();
			exit();
	    }
	}
 
 
	public function num_rows($sql)
	{
		$query = $this->query($sql);
		$num = mysql_num_rows($query);
		return  $num;
	}
 
	public function affected_rows()
	{
		return mysql_affected_rows();
	}
 
	public function halt($msg,$url="")
	{
		if($url == "")
		{
			$error = '<strong><center>'.$msg.'</center></strong>';
			exit($error);
		}
		else
		{
			$error = '<strong><center>'.$msg.'</center></strong>';
			$error.='<a href="'.$url.'">'.$url.'</a>';
			exit($error);
		}
	}
}
?>