Fixed a dozen typos. Completed the insert statement
This commit is contained in:
@@ -92,18 +92,18 @@ int cfgreadcompareidvalue(int element) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
char *cfgreadDatabaseUser(void) {
|
const char *cfgreadDatabaseUser(void) {
|
||||||
const char *databseuser;
|
const char *databaseuser;
|
||||||
if (!config_setting_lookup_string(cfg, "databaseuser", databaseuser)) {
|
if (!config_lookup_string(&cfg, "databaseuser", &databaseuser)) {
|
||||||
continue;
|
databaseuser = "dhtuser";
|
||||||
}
|
}
|
||||||
return databaseuser;
|
return databaseuser;
|
||||||
}
|
}
|
||||||
|
|
||||||
int cfgreadNodeRefreshRate(void) {
|
int cfgreadNodeRefreshRate(void) {
|
||||||
int refreshRate = 60; //Default value
|
int refreshRate;
|
||||||
if (!config_setting_lookup_int(cfg, "refreshRate", &refreshRate)) {
|
if (!config_lookup_int(&cfg, "refreshRate", &refreshRate)) {
|
||||||
continue;
|
refreshRate = 60; //Default value
|
||||||
}
|
}
|
||||||
return refreshRate;
|
return refreshRate;
|
||||||
}
|
}
|
||||||
|
@@ -18,7 +18,7 @@ int cfgreadpinamount(void);
|
|||||||
int cfgreadsensornodes(sensornode *nodes, int nodecount);
|
int cfgreadsensornodes(sensornode *nodes, int nodecount);
|
||||||
int cfgreadcompareidamount(void); //currently unused but will be necessary if there'll be any node filters
|
int cfgreadcompareidamount(void); //currently unused but will be necessary if there'll be any node filters
|
||||||
int cfgreadcompareidvalue(int element); //same
|
int cfgreadcompareidvalue(int element); //same
|
||||||
char *cfgreadDatabaseUser(void);
|
const char *cfgreadDatabaseUser(void);
|
||||||
int cfgreadNodeRefreshRate(void);
|
int cfgreadNodeRefreshRate(void);
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
@@ -96,12 +96,12 @@ int main(void) {
|
|||||||
for (j = 0; j < nodecount; j++) {
|
for (j = 0; j < nodecount; j++) {
|
||||||
if (nodedata[j].isoutside == 0) {
|
if (nodedata[j].isoutside == 0) {
|
||||||
//This node is a indoor node
|
//This node is a indoor node
|
||||||
avtemp_in += nodedate[j].temperature;
|
avtemp_in += nodedata[j].temperature;
|
||||||
avhum_in += nodedata[j].humidity;
|
avhum_in += nodedata[j].humidity;
|
||||||
inCount++;
|
inCount++;
|
||||||
} else {
|
} else {
|
||||||
//This node is a outdoor node
|
//This node is a outdoor node
|
||||||
avtemp_out += nodedate[j].temperature;
|
avtemp_out += nodedata[j].temperature;
|
||||||
avhum_out += nodedata[j].humidity;
|
avhum_out += nodedata[j].humidity;
|
||||||
outCount++;
|
outCount++;
|
||||||
}
|
}
|
||||||
@@ -115,8 +115,8 @@ int main(void) {
|
|||||||
float avgOutsideHumidity = avhum_in / outCount;
|
float avgOutsideHumidity = avhum_in / outCount;
|
||||||
|
|
||||||
//Insert the results into the database
|
//Insert the results into the database
|
||||||
insertDataAverages(avgInsideTemperature, avgInsideHumidity, absoluteHumidityFloat(avgInsideTemperature, avgInsideHumidity));
|
//insertDataAverages(avgInsideTemperature, avgInsideHumidity, absoluteHumidityFloat(avgInsideTemperature, avgInsideHumidity));
|
||||||
insertDataAverages(avgOutsideTemperature, avgOutsideHumidity, absoluteHumidityFloat(avgOutsideTemperature, avgOutsideHumidity));
|
//insertDataAverages(avgOutsideTemperature, avgOutsideHumidity, absoluteHumidityFloat(avgOutsideTemperature, avgOutsideHumidity));
|
||||||
|
|
||||||
|
|
||||||
//free
|
//free
|
||||||
|
@@ -66,7 +66,7 @@ void insertData(sensor *s) {
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
void insertDataAverages(float temperature, float humidity, float gm3) {
|
void insertDataAverages(float temperature, float humidity, float gm3, int isoutside) {
|
||||||
MYSQL *conn;
|
MYSQL *conn;
|
||||||
//MYSQL_RES *res;
|
//MYSQL_RES *res;
|
||||||
//MYSQL_ROW row;
|
//MYSQL_ROW row;
|
||||||
@@ -101,9 +101,8 @@ void insertDataAverages(float temperature, float humidity, float gm3) {
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
char *pquerystring = NULL;
|
char *pquerystring = NULL;
|
||||||
//TODO adjust query string
|
|
||||||
if (-1 == asprintf(&pquerystring,
|
if (-1 == asprintf(&pquerystring,
|
||||||
"INSERT INTO stats (node_id, pin, humidity, temperature, isoutside, gm3) VALUES (%i, %i, %f, %f, %i, %f)", s->node_id, s->pin, s->humidity, s->temperature, s->isoutside, absoluteHumidity(s))) {
|
"INSERT INTO stats (humidity, temperature, gm3, isoutside) VALUES (%f, %f, %f, %i)", humidity, temperature, absoluteHumidityFloat(temperature, humidity), isoutside)) {
|
||||||
perror("asprintf() failed");
|
perror("asprintf() failed");
|
||||||
} else {
|
} else {
|
||||||
if (mysql_query(conn, pquerystring)) {
|
if (mysql_query(conn, pquerystring)) {
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
#include "dht22.h"
|
#include "dht22.h"
|
||||||
|
|
||||||
void insertData(sensor *s);
|
void insertData(sensor *s);
|
||||||
void insertDataAverages(float temperature, float humidity, float gm3;
|
void insertDataAverages(float temperature, float humidity, float gm3, int isoutside);
|
||||||
|
Reference in New Issue
Block a user