This article mainly introduces the mysqldb read-write separation operation class implemented by PHP. It analyzes PHP's read-write separation operation implementation skills for the database in the form of examples, and gives the specific usage of this encapsulation class. Friends who need it You can refer to the following
The example of this article describes the mysqldb read-write separation operation class implemented by PHP. Share it with everyone for your reference, the details are as follows:
/**
* 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['slave']) {
if(!$this->linkr = $this->connect($this->dbconfig['slave'][0],$this->dbconfig['slave'][1],$this->dbconfig['slave'][2],$this->dbconfig['slave'][3])) {
$this->dbconfig['slave'] = false;
$this->connectS();
}
//echo "<br>##connectS!.<br>";
} else {
if(!$this->linkw) {
$this->connectM();
}
$this->linkr = $this->linkw;
}
}
// db read
function query($sql, $type = '') {
if(!$this->linkr) {
$this->connectS();
}
$func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?
'mysql_unbuffered_query' : 'mysql_query';
$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['page']);
$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['QUERY_STRING'];
$url = preg_replace("/&?page=[0-9]+/i","",$url);
$array['countnum'] = $countnum;
$array['countpage'] = $countpage;
$array['result'] = $result;
$array['page'] = $page;
if($page>1) {
$array['preurl'] = "?".$url."&page=".($page-1);
$array['prepage'] = $page-1;
} else {
$array['preurl'] = "?".$url."&page=1";
$array['prepage'] = 1;
}
if($page<$countpage) {
$array['nexturl'] = "?".$url."&page=".($page+1);
$array['nextpage'] = $page+1;
} else {
$array['nexturl'] = "?".$url."&page=".$countpage;
$array['nextpage'] = $countpage;
}
$array['firsturl'] = "?".$url."&page=1";
$array['firstpage'] = 1;
$array['lasturl'] = "?".$url."&page=".$countpage;
$array['lastpage'] = $countpage;
$array['nopage'] = "?".$url."&page=";
return $array;
}
// db write
function queryw($sql, $type = '') {
if(!$this->linkw) {
$this->connectM();
}
$func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?
'mysql_unbuffered_query' : 'mysql_query';
$query = $func($sql, $this->linkw);
$this->querynum++;
return $query;
}
function update($table,$where,$array) {
$whereset = $set = $dot = '';
foreach($array as $key=>$value) {
$set .= $dot." `$key`='$value'";
$dot = ',';
}
$whereset = $dot = '';
foreach($where as $k=>$v) {
$whereset .= $dot." `$k`='$v'";
$dot = ' and ';
}
$sql = "update $table set $set where $whereset";
return $this->queryw($sql);
}
function insert($table,$array) {
$col = $v = $dot = '';
foreach($array as $key=>$value) {
$v .= $dot."'$value'";
$col .= $dot."`$key`";
$dot = ',';
}
$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('localhost','bevin','password','test');
* $dbarray[] = array('ilaopo.net','root','password','test');
* $dbarray[] = array('192.168.1.77','cxh','password','test');
* $newdb = new mysqldb($dbarray,'utf8');
* $array = array('name' => date("Y-m-d H:i:s"));
* $id = $newdb->insert("test",$array);
* $result = $newdb->fetch_page("select * from test order by id desc",'10');
* print_r($result);
* $id = $newdb->insert("test",$array);
* echo $id;
*/The above is the entire content of this article, I hope it will be helpful to everyone's study.
Related recommendations:
Python implements encapsulation of MySQLdb basic operation classes
##python How to install the mysqldb module under windows
Installing the MySQLdb module under Python environment
The above is the detailed content of Mysqldb read-write separation operation class implemented by PHP. For more information, please follow other related articles on the PHP Chinese website!
![[Web front-end] Node.js quick start](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
