use mysql as db store

[pulsecounter.git] / linux / dbstore.c

diff --git a/linux/dbstore.c b/linux/dbstore.c
index edd443102fdcb1e4826c72b922a7b142e8cbe3e2..395654da09f681d35921206e0103d2decbf91093 100644 (file)
--- a/linux/dbstore.c
+++ b/linux/dbstore.c
@@ -2,20 +2,39 @@
 #include <stdint.h>
 #include <time.h>
 
+#include <mysql/mysql.h>
+
 #include "dbstore.h"
 
 int dbstore(uint8_t which, uint32_t val)
 {
        time_t t;
        int i;
+       MYSQL mysql;
+       int rc = 0;
        struct tm tm;
        char buf[64];
-       char tstr[64];
+       char tstr[32];
        char *table = (which == 1) ? "coldcnt" : "hotcnt";
+       char statement[64];
 
        t = time(NULL);
        (void)gmtime_r(&t, &tm);
        (void)strftime(tstr, sizeof(tstr), "%Y-%m-%d %H:%M:%S", &tm);
-       printf("insert into %s values (\"%s\",%u);\n", table, tstr, val);
-       return 0;
+       mysql_init(&mysql);
+       if(!mysql_real_connect(&mysql, NULL, "pulsecounter",
+                               "xxxxxxxxxxxxx", "watermeter", 0, NULL, 0)) {
+               fprintf(stderr, "mysql connect error: %s\n",
+                       mysql_error(&mysql));
+               return 1;
+       }
+       snprintf(statement, sizeof(statement),
+                "insert into %s values (\"%s\",%u);\n",
+                table, tstr, val);
+       rc = mysql_query(&mysql, statement);
+       if (rc)
+               fprintf(stderr, "mysql insert \"%s\" error: %s\n",
+                       statement, mysql_error(&mysql));
+       mysql_close(&mysql);
+       return rc;
 }