mysql 類 待更新完善

<?php
class Mysql
{
	//鏈接句柄
	public $con = null;

	public function __construct($host,$user,$pwd,$db)
	{
		$this->connect($host,$user,$pwd,$db);
	}

	//數據庫鏈接
	public function connect($host,$user,$pwd,$db)
	{
	    $this->con = @mysql_connect($host,$user,$pwd,true);
		if(!$this->con)
		{
			echo '鏈接失敗'.mysql_error();
			die();
		}
		if(!mysql_select_db($db,$this->con))
		{
			echo '庫選擇失敗'.mysql_error();
		}
		mysql_query('set names utf8');
	}

	//查詢
	Public function query($sql)
	{
		$rs = mysql_query($sql,$this->con);
		if(!$rs)
		{
			echo 'sql語句錯誤'.mysql_error();
			die();
		}
		return $rs;
	}

	//單挑查詢
	public function find($sql)
	{
		$rt = mysql_fetch_assoc($this->query($sql));
		return $rt;
	}

	//全部查詢
	public function findall($sql)
	{
		$r = $this->query($sql);
		$arr = array();
		while(($row = mysql_fetch_assoc($r))!=false)
		{
			$arr[] = $row;
		}
		return $arr;
	}

	//查詢記錄數
	public function count($sql)
	{
		$r = $this->query($sql);
		return mysql_num_rows($r);
	}

	//更新數據
	public function update($table,$data,$condition)
	{
		$sql = 'update '.$table.' set ';
		while(list($k,$v) = each($data))
		{

			$sql .= $k.' = "'.$v.'"'.',';
		}
		$sql = substr($sql,0,-1);
		$sql .=' where 1=1';
		while(list($key,$val) = each($condition))
		{

			$sql .= ' and  '.$key.' = "'.$val.'"';
		}
		echo $sql;

		$this->query($sql);
	}

	//刪除數據
	//condition array($key=>$val,.......)
	Public function del($table,$condition)
	{
		//$condition = array('id'=>12,'name'=>'zj');
		$sql = 'delete from '.$table.' where 1=1';
		while(list($key,$val) = each($condition))
		{

			$sql .= ' and '.$key.' = "'.$val.'"';
		}
		$this->query($sql);
	}
}


$db = new Mysql('192.168.0.230','root','fpdev','oa');
//$one = print_r($db->find('select * from users'));
//$all = print_r($db->findall('select * from users'));
//echo $db->count('select * from users');
//$db->del('user_bak',array('id'=>1019,'username'=>'katherine'));
$db->update('user_bak',array('username'=>'zhangsan'),array('id'=>1020,'username'=>'lq'));