コミュニティ 学ぶ ツールライブラリ レジャー
検索
日本語
ホームページ > バックエンド開発 > PHPチュートリアル > 本文

PHPで実装されたMysqldbの読み書き分離操作クラス

墨辰丷
リリース： 2023-03-28 07:36:02
オリジナル
1713 人が閲覧しました

この記事では、主に PHP によって実装された mysqldb の読み取り/書き込み分離操作クラスを紹介し、サンプルの形式でデータベースに対する PHP の読み取り/書き込み分離操作の実装スキルを分析し、カプセル化クラスの具体的な使用方法を説明します。次へ

この記事の例では、PHP で実装された mysqldb の読み書き分離操作クラスについて説明します。参考のために皆さんと共有してください。詳細は次のとおりです: 

/**
* 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;
*/
ログイン後にコピー

以上がこの記事の全内容です。皆さんの学習に役立つことを願っています。


関連する推奨事項:

Python は MySQLdb 基本操作クラスのカプセル化を実装します

Windows での Python の mysqldb モジュールのインストール方法

MySQLdb モジュールをインストールするPython環境で

以上がPHPで実装されたMysqldbの読み書き分離操作クラスの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル：
php 操作する
ソース：php.cn
前の記事：PHPに実装されているCSVファイル読み込み機能の方法 次の記事：端末の種類が携帯電話かどうかを確認するPHPの例
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
著者別の最新記事
最新の問題
function_exists() はカスタム関数を決定できません Function test () {return true;} if (function_exists ('test')) {echo "テストは関数です";
から 2024-04-29 11:01:01
0
2
1941
Google Chromeのモバイル版を表示する方法 こんにちは、先生、Google Chrome をモバイル版に変更するにはどうすればよいですか?
から 2024-04-23 00:22:19
0
10
2112
子ウィンドウは親ウィンドウを操作しますが、出力は応答しません。 最初の 2 つの文は実行可能ですが、最後の文は実装できません。
から 2024-04-19 15:37:47
0
1
1782
親ウィンドウには出力がありません document.onclick = function(){ window.opener.document.write('私は子ウィンドウの出力です');
から 2024-04-18 23:52:34
0
1
1682
CSS マインド マッピングに関するコースウェアはどこにありますか? コースウェア
から 2024-04-16 10:10:18
0
0
1693
関連トピック
詳細>
人気のおすすめ
人気のチュートリアル
詳細>
関連するチュートリアル
人気のおすすめ
最新のコース
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート