Maison > développement back-end > tutoriel php > php实现Mysql读写分离的代码举例

php实现Mysql读写分离的代码举例

WBOY
Libérer: 2016-07-25 08:58:11
original
909 Les gens l'ont consulté
本文介绍下,php实现mysql读写分离的一个例子,希望正在研究mysql读写分离的朋友,作个参考吧。

PHP实现的Mysql读写分离 主要特性: 1.简单的读写分离 2.一个主数据库,可以添加更多的只读数据库 3.读写分离但不用担心某些特性不支持 4.缺点:同时连接两个数据库 feature: simply rw split one master,can add more slaves support all mysql feature link to the master and slave at the same time

文件 mysql_rw_php.class.php

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

<?php

/****************************

*** mysql-rw-php version 0.1

*** code by hqlulu#gmail.com

*** http://bbs.it-home.org

*** http://code.google.com/p/mysql-rw-php/

*** code modify from class_mysql.php (uchome)

****************************************/

class mysql_rw_php {

//查询个数

var $querynum = 0;

//当前操作的数据库连接

var $link = null;

//字符集

var $charset;

//当前数据库

var $cur_db = '';

//是否存在有效的只读数据库连接

var $ro_exist = false;

//只读数据库连接

var $link_ro = null;

//读写数据库连接

var $link_rw = null;

function mysql_rw_php(){

}

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 style=\"position:absolute;font-size:11px;font-family:verdana,arial;background:#EBEBEB;padding:0.5em;\">

<b>MySQL Error</b><br>

<b>Message</b>: $message<br>

<b>SQL</b>: $sql<br>

<b>Error</b>: $dberror<br>

<b>Errno.</b>: $dberrno<br>

</div>";

exit();

}

}

?>

Copier après la connexion


Étiquettes associées:
source:php.cn
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal