--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/bmsd/mysql.c Sat Aug 04 21:19:15 2018 +0200
@@ -0,0 +1,600 @@
+/**
+ * @file mysql.c
+ * @brief MySQL/MariaDB access.
+ * @author Michiel Broek <mbroek at mbse dot eu>
+ *
+ * Copyright (C) 2018
+ *
+ * This file is part of the bms (Brewery Management System)
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation; either version 2, or (at your option) any
+ * later version.
+ *
+ * bms is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with ThermFerm; see the file COPYING. If not, write to the Free
+ * Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
+ */
+
+#include "bms.h"
+#include "xutil.h"
+#include "mysql.h"
+#include "nodes.h"
+
+
+MYSQL *con = NULL;
+MYSQL_RES *res_set;
+MYSQL_ROW row;
+
+extern sys_config Config;
+extern sys_node_list *nodes;
+extern sys_fermenter_list *fermenters;
+extern int debug;
+
+
+time_t datetime_to_time_t(char *dt_string)
+{
+ struct tm tm;
+
+ memset(&tm, 0, sizeof(struct tm));
+ tm.tm_year = atoi(strtok(dt_string, "-")) - 1900;
+ tm.tm_mon = atoi(strtok(NULL, "-")) - 1;
+ tm.tm_mday = atoi(strtok(NULL, " "));
+ tm.tm_hour = atoi(strtok(NULL, ":"));
+ tm.tm_min = atoi(strtok(NULL, ":"));
+ tm.tm_sec = atoi(strtok(NULL, "\0"));
+ tm.tm_isdst = 1;
+
+ return mktime(&tm);
+}
+
+
+
+int bms_mysql_init(void)
+{
+ sys_node_list *node, *tmpp;
+ sys_fermenter_list *fermenter, *tmpf;
+ int ncnt = 0, fcnt = 0;
+
+ con = mysql_init(NULL);
+ if (con == NULL) {
+ syslog(LOG_NOTICE, "MySQL: mysql_init() failed");
+ return 1;
+ }
+
+ if (mysql_real_connect(con, Config.mysql_host, Config.mysql_user, Config.mysql_pass, Config.mysql_database, Config.mysql_port, NULL, 0) == NULL) {
+ syslog(LOG_NOTICE, "MySQL: mysql_real_connect() %s", mysql_error(con));
+ return 2;
+ }
+
+ syslog(LOG_NOTICE, "MySQL: connected to %s:%d database %s", Config.mysql_host, Config.mysql_port, Config.mysql_database);
+ syslog(LOG_NOTICE, "MySQL: %s server info: %s", mysql_get_host_info(con), mysql_get_server_info(con));
+ if (debug)
+ fprintf(stdout, "MySQL: connected\n");
+
+ /*
+ * Restore nodes from the database
+ */
+ if (mysql_query(con, "SELECT * FROM nodes")) {
+ syslog(LOG_NOTICE, "MySQL: SELECT * FROM nodes error %u (%s))", mysql_errno(con), mysql_error(con));
+ } else {
+ res_set = mysql_store_result(con);
+ if (res_set == NULL) {
+ syslog(LOG_NOTICE, "MySQL: mysq_store_result error %u (%s))", mysql_errno(con), mysql_error(con));
+ } else {
+ // Process results
+ while ((row = mysql_fetch_row(res_set)) != NULL) {
+ node = (sys_node_list *)malloc(sizeof(sys_node_list));
+ memset(node, 0, sizeof(sys_node_list));
+ node->next = NULL;
+ node->uuid = xstrcpy(row[1]);
+ node->node = xstrcpy(row[2]);
+ node->online = false; // Will be set using MQTT
+ node->group_id = xstrcpy(row[4]);
+ node->hardwaremake = xstrcpy(row[5]);
+ node->hardwaremodel = xstrcpy(row[6]);
+ node->os = xstrcpy(row[7]);
+ node->os_version = xstrcpy(row[8]);
+ node->firmware = xstrcpy(row[9]);
+ node->firstseen = datetime_to_time_t(row[10]);
+ node->lastseen = datetime_to_time_t(row[11]);
+ node->temperature = atof(row[12]);
+ node->humidity = atof(row[13]);
+ node->barometer = atof(row[14]);
+ node->gps_latitude = atof(row[15]);
+ node->gps_longitude = atof(row[16]);
+ node->gps_altitude = atof(row[17]);
+ node->net_address = xstrcpy(row[18]);
+ node->net_ifname = xstrcpy(row[19]);
+ node->net_rssi = atoi(row[20]);
+
+ if (nodes == NULL) {
+ nodes = node;
+ } else {
+ for (tmpp = nodes; tmpp; tmpp = tmpp->next) {
+ if (tmpp->next == NULL) {
+ tmpp->next = node;
+ break;
+ }
+ }
+ }
+ ncnt++;
+ }
+ mysql_free_result(res_set);
+ }
+ }
+
+ if (mysql_query(con, "SELECT * FROM fermenters")) {
+ syslog(LOG_NOTICE, "MySQL: SELECT * FROM fermenters error %u (%s))", mysql_errno(con), mysql_error(con));
+ } else {
+ res_set = mysql_store_result(con);
+ if (res_set == NULL) {
+ syslog(LOG_NOTICE, "MySQL: mysq_store_result error %u (%s))", mysql_errno(con), mysql_error(con));
+ } else {
+ while ((row = mysql_fetch_row(res_set)) != NULL) {
+ fermenter = (sys_fermenter_list *)malloc(sizeof(sys_fermenter_list));
+ memset(fermenter, 0, sizeof(sys_fermenter_list));
+ fermenter->next = NULL;
+ fermenter->uuid = xstrcpy(row[1]);
+ fermenter->alias = xstrcpy(row[2]);
+ fermenter->node = xstrcpy(row[3]);
+ fermenter->online = false; // Will be set later
+ fermenter->beercode = xstrcpy(row[5]);
+ fermenter->beername = xstrcpy(row[6]);
+ if (strlen(row[7])) {
+ fermenter->air_address = xstrcpy(row[7]);
+ fermenter->air_state = xstrcpy(row[8]);
+ fermenter->air_temperature = atof(row[9]);
+ }
+ if (strlen(row[10])) {
+ fermenter->beer_address = xstrcpy(row[10]);
+ fermenter->beer_state = xstrcpy(row[11]);
+ fermenter->beer_temperature = atof(row[12]);
+ }
+ if (strlen(row[13])) {
+ fermenter->chiller_address = xstrcpy(row[13]);
+ fermenter->chiller_state = xstrcpy(row[14]);
+ fermenter->chiller_temperature = atof(row[15]);
+ }
+ if (strlen(row[16])) {
+ fermenter->heater_address = xstrcpy(row[16]);
+ fermenter->heater_state = atoi(row[17]);
+ fermenter->heater_usage = atoi(row[18]);
+ }
+ if (strlen(row[19])) {
+ fermenter->cooler_address = xstrcpy(row[19]);
+ fermenter->cooler_state = atoi(row[20]);
+ fermenter->cooler_usage = atoi(row[21]);
+ }
+ if (strlen(row[22])) {
+ fermenter->fan_address = xstrcpy(row[22]);
+ fermenter->fan_state = atoi(row[23]);
+ fermenter->fan_usage = atoi(row[24]);
+ }
+ if (strlen(row[25])) {
+ fermenter->light_address = xstrcpy(row[25]);
+ fermenter->light_state = atoi(row[26]);
+ fermenter->light_usage = atoi(row[27]);
+ }
+ if (strlen(row[28])) {
+ fermenter->door_address = xstrcpy(row[28]);
+ fermenter->door_state = atoi(row[29]);
+ }
+ if (strlen(row[30])) {
+ fermenter->psu_address = xstrcpy(row[30]);
+ fermenter->psu_state = atoi(row[31]);
+ }
+ fermenter->mode = xstrcpy(row[32]);
+ fermenter->alarm = atoi(row[33]);
+ fermenter->setpoint_high = atof(row[34]);
+ fermenter->setpoint_low = atof(row[35]);
+ if (strlen(row[36])) {
+ fermenter->profile_uuid = xstrcpy(row[36]);
+ fermenter->profile_name = xstrcpy(row[37]);
+ fermenter->profile_state = xstrcpy(row[38]);
+ fermenter->profile_percent = atoi(row[39]);
+ fermenter->profile_inittemp_high = atof(row[40]);
+ fermenter->profile_inittemp_low = atof(row[41]);
+ fermenter->profile_steps = xstrcpy(row[42]);
+ }
+ fermenter->stage = xstrcpy(row[43]);
+
+ if (fermenters == NULL) {
+ fermenters = fermenter;
+ } else {
+ for (tmpf = fermenters; tmpf; tmpf = tmpf->next) {
+ if (tmpf->next == NULL) {
+ tmpf->next = fermenter;
+ break;
+ }
+ }
+ }
+ fcnt++;
+ }
+ mysql_free_result(res_set);
+ }
+ }
+
+ syslog(LOG_NOTICE, "MySQL: loaded %d nodes, %d fermenters", ncnt, fcnt);
+ return 0;
+}
+
+
+
+void bms_mysql_end(void)
+{
+ sys_fermenter_list *tmpf, *oldtmpf;
+ sys_node_list *tmpn, *oldtmpn;
+
+ mysql_close(con);
+
+ syslog(LOG_NOTICE, "MySQL: disconnected");
+ if (debug)
+ fprintf(stdout, "MySQL: disconnected\n");
+
+ for (tmpf = fermenters; tmpf; tmpf = oldtmpf) {
+ oldtmpf = tmpf->next;
+ if (tmpf->uuid)
+ free(tmpf->uuid);
+ if (tmpf->alias)
+ free(tmpf->alias);
+ if (tmpf->node)
+ free(tmpf->node);
+ if (tmpf->beercode)
+ free(tmpf->beercode);
+ if (tmpf->beername)
+ free(tmpf->beername);
+ if (tmpf->air_address)
+ free(tmpf->air_address);
+ if (tmpf->air_state)
+ free(tmpf->air_state);
+ if (tmpf->beer_address)
+ free(tmpf->beer_address);
+ if (tmpf->beer_state)
+ free(tmpf->beer_state);
+ if (tmpf->chiller_address)
+ free(tmpf->chiller_address);
+ if (tmpf->chiller_state)
+ free(tmpf->chiller_state);
+ if (tmpf->heater_address)
+ free(tmpf->heater_address);
+ if (tmpf->cooler_address)
+ free(tmpf->cooler_address);
+ if (tmpf->fan_address)
+ free(tmpf->fan_address);
+ if (tmpf->light_address)
+ free(tmpf->light_address);
+ if (tmpf->door_address)
+ free(tmpf->door_address);
+ if (tmpf->psu_address)
+ free(tmpf->psu_address);
+ if (tmpf->mode)
+ free(tmpf->mode);
+ if (tmpf->stage)
+ free(tmpf->stage);
+ if (tmpf->profile_uuid)
+ free(tmpf->profile_uuid);
+ if (tmpf->profile_name)
+ free(tmpf->profile_name);
+ if (tmpf->profile_state)
+ free(tmpf->profile_state);
+ if (tmpf->profile_steps)
+ free(tmpf->profile_steps);
+ free(tmpf);
+ }
+ for (tmpn = nodes; tmpn; tmpn = oldtmpn) {
+ oldtmpn = tmpn->next;
+ if (tmpn->uuid)
+ free(tmpn->uuid);
+ if (tmpn->node)
+ free(tmpn->node);
+ if (tmpn->group_id)
+ free(tmpn->group_id);
+ if (tmpn->hardwaremake)
+ free(tmpn->hardwaremake);
+ if (tmpn->hardwaremodel)
+ free(tmpn->hardwaremodel);
+ if (tmpn->os)
+ free(tmpn->os);
+ if (tmpn->os_version)
+ free(tmpn->os_version);
+ if (tmpn->firmware)
+ free(tmpn->firmware);
+ if (tmpn->net_address)
+ free(tmpn->net_address);
+ if (tmpn->net_ifname)
+ free(tmpn->net_ifname);
+ free(tmpn);
+ }
+}
+
+
+
+void bms_mysql_ping(void)
+{
+}
+
+
+
+void node_mysql_insert(sys_node_list *node)
+{
+ char *query = malloc(512), first[21], last[21];
+ struct tm *mytime;
+
+ mytime = localtime(&node->firstseen);
+ snprintf(first, 20, "%04d-%02d-%02d %02d:%02d:%02d",
+ mytime->tm_year + 1900, mytime->tm_mon + 1, mytime->tm_mday, mytime->tm_hour, mytime->tm_min, mytime->tm_sec);
+ mytime = localtime(&node->lastseen);
+ snprintf(last, 20, "%04d-%02d-%02d %02d:%02d:%02d",
+ mytime->tm_year + 1900, mytime->tm_mon + 1, mytime->tm_mday, mytime->tm_hour, mytime->tm_min, mytime->tm_sec);
+
+ snprintf(query, 511,
+ "INSERT INTO nodes SET uuid='%s', node='%s', online='%s', group_id='%s', " \
+ "hardwaremake='%s', hardwaremodel='%s', os='%s', os_version='%s', firmware='%s', firstseen='%s', lastseen='%s', " \
+ "temperature='%.3f', humidity='%.3f', barometer='%.3f', gps_latitude='%.8f', gps_longitude='%.8f', gps_altitude='%.8f', " \
+ "net_address='%s', net_ifname='%s', net_rssi='%d'",
+ node->uuid, node->node, node->online ?"Y":"N", node->group_id,
+ node->hardwaremake, node->hardwaremodel, node->os, node->os_version, node->firmware, first, last,
+ node->temperature, node->humidity, node->barometer, node->gps_latitude, node->gps_longitude, node->gps_altitude,
+ node->net_address, node->net_ifname, node->net_rssi);
+
+ if (mysql_query(con, query)) {
+ syslog(LOG_NOTICE, "MySQL: INSERT INTO nodes error %u (%s))", mysql_errno(con), mysql_error(con));
+ } else {
+ syslog(LOG_NOTICE, "MySQL: insert new node %s", node->node);
+ }
+
+ free(query);
+}
+
+
+
+void node_mysql_update(sys_node_list *node)
+{
+ char *query = malloc(512), last[21];
+ struct tm *mytime;
+
+ mytime = localtime(&node->lastseen);
+ snprintf(last, 20, "%04d-%02d-%02d %02d:%02d:%02d",
+ mytime->tm_year + 1900, mytime->tm_mon + 1, mytime->tm_mday, mytime->tm_hour, mytime->tm_min, mytime->tm_sec);
+
+ snprintf(query, 511,
+ "UPDATE nodes SET online='%s', hardwaremake='%s', hardwaremodel='%s', os='%s', os_version='%s', firmware='%s', lastseen='%s', " \
+ "temperature='%.3f', humidity='%.3f', barometer='%.3f', gps_latitude='%.8f', gps_longitude='%.8f', gps_altitude='%.8f', " \
+ "net_address='%s', net_ifname='%s', net_rssi='%d' WHERE uuid='%s'",
+ node->online ?"Y":"N", node->hardwaremake, node->hardwaremodel, node->os, node->os_version, node->firmware, last,
+ node->temperature, node->humidity, node->barometer, node->gps_latitude, node->gps_longitude, node->gps_altitude,
+ node->net_address, node->net_ifname, node->net_rssi, node->uuid);
+
+ if (mysql_query(con, query)) {
+ syslog(LOG_NOTICE, "MySQL: UPDATE nodes error %u (%s))", mysql_errno(con), mysql_error(con));
+ }
+
+ free(query);
+}
+
+
+
+void node_mysql_death(char *node)
+{
+ char *query = malloc(512);
+
+ snprintf(query, 511, "UPDATE nodes SET online='N' WHERE node='%s'", node);
+// printf("%s\n", query);
+
+ if (mysql_query(con, query)) {
+ syslog(LOG_NOTICE, "MySQL: UPDATE nodes error %u (%s))", mysql_errno(con), mysql_error(con));
+ }
+
+ free(query);
+}
+
+
+
+void fermenter_mysql_insert(sys_fermenter_list *fermenter)
+{
+ char *query = malloc(2560);
+
+ snprintf(query, 2559,
+ "INSERT INTO fermenters SET uuid='%s', alias='%s', node='%s', online='%s', " \
+ "beercode='%s', beername='%s', " \
+ "air_address='%s', air_state='%s', air_temperature='%.3f', " \
+ "beer_address='%s', beer_state='%s', beer_temperature='%.3f', " \
+ "chiller_address='%s', chiller_state='%s', chiller_temperature='%.3f', " \
+ "heater_address='%s', heater_state='%d', heater_usage='%lu', " \
+ "cooler_address='%s', cooler_state='%d', cooler_usage='%lu', " \
+ "fan_address='%s', fan_state='%d', fan_usage='%lu', " \
+ "light_address='%s', light_state='%d', light_usage='%lu', " \
+ "door_address='%s', door_state='%d', " \
+ "psu_address='%s', psu_state='%d', " \
+ "mode='%s', alarm='%d', setpoint_high='%.3f', setpoint_low='%.3f', " \
+ "profile_uuid='%s', profile_name='%s', profile_state='%s', profile_percent='%d', " \
+ "profile_inittemp_high='%.3f', profile_inittemp_low='%.3f', profile_steps='%s', stage='%s'",
+ fermenter->uuid, fermenter->alias, fermenter->node, fermenter->online ? "Y":"N",
+ fermenter->beercode ? fermenter->beercode : "", fermenter->beername ? fermenter->beername : "",
+ fermenter->air_address ? fermenter->air_address : "", fermenter->air_state ? fermenter->air_state : "", fermenter->air_temperature,
+ fermenter->beer_address ? fermenter->beer_address : "", fermenter->beer_state ? fermenter->beer_state : "", fermenter->beer_temperature,
+ fermenter->chiller_address ? fermenter->chiller_address : "", fermenter->chiller_state ? fermenter->chiller_state : "", fermenter->chiller_temperature,
+ fermenter->heater_address ? fermenter->heater_address : "", fermenter->heater_state, fermenter->heater_usage,
+ fermenter->cooler_address ? fermenter->cooler_address : "", fermenter->cooler_state, fermenter->cooler_usage,
+ fermenter->fan_address ? fermenter->fan_address : "", fermenter->fan_state, fermenter->fan_usage,
+ fermenter->light_address ? fermenter->light_address : "", fermenter->light_state, fermenter->light_usage,
+ fermenter->door_address ? fermenter->door_address : "", fermenter->door_state,
+ fermenter->psu_address ? fermenter->psu_address : "", fermenter->psu_state,
+ fermenter->mode, fermenter->alarm, fermenter->setpoint_high, fermenter->setpoint_low,
+ fermenter->profile_uuid ? fermenter->profile_uuid : "", fermenter->profile_name ? fermenter->profile_name : "",
+ fermenter->profile_state ? fermenter->profile_state : "", fermenter->profile_percent,
+ fermenter->profile_inittemp_high, fermenter->profile_inittemp_low,
+ fermenter->profile_steps ? fermenter->profile_steps : "", fermenter->stage);
+
+// printf("%s\n", query);
+
+ if (mysql_query(con, query)) {
+ syslog(LOG_NOTICE, "MySQL: INSERT INTO fermenters error %u (%s))", mysql_errno(con), mysql_error(con));
+ } else {
+ syslog(LOG_NOTICE, "MySQL: insert new fermenter %s/%s", fermenter->node, fermenter->alias);
+ }
+
+ free(query);
+}
+
+
+void fermenter_mysql_update(sys_fermenter_list *fermenter)
+{
+ char *query = malloc(2560);
+
+ snprintf(query, 2559,
+ "UPDATE fermenters SET online='%s', beercode='%s', beername='%s', " \
+ "air_address='%s', air_state='%s', air_temperature='%.3f', " \
+ "beer_address='%s', beer_state='%s', beer_temperature='%.3f', " \
+ "chiller_address='%s', chiller_state='%s', chiller_temperature='%.3f', " \
+ "heater_address='%s', heater_state='%d', heater_usage='%lu', " \
+ "cooler_address='%s', cooler_state='%d', cooler_usage='%lu', " \
+ "fan_address='%s', fan_state='%d', fan_usage='%lu', " \
+ "light_address='%s', light_state='%d', light_usage='%lu', " \
+ "door_address='%s', door_state='%d', " \
+ "psu_address='%s', psu_state='%d', " \
+ "mode='%s', alarm='%d', setpoint_high='%.3f', setpoint_low='%.3f', " \
+ "profile_uuid='%s', profile_name='%s', profile_state='%s', profile_percent='%d', " \
+ "profile_inittemp_high='%.3f', profile_inittemp_low='%.3f', profile_steps='%s', stage='%s' WHERE uuid='%s'",
+ fermenter->online ? "Y":"N", fermenter->beercode ? fermenter->beercode : "", fermenter->beername ? fermenter->beername : "",
+ fermenter->air_address ? fermenter->air_address : "", fermenter->air_state ? fermenter->air_state : "", fermenter->air_temperature,
+ fermenter->beer_address ? fermenter->beer_address : "", fermenter->beer_state ? fermenter->beer_state : "", fermenter->beer_temperature,
+ fermenter->chiller_address ? fermenter->chiller_address : "", fermenter->chiller_state ? fermenter->chiller_state : "", fermenter->chiller_temperature,
+ fermenter->heater_address ? fermenter->heater_address : "", fermenter->heater_state, fermenter->heater_usage,
+ fermenter->cooler_address ? fermenter->cooler_address : "", fermenter->cooler_state, fermenter->cooler_usage,
+ fermenter->fan_address ? fermenter->fan_address : "", fermenter->fan_state, fermenter->fan_usage,
+ fermenter->light_address ? fermenter->light_address : "", fermenter->light_state, fermenter->light_usage,
+ fermenter->door_address ? fermenter->door_address : "", fermenter->door_state,
+ fermenter->psu_address ? fermenter->psu_address : "", fermenter->psu_state,
+ fermenter->mode, fermenter->alarm, fermenter->setpoint_high, fermenter->setpoint_low,
+ fermenter->profile_uuid ? fermenter->profile_uuid : "", fermenter->profile_name ? fermenter->profile_name : "",
+ fermenter->profile_state ? fermenter->profile_state : "", fermenter->profile_percent,
+ fermenter->profile_inittemp_high, fermenter->profile_inittemp_low,
+ fermenter->profile_steps ? fermenter->profile_steps : "", fermenter->stage, fermenter->uuid);
+
+// printf("%s\n", query);
+
+ if (mysql_query(con, query)) {
+ syslog(LOG_NOTICE, "MySQL: UPDATE fermenters error %u (%s))", mysql_errno(con), mysql_error(con));
+ }
+
+ free(query);
+}
+
+
+
+void fermenter_mysql_death(char *node, char *alias)
+{
+ char *query = malloc(512);
+
+ if (alias)
+ snprintf(query, 511, "UPDATE fermenters SET online='N' WHERE node='%s' and alias='%s'", node, alias);
+ else
+ snprintf(query, 511, "UPDATE fermenters SET online='N' WHERE node='%s'", node);
+
+ if (mysql_query(con, query)) {
+ syslog(LOG_NOTICE, "MySQL: UPDATE fermenters error %u (%s))", mysql_errno(con), mysql_error(con));
+ }
+
+ free(query);
+}
+
+
+
+void fermentation_mysql_log(fermentation_log *log)
+{
+ char *query, buf[65];
+
+ query = xstrcpy((char *)"INSERT INTO log_fermentation SET datetime='");
+ query = xstrcat(query, log->datetime);
+ query = xstrcat(query, (char *)":00");
+ if (log->product_uuid) {
+ query = xstrcat(query, (char *)"', product_uuid='");
+ query = xstrcat(query, log->product_uuid);
+ }
+ if (log->product_code) {
+ query = xstrcat(query, (char *)"', product_code='");
+ query = xstrcat(query, log->product_code);
+ }
+ if (log->product_name) {
+ query = xstrcat(query, (char *)"', product_name='");
+ query = xstrcat(query, log->product_name);
+ }
+ query = xstrcat(query, (char *)"', stage='");
+ query = xstrcat(query, log->stage);
+ query = xstrcat(query, (char *)"', mode='");
+ query = xstrcat(query, log->mode);
+ query = xstrcat(query, (char *)"', temperature_beer='");
+ snprintf(buf, 64, "%.3f", log->temperature_beer);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', temperature_air='");
+ snprintf(buf, 64, "%.3f", log->temperature_air);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', temperature_chiller='");
+ snprintf(buf, 64, "%.3f", log->temperature_chiller);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', temperature_room='");
+ snprintf(buf, 64, "%.3f", log->temperature_room);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', target_low='");
+ snprintf(buf, 64, "%.1f", log->setpoint_low);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', target_high='");
+ snprintf(buf, 64, "%.1f", log->setpoint_high);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', heater_power='");
+ snprintf(buf, 64, "%d", log->heater_power);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', heater_usage='");
+ snprintf(buf, 64, "%ld", log->heater_usage);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', cooler_power='");
+ snprintf(buf, 64, "%d", log->cooler_power);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', cooler_usage='");
+ snprintf(buf, 64, "%ld", log->cooler_usage);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', fan_power='");
+ snprintf(buf, 64, "%d", log->fan_power);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"', fan_usage='");
+ snprintf(buf, 64, "%ld", log->fan_usage);
+ query = xstrcat(query, buf);
+ query = xstrcat(query, (char *)"'");
+ // sg
+ if (log->event) {
+ query = xstrcat(query, (char *)", event='");
+ query = xstrcat(query, log->event);
+ query = xstrcat(query, (char *)"'");
+ }
+ if (log->fermenter_uuid) {
+ query = xstrcat(query, (char *)", fermenter_uuid='");
+ query = xstrcat(query, log->fermenter_uuid);
+ query = xstrcat(query, (char *)"'");
+ }
+ if (log->fermenter_node) {
+ query = xstrcat(query, (char *)", fermenter_node='");
+ query = xstrcat(query, log->fermenter_node);
+ query = xstrcat(query, (char *)"'");
+ }
+ if (log->fermenter_alias) {
+ query = xstrcat(query, (char *)", fermenter_alias='");
+ query = xstrcat(query, log->fermenter_alias);
+ query = xstrcat(query, (char *)"'");
+ }
+
+ if (mysql_real_query(con, query, strlen(query))) {
+ syslog(LOG_NOTICE, "MySQL: `%s' error %u (%s)\n)", query, mysql_errno(con), mysql_error(con));
+ }
+
+ free(query);
+}
+
+