本代码是从uchome的代码修改的，是因为要解决uchome的效率而处理的。这个思维其实很久就有了，只是一直没有去做，相信也有人有同样的想法，如果有类似的，那真的希望提出相关的建议。<br />封装的方式比较简单，增加了只读数据库连接的接口扩展，不使用只读数据库也不影响原代码使用。有待以后不断完善。。<br />为了方便，试试建立了google的一个项目：<br />http://code.google.com/p/mysql-rw-php/<br />希望给有需要的朋友带来帮助。<br />PHP实现的Mysql读写分离<br />主要特性：<br />[li]简单的读写分离 [/li][li]一个主数据库，可以添加更多的只读数据库 [/li][li]读写分离但不用担心某些特性不支持 [/li][li]缺点：同时连接两个数据库 [/li] 英文比较烂，也写几个字吧<br />php code for mysql read/write split<br />feature:<br />simply rw split <br />one master,can add more slaves <br />support all mysql feature <br />link to the master and slave at the same time <br />PHP代码：<br />mysql_rw_php.class.php<br />| <?php<br />/****************************************<br />*** mysql-rw-php version 0.1 @ 2009-4-16<br />*** code by hqlulu#gmail.com<br />*** http://www.aslibra.com<br />*** http://code.google.com/p/mysql-rw-php/<br />*** code modify from class_mysql.php (uchome)<br />****************************************/<br />class mysql_rw_php {<br /> //查询个数<br /> var $querynum = 0;<br /> //当前操作的数据库连接<br /> var $link = null;<br /> //字符集<br /> var $charset;<br /> //当前数据库<br /> var $cur_db = \'\';<br /> //是否存在有效的只读数据库连接<br /> var $ro_exist = false;<br /> //只读数据库连接<br /> var $link_ro = null;<br /> //读写数据库连接<br /> var $link_rw = null;<br /> function mysql_rw_php(){<br /> }<br /> function connect($dbhost, $dbuser, $dbpw, $dbname = \'\', $pconnect = 0, $halt = TRUE) {<br /> if($pconnect) {<br /> if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {<br /> $halt && $this->halt(\'Can not connect to MySQL server\');<br /> }<br /> } else {<br /> if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {<br /> $halt && $this->halt(\'Can not connect to MySQL server\');<br /> }<br /> }<br /> <br /> //只读连接失败<br /> if(!$this->link && !$halt) return false;<br /> <br /> //未初始化rw时，第一个连接作为rw<br /> if($this->link_rw == null)<br /> $this->link_rw = $this->link;<br /> if($this->version() > \'4.1\') {<br /> if($this->charset) {<br /> @mysql_query(\"SET character_set_connection=$this->charset, character_set_results=$this->charset, character_set_client=binary\", $this->link);<br /> }<br /> if($this->version() > \'5.0.1\') {<br /> @mysql_query(\"SET sql_mode=\'\'\", $this->link);<br /> }<br /> }<br /> if($dbname) {<br /> $this->select_db($dbname);<br /> }<br /> }<br /> //连接一个只读的mysql数据库<br /> function connect_ro($dbhost, $dbuser, $dbpw, $dbname = \'\', $pconnect = 0){<br /> if($this->link_rw == null)<br /> $this->link_rw = $this->link;<br /> $this->link = null;<br /> //不产生halt错误<br /> $this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, false);<br /> if($this->link){<br /> //连接成功<br /> //echo \"link ro sussess!<br>\";<br /> $this->ro_exist = true;<br /> $this->link_ro = $this->link;<br /> if($this->cur_db){<br /> //如果已经选择过数据库则需要操作一次<br /> @mysql_select_db($this->cur_db, $this->link_ro);<br /> }<br /> }else{<br /> //连接失败<br /> //echo \"link ro failed!<br>\";<br /> $this->link = &$this->link_rw;<br /> }<br /> }<br /> //设置一系列只读数据库并且连接其中一个<br /> function set_ro_list($ro_list){<br /> if(is_array($ro_list)){<br /> //随机选择其中一个<br /> $link_ro = $ro_list[array_rand($ro_list)];<br /> $this->connect_ro($link_ro[\'dbhost\'], $link_ro[\'dbuser\'], $link_ro[\'dbpw\']);<br /> }<br /> }<br /> function select_db($dbname) {<br /> //同时操作两个数据库连接<br /> $this->cur_db = $dbname;<br /> if($this->ro_exist){<br /> @mysql_select_db($dbname, $this->link_ro);<br /> }<br /> return @mysql_select_db($dbname, $this->link_rw);<br /> }<br /> function fetch_array($query, $result_type = MYSQL_ASSOC) {<br /> return mysql_fetch_array($query, $result_type);<br /> }<br /> function fetch_one_array($sql, $type = \'\') {<br /> $qr = $this->query($sql, $type);<br /> return $this->fetch_array($qr);<br /> }<br /> function query($sql, $type = \'\') {<br /> $this->link = &$this->link_rw;<br /> //判断是否select语句<br /> if($this->ro_exist && preg_match (\"/^(\\s*)select/i\", $sql)){<br /> $this->link = &$this->link_ro;<br /> }<br /> $func = $type == \'UNBUFFERED\' && @function_exists(\'mysql_unbuffered_query\') ?<br /> \'mysql_unbuffered_query\' : \'mysql_query\';<br /> if(!($query = $func($sql, $this->link)) && $type != \'SILENT\') {<br /> $this->halt(\'MySQL Query Error\', $sql);<br /> }<br /> $this->querynum++;<br /> return $query;<br /> }<br /> function affected_rows() {<br /> return mysql_affected_rows($this->link);<br /> }<br /> function error() {<br /> return (($this->link) ? mysql_error($this->link) : mysql_error());<br /> }<br /> function errno() {<br /> return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());<br /> }<br /> function result($query, $row) {<br /> $query = @mysql_result($query, $row);<br /> return $query;<br /> }<br /> function num_rows($query) {<br /> $query = mysql_num_rows($query);<br /> return $query;<br /> }<br /> function num_fields($query) {<br /> return mysql_num_fields($query);<br /> }<br /> function free_result($query) {<br /> return mysql_free_result($query);<br /> }<br /> function insert_id() {<br /> return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query(\"SELECT last_insert_id()\"), 0);<br /> }<br /> function fetch_row($query) {<br /> $query = mysql_fetch_row($query);<br /> return $query;<br /> }<br /> function fetch_fields($query) {<br /> return mysql_fetch_field($query);<br /> }<br /> function version() {<br /> return mysql_get_server_info($this->link);<br /> }<br /> function close() {<br /> return mysql_close($this->link);<br /> }<br /> function halt($message = \'\', $sql = \'\') {<br /> $dberror = $this->error();<br /> $dberrno = $this->errno();<br /> echo \"<div style=\\\"position:absolute;font-size:11px;font-family:verdana,arial;background:#EBEBEB;padding:0.5em;\\\"><br /> <b>MySQL Error</b><br><br /> <b>Message</b>: $message<br><br /> <b>SQL</b>: $sql<br><br /> <b>Error</b>: $dberror<br><br /> <b>Errno.</b>: $dberrno<br><br /> </div>\";<br /> exit();<br /> }<br />}<br />?> |
<br /><br /><br /><blockquote class="blockquote">From: http://www.lantuz.com/read.php?tid=4143&page=e&newreply=1& Powered by PHPWind.com</blockquote> |
发表于 2009-5-10 02:06:53
关注公众号