X-Git-Url: http://www.average.org/gitweb/?p=pulsecounter.git;a=blobdiff_plain;f=linux%2Fdbstore.c;h=395654da09f681d35921206e0103d2decbf91093;hp=edd443102fdcb1e4826c72b922a7b142e8cbe3e2;hb=896a89d59b527f5099b38ea58aebeb6ad674ae13;hpb=bf310cc703ac0ed8be107c8f93b63d646b711f26

diff --git a/linux/dbstore.c b/linux/dbstore.c
index edd4431..395654d 100644
--- 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;
 }