本文讲述树莓派用C语言程序采集温度传感器DS18B20数据，并存入SQLite和MySQL数据库。之前我们已经用Shell脚本程序实现了这些功能。

为顺利阅读本文，应先看后面参考文档中的相关内容。

《树莓派采集温度数据并存入数据库(Shell版)》https://blog.csdn.net/chentuo2000/article/details/108723075

• 硬件连接和基本操作

细节请看参考文档《树莓派+温度传感器DS18B20》一文。

https://blog.csdn.net/chentuo2000/article/details/81051701

• 查看DS18B20序列号

每个传感器有一个唯一的序列号。

ls /sys/bus/w1/devices/

我的DS18B20温度传感器序列号是28-000004d6162f。下面我们通过序列号读传感器的温度值。

• 读温度值

cat /sys/bus/w1/devices/28-000004d6162f/w1_slave

第二行的t=23125就是当前的温度值，要換算成攝氏度，除以1000，即当前温度为23125/1000=23.125攝氏度。

2. 获取数据库编程头文件和链接库

我们的温度数据将写入SQLite和MySQL两个数据库，需要相应的文件。

2.1 SQLite头文件和库文件

在C语言编程时需要头文件sqlite3.h和动态链接库文件libsqlite3.so。

• 下载sqlite3.h

在编译时会用到sqlite3.h，可以到SQLite官网下载。

https://www.sqlite.org/download.html

SQLite目前最新版本是3.33.0。

右击sqlite-autoconf-3330000.tar.gz(2.78 MiB)，复制链接地址：

https://www.sqlite.org/2020/sqlite-autoconf-3330000.tar.gz

下载：

wget -c https://www.sqlite.org/2020/sqlite-autoconf-3330000.tar.gz

安装ca-certificates包:

sudo apt-get install -y ca-certificates

重新下载：sqlite-autoconf-3330000.tar.gz

解压缩：

tar zxvf sqlite-autoconf-3330000.tar.gz

复制sqlite3.h到当前目录：

cp sqlite-autoconf-3330000/sqlite3.h .

• 查看sqlite3动态链接库

 libsqlite3.so.0是一个指向libsqlite3.so.0.8.6的软链接，也就是一个快捷方式。

• 再创建一个libsqlite3.so.0.8.6的软链接libsqlite3.so

sudo ln -s libsqlite3.so.0.8.6 /usr/lib/arm-linux-gnueabihf/libsqlite3.so

3.2 MySQL头文件和库文件

在C语言编程时需要头文件mysql.h和动态链接库文件libmariadbclient.so。

• 安装库文件

sudo apt-get install libmariadb-dev

• 查找mysql.h

sudo find / -name mysql.h

/usr/include/mariadb/mysql.h

• 查找libmariadbclient.so

sudo find / -name libmariadbclient.so

/usr/lib/arm-linux-gnueabihf/libmariadbclient.so

4. 编写C程序

在《树莓派采集温度数据并存入数据库(Shell版)》一文中我们用Shell程序实现了温度采样和数据存储功能，在本文中我们用C语言实现同样的功能。

4.1 创建数据库

• 进入工作目录

cd idata

在《树莓派安装使用数据库SQLite》一文中我们已经创建了SQLite的数据库文件：smarthome.db。

在《树莓派安装使用数据库MariaDB (MySQL)》一文中我们也已经创建了数据库smarthome。

read_data.sh是我们在《树莓派采集温度数据并存入数据库(Shell版)》一文中写的shell脚本程序。

4.2 写C程序

nano read_data.c

1. #include <stdio.h>
2. #include <stdlib.h>
3. #include <unistd.h>
4. #include <fcntl.h>
5. #include <string.h>
6. #include <time.h>
7. #include “sqlite3.h”
8. #include <mysql.h>
10. // 保存数据到SQLite数据库
11. int save_data_sqlite(char sql[]) {
12. sqlite3 _pdb = NULL; /_数据库连接指针_/
13. char _error_msg = 0; /_错误信息指针_/
14. int rc, return_value;
16. rc=sqlite3_open(“smarthome.db”,&pdb);
17. if(rc) {
18. fprintf(stderr , “can’t open database: %s\n”,sqlite3_errmsg(pdb));
19. return_value = -1;
20. } else {
21. // 插入或更新命令
22. rc = sqlite3_exec(pdb,sql,0,0,&error_msg); // sqlite3_exec()是sqlite3_ prepare(), sqlite3_step(), and sqlite3_finalize() 三个函数的一个封装，最好的方法是直接使用sqlite3_exec()。
23. if (rc == SQLITE_OK) {
24. //printf(“Insert data OK! rc=%d\n”, rc); //测试
25. return_value = 0;
26. } else {
27. //printf(“Insert data Error! rc=%d\n”, rc); //测试
28. return_value = -2;
29. }
30. }
31. sqlite3_close(pdb);
32. return return_value;
33. }
35. static inline void _mysql_check(MYSQL _ con) {
36. fprintf(stderr, “%s\n”, mysql_error(con));
37. mysql_close(con);
38. exit(EXIT_FAILURE);
39. }
40. // 保存数据到MySQL数据库
41. void save_data_mysql(char sql[]) {
42. int rc;
43. // 创建数据连接对象，需要和 mysql_close成对出现
44. MYSQL _con = mysql_init(NULL);
45. if (con == NULL) {
46. fprintf(stderr, “%s\n”, mysql_error(con));
47. exit(EXIT_FAILURE);
48. }
49. // 创建TCP常连接对象
50. if (!mysql_real_connect(con, “127.0.0.1”, “ct”, “ct”, “smarthome”, 0, NULL, 0)) {
51. _mysql_check(con);
52. }
53. //puts(“mariadb is connect and run succesed!”);
54. // 插入或更新命令
55. rc = mysql_real_query(con, sql, strlen(sql));
56. if (0 != rc) {
57. _mysql_check(con);
58. }
60. mysql_close(con);
61. }
63. int main(int argc, char _argv[])
64. {
65. char itime[255];
66. char buf[128];
67. char path[64] = “/sys/bus/w1/devices/28-000004d6162f/w1_slave”;
68. char _itemp;
69. float ftemp;
70. int fd = -1;
72. char sql[256];
73. char deviceid[10] = “temp001”;
74. int ibattery_voltage = 3333;
76. // 设置时区
77. setenv(“TZ”, “GMT-8”, 1);
79. while(1) {
80. // 取系统时间
81. time_t t = time( 0 );
82. strftime(itime, 255, “%Y-%m-%d %H:%M:%S”, localtime(&t)); //format date and time.
83. printf(“%s\n”, itime);
85. // 读传感器数据
86. if((fd = open(path, O_RDONLY)) < 0) {
87. printf(“Open temperature file error! Please check /sys/bus/w1/devices/28-00000xxxxxxx file! \n”);
88. } else {
89. if(read(fd, buf, sizeof(buf)) < 0) {
90. printf(“Read temperature error!\n”);
91. } else {
92. itemp = strchr(buf,‘t’);
93. sscanf(itemp, “t=%s”, itemp);
94. ftemp = atof(itemp)/1000;
95. printf(“ temp=%3.2f°C\n”, ftemp);
97. // 构造SQL语句
98. sprintf(sql, “INSERT INTO temperature(deviceid, time, battery_voltage, celsius_temp) VALUES(‘%s’, ‘%s’, %d, %f);”, deviceid, itime, ibattery_voltage, ftemp);
99. puts(sql);
100. puts(“ “);
102. // 保存数据到SQLite数据库
103. save_data_sqlite(sql);
105. // 保存数据到MySQL数据库
106. save_data_mysql(sql);
108. sleep(300); // 延时300秒
109. }
110. }
111. }
113. return 0;
114. }

数据同时写入SQLite和MySQL数据库，具体项目可根据情况取舍。

• 编译

gcc -I /usr/include/mariadb read_data.c -o read_data -lmariadbclient -lsqlite3

3.3 运行C程序

./read_data

3.4 查看数据库

• 查看SQLite数据库

具体操作请看《树莓派安装使用数据库SQLite》
https://blog.csdn.net/chentuo2000/article/details/108682421

查看最后一条数据：

select * from temperature where id=(select max(id) from temperature);

• 查看MySQL数据库

具体操作请看《树莓派安装使用数据库MariaDB (MySQL)》https://blog.csdn.net/chentuo2000/article/details/108702880

参考文档

1. 树莓派采集温度数据并存入数据库(Shell版) https://blog.csdn.net/chentuo2000/article/details/108723075
2. 树莓派安装使用数据库SQLite https://blog.csdn.net/chentuo2000/article/details/108682421
3. 树莓派安装使用数据库MariaDB (MySQL) https://blog.csdn.net/chentuo2000/article/details/108702880
4. 树莓派+温度传感器DS18B20 https://blog.csdn.net/chentuo2000/article/details/81051701
5. ESP8266_SDK发送温度数据到阿里云 https://blog.csdn.net/chentuo2000/article/details/105592791
6. 树莓派系列教程14：单总线控制DS18B20 https://www.waveshare.net/study/article-607-1.html