Von PHP implementierte Mysqldb-Lese-/Schreib-Trennoperationsklasse

In diesem Artikel wird hauptsächlich die von PHP implementierte Lese-/Schreib-Trennungsoperationsklasse von PHP in Form von Beispielen vorgestellt und die spezifische Verwendung der Kapselungsklasse beschrieben Ich brauche es Sie können auf Folgendes verweisen

Das Beispiel in diesem Artikel beschreibt die von PHP implementierte Lese-/Schreib-Trennungsoperationsklasse mysqldb. Teilen Sie es als Referenz mit allen. Die Details lauten wie folgt:

/**
* php MysqlDB 读写分离类
* -----------------------------------------------------
* $Source: http://code.ilaopo.net/php.class.mysqldb $
* $Author: Bevin Chen $
* $Email: bevin#lifa8.cn $
* $Date: 2009-10-10 $
* -----------------------------------------------------
*/
class mysqldb {
  var $querynum = 0;
  var $linkr,$linkw,$charset,$pconnect,$dbconfig;
  function __constructor($dbarray) {
    $this->mysqldb($dbarray);
  }
  function mysqldb($dbarray,$dbcharset='utf8',$pcontent=0) {
    if(!is_array($dbarray[0])) {
      echo "数据库参数错误";
      return false;
    }
    $this->charset = $dbcharset;
    $this->pconnect = $pconnect;
    $this->dbconfig['master'] = $dbarray[0];
    $dbServerNum = count($dbarray);
    if($dbServerNum > 1) {
      /*
  * 当x=1 时，$dbarray[0]不作slave
  * 当x=0 时，$dbarray[0]作slave
  */
      $x = 1;
      $rand = rand($x,$dbServerNum-1);
      $this->dbconfig['slave'] = $dbarray[$rand];
    } else {
      $this->dbconfig['slave'] = false;
    }
  }
  function connect($dbhost,$dbuser,$dbpw,$dbname) {
    if($this->pconnect) {
      $link = @mysql_pconnect($dbhost, $dbuser, $dbpw);
    } else {
      $link = @mysql_connect($dbhost, $dbuser, $dbpw, 1);
    }
    if($link) {
      if($this->version($link) > '4.1') {
        if($this->charset) {
          @mysql_query("SET character_set_connection=".$this->charset.", character_set_results=".$this->charset.", character_set_client=binary", $link);
        }
        if($this->version($link) > '5.0.1') {
          @mysql_query("SET sql_mode=''", $link);
        }
      }
      if($dbname) {
        @mysql_select_db($dbname, $link);
      }
      //print_r($link);
      return $link;
    } else {
      return false;
    }
  }
  function connectM() {
    if(!$this->linkw = $this->connect($this->dbconfig['master'][0],$this->dbconfig['master'][1],$this->dbconfig['master'][2],$this->dbconfig['master'][3])) {
      exit("主数据库连接失败！");
    }
    //echo "<br>##connectM!.<br>";
  }
  function connectS() {
    if($this->dbconfig[&#39;slave&#39;]) {
      if(!$this->linkr = $this->connect($this->dbconfig[&#39;slave&#39;][0],$this->dbconfig[&#39;slave&#39;][1],$this->dbconfig[&#39;slave&#39;][2],$this->dbconfig[&#39;slave&#39;][3])) {
        $this->dbconfig[&#39;slave&#39;] = false;
        $this->connectS();
      }
      //echo "<br>##connectS!.<br>";
    } else {
      if(!$this->linkw) {
        $this->connectM();
      }
      $this->linkr = $this->linkw;
    }
  }
  // db read
  function query($sql, $type = &#39;&#39;) {
    if(!$this->linkr) {
      $this->connectS();
    }
    $func = $type == &#39;UNBUFFERED&#39; && @function_exists(&#39;mysql_unbuffered_query&#39;) ?
      &#39;mysql_unbuffered_query&#39; : &#39;mysql_query&#39;;
    $query = $func($sql, $this->linkr);
    $this->querynum++;
    return $query;
  }
  function fetch_array($query, $result_type = MYSQL_ASSOC) {
    return @mysql_fetch_array($query, $result_type);
  }
  function fetch_row($query) {
    $query = mysql_fetch_row($query);
    return $query;
  }
  function fetch_One($sql) {
    $query = $this->query($sql);
    return $this->fetch_row($query);
  }
  /* 获取分页方法 */
  function fetch_page($sql, $pagenum) {
    $page = intval($_GET[&#39;page&#39;]);
    $query = $this->query($sql);
    $countnum = $this->num_rows($query);
    $countpage = ceil($countnum/$pagenum);
    if($page<1) {
      $page=1;
    }
    if($page>$countpage) {
      $page=$countpage;
    }
    $limitstart = ($page-1)*$pagenum;
    /* 获取数据结果集 */
    for ($i=0; $i<($limitstart+$pagenum); $i++) {
      if($i>=$countnum) {
        break;
      }
      if($i>=$limitstart) {
        $result[] = $this->fetch_array($query);
      } else {
        $this->fetch_array($query);
      }
    }
    /* 生成url */
    $url = $_SERVER[&#39;QUERY_STRING&#39;];
    $url = preg_replace("/&?page=[0-9]+/i","",$url);
    $array[&#39;countnum&#39;] = $countnum;
    $array[&#39;countpage&#39;] = $countpage;
    $array[&#39;result&#39;] = $result;
    $array[&#39;page&#39;] = $page;
    if($page>1) {
      $array[&#39;preurl&#39;] = "?".$url."&page=".($page-1);
      $array[&#39;prepage&#39;] = $page-1;
    } else {
      $array[&#39;preurl&#39;] = "?".$url."&page=1";
      $array[&#39;prepage&#39;] = 1;
    }
    if($page<$countpage) {
      $array[&#39;nexturl&#39;] = "?".$url."&page=".($page+1);
      $array[&#39;nextpage&#39;] = $page+1;
    } else {
      $array[&#39;nexturl&#39;] = "?".$url."&page=".$countpage;
      $array[&#39;nextpage&#39;] = $countpage;
    }
    $array[&#39;firsturl&#39;] = "?".$url."&page=1";
    $array[&#39;firstpage&#39;] = 1;
    $array[&#39;lasturl&#39;] = "?".$url."&page=".$countpage;
    $array[&#39;lastpage&#39;] = $countpage;
    $array[&#39;nopage&#39;] = "?".$url."&page=";
    return $array;
  }
  // db write
  function queryw($sql, $type = &#39;&#39;) {
    if(!$this->linkw) {
      $this->connectM();
    }
    $func = $type == &#39;UNBUFFERED&#39; && @function_exists(&#39;mysql_unbuffered_query&#39;) ?
      &#39;mysql_unbuffered_query&#39; : &#39;mysql_query&#39;;
    $query = $func($sql, $this->linkw);
    $this->querynum++;
    return $query;
  }
  function update($table,$where,$array) {
    $whereset = $set = $dot = &#39;&#39;;
    foreach($array as $key=>$value) {
      $set .= $dot." `$key`=&#39;$value&#39;";
      $dot = &#39;,&#39;;
    }
    $whereset = $dot = &#39;&#39;;
    foreach($where as $k=>$v) {
      $whereset .= $dot." `$k`=&#39;$v&#39;";
      $dot = &#39; and &#39;;
    }
    $sql = "update $table set $set where $whereset";
    return $this->queryw($sql);
  }
  function insert($table,$array) {
    $col = $v = $dot = &#39;&#39;;
    foreach($array as $key=>$value) {
      $v .= $dot."&#39;$value&#39;";
      $col .= $dot."`$key`";
      $dot = &#39;,&#39;;
    }
    $sql = "insert into $table ($col) values ($v)";
    if($this->queryw($sql)) {
      return $this->insert_id();
    } else {
      return false;
    }
  }
  function insert_id() {
    return ($id = mysql_insert_id($this->linkw)) >= 0 ? $id : $this->result($this->queryw("SELECT last_insert_id()"), 0);
  }
  // db other
  function affected_rows($link) {
    return mysql_affected_rows($link);
  }
  function error($link) {
    return (($link) ? mysql_error($link) : mysql_error());
  }
  function errno($link) {
    return intval(($link) ? mysql_errno($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 fetch_fields($query) {
    return mysql_fetch_field($query);
  }
  function version($link) {
    return mysql_get_server_info($link);
  }
  function close($link) {
    return mysql_close($link);
  }
}
/* 测试例子 //
* $dbarray[] = array(&#39;localhost&#39;,&#39;bevin&#39;,&#39;password&#39;,&#39;test&#39;);
* $dbarray[] = array(&#39;ilaopo.net&#39;,&#39;root&#39;,&#39;password&#39;,&#39;test&#39;);
* $dbarray[] = array(&#39;192.168.1.77&#39;,&#39;cxh&#39;,&#39;password&#39;,&#39;test&#39;);
* $newdb = new mysqldb($dbarray,&#39;utf8&#39;);
* $array = array(&#39;name&#39; => date("Y-m-d H:i:s"));
* $id = $newdb->insert("test",$array);
* $result = $newdb->fetch_page("select * from test order by id desc",&#39;10&#39;);
* print_r($result);
* $id = $newdb->insert("test",$array);
* echo $id;
*/

Das Obige ist der gesamte Inhalt dieses Artikels, ich hoffe, er wird hilfreich sein jedermanns Arbeitszimmer.

Verwandte Empfehlungen:

Python-Implementierung, die die grundlegende Operationsklasse von MySQLdb kapselt

Python So installieren Sie das Modul mysqldb unter Windows

Installieren Sie das Modul MySQLdb in der Python-Umgebung

Das obige ist der detaillierte Inhalt vonVon PHP implementierte Mysqldb-Lese-/Schreib-Trennoperationsklasse. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!