1 files changed, 174 insertions, 0 deletions

diff --git a/contrib/check_mysqlslave.pl b/contrib/check_mysqlslave.pl
new file mode 100644
index 0000000..ab7af89
--- /dev/null
+++ b/contrib/check_mysqlslave.pl
@@ -0,0 +1,174 @@
+#!/usr/bin/perl -w
+#
+# check_mysqlslave.pl - nagios plugin
+#
+# 
+# Copyright 2002 Mario Witte
+#
+# This program is free software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; either version 2
+# of the License, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+# Credits: 
+# - Thanks to Christoph Kron <ck@zet.net> for check_ifstatus.pl
+#   I used check_ifstatus.pl as a layout when writing this
+#
+# Report bugs to: chengfu@users.sourceforge.net
+#
+# 20.09.2002 Version 0.1
+
+
+use strict;
+use lib "/usr/local/nagios/libexec";
+use utils qw($TIMEOUT %ERRORS &print_revision &support);
+
+use DBI;
+use DBD::mysql;
+use Getopt::Long;
+Getopt::Long::Configure('bundling');
+
+# Predeclare some variables
+my $PROGNAME = 'check_mysqlslave';
+my $REVISION = '0.1';
+my $status;
+my $state = 'UNKNOWN';
+my $opt_V;
+my $opt_h;
+my $port = 3306;
+my $hostname;
+my $user = 'root';
+my $pass = '';
+my $driver;
+my $dbh;
+my $query;
+my $result;
+my $data;
+
+# Just in case of problems, let's not hang Nagios
+$SIG{'ALRM'} = sub {
+     print ("ERROR: No response from $hostname (alarm timeout)\n");
+     exit $ERRORS{"UNKNOWN"};
+};
+alarm($TIMEOUT);
+
+$status = GetOptions(
+                "V"     => \$opt_V, "version"   => \$opt_V,
+                "h"     => \$opt_h, "help"      => \$opt_h,
+                "p=i"   => \$port, "port=i"     => \$port,
+                "H=s"   => \$hostname, "hostname=s"     => \$hostname,
+                "u=s"   => \$user, "user=s"     => \$user,
+                "P=s"   => \$pass, "pass=s"     => \$pass,
+                );
+
+                
+if ($status == 0) {
+        print_help() ;
+        exit $ERRORS{'OK'};
+}
+
+if ($opt_V) {
+        print_revision($PROGNAME,'$Revision$REVISION .' $ ');
+        exit $ERRORS{'OK'};
+}
+
+if ($opt_h) {
+        print_help();
+        exit $ERRORS{'OK'};
+}
+
+if (! utils::is_hostname($hostname)){
+        usage();
+        exit $ERRORS{"UNKNOWN"};
+}
+
+
+$driver = 'DBI:mysql::'. $hostname; 
+
+eval {
+        $dbh = DBI->connect($driver, $user, $pass, { RaiseError => 1, PrintError => 0});
+};
+if ($@) {
+        $status = $@;
+        if ($status =~ /^.*failed:\ (.+)\ at\ $0/i) { $status = $1; }
+        $state='CRITICAL';
+        print $state .': Connect failed: '."$status\n";
+        exit ($ERRORS{$state});
+}
+
+eval {
+        $query = 'SHOW SLAVE STATUS';
+        $result = $dbh->prepare($query);
+        $result->execute;
+        $data = $result->fetchrow_hashref();
+        $result->finish();
+        $dbh->disconnect();
+};
+if ($@) {
+        $status = $@;
+        $status =~ s/\n/ /g;
+        if ($status =~ /^DB[ID].*(failed|prepare):\ (.+)\ at\ $0/i) { $status = $2; }
+        $state = 'CRITICAL';
+        print $state .': Couldn\'t check slave: '."$status\n";
+        exit($ERRORS{$state});
+}
+
+if ($data->{'Slave_Running'} eq 'Yes') {
+        $status = 'Replicating from '. $data->{'Master_Host'};
+        $state = 'OK';
+        print $state .': '. $status ."\n";
+        exit($ERRORS{$state});
+} elsif ($data->{'Slave_Running'} eq 'No') {
+        if (length($data->{'Last_error'}) > 0) {
+                $status = 'Slave stopped with error message';
+                $state = 'CRITICAL';
+                print $state .': '. $status ."\n";
+                exit($ERRORS{$state});
+        } else {
+                $status = 'Slave stopped without errors';
+                $state = 'WARNING';
+                print $state .': '. $status ."\n";
+                exit($ERRORS{$state});
+        }
+} else {
+        $status = 'Unknown slave status: (Running: '. $data->{'Slave_Running'} .')';
+        $state = 'UNKNOWN';
+        print $state .': '. $status ."\n";
+        exit($ERRORS{$state});
+}
+
+sub usage {
+        printf "\nMissing arguments!\n";
+        printf "\n";
+        printf "check_mysqlslave -H <hostname> [-p <port> -u <username> -P <password>]\n";
+        printf "Copyright 2002 Mario Witte\n";
+        printf "\n\n";
+        support();
+        exit $ERRORS{"UNKNOWN"};
+}
+
+sub print_help {
+        printf "check_mysqlslave plugin for Nagios checks \n";
+        printf "if the replication on a backup mysql-server\n";
+        printf "is up and running\n";
+        printf "\nUsage:\n";
+        printf "   -H (--hostname)   Hostname to query\n";
+        printf "   -p (--port)       mysql port (default: 3306)\n";
+        printf "   -u (--user)       username for accessing mysql host\n";
+        printf "                     (default: root)\n";
+        printf "   -P (--pass)       password for accessing mysql host\n";
+        printf "                     (default: '')\n";
+        printf "   -V (--version)    Plugin version\n";
+        printf "   -h (--help)       usage help \n\n";
+        print_revision($PROGNAME, '$Revision$REVISION .' $');
+        
+}