aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorreinelt <>2006-01-16 15:39:58 +0000
committerreinelt <>2006-01-16 15:39:58 +0000
commit15b43c0fd012de6fbfd0e1265d4c2b5b19bf9375 (patch)
tree01acbb6e9b808607b3eefdf348658eee7193e69e
parentab8501eef2b55218e6bd683c310759e88314c6b7 (diff)
downloadlcd4linux-15b43c0fd012de6fbfd0e1265d4c2b5b19bf9375.tar.gz
[lcd4linux @ 2006-01-16 15:39:58 by reinelt]
MySQL::queryvalue() extension from Harald Klemm
Diffstat (limited to '')
-rw-r--r--plugin_mysql.c39
1 files changed, 38 insertions, 1 deletions
diff --git a/plugin_mysql.c b/plugin_mysql.c
index 66fc1ea..49af25c 100644
--- a/plugin_mysql.c
+++ b/plugin_mysql.c
@@ -1,4 +1,4 @@
-/* $Id: plugin_mysql.c,v 1.7 2005/06/06 09:24:07 reinelt Exp $
+/* $Id: plugin_mysql.c,v 1.8 2006/01/16 15:39:58 reinelt Exp $
*
* plugin for execute SQL queries into a MySQL DBSM.
*
@@ -23,6 +23,9 @@
*
*
* $Log: plugin_mysql.c,v $
+ * Revision 1.8 2006/01/16 15:39:58 reinelt
+ * MySQL::queryvalue() extension from Harald Klemm
+ *
* Revision 1.7 2005/06/06 09:24:07 reinelt
* two bugs in plugin_mysql.c fixed
*
@@ -189,6 +192,39 @@ static void my_MySQLquery(RESULT * result, RESULT * query)
SetResult(&result, R_NUMBER, &value);
}
+static void my_MySQLqueryValue(RESULT * result, RESULT * query)
+{
+ char *q;
+ double value;
+ MYSQL_RES *res;
+ MYSQL_ROW row=NULL;
+
+ if (configure_mysql() < 0) {
+ value = -1;
+ SetResult(&result, R_NUMBER, &value);
+ return;
+ }
+
+ 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);
+ row = mysql_fetch_row(res);
+ mysql_free_result(res);
+ }
+
+ SetResult(&result, R_STRING, row[0]);
+}
+
static void my_MySQLstatus(RESULT * result)
{
@@ -218,6 +254,7 @@ int plugin_init_mysql(void)
{
#ifdef HAVE_MYSQL_MYSQL_H
AddFunction("MySQL::query", 1, my_MySQLquery);
+ AddFunction("MySQL::queryvalue", 1, my_MySQLqueryValue);
AddFunction("MySQL::status", 0, my_MySQLstatus);
#endif
return 0;