数据库连接操作类 _link = mysql_connect($dbhost,$dbuser,$dbpassword,true); /*连接数据库*/ $this->_link or $this->errmsg('can\'t connect to mysql server!'); /*是否连接成功*/ if ($this->version() > '4.1') { /*检查数据库版本*/ $this->query('set names '.$charset); /*设置数据库编码*/ } mysql_select_db($dbname,$this->_link) or $this->errmsg('can\'t select the database!'); /*打开数据库*/ } /*执行数据库操作*/ public function query($sql) { $result = mysql_query($sql,$this->_link); $result or $this->errmsg('execute sql sentence error!'); return $result; } /*返回根据从结果集取得的行生成的数组*/ /*mysql_both 得到一个同时包含关联和数字索引的数组 (如同 mysql_fetch_array())*/ /*mysql_assoc 得到一个同时包含关联和数字索引的数组 (如同 mysql_fetch_assoc())*/ /*mysql_num 得到一个同时包含关联和数字索引的数组 (如同 mysql_fetch_row())*/ public function fetch_array($result,$type = mysql_both) { return mysql_fetch_array($result,$type); } /*返回根据所取得的行生成的对象*/ public function fetch_object($result) { return mysql_fetch_object($result); } /*取得前一次 mysql 操作所影响的记录行数*/ public function affected_rows() { return mysql_affected_rows($this->_link); } /* 释放结果内存*/ public function free_result($result) { return mysql_free_result($result); } /* 取得结果集中行的数目*/ public function num_rows($result) { return mysql_num_rows($result); } /* 取得结果集中字段的数目*/ public function num_fields($result) { return mysql_num_fields($result); } /*取得上一步 insert 操作产生的 id*/ public function insert_id() { return mysql_insert_id($this->_link); } /* 发出mysql执行错误*/ private function errmsg($msg) { $message = 'a mysql error has occurred!
'; $message .= 'error number:'. mysql_errno($this->_link) .'
'; $message .= 'error description:'. $msg . mysql_error($this->_link) .'
'; $message .= 'error time:'. date('y-m-d h:i:s'); exit($message); } /*返回连接的标识*/ public function link_id() { return $this->_link; } /*返回数据库服务器版本*/ public function version() { return mysql_get_server_info($this->_link); } /*获得客户端真实的ip地址*/ function getip() { if (getenv(http_client_ip) && strcasecmp(getenv(http_client_ip), unknown)) { $ip = getenv(http_client_ip); } else if (getenv(http_x_forwarded_for) && strcasecmp(getenv(http_x_forwarded_for), unknown)) { $ip = getenv(http_x_forwarded_for); } else if (getenv(remote_addr) && strcasecmp(getenv(remote_addr), unknown)) { $ip = getenv(remote_addr); } else if (isset ($_server['remote_addr']) && $_server['remote_addr'] && strcasecmp($_server['remote_addr'], unknown)) { $ip = $_server['remote_addr']; } else { $ip = unknown; } return ($ip); } }
复制代码