改造自discuz的mysql查询类(带注释) (PHP)

by dzjzmj, Wednesday, May 28, 2008, 21:05
edited by dzjzmj, Thursday, May 29, 2008, 21:40

<?php
/**
 * mysql查询类
 *
 */
class dbQuery {
	/**
	 * 查询总次数
	 *
	 * @var int
	 */
	var $querynum = 0;
	/**
	 * 连接句柄
	 *
	 * @var object
	 */
	var $link;
	
	/**
	 * 构造函数
	 *
	 * @param string $dbhost 主机名
	 * @param string $dbuser 用户
	 * @param string $dbpw   密码
	 * @param string $dbname 数据库名
	 * @param int $pconnect 是否持续连接
	 */
	function dbQuery($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0) {
		if($pconnect) {
			if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
				$this->halt('Can not connect to MySQL server');
			}
		} else {
			if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
				$this->halt('Can not connect to MySQL server');
			}
		}
		if($this->version() > '4.1') {
			global $dbcharset;
			if($dbcharset) {
				mysql_query("SET character_set_connection=$dbcharset, character_set_results=$dbcharset, character_set_client=binary", $this->link);
			}

if($this->version() > '5.0.1') {
				mysql_query("SET sql_mode=''", $this->link);
			}
		}

if($dbname) {
			mysql_select_db($dbname, $this->link);
		}

}
	/**
	 * 选择数据库
	 *
	 * @param string $dbname
	 * @return 
	 */
	function select_db($dbname) {
		return mysql_select_db($dbname, $this->link);
	}
	/**
	 * 取出结果集中一条记录
	 *
	 * @param object $query
	 * @param int $result_type
	 * @return array
	 */
	function fetch_array($query, $result_type = MYSQL_ASSOC) {
		return mysql_fetch_array($query, $result_type);
	}
	
	/**
	 * 查询SQL
	 *
	 * @param string $sql
	 * @param string $type
	 * @return object
	 */
	function query($sql, $type = '') {
		
		$func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?
			'mysql_unbuffered_query' : 'mysql_query';
		if(!($query = $func($sql, $this->link)) && $type != 'SILENT') {
			$this->halt('MySQL Query Error', $sql);
		}

$this->querynum++;
		return $query;
	}
	/**
	 * 取影响条数
	 *
	 * @return int
	 */
	function affected_rows() {
		return mysql_affected_rows($this->link);
	}
	/**
	 * 返回错误信息
	 *
	 * @return array
	 */
	function error() {
		return (($this->link) ? mysql_error($this->link) : mysql_error());
	}
	/**
	 * 返回错误代码
	 *
	 * @return int
	 */
	function errno() {
		return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());
	}
	/**
	 * 返回查询结果
	 *
	 * @param object $query
	 * @param string $row
	 * @return mixed
	 */
	function result($query, $row) {
		$query = @mysql_result($query, $row);
		return $query;
	}
	/**
	 * 结果条数
	 *
	 * @param object $query
	 * @return int
	 */
	function num_rows($query) {
		$query = mysql_num_rows($query);
		return $query;
	}
	/**
	 * 取字段总数
	 *
	 * @param object $query
	 * @return int
	 */
	function num_fields($query) {
		return mysql_num_fields($query);
	}
	/**
	 * 释放结果集
	 *
	 * @param object $query
	 * @return bool
	 */
	function free_result($query) {
		return mysql_free_result($query);
	}
	/**
	 * 返回自增ID
	 *
	 * @return int
	 */
	function insert_id() {
		return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);
	}
	/**
	 * 从结果集中取得一行作为枚举数组
	 *
	 * @param object $query
	 * @return array
	 */
	function fetch_row($query) {
		$query = mysql_fetch_row($query);
		return $query;
	}
	/**
	 * 从结果集中取得列信息并作为对象返回
	 *
	 * @param object $query
	 * @return object
	 */
	function fetch_fields($query) {
		return mysql_fetch_field($query);
	}
	/**
	 * 返回mysql版本
	 *
	 * @return string
	 */
	function version() {
		return mysql_get_server_info($this->link);
	}
	/**
	 * 关闭连接
	 *
	 * @return bool
	 */
	function close() {
		return mysql_close($this->link);
	}
	/**
	 * 输出错误信息
	 *
	 * @param string $message
	 * @param string $sql
	 */
	function halt($message = '', $sql = '') {
		echo $message . ' ' . $sql;
		exit;

}
}

改造自discuz的mysql查询类

使用查询类的好处在于可以快速行数据库的替换，比如我现在要使用sql server只要再写一个mssql的类，sql少许改动就可以完成了。

Tags: PHP 我来评分：高手一般菜鸟

Complete thread:

RSS Feed of thread

改造自discuz的mysql查询类(带注释) - dzjzmj, 2008-05-28, 21:05 (PHP)

代码之家

改造自discuz的mysql查询类(带注释) (PHP)