超级简单但超级实用的 PHP 的 mysql 类

haidong · 发表于 2010-2-24 13:38:26

<

>设计这个类的目的是为了实用，提高效率，不求包含的功能有多全，比如它不提供整理 SQL 语句的功能，因为我觉得那些功能可以在单独的查询语句生成类中实现，这样比在这里写几个通用的简单的 SQL 语句整理功能强的多。但是这个类提供的功能绝对够你用了。如果你觉得哪儿里设计的还不合理，或者你认为还应该增加什么功能，非常欢迎能留下你的高见。<

>顺便说一下，程序我没写注释，因为我觉得太简单了，没有必要注释。<DIV class=hl-surround><OL class="hl-main ln-show" ondblclick=linenumber(this) title="Double click to hide line number."><LI class=hl-firstline><?php<LI>/**<LI>* @author 马秉尧<LI>* @copyright (C) 2005 CoolCode.CN<LI>* @package class_mysql.php<LI>* @version 0.8<LI>*/<LI><LI>class mysql{<LI> var $debug;<LI> var $host;<LI> var $name;<LI> var $user;<LI> var $pass;<LI> var $linkid;<LI> var $queryid;<LI> var $affected_rows;<LI> var $result;<LI> var $sql;<LI> var $errno;<LI> var $error;<LI> var $sqls = array();<LI><LI> function mysql($host = '', $name = '', $user = '', $pass = '', $charset = 'UTF8', $debug = false){<LI> if (!extension_loaded('mysql')){<LI> if (strtoupper(substr(

HP_OS, 0, 3) == 'WIN')){<LI> dl('php_mysql.dll');<LI> } else{<LI> dl('mysql.so');<LI> }<LI> }<LI> $this->debug = $debug;<LI> if ($host != ''){<LI> if (is_resource($this->connect($host, $user, $pass))){<LI> if (mysql_get_server_info() >= "4.1"){<LI> mysql_query("set names $charset", $this->linkid);<LI> }<LI> if ($name != ''){<LI> $this->select_db($name);<LI> }<LI> }<LI> }<LI> register_shutdown_function(array(&$this, "shutdown"));<LI> }<LI><LI> function connect($host, $user, $pass){<LI> $this->host = $host;<LI> $this->user = $user;<LI> $this->pass = $pass;<LI> if ($this->debug){<LI> $this->linkid = mysql_connect($this->host, $this->user, $this->pass);<LI> }<LI> else {<LI> $this->linkid = @mysql_connect($this->host, $this->user, $this->pass);<LI> }<LI> $this->errno = mysql_errno();<LI> $this->error = mysql_error();<LI> return $this->linkid;<LI> }<LI><LI> function select_db($name){<LI> $this->name = $name;<LI> if (is_resource($this->linkid)){<LI> if ($this->debug){<LI> if (!mysql_select_db($this->name, $this->linkid)){<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> }<LI> }<LI> else {<LI> if (!@mysql_select_db($this->name, $this->linkid)){<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> }<LI> }<LI> }<LI> }<LI><LI> function query($sql = '', $type = 'assoc'){<LI> if (is_array($sql)){<LI> $err = false;<LI> foreach($sql as$s){<LI> if ($this->debug){<LI> if (!mysql_query($s, $this->linkid)){<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> $err = true;<LI> }<LI> }<LI> else {<LI> if (!@mysql_query($s, $this->linkid)){<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> $err = true;<LI> }<LI> }<LI> if (preg_match("/^\s*(delete|insert|replace|update)/i", $s)){<LI> $this->affected_rows = mysql_affected_rows($this->linkid);<LI> }<LI> }<LI> return !$err;<LI> }<LI> if ($sql != ''){<LI> $this->sql = $sql;<LI> }<LI> if ($this->debug){<LI> $this->queryid = mysql_query($this->sql, $this->linkid);<LI> }<LI> else {<LI> $this->queryid = @mysql_query($this->sql, $this->linkid);<LI> }<LI> if (preg_match("/^\s*(delete|insert|replace|update)/i", $this->sql)){<LI> $this->affected_rows = mysql_affected_rows($this->linkid);<LI> }<LI> if (is_resource($this->queryid)){<LI> if (mysql_num_rows($this->queryid) == 0){<LI> $this->result = 0;<LI> }<LI> else if((mysql_num_rows($this->queryid) == 1)and<LI> preg_match("/limit\s+1\s*$|limit\s+1\s*[^,]+/i", $this->sql)) {<LI> $this->result = call_user_func("mysql_fetch_" . $type, $this->queryid);<LI> }<LI> else {<LI> $this->result = array();<LI> while ($row = call_user_func("mysql_fetch_" . $type, $this->queryid)){<LI> array_push($this->result, $row);<LI> }<LI> }<LI> return $this->result;<LI> }<LI> else if($this->queryid === false){<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> }<LI> return $this->queryid;<LI> }<LI><LI> function explain($sql = ''){<LI> if ($sql != ''){<LI> $this->sql = $sql;<LI> }<LI> if ($this->debug){<LI> $this->queryid = mysql_query("EXPLAIN " . $this->sql, $this->linkid);<LI> }<LI> else {<LI> $this->queryid = @mysql_query("EXPLAIN " . $this->sql, $this->linkid);<LI> }<LI> if (is_resource($this->queryid)){<LI> $this->result = array();<LI> while ($row = mysql_fetch_array($this->queryid)){<LI> array_push($this->result, $row);<LI> }<LI> return $this->result;<LI> }<LI> else {<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> return false;<LI> }<LI> }<LI><LI> function last_insert_id(){<LI> if ($this->debug){<LI> $result = mysql_query("select LAST_INSERT_ID() as `last_insert_id`", $this->linkid);<LI> }<LI> else {<LI> $result = @mysql_query("select LAST_INSERT_ID() as `last_insert_id`", $this->linkid);<LI> }<LI> if (is_resource($result)){<LI> $row = mysql_fetch_object($result);<LI> return $row->last_insert_id;<LI> }<LI> else {<LI> $this->errno = mysql_errno($this->linkid);<LI> $this->error = mysql_error($this->linkid);<LI> return false;<LI> }<LI> }<LI><LI> function affected_rows(){<LI> return $this->affected_rows;<LI> }<LI><LI> function register_shutdown_query($sql){<LI> array_push($this->sqls, $sql);<LI> }<LI><LI> function shutdown(){<LI> if (is_resource($this->linkid)){<LI> foreach($this->sqls as$sql){<LI> if ($this->debug){<LI> mysql_query($sql, $this->linkid);<LI> }<LI> else {<LI> @mysql_query($sql, $this->linkid);<LI> }<LI> }<LI> }<LI> }<LI><LI> function close(){<LI> if ($this->debug){<LI> mysql_close($this->linkid);<LI> }<LI> else {<LI> @mysql_close($this->linkid);<LI> }<LI> }<LI> <LI> function escape_string($string){<LI> if (version_compare(phpversion(), "4.3.0") == "-1"){<LI> return mysql_escape_string($string);<LI> }<LI> else if(is_resource($this->linkid)){<LI> return mysql_real_escape_string($string, $this->linkid);<LI> }<LI> else {<LI> return false;<LI> }<LI> }<LI>}<LI>?></LI></OL></DIV>

账号		自动登录	找回密码
密码			论坛注册

超级简单但超级实用的 PHP 的 mysql 类

浏览过的版块

客服中心

投诉建议