Séparation de lecture et d'écriture Mysql implémentée par PHP

Auteur：Eve Cole Date de mise à jour：2009-06-07 15:14:46

Ce code est modifié à partir du code uchome et est traité pour résoudre l'efficacité d'uchome.
La méthode d'encapsulation est relativement simple, l'ajout d'une extension d'interface pour la connexion à une base de données en lecture seule, et le fait de ne pas utiliser de base de données en lecture seule n'affecte pas l'utilisation du code d'origine.
Il reste à l'améliorer continuellement à l'avenir. .

Pour plus de commodité, essayez de configurer un projet Google :
http://code.google.com/p/mysql-rw-php/Hope

pour aider des amis dans le besoin.

Les principales fonctionnalités

de la séparation lecture-écriture Mysql implémentée par PHP

séparation simple lecture-écriture d'une base de données principale, vous pouvez ajouter davantage de bases de données en lecture seule, mais ne vous inquiétez pas de certaines fonctionnalités non prises en charge. Inconvénients : connexion de deux bases de données en même temps. en même temps, l'anglais est médiocre et écrivez quelques mots

de code php pour le partage lecture/écriture mysql
fonctionnalité:
simplement rw split
un maître, peut ajouter plus d'esclaves
prend en charge toutes les fonctionnalités MySQL
lien vers le maître et l'esclave en même temps

Code PHP :

mysql_rw_php.class.php

<?php
/******************************************
*** mysql-rw-php version 0.1 @ 2009-4-16
*** code par hqlulu#gmail.com
*** http://www.aslibra.com
*** http://code.google.com/p/mysql-rw-php/
*** modification du code depuis class_mysql.php (uchome)
*****************************************/
classe mysql_rw_php {
//Requête du numéro
var $numérorequête = 0;
//Connexion à la base de données pour l'opération en cours
var $lien = nul ;
//Jeu de caractères
var $jeu de caractères ;
//Base de données actuelle
var $cur_db = ";
// S'il existe une connexion à la base de données en lecture seule valide
var $ro_exist = faux;
//Connexion à la base de données en lecture seule
var $link_ro = nul ;
// Lecture et écriture de la connexion à la base de données
var $link_rw = nul ;
fonction mysql_rw_php(){
}
function connect($dbhost, $dbuser, $dbpw, $dbname = ”, $pconnect = 0, $halt = TRUE) {
si($pconnect) {
if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
$halt && $this->halt('Impossible de se connecter au serveur MySQL');
}
} autre {
if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
$halt && $this->halt('Impossible de se connecter au serveur MySQL');
}
}

//La connexion en lecture seule a échoué
if(!$this->link && !$halt) return false;

//Lorsque rw n'est pas initialisé, la première connexion est utilisée comme rw
si($this->link_rw == null)
$this->link_rw = $this->link;
si($this->version() > '4.1′) {
si($this->jeu de caractères) {
@mysql_query("SET Character_set_connection=$this->charset, Character_set_results=$this->charset, Character_set_client=binary", $this->link);
}
si($this->version() > '5.0.1′) {
@mysql_query(”SET sql_mode="", $this->link);
}
}
si ($ nom de base de données) {
$this->select_db($dbname);
}
}
//http://www.knowsky.com/php.asp Connectez-vous à une base de données MySQL en lecture seule
fonction connect_ro($dbhost, $dbuser, $dbpw, $dbname = ”, $pconnect = 0){
si($this->link_rw == null)
$this->link_rw = $this->link;
$this->lien = null ;
//Ne génère pas d'erreur d'arrêt
$this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, false);
si($this->lien){
//Connexion réussie
//echo "lien vers sussess ! " ;
$this->ro_exist = true ;
$this->link_ro = $this->link;
si($this->cur_db){
//Si vous avez déjà sélectionné la base de données, vous devez l'exploiter une fois
@mysql_select_db($this->cur_db, $this->link_ro);
}
}autre{
//La connexion a échoué
//echo "le lien ro a échoué ! " ;
$this->link = &$this->link_rw;
}
}
//Configurer une série de bases de données en lecture seule et se connecter à l'une d'entre elles
fonction set_ro_list($ro_list){
si(is_array($ro_list)){
//Sélectionnez-en un au hasard
$link_ro = $ro_list[array_rand($ro_list)];
$this->connect_ro($link_ro['dbhost'], $link_ro['dbuser'], $link_ro['dbpw']);
}
}
fonction select_db ($ nom de base de données) {
//Exploiter deux connexions à la base de données en même temps
$this->cur_db = $nomdb;
si($this->ro_exist){
@mysql_select_db ($dbname, $this->link_ro);
}
return @mysql_select_db ($dbname, $this->link_rw);
}
fonction fetch_array($query, $result_type = MYSQL_ASSOC) {
return mysql_fetch_array($query, $result_type);
}
fonction fetch_one_array($sql, $type = ”) {
$qr = $this->query($sql, $type);
return $this->fetch_array($qr);
}
requête de fonction ($sql, $type = ”) {
$this->link = &$this->link_rw;
//Détermine s'il faut sélectionner l'instruction
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('Erreur de requête MySQL', $sql);
}
$this->querynum++;
retourner $requête ;
}
fonction affectée_rows() {
return mysql_affected_rows($this->link);
}
erreur de fonction() {
return ($this->link) ? mysql_error($this->link) : mysql_error());
}
fonction numéro d'erreur() {
return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());
}
résultat de la fonction ($ requête, $ ligne) {
$query = @mysql_result($query, $row);
retourner $requête ;
}
fonction num_rows ($ requête) {
$query = mysql_num_rows($query);
retourner $requête ;
}
fonction num_fields ($ requête) {
return mysql_num_fields($query);
}
fonction free_result($query) {
return mysql_free_result($query);
}
fonction insert_id() {
return ($id = mysql_insert_id($this->link)) >= 0 $id : $this->result($this->query("SELECT last_insert_id()"), 0);
}
fonction fetch_row($query) {
$query = mysql_fetch_row($query);
retourner $requête ;
}
fonction fetch_fields ($ requête) {
return mysql_fetch_field($query);
}
fonction version() {
return mysql_get_server_info($this->link);
}
fonction fermer() {
return mysql_close($this->link);
}
fonction halt($message = ”, $sql = ”) {
$dberror = $this->error();
$dberrno = $this->errno();
echo "<div style="position:absolute;font-size:11px;font-family:verdana,arial;background:#EBEBEB;padding:0.5em;">
Erreur MySQL 
Message : $message 
SQL : $sql 
Erreur : $dberror 
Errno. : $dberrno 
</div>";
sortie();
}
}
?>
exemple.php