<META HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=windows-1255"> <html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40"> <head> <meta name=Generator content="Microsoft Word 12 (filtered medium)"> <style>  </style>  </head> <body lang=EN-US link=blue vlink=purple> <div class=Section1> Hey there,<o:p></o:p> <o:p> </o:p> This is a small plugin, based on the original check_mysql_query.c<o:p></o:p> I wanted to know what you think about it and maybe you have other ideas how to implement this.<o:p></o:p> <o:p> </o:p> The idea is to monitor slow queries on remote systems that may be bringing a mysql process to its knees,<o:p></o:p> Which as of current does not raise an exception on the nagios system<o:p></o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> const char *progname = "check_mysql_query";<o:p></o:p> const char *revision = "$Revision: 2034 $";<o:p></o:p> const char *copyright = "1999-2007";<o:p></o:p> const char *email = "nagiosplug-devel@lists.sourceforge.net";<o:p></o:p> <o:p> </o:p> #include "common.h"<o:p></o:p> #include "utils.h"<o:p></o:p> #include "utils_base.h"<o:p></o:p> #include "netutils.h"<o:p></o:p> <o:p> </o:p> #include <mysql.h><o:p></o:p> #include <errmsg.h><o:p></o:p> <o:p> </o:p> char *db_user = NULL;<o:p></o:p> char *db_host = NULL;<o:p></o:p> char *db_socket = NULL;<o:p></o:p> char *db_pass = NULL;<o:p></o:p> char *db = NULL;<o:p></o:p> char *warning = NULL;<o:p></o:p> char *critical = NULL;<o:p></o:p> <o:p> </o:p> unsigned int db_port = MYSQL_PORT;<o:p></o:p> <o:p> </o:p> int process_arguments (int, char **);<o:p></o:p> int validate_arguments (void);<o:p></o:p> void print_help (void);<o:p></o:p> void print_usage (void);<o:p></o:p> <o:p> </o:p> char *sql_query = NULL;<o:p></o:p> int verbose = 0;<o:p></o:p> thresholds *my_thresholds = NULL;<o:p></o:p> <o:p> </o:p> int main (int argc, char **argv)<o:p></o:p> {<o:p></o:p> 牋牋牋 MYSQL mysql;<o:p></o:p> 牋牋牋 MYSQL_RES *res;<o:p></o:p> 牋牋牋 MYSQL_ROW row;<o:p></o:p> 牋牋牋 <o:p></o:p> 牋牋牋 char *error = NULL;<o:p></o:p> 牋牋牋 int time;<o:p></o:p> 牋牋牋 int warning_int,critical_int;<o:p></o:p> <o:p> </o:p> 牋牋牋 setlocale (LC_ALL, "");<o:p></o:p> 牋牋牋 bindtextdomain (PACKAGE, LOCALEDIR);<o:p></o:p> 牋牋牋 textdomain (PACKAGE);<o:p></o:p> <o:p> </o:p> 牋牋牋 /* Parse extra opts if any */<o:p></o:p> 牋牋牋 argv=np_extra_opts (&argc, argv, progname);<o:p></o:p> <o:p> </o:p> 牋牋牋 if (process_arguments (argc, argv) == ERROR)<o:p></o:p> 牋牋牋牋牋牋� usage4 (_("Could not parse arguments"));<o:p></o:p> <o:p> </o:p> 牋牋牋� warning_int = atoi(warning);<o:p></o:p> 牋牋牋� critical_int = atoi(critical);<o:p></o:p> <o:p> </o:p> 牋牋牋 /* initialize mysql� */<o:p></o:p> 牋牋牋 mysql_init (&mysql);<o:p></o:p> <o:p> </o:p> 牋牋牋 mysql_options(&mysql,MYSQL_READ_DEFAULT_GROUP,"client");<o:p></o:p> <o:p> </o:p> 牋牋牋 /* establish a connection to the server and error checking */<o:p></o:p> 牋牋牋 if (!mysql_real_connect(&mysql,db_host,db_user,db_pass,"",db_port,db_socket,0)) {<o:p></o:p> 牋牋牋牋牋牋� if (mysql_errno (&mysql) == CR_UNKNOWN_HOST)<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 die (STATE_WARNING, "QUERY %s: %s\n", _("WARNING"), mysql_error (&mysql));<o:p></o:p> 牋牋牋牋牋牋� else if (mysql_errno (&mysql) == CR_VERSION_ERROR)<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 die (STATE_WARNING, "QUERY %s: %s\n", _("WARNING"), mysql_error (&mysql));<o:p></o:p> 牋牋牋牋牋牋� else if (mysql_errno (&mysql) == CR_OUT_OF_MEMORY)<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 die (STATE_WARNING, "QUERY %s: %s\n", _("WARNING"), mysql_error (&mysql));<o:p></o:p> 牋牋牋牋牋牋� else if (mysql_errno (&mysql) == CR_IPSOCK_ERROR)<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 die (STATE_WARNING, "QUERY %s: %s\n", _("WARNING"), mysql_error (&mysql));<o:p></o:p> 牋牋牋牋牋牋� else if (mysql_errno (&mysql) == CR_SOCKET_CREATE_ERROR)<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 die (STATE_WARNING, "QUERY %s: %s\n", _("WARNING"), mysql_error (&mysql));<o:p></o:p> 牋牋牋牋牋牋� else<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 die (STATE_CRITICAL, "QUERY %s: %s\n", _("CRITICAL"), mysql_error (&mysql));<o:p></o:p> 牋牋牋 }<o:p></o:p> <o:p> </o:p> 牋牋牋 if (mysql_query (&mysql, "show processlist;") != 0) {<o:p></o:p> 牋牋牋牋牋牋� error = strdup(mysql_error(&mysql));<o:p></o:p> 牋牋牋牋牋牋� mysql_close (&mysql);<o:p></o:p> 牋牋牋牋牋牋� die (STATE_CRITICAL, "QUERY %s: %s - %s\n", _("CRITICAL"), _("Error with query"), error);<o:p></o:p> 牋牋牋 }<o:p></o:p> <o:p> </o:p> 牋牋牋 /* store the result */<o:p></o:p> 牋牋牋 if ( (res = mysql_store_result (&mysql)) == NULL) {<o:p></o:p> 牋牋牋牋牋牋� error = strdup(mysql_error(&mysql));<o:p></o:p> 牋牋牋牋牋牋� mysql_close (&mysql);<o:p></o:p> 牋牋牋牋牋牋� die (STATE_CRITICAL, "QUERY %s: Error with store_result - %s\n", _("CRITICAL"), error);<o:p></o:p> 牋牋牋 }<o:p></o:p> <o:p> </o:p> 牋牋牋 /* Check there is some data */<o:p></o:p> 牋牋牋 if (mysql_num_rows(res) == 0) {<o:p></o:p> 牋牋牋牋牋牋� mysql_close(&mysql);<o:p></o:p> 牋牋牋牋牋牋� die (STATE_WARNING, "QUERY %s: %s\n", _("WARNING"), _("No rows returned"));<o:p></o:p> 牋牋牋 }<o:p></o:p> <o:p> </o:p> 牋牋牋 /* fetch the first row */<o:p></o:p> 牋牋牋 while ( (row = mysql_fetch_row (res)) != NULL) {<o:p></o:p> � 牋牋牋if(strcmp(row[4],"Query") == 0)<o:p></o:p> 牋牋牋 � {<o:p></o:p> 牋牋牋牋牋� time = (int) atoi(row[5]);<o:p></o:p> 牋牋牋牋� if (time>=warning_int && time<critical_int)<o:p></o:p> 牋牋牋牋� {<o:p></o:p> 牋牋牋牋牋牋� die (STATE_WARNING, "%s QUERY time %d\n", _("WARNING"),time);<o:p></o:p> 牋牋牋牋� }<o:p></o:p> 牋牋牋牋� else if (time>=critical_int)<o:p></o:p> 牋牋牋牋� {<o:p></o:p> 牋牋牋牋牋牋� die (STATE_CRITICAL, "%s QUERY time %d\n", _("CRITICAL"),time);<o:p></o:p> 牋牋牋牋� }<o:p></o:p> 牋牋牋 � }<o:p></o:p> /**牋� � else if (strcmp(row[4],"Sleep") == 0)<o:p></o:p> 牋牋牋 � {<o:p></o:p> 牋牋牋牋牋� time = (int)atoi(row[5]);<o:p></o:p> 牋牋牋牋牋� printf("MYSQL PERFORMANCE SEEMS OK\n");<o:p></o:p> 牋牋牋牋牋� exit (STATE_OK);<o:p></o:p> 牋牋牋 � }<o:p></o:p> **/<o:p></o:p> 牋牋牋 }<o:p></o:p> <o:p> </o:p> 牋牋牋� printf("MYSQL PERFORMANCE SEEMS OK \n");<o:p></o:p> 牋牋牋 mysql_free_result (res);<o:p></o:p> 牋牋牋 mysql_close (&mysql);<o:p></o:p> 牋牋牋� exit (STATE_OK);<o:p></o:p> 牋牋牋 return 1;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> /* process command-line arguments */<o:p></o:p> int<o:p></o:p> process_arguments (int argc, char **argv)<o:p></o:p> {<o:p></o:p> 牋牋牋 int c;<o:p></o:p> 牋牋牋 int option = 0;<o:p></o:p> <o:p> </o:p> 牋牋牋 static struct option longopts[] = {<o:p></o:p> 牋牋牋牋牋牋� {"hostname", required_argument, 0, 'H'},<o:p></o:p> 牋牋牋牋牋牋� {"socket", required_argument, 0, 's'},<o:p></o:p> 牋牋牋牋牋牋� {"database", required_argument, 0, 'd'},<o:p></o:p> 牋牋牋牋牋牋� {"username", required_argument, 0, 'u'},<o:p></o:p> 牋牋牋牋牋牋� {"password", required_argument, 0, 'p'},<o:p></o:p> 牋牋牋牋牋牋� {"port", required_argument, 0, 'P'},<o:p></o:p> 牋牋牋牋牋牋� {"verbose", no_argument, 0, 'v'},<o:p></o:p> 牋牋牋牋牋牋� {"version", no_argument, 0, 'V'},<o:p></o:p> 牋牋牋牋牋牋� {"help", no_argument, 0, 'h'},<o:p></o:p> 牋牋牋牋牋牋� {"warning", required_argument, 0, 'w'},<o:p></o:p> 牋牋牋牋牋牋� {"critical", required_argument, 0, 'c'},<o:p></o:p> 牋牋牋牋牋牋� {0, 0, 0, 0}<o:p></o:p> 牋牋牋 };<o:p></o:p> <o:p> </o:p> 牋牋牋 if (argc < 1)<o:p></o:p> 牋牋牋牋牋牋� return ERROR;<o:p></o:p> <o:p> </o:p> 牋牋牋 while (1) {<o:p></o:p> 牋牋牋牋牋牋� c = getopt_long (argc, argv, "hvVSP:p:u:d:H:s:q:w:c:", longopts, &option);<o:p></o:p> <o:p> </o:p> 牋牋牋牋牋牋� if (c == -1 || c == EOF)<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> <o:p> </o:p> 牋牋牋牋牋牋� switch (c) {<o:p></o:p> 牋牋牋牋牋牋� case 'H':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* hostname */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 if (is_host (optarg)) {<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋牋牋牋� db_host = optarg;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 }<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 else {<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋牋牋牋� usage2 (_("Invalid hostname/address"), optarg);<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 }<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 's':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* socket */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 db_socket = optarg;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 'u':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* username */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 db_user = optarg;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 'p':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* authentication information: password */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 db_pass = strdup(optarg);<o:p></o:p> <o:p> </o:p> 牋牋牋牋牋牋牋牋牋牋 /* Delete the password from process list */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 while (*optarg != '\0') {<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋牋牋牋� *optarg = 'X';<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋牋牋牋� optarg++;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 }<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 'P':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* critical time threshold */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 db_port = atoi (optarg);<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 'v':<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 verbose++;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 'V':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* version */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 print_revision (progname, revision);<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 exit (STATE_OK);<o:p></o:p> 牋牋牋牋牋牋� case 'h':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* help */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 print_help ();<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 exit (STATE_OK);<o:p></o:p> 牋牋牋牋牋牋� case 'w':<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 warning = optarg;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case 'c':<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 critical = optarg;<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 break;<o:p></o:p> 牋牋牋牋牋牋� case '?':牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋牋 /* help */<o:p></o:p> 牋牋牋牋牋牋牋牋牋牋 usage5 ();<o:p></o:p> 牋牋牋牋牋牋� }<o:p></o:p> 牋牋牋 }<o:p></o:p> <o:p> </o:p> 牋牋牋 c = optind;<o:p></o:p> <o:p> </o:p> 牋牋牋 set_thresholds(&my_thresholds, warning, critical);<o:p></o:p> <o:p> </o:p> 牋牋牋 return validate_arguments ();<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> int<o:p></o:p> validate_arguments (void)<o:p></o:p> {<o:p></o:p> 牋牋牋 if (db_user == NULL)<o:p></o:p> 牋牋牋牋牋牋� db_user = strdup("");<o:p></o:p> <o:p> </o:p> 牋牋牋 if (db_host == NULL)<o:p></o:p> 牋牋牋牋牋牋� db_host = strdup("");<o:p></o:p> <o:p> </o:p> 牋牋牋 if (db_pass == NULL)<o:p></o:p> 牋牋牋牋牋牋� db_pass = strdup("");<o:p></o:p> <o:p> </o:p> 牋牋牋 if (db == NULL)<o:p></o:p> 牋牋牋牋牋牋� db = strdup("");<o:p></o:p> <o:p> </o:p> 牋牋牋 if (warning == NULL)<o:p></o:p> 牋牋牋牋牋牋� warning = strdup("3");<o:p></o:p> <o:p> </o:p> 牋牋牋 if (critical == NULL)<o:p></o:p> 牋牋牋牋牋牋� critical = strdup("10");<o:p></o:p> <o:p> </o:p> 牋牋牋 return OK;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> void<o:p></o:p> print_help (void)<o:p></o:p> {<o:p></o:p> 牋牋牋 char *myport;<o:p></o:p> 牋牋牋 asprintf (&myport, "%d", MYSQL_PORT);<o:p></o:p> <o:p> </o:p> 牋牋牋 print_revision (progname, revision);<o:p></o:p> <o:p> </o:p> 牋牋牋 printf (_(COPYRIGHT), copyright, email);<o:p></o:p> <o:p> </o:p> 牋牋牋 printf ("%s\n", _("This program checks a query result against threshold levels"));<o:p></o:p> <o:p> </o:p> � 牋牋 printf ("\n\n");<o:p></o:p> 牋牋牋 print_usage ();<o:p></o:p> <o:p> </o:p> 牋牋牋 printf (_(UT_HELP_VRSN));<o:p></o:p> 牋牋牋 printf (_(UT_EXTRA_OPTS));<o:p></o:p> 牋牋牋 printf ("牋� %s\n", _("SQL query to run. Only first column in first row will be read"));<o:p></o:p> 牋牋牋 printf (_(UT_WARN_CRIT_RANGE));<o:p></o:p> 牋牋牋 printf (_(UT_HOST_PORT), 'P', myport);<o:p></o:p> 牋牋牋 printf (" %s\n", "-s, --socket=STRING");<o:p></o:p> 牋牋牋 printf ("牋� %s\n", _("Use the specified socket (has no effect if -H is used)"));<o:p></o:p> 牋牋牋 printf (" -u, --username=STRING\n");<o:p></o:p> 牋牋牋 printf ("牋� %s\n", _("Username to login with"));<o:p></o:p> 牋牋牋 printf (" -p, --password=STRING\n");<o:p></o:p> 牋牋牋 printf ("牋� %s\n", _("Password to login with"));<o:p></o:p> 牋牋牋 printf ("牋� ==> %s <==\n", _("IMPORTANT: THIS FORM OF AUTHENTICATION IS NOT SECURE!!!"));<o:p></o:p> 牋牋牋 printf ("牋� %s\n", _("Your clear-text password could be visible as a process table entry"));<o:p></o:p> <o:p> </o:p> 牋牋牋 printf ("\n");<o:p></o:p> 牋牋牋 printf (" %s\n", _("A query is required. The result from the query should be numeric."));<o:p></o:p> 牋牋牋 printf (" %s\n", _("For extra security, create a user with minimal access."));<o:p></o:p> <o:p> </o:p> #ifdef NP_EXTRA_OPTS<o:p></o:p> 牋牋牋 printf ("\n");<o:p></o:p> 牋牋牋 printf ("%s\n", _("Notes:"));<o:p></o:p> 牋牋牋 printf (_(UT_EXTRA_OPTS_NOTES));<o:p></o:p> #endif<o:p></o:p> <o:p> </o:p> 牋牋牋 printf (_(UT_SUPPORT));<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> void<o:p></o:p> print_usage (void)<o:p></o:p> {<o:p></o:p> � printf (_("Usage:"));<o:p></o:p> � printf (" %s -q SQL_slow [-w warn] [-c crit] [-H host] [-P port] [-s socket]\n",progname);<o:p></o:p> � printf ("牋牋牋 [-d database] [-u user] [-p password]\n");<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> 囔� �<o:p></o:p> 铕潇 妃 WEB<o:p></o:p> 麇瘃轳� 铗妃<o:p></o:p> 0523-353534<o:p></o:p> <o:p> </o:p> <o:p> </o:p> </div> </body> </html>