软件测试网 软件测试培训 软件测试论坛 测试解决方案 文章资料精选 软件测试博客 软件测试招聘

手把手教你实现MySQL双机数据同步

发表于：2011-7-01 09:53

字体：大 中 小 | 上一篇 | 下一篇 | 我要投稿

 作者：未知    来源：51Testing软件测试网采编

分享：
  1. root@test2 ~: mysql -u root -p  
  2. Enter password:   
  3. Welcome to the MySQL monitor.  Commands end with ; or \g.   
  4. Your MySQL connection id is 2   
  5. Server version: 5.0.45 Source distribution   
  6.    
  7. Type 'help;' or '\h' for help. Type '\c' to clear the buffer.   
  8.    
  9. mysql> create database foo ;  
  10. Query OK, 1 row affected (0.00 sec)   
  11. ###增加用户 test123 从任何主机登录到 MySQL  
  12. mysql> grant all privileges on *.* to 'test123'@'%' identified by 'test123' with grant  option;   
  13. Query OK, 0 rows affected (0.00 sec)   
  14. ###增加用户 test1 从 192.168.7.67 主机登录到 MySQL  
  15. mysql> grant all privileges on foo.* to 'test1'@'192.168.7.67' identified by 'test1' with grant   option;   
  16. Query OK, 0 rows affected (0.00 sec)

　　如果有防火墙的设置的话，可以如下设置：

  1. root@test2 ~: iptables -A INPUT -i eth0 -s 192.168.7.67 -p tcp --dport 3306 -j ACCEPT   
  2. root@test2~: /etc/init.d/iptales save

　　最后在客户端就可以输入下面命令来远程进入 MySQL 数据库：

  1. jian.ma@camlit ~: mysql -u test1 -h 192.168.56.103 -p   
  2. Enter password:   
  3. Welcome to the MySQL monitor.  Commands end with ; or \g.   
  4. Your MySQL connection id is 13   
  5. Server version: 5.0.45 Source distribution   
  6. Type 'help;' or '\h' for help. Type '\c' to clear the buffer.

　　mysqld.pl内容如下：

  1. #!/usr/bin/perl 
  2.  
  3. #This script is used to check if the mysql replication is ok 
  4.  
  5. use strict; 
  6. use DBI; 
  7. use POSIX "strftime"; 
  8.  
  9. my $host           = "192.168.56.103"; 
  10. my $user           = "test1"; 
  11. my $passwd         = "test1"; 
  12. my $port           = "3306"; 
  13. my $max_behind     = "120"; 
  14. my $check_log      = "./mysql_check.log"; 
  15.  
  16.  
  17. #Open the log file  
  18. open (FH, ">> $check_log") or die $!; 
  19.  
  20. #Connect the mysql server  
  21. my $dbh = &MysqlConnect ($host, $port, $user, $passwd); 
  22.  
  23.  
  24. #Get slave sql status 
  25. my $slave_status = &MysqlQuery( $dbh, 'show slave status'); 
  26. print FH "Error: SQL Query Error:" . $dbh->errstr; 
  27.  
  28.  
  29. my $slave_IO              = $slave_status->{Slave_IO_Running}; 
  30. my $slave_SQL             = $slave_status->{Slave_SQL_Running}; 
  31. my $seconds_behind_master = $slave_status->{Seconds_Behind_Master}; 
  32. my $now_time              = POSIX::strftime ("[%Y-%m-%d %H:%M:%S]", localtime); 
  33.  
  34.  
  35. print "Check the Slave MySQL stauts....\n"; 
  36. print "_" x 50, "\n"; 
  37. print "Time:\t\t\t$now_time\n"; 
  38. print "Slave IO Running:\t\t$slave_IO\n"; 
  39. print "Slave SQL Running::\t\t$slave_SQL\n"; 
  40. print "Behind Master Seconds:\t\t$seconds_behind_master\n"; 
  41.  
  42.  
  43. if ($seconds_behind_master > $max_behind){ 
  44.     print "Slave SQL Server is far behind master "; 
  45. } 
  46.  
  47.  
  48. #---Functions----# 
  49. sub MysqlConnect  { 
  50.  
  51.     my ($host, $port, $user, $passwd) = @_; 
  52.     my $dsn  = "DBI:mysql:host=$host;port=$port"; 
  53.     return DBI->connect($dsn, $user, $passwd, {RaiseError => 1}); 
  54. } 
  55.  
  56.  
  57. sub MysqlQuery { 
  58.  
  59.     my ($dbh , $query) = @_; 
  60.     my $sth = $dbh->prepare($query); 
  61.     my $res = $sth->execute; 
  62.     return undef unless $res; 
  63.     my $row = $sth->fetchrow_hashref; 
  64.     $sth->finish; 
  65.     return $row; 
  66. }

44/4<1234
价值398元的测试课程免费赠送，填问卷领取吧！

热门推荐

搜索风云榜

测试技术了解

玩转数据分析

挣点稿费

测试用例指南get

关注51Testing

热门标签

博文推荐

热点聚焦

最近讲堂

友情链接

51Testing软件测试网 蓝色理想 太平洋软件 天极软件 51CTO开发频道 中国站长学院 云计算 第三媒体数码 数据恢复 51Job职场资讯 新客网 Java开源大全 数据分析

联系我们

快捷面板 站点地图 联系我们 广告服务 关于我们 站长统计

法律顾问：上海漕溪律师事务所 项棋律师
版权所有 上海博为峰软件技术股份有限公司 Copyright©51testing.com 2003-2022
投诉及意见反馈：webmaster@51testing.com; 业务联系：service@51testing.com 021-64471599-8017

沪ICP备05003035号

沪公网安备 31010102002173号