php中怎么实现Mysql读写分离操作

共计 3739 个字符，预计需要花费 10 分钟才能阅读完成。

php 中怎么实现 Mysql 读写分离操作，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面丸趣 TV 小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

连接案例：

 ?php

require_once(mysql_rw_php.class.php

$db_rw = array(

 dbhost = www.aslibra.com ,

 dbuser = aslibra ,

 dbpw = www.aslibra.com ,

 dbname = test

$db_ro = array(

 array(

 dbhost = www.aslibra.com:4306 ,

 dbuser = aslibra ,

 dbpw = www.aslibra.com

$DB = new mysql_rw_php;

// 写入连接，单服务器操作 

$DB- connect($db_rw[dbhost], $db_rw[dbuser], $db_rw[dbpw], $db_rw[dbname]); 

// 读取连接，可以多服务器操作 

$DB- connect_ro($db_ro[0][dbhost], $db_ro[0][dbuser], $db_ro[0][dbpw]);

$DB- set_ro_list($db_ro);


 function connect($dbhost, $dbuser, $dbpw, $dbname =  , $pconnect = 0, $halt = TRUE) {

 if($pconnect) {

 if(!$this- link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {

 $halt   $this- halt(Can not connect to MySQL server

 } else {

 if(!$this- link = @mysql_connect($dbhost, $dbuser, $dbpw)) {

 $halt   $this- halt(Can not connect to MySQL server

 // 只读连接失败 

 if(!$this- link   !$halt) return false;

 // 未初始化 rw 时，第一个连接作为 rw

 if($this- link_rw == null)

 $this- link_rw = $this- link;

 if($this- version()    4.1 ) {

 if($this- charset) {

 @mysql_query(SET character_set_connection=$this- charset, character_set_results=$this- charset, character_set_client=binary , $this- link);

 if($this- version()    5.0.1 ) {

 @mysql_query(SET sql_mode= , $this- link);

 if($dbname) {

 $this- select_db($dbname);

 // 连接一个只读的 mysql 数据库 

 function connect_ro($dbhost, $dbuser, $dbpw, $dbname =  , $pconnect = 0){

 if($this- link_rw == null)

 $this- link_rw = $this- link;

 $this- link = null;

 // 不产生 halt 错误 

 $this- connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, false);

 if($this- link){

 // 连接成功 

 //echo  link ro sussess! br

 $this- ro_exist = true;

 $this- link_ro = $this- link;

 if($this- cur_db){

 // 如果已经选择过数据库则需要操作一次 

 @mysql_select_db($this- cur_db, $this- link_ro);

 }else{

 // 连接失败 

 //echo  link ro failed! br

 $this- link =  $this- link_rw;

 // 设置一系列只读数据库并且连接其中一个 

 function set_ro_list($ro_list){

 if(is_array($ro_list)){

 // 随机选择其中一个 

 $link_ro = $ro_list[array_rand($ro_list)];

 $this- connect_ro($link_ro[ dbhost], $link_ro[dbuser], $link_ro[dbpw

 function select_db($dbname) {

 // 同时操作两个数据库连接 

 $this- cur_db = $dbname;

 if($this- ro_exist){

 @mysql_select_db($dbname, $this- link_ro);

 return @mysql_select_db($dbname, $this- link_rw);

 function fetch_array($query, $result_type = MYSQL_ASSOC) {

 return mysql_fetch_array($query, $result_type);

 function fetch_one_array($sql, $type = ) {

 $qr = $this- query($sql, $type);

 return $this- fetch_array($qr);

 function query($sql, $type = ) {

 $this- link =  $this- link_rw;

 // 判断是否 select 语句 

 if($this- ro_exist   preg_match ( /^(\s*)select/i , $sql)){

 $this- link =  $this- link_ro;

 $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;

 function affected_rows() {

 return mysql_affected_rows($this- link);

 function error() {

 return (($this- link) ? mysql_error($this- link) : mysql_error());

 function errno() {

 return intval(($this- link) ? mysql_errno($this- link) : mysql_errno());

 function result($query, $row) {

 $query = @mysql_result($query, $row);

 return $query;

 function num_rows($query) {

 $query = mysql_num_rows($query);

 return $query;

 function num_fields($query) {

 return mysql_num_fields($query);

 function free_result($query) {

 return mysql_free_result($query);

 function insert_id() {

 return ($id = mysql_insert_id($this- link))  = 0 ? $id : $this- result($this- query( SELECT last_insert_id() ), 0);

 function fetch_row($query) {

 $query = mysql_fetch_row($query);

 return $query;

 function fetch_fields($query) {

 return mysql_fetch_field($query);

 function version() {

 return mysql_get_server_info($this- link);

 function close() {

 return mysql_close($this- link);

 function halt($message =  , $sql = ) {

 $dberror = $this- error();

 $dberrno = $this- errno();

 echo  div  >

 看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注丸趣 TV 行业资讯频道，感谢您对丸趣 TV 的支持。