您好,欢迎来到刀刀网。
搜索
您的当前位置:首页Perl批量跳过MySQLSlave复制错误

Perl批量跳过MySQLSlave复制错误

来源:刀刀网


发现mysql slave服务器经常因为一些特殊字符或者符号产生的更新语句报错,整个同步也会因此而卡在那,最初的办法只是手动去出错的机器,执行下面三条sql语句,跳过错误即可。 slave stop;set GLOBAL SQL_SLAVE_SKIP_COUNTER=1;slave start; 一台slave机器用

发现mysql slave服务器经常因为一些特殊字符或者符号产生的更新语句报错,整个同步也会因此而卡在那,最初的办法只是手动去出错的机器,执行下面三条sql语句,跳过错误即可。

slave stop;
set GLOBAL SQL_SLAVE_SKIP_COUNTER=1;
slave start;

一台slave机器用这样方法还行,多台就麻烦了,就顺手写了个简单的perl脚本,方便统一跳过错误,代码如下:

#!/usr/bin/env perl
use strict;
use warnings;
# get slave status
sub get_status {
 my ($ip, $usr, $pass) = @_;
 my $info = `mysql -u$usr -p$pass -h$ip -e 'show slave status\\G;'`;
 if (($info =~ /Slave_IO_Running: Yes/) && ($info =~ /Slave_SQL_Running: No/)) {
 return 1;
 }
 return 0;
}
# mysql slave skip
sub slaveskip {
 my ($ip, $usr, $pass) = @_;
 print "slave error **\n";
 system("mysql -u$usr -p$pass -h$ip -e 'slave stop;'");
 system("mysql -u$usr -p$pass -h$ip -e 'set GLOBAL SQL_SLAVE_SKIP_COUNTER=1;'");
 system("mysql -u$usr -p$pass -h$ip -e 'slave start;'");
}
my @hosts = qw/
192.168.0.101:root:tt1234
192.168.0.102:root: tt1234
192.168.0.103:root: tt1234
/;
foreach (@hosts) {
 my ($ip, $usr, $pass) = split ':';
 print "// ----- $ip\n";
 my $count = 1;
 while ($count < 100000) {
 my $status = get_status($ip, $usr, $pass);
 print "i: $count status: $status\n";
 last if $status == 0;
 slaveskip($ip, $usr, $pass);
 select(undef, undef, undef, 0.1);
 $count++;
 }
 print "\n";
}
exit;

Copyright © 2019- gamedaodao.com 版权所有 湘ICP备2022005869号-6

违法及侵权请联系:TEL:199 18 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务