php mysql 操作类

<?php
class mysql{
	/**
	 * 连接 MYSQL 函数
	 * 连接 MYSQL 函数, 通过常量的形式来连接数据库
	 * 自定义配置文件，配置文件中自定义常量，包含需要使用的信息
	 * @return resource
	 */
	function connect2 (){ 
		// 连接 mysql
		$link=@mysql_connect(DB_HOST,DB_USER,DB_PWD) or die ('数据库连接失败 <br/>ERROR'.mysql_errno().':'.mysql_error());
		// 设置字符集
		mysql_set_charset(DB_CHARSET);
		// 打开指定的数据库
		mysql_select_db(DB_DBNAME) or die('指定的数据库打开失败');
		return $link;
	}
	
	
	
	/* array(
	'username'=>'cy',
	'password'=>'123456',
	'email'=>'cy@qq.com'
	) */
	
	/**
	 * 插入记录的操作
	 * @param array $array
	 * @param string $table
	 * @return boolean
	 */
	function insert($array,$table){$keys=join(',',array_keys($array));
		$values="'".join("','", array_values($array))."'";
		$sql="insert {$table}({$keys}) VALUES ({$values})";
		$res=mysql_query($sql);
		if($res){return mysql_insert_id();
		}else{return false;}
	}
	
	
	/**
	 * MYSQL 更新操作
	 * @param array $array
	 * @param string $table
	 * @param string $where
	 * @return number|boolean
	 */
	function update($array,$table,$where=null){foreach ($array as $key=>$val){$sets.=$key."='".$val."',";}
		$sets=rtrim($sets,','); // 去掉 SQL 里的最后一个逗号
		$where=$where==null?'':' WHERE '.$where;
		$sql="UPDATE {$table} SET {$sets} {$where}";
		$res=mysql_query($sql);
		if ($res){return mysql_affected_rows();
		}else {return false;}
	}
	
	
	/**
	 * 删除记录的操作
	 * @param string $table
	 * @param string $where
	 * @return number|boolean
	 */
	function delete($table,$where=null){
		$where=$where==null?'':' WHERE '.$where;
		$sql="DELETE FROM {$table}{$where}";
		$res=mysql_query($sql);
		if ($res){return mysql_affected_rows();
		}else {return false;}
	}
	
	
	
	/**
	 * 查询一条记录
	 * @param string $sql
	 * @param string $result_type
	 * @return boolean
	 */
	function fetchOne($sql,$result_type=MYSQL_ASSOC){$result=mysql_query($sql);
		if ($result && mysql_num_rows($result)>0){return mysql_fetch_array($result,$result_type);
		}else {return false;}
	}
	
	
	
	
	
	/**
	 * 得到表中的所有记录
	 * @param string $sql
	 * @param string $result_type
	 * @return boolean
	 */
	function fetchAll($sql,$result_type=MYSQL_ASSOC){$result=mysql_query($sql);
		if ($result && mysql_num_rows($result)>0){while ($row=mysql_fetch_array($result,$result_type)){$rows[]=$row;
			}
			return $rows;
		}else {return false;}
	}
	
	
	/** 取得结果集中的记录的条数
	 * @param string $sql
	 * @return number|boolean
	 */
	function getTotalRows($sql){$result=mysql_query($sql);
		if($result){return mysql_num_rows($result);
		}else {return false;}
		
	}
	
	/** 释放结果集
	 * @param resource $result
	 * @return boolean
	 */
	function  freeResult($result){return  mysql_free_result($result);
	}
	
	
	
	/** 断开 MYSQL
	 * @param resource $link
	 * @return boolean
	 */
	function close($link=null){return mysql_close($link);
	}
	
	
	/** 得到客户端的信息
	 * @return string
	 */
	function getClintInfo(){return mysql_get_client_info();
	}
	
	
	/** 得到 MYSQL 服务器端的信息
	 * @return string
	 */
	function getServerInfo($link=null){return mysql_get_server_info($link);
	}
	
	
	
	/** 得到主机的信息
	 * @return string
	 */
	function getHostInfo($link=null){return mysql_get_host_info($link);
	}
	
	/** 得到协议信息
	 * @return string
	*/
	function getProtoInfo($link=null){return mysql_get_proto_info($link);
	}
}
?>

<?php  define('DB_HOST', 'localhost');  define('DB_USER', 'root');  define('DB_PWD', 'ybzl1234');  define('DB_CHARSET', 'UTF8');  define('DB_DBNAME', 'jpbaike');
?>

<?php
$db = new mysql();
$link = $db->connect2();  

$sql = "SELECT * FROM baike  WHERE id ='".$id."'";  

$rs = $db->fetchAll($sql); 
$rs =$rs[0];
if (empty($rs)) {
$dataout = $datax;
$db->insert($dataout,"baike"); 

} 
else { $dataout=$rs;
} ?>