raspberrypi/sensor-data-upload/main.c

101 lines
2.7 KiB
C

#include "main.h"
void printResult(MYSQL * mysqlPrint) // 打印结果集(此处传入指针,而非内容)
{
MYSQL_RES *result;
int i;
int numFields = 0;
int numRows = 0;
MYSQL_FIELD *field;
MYSQL_ROW row;
result = mysql_store_result(mysqlPrint); // 将查询的全部结果读取到客户端
numFields = mysql_num_fields(result); // 统计结果集中的字段数
numRows = mysql_num_rows(result); // 统计结果集的行数
while ((field = mysql_fetch_field(result))) // 返回结果集中的列信息(字段)
printf("%s\t", field->name);
printf("\n");
if (result) {
while ((row = mysql_fetch_row(result))) // 返回结果集中行的记录
{
for (i = 0; i < numFields; i++) {
printf("%s\t", row[i]);
}
printf("\n");
}
}
mysql_free_result(result); // 释放result空间
}
int main(int argc, char *argv[], char **env)
{
FILE *fp;
char temperature[BUFFER];
char time[BUFFER];
char dht11[BUFFER];
char sql_insert[BUFFER];
char system[BUFFER];
fp = NULL;
bzero(temperature, 0);
bzero(time, 0);
bzero(dht11, 0);
bzero(sql_insert, 0);
bzero(system, 0);
fp = popen("/root/gpio/wind -d 28", "r");
fgets(temperature, sizeof(temperature), fp);
temperature[strlen(temperature) - 1] = 0;
fp = popen("date '+%y%m%d%H%M%S'", "r");
fgets(time, sizeof(time), fp);
time[strlen(time) - 1] = 0;
pclose(fp);
fp = popen("/root/gpio/dht11 29", "r");
fgets(dht11, sizeof(dht11), fp);
dht11[strlen(dht11) - 1] = 0;
printf("%s\n", dht11);
pclose(fp);
fp = popen("getcpudata | xargs", "r");
fgets(system, sizeof(system), fp);
system[strlen(system) - 1] = 0;
printf("%s\n", system);
pclose(fp);
sprintf(sql_insert, "INSERT INTO temperature (time, temperature, dht11, SYSTEM) VALUES ('%s', '%s', '%s', '%s');", time, temperature, dht11, system);
puts(sql_insert);
MYSQL mysql;
mysql_init(&mysql);
if (mysql_real_connect(&mysql, "git.aixiao.me", "root", "198", "mysql", 3306, NULL, 0)) {
;
} else {
fprintf(stderr, "Connect failed:\n");
if (mysql_errno(&mysql)) {
printf("\terror code is %d\n\treason:%s\n", mysql_errno(&mysql), mysql_error(&mysql));
}
goto shutdown;
}
if (0 != mysql_set_character_set(&mysql, "utf8"))
{
perror("mysql_set_character_set");
}
mysql_query(&mysql, "use raspberrypi;");
mysql_query(&mysql, sql_insert);
mysql_query(&mysql, "select *from temperature;");
//printResult(&mysql);
shutdown:
mysql_close(&mysql);
return 0;
}