[lcd4linux @ 2004-03-20 23:09:01 by reinelt]

MySQL plugin fixes from Javi

git-svn-id: https://ssl.bulix.org/svn/lcd4linux/trunk@407 3ae390bd-cb1e-0410-b409-cd5a39f66f1f

diff --git a/lcd4linux.conf.sample b/lcd4linux.conf.sample
index e5a3f483a0090a9380a3dacdf74db23d112554f3..971e55965fd5446faa5cdf973d0bb3bf104ee902 100644 (file)
--- a/lcd4linux.conf.sample
+++ b/lcd4linux.conf.sample
@@ -101,6 +101,14 @@ Plugin Seti {
 }
 
 
+Plugin MySQL {
+    server 'gsmlandia.com'     # if none, localhost assumed
+    port 3306                  # if none, MySQL default assumed
+    user 'lcd4linux'           # if none, lcd4linux unix owner assumed
+    password 'lcd4linux'       # if none, empty password assumed
+    database 'lcd4linux'       # MUST be specified
+}
+
 Widget OS {
     class 'Text'
     expression '*** '.uname('sysname').' '.uname('release').' ***'
@@ -213,6 +221,24 @@ Widget Eth0Bar {
     update tack
 }
 
+Widget MySQLtest1 {
+       class 'Text'
+       expression MySQLquery('SELECT id FROM table1')
+       width 8
+       align 'R'
+       prefix 'MySQL'
+       update minute
+}
+
+Widget MySQLtest2 {
+       class 'Text'
+       expression MySQLstatus()
+       width 20
+       align 'M'
+       prefix 'Status: '
+       update minute
+}
+
 Widget Heartbeat {
     class 'Icon'
     speed 800
@@ -411,6 +437,18 @@ Layout Test {
 #    Row16.Col1 'Test'
 }
 
+
+Layout testMySQL {
+       Row1 {
+               Col1 'Heartbeat'
+               Col2 'MySQLtest1'
+       }
+       Row2 {
+               Col1 'MySQLtest2'
+       }
+}
+
+
 #Display 'LK204'
 #Display 'HD44780-20x4'
 #Display 'M50530-24x8'

diff --git a/plugin_mysql.c b/plugin_mysql.c
index 8f855802512e22351f14f8b1e8f8390ee71685f7..e234dc903c11b8191b653b7ab50a515c62d3ecd7 100644 (file)
--- a/plugin_mysql.c
+++ b/plugin_mysql.c
@@ -1,4 +1,4 @@
-/* $Id: plugin_mysql.c,v 1.1 2004/03/10 07:16:15 reinelt Exp $
+/* $Id: plugin_mysql.c,v 1.2 2004/03/20 23:09:01 reinelt Exp $
  *
  * plugin for execute SQL queries into a MySQL DBSM.
  *
@@ -23,6 +23,9 @@
  *
  *
  * $Log: plugin_mysql.c,v $
+ * Revision 1.2  2004/03/20 23:09:01  reinelt
+ * MySQL plugin fixes from Javi
+ *
  * Revision 1.1  2004/03/10 07:16:15  reinelt
  * MySQL plugin from Javier added
  *
@@ -38,11 +41,12 @@
  * int plugin_init_mysql (void)
  *
  *  adds various functions:
- *     mySQLquery(server,login,pass,database,query) 
- *        Returns the number of rows in a query.
- *     mySQLstatus(server,login,pass)
+ *     MySQLquery(query) 
+ *        Returns the number of rows in query.
+ *     MySQLstatus()
  *        Returns the current server status:
- *        Uptime, Threads, Questions,Slow queries, Flush tables,...
+ *        Uptime in seconds and the number of running threads,
+ *        questions, reloads, and open tables.
  *
  */
 
@@ -52,6 +56,7 @@
 #include <ctype.h>
 #include "debug.h"
 #include "plugin.h"
+#include "cfg.h"
 
 #ifdef HAVE_MYSQL_MYSQL_H
 #include <mysql/mysql.h>
@@ -65,74 +70,52 @@
 
 
 #ifdef HAVE_MYSQL_MYSQL_H
-static void my_mySQLquery (RESULT *result, RESULT *server, RESULT *login, RESULT *pass, RESULT *database, RESULT *query)
+static MYSQL conex;
+
+static char Section[] = "Plugin:MySQL";
+
+static void my_MySQLquery (RESULT *result, RESULT *query)
 {
-       double value;
-       MYSQL conex;
-       MYSQL_RES *res;
-       char *s=R2S(server);
-       char *l=R2S(login);
-       char *p=R2S(pass);
-       char *db=R2S(database);
-       char *q=R2S(query);
-       
-       mysql_init(&conex);
-       if (!mysql_real_connect(&conex,s,l,p,db,0,NULL,0))
-       {
-               error( "mySQL conection error: %s",mysql_error(&conex));
-               value=-1;
-       }
-       else
-       {
-               if (mysql_real_query(&conex,q,(unsigned int) strlen(q)))
-               {
-                       error( "mySQL query error: %s",mysql_error(&conex));
-                       value=-2;
-               }
-               else
-               {
-                       /* We don't use res=mysql_use_result();  because mysql_num_rows() will not
-                        return the correct value until all the rows in the result set have been retrieved
-                         with mysql_fetch_row(), so we use res=mysql_store_result(); instead */
-                       res=mysql_store_result(&conex);  
-                       value = (double) mysql_num_rows(res);
-                       mysql_free_result(res);
-               }
-       }
-       mysql_close(&conex);
-       SetResult(&result, R_NUMBER, &value); 
+  double value;
+  MYSQL_RES *res;
+  char *q=R2S(query);
+  
+  /* mysql_ping(MYSQL *mysql) checks whether the connection to the server is working.
+     If it has gone down, an automatic reconnection is attempted. */
+  mysql_ping(&conex);
+  if (mysql_real_query(&conex,q,(unsigned int) strlen(q)))
+  {
+    error( "[MySQL] query error: %s",mysql_error(&conex));
+    value=-1;
+  }
+  else
+    {
+    /* We don't use res=mysql_use_result();  because mysql_num_rows() will not
+       return the correct value until all the rows in the result set have been retrieved
+       with mysql_fetch_row(), so we use res=mysql_store_result(); instead */
+    res=mysql_store_result(&conex);   
+    value = (double) mysql_num_rows(res);
+    mysql_free_result(res);
+  }
+
+  SetResult(&result, R_NUMBER, &value); 
 }
 
-static void my_mySQLstatus (RESULT *result, RESULT *server, RESULT *login, RESULT *pass)
+static void my_MySQLstatus (RESULT *result)
 {
-       char *value;
-       MYSQL conex;
-       char *s=R2S(server);
-       char *l=R2S(login);
-       char *p=R2S(pass);
-       char *status;
-       
-       mysql_init(&conex);
-       if (!mysql_real_connect(&conex,s,l,p,NULL,0,NULL,0))
-       {
-               error( "mySQL conection error: %s",mysql_error(&conex));
-               value="error";
-       }
-       else
-       {
-               status=strdup(mysql_stat(&conex));
-               if (!status)
-               {
-                       error( "mySQLstatus error: %s",mysql_error(&conex));
-                       value="error";
-               }
-               else
-               {
-                       value = status;
-               }
-       }
-       mysql_close(&conex);
-       SetResult(&result, R_STRING, value); 
+  char *value;
+  char *status;
+  
+  mysql_ping(&conex);
+  status=strdup(mysql_stat(&conex));
+  if (!status)
+  {
+    error( "[MySQL] status error: %s",mysql_error(&conex));
+    value="error";
+  }
+  else value = status;
+  
+  SetResult(&result, R_STRING, value); 
 }
 
 #endif
@@ -140,12 +123,68 @@ static void my_mySQLstatus (RESULT *result, RESULT *server, RESULT *login, RESUL
 int plugin_init_mysql (void)
 {
 #ifdef HAVE_MYSQL_MYSQL_H
-  AddFunction ("mySQLquery",    5, my_mySQLquery);
-  AddFunction ("mySQLstatus",   3, my_mySQLstatus);
+  char server[256];
+  unsigned int port;
+  char user[128];
+  char password[256];
+  char database[256];  
+
+  char *s = cfg_get (Section, "server", "localhost");
+  if (*s=='\0') {
+    info ("[MySQL] empty '%s.server' entry from %s, assuming 'localhost'", Section, cfg_source());
+    strcpy(server,"localhost"); 
+  }
+  else strcpy(server,s);
+  free(s);
+  
+  if (cfg_number(Section, "port", 0, 1, 65536, &port)<1) {
+    /* using * as default port because mysql_real_connect() will convert it to real default one */
+    info ("[MySQL] no '%s.port' entry from %s using MySQL's default", Section, cfg_source());
+  }
+
+  s = cfg_get (Section, "user", "");
+  if (*s=='\0') {
+    /* If user is NULL or the empty string "", the lcd4linux Unix user is assumed. */
+    info ("[MySQL] empty '%s.user' entry from %s, assuming lcd4linux owner", Section, cfg_source());
+    strcpy(user,""); 
+  }
+  else strcpy(user,s);
+  free(s);   
+
+  s = cfg_get (Section, "password","");
+  /*Do not encrypt the password because encryption is handled automatically
+   by the MySQL client API.*/  
+  if (*s=='\0') {
+    info ("[MySQL] empty '%s.password' entry in %s, assuming none", Section, cfg_source());
+    strcpy(password,""); 
+  }
+  else strcpy(password,s);
+  free(s);  
+  
+  s = cfg_get (Section, "database","\0");
+  if (*s=='\0') {
+    error ("[MySQL] no '%s:database' entry from %s, specify one", Section, cfg_source());
+  }
+  else {
+    strcpy(database,s);
+    free(s);  
+    
+    mysql_init(&conex);
+    if (!mysql_real_connect(&conex,server,user,password,database,port,NULL,0))
+      error( "[MySQL] conection error: %s",mysql_error(&conex));
+    else
+    {
+      AddFunction ("MySQL::query",  1, my_MySQLquery);
+      AddFunction ("MySQL::status", 0, my_MySQLstatus);
+    }
+  }
 #endif
   return 0;
 }
 
 void plugin_exit_mysql(void) 
 {
+#ifdef HAVE_MYSQL_MYSQL_H
+  mysql_close(&conex);
+#endif
 }