貢獻一個mysql replication出錯自動檢測的腳本

平凡的香草

需要DBIX及Mail等perl模塊
注意，雖然能夠自動修復，但是可能造成slave的數(shù)據(jù)條目少于master的條目！使用的時候自己注意些好了
本腳本是修改版，原作者是Jeremy Zawodny

1. #!/usr/local/bin/perl -w
   
2. #
   
3. # fix mysql replication if it encounters a problem
   
4. # Useage：perl fix_repl.pl ip1 ip2 ip3
   
5. 
   
6.         $|=1;      # unbuffer stdout
   
7.         use strict;
   
8.         use DBIx::DWIW;
   
9.         use Mail::Mailer;
   
10.         my $ip;
    
11. foreach $ip (@ARGV) {
    
12.         &fixdb($ip);
    
13. }
    
14. 
    
15. exit;
    
16. 
    
17. sub fixdb()
    
18. {
    
19.         my $host = shift || 'localhost';
    
20.         my $conn = DBIx::DWIW->;Connect(
    
21.                 DB   =>; "test",
    
22.                 User =>; "sqlmon",
    
23.                 Pass =>; '!@#$%^&*()',
    
24.             Host =>; $host,
    
25.                 Port  =>; 3306) or die "Couldn't connect to database!";
    
26. 
    
27.         print "checking $host ... \n";
    
28.         my $info = $conn->;Hash("SHOW SLAVE STATUS") or die $@;
    
29.         my @version = $conn->;Array("SHOW VARIABLES LIKE 'Version'");
    
30.         my $fix_cmd;
    
31.         my $start_cmd;
    
32. # slave not start
    
33.         if ($info->;{Slave_IO_Running} eq 'No' and $info->;{Slave_SQL_Running} eq 'No')
    
34.         {
    
35.                 $fix_cmd = "SET SQL_SLAVE_SKIP_COUNTER = 1";
    
36.                 $start_cmd = "SLAVE START";
    
37.         }
    
38. # 4.0.0 - 4.0.2
    
39.         elsif ($version[1] =~ /^4\.0\.[012]/ and $info->;{Slave_SQL_Running} eq 'No')
    
40.         {
    
41.                 $fix_cmd = "SET SQL_SLAVE_SKIP_COUNTER = 1";
    
42.                 $start_cmd = "SLAVE START SQL_THREAD";
    
43.         }
    
44. # 4.0.3 - 4.0.xx, 4.1.xx.  Don't know what 5.0 will be like.
    
45.         elsif ($version[1] =~ /^4\.[01]\./ and $info->;{Slave_SQL_Running} eq 'No')
    
46.         {
    
47.                 $fix_cmd = "SET GLOBAL SQL_SLAVE_SKIP_COUNTER = 1";
    
48.                 $start_cmd = "SLAVE START SQL_THREAD";
    
49.         }
    
50. # things are okay or unknown version?
    
51.         else
    
52.         {
    
53.                         print "GOOD\n";
    
54.         }
    
55.         if ($info->;{Slave_IO_Running} eq 'No'  or  $info->;{Slave_SQL_Running} eq 'No' ){
    
56.         &mailtoadmin($info,$host);
    
57.         print "FIXING ... ";
    
58.         $conn->;Execute($fix_cmd);
    
59.         $conn->;Execute($start_cmd);
    
60.         print "DONE\n";
    
61.         }
    
62. 
    
63. }
    
64. 
    
65. sub mailtoadmin(){
    
66.         my $body=shift;
    
67.                 my $host = shift;
    
68.         my @MailTo=("xxxx\@yyyy.com");
    
69.         my $subject = "Mysql Self fix replication on $host ";
    
70.                 my $mailer = Mail::Mailer->;new() or die $@;
    
71.                 $mailer->;open({ From    =>; $host,
    
72.                 To      =>; \@MailTo,
    
73.                 Subject =>; $subject,
    
74.                 })or die "Can't open: $!\n";
    
75. #    while ( my ($key, $value) = each(%$body) ) {
    
76. #        print $mailer "$key =>; $value\n";
    
77. #    }
    
78.         print $mailer <<MAILCONTENT;
    
79. 
    
80.         *************************** show slave status***************************
    
81. 
    
82.         Master_Host                        =>;  $body->;{'Master_Host'}
    
83.         Master_User                        =>;  $body->;{'Master_User'}
    
84.         Master_Port                        =>;  $body->;{'Master_Port'}
    
85.         Connect_retry                =>;  $body->;{'Connect_retry'}
    
86.         Master_Log_File        =>;  $body->;{'Master_Log_File'}
    
87.         Read_Master_Log_Pos =>;$body->;{'Read_Master_Log_Pos'}
    
88.         Relay_Log_File                =>;  $body->;{'Relay_Log_File'}
    
89.         Relay_Log_Pos                =>;  $body->;{'Relay_Log_Pos'}
    
90.         Relay_Master_Log_File =>;$body->;{'Relay_Master_Log_File'}
    
91.         Slave_IO_Running =>;$body->;{'Slave_IO_Running'}
    
92.         Slave_SQL_Running =>;$body->;{'Slave_SQL_Running'}
    
93.         Replicate_do_db        =>;   $body->;{'Replicate_do_db'}
    
94.         Replicate_ignore_db =>;$body->;{'Replicate_ignore_db'}
    
95.         Last_errno                                =>;    $body->;{'Last_errno'}
    
96.         Last_error                                =>;    $body->;{'Last_error'}
    
97.         Skip_counter                        =>;    $body->;{'Skip_counter'}
    
98.         Exec_master_log_pos =>; $body->;{'Exec_master_log_pos'}
    
99.         Relay_log_space        =>;    $body->;{'Relay_log_space'}
    
100. MAILCONTENT
     
101.         $mailer->;close();
     
102. }
     
103. 
     

復制代碼

yejr

呵呵,謝謝樓主,其實如果用shell來做的話,是粉簡單的,而且以前也已經(jīng)有現(xiàn)成的了.

odin_free

不錯~~~保留

qinshiling

看你的腳本作用不錯，能高訴我怎么用嗎？

qinshiling

看你的腳本作用不錯，能高訴我怎么用嗎？

king1981

yejr 你中文的MYSQL 手冊能打個包給我嗎?
先謝謝拉.
ba20000@163.com

qlks

不錯
不過生產(chǎn)環(huán)境中還是shell腳本來的方便

grfjs

原帖由 yejr 于 2005-1-5 17:14 發(fā)表
呵呵,謝謝樓主,其實如果用shell來做的話,是粉簡單的,而且以前也已經(jīng)有現(xiàn)成的了.

請版主幫幫忙，能提供shell腳本的連接嗎？ 我翻了好久以前的帖子都沒翻到啊

yejr

http://imysql.cn/?q=node/77
中的 mysql日常維護 里頭有類似的

yueliangdao0608

你可以把perl的翻譯成shell