夜市小霸王

我的ESP32實做書籍：https://youyouyou.pixnet.net/blog/post/121105860
博客來網址：https://www.books.com.tw/products/0010901195

---

ESP內建的WiFi上網，我們就可以將收集到的資料存入雲端資料庫，方便立即查看即時狀況，而且有長期的資料後就可以進行後續分析與比較，也能在發生異常時發出Mail, Line等通知管理者，達到立即處理的功能，這樣才算真正發揮IoT裝置的功能。

本章要介紹如何將DHT11的溫濕度等資料上傳到自己建立的資料庫，若讀者沒有網路伺服器可以建立MySQL，則可跳過本章，直接閱讀下一章「ESP32 資料庫存取ThingSpeak圖表製作」，不需要自己建立資料庫，畢竟資料庫伺服器的管理維護問題之外，還有網路連線IP、DDNS、NAT、虛擬伺服器、連接埠轉送等網路相關的知識，再加上SQL資料庫的維護與語法也是一個很大的議題。不過自己建立資料庫的好處則是資料儲存、使用、及後續管理與查詢都是由自己掌控，相對更加自由，這也是很多進階玩家選擇這樣作法的原因。

另外要說明的則是本篇介紹的方法是讓ESP32與MySQL直接建立連接，而不是更正式的三層式(Three Tier)作法，也就是讓ESP32透過HTTP Post或Get傳資料到AP Server，而AP Server再存入資料庫中的間接連線方式。

為了快速讓讀者能完成練習，本章分成以下幾個部份說明

一、環境設定：安裝MySQL及workbench

二、線路佈置：連接ESP32及DHT11

三、程式開發：在Arduino IDE中撰寫程式

---

一、環境設定

本章使用MySQL最大的好處是，他是免費的，執行效能也不差，另外就是workbench，這是懶人的福音，如果你跟我一樣，對cmd界面不熟悉，你一定要安裝workbench，他提供你完整的MySQL圖形界面操作模式，真心推薦。

1.安裝MySQL伺服器，安裝方式網路非常多介紹，請自行google，或參考這篇： https://jerrynest.io/windows-mysql-installer/ ，下載的網址： https://dev.mysql.com/downloads/installer/ ，題外話，如果你想用cluster版，可參考本人本篇文章： http://youyouyou.pixnet.net/blog/post/119326123

2.安裝workbench，下載網址： https://www.mysql.com/products/workbench/ 

3.將workbench連線到mysql資料庫

workbench安裝完畢後，我們就可以透過workbench進入資料庫，以進行設定，包括建立新的資料庫欄位以及開放讓IoT可連入更新資料，讓Arduino可以WiFi遠端更新資料庫，

3.1 Workbench連線

一般Workbench安裝完畢都會建立一個連線是直接連線到本機端MySQL，名稱是127.0.0.1直接打開即可。

3.2 建立新資料庫

點選左上方的Create new schema圖示，以建立資料庫，將存放DHT11傳入的溫濕度資料。

資料庫名稱可自己取名，但不可用中文，例如筆者將新的資料庫取名為「tempandhumd」，代表收取的是溫度及濕度，完成名稱輸入後Collation依照預設值Server Default即可，最後按右下角的Apply即會看到完成的視窗。

再來建立資料表，在剛建好的資料庫前方+號點開，在table上按右鍵，選擇Create Table，建立資料表。
 

建立的資料表名稱為「datalog」，欄位除了溫度、濕度之外，可用自動編號當作主鍵，最後在給一個更新時間，因此有四個欄位設定如下
1. id：整數，（代表自動編號欄位）
2. temp：整數（代表溫度欄位）
3. humd：整數（代表溼度欄位）
4. updatetime：timestamp（代表資料時間欄位），並給予預設值：CURRENT_TIMESTAMP，目的是這樣當資料新增時，直接給插入資料的時間。
然有四個欄位，但實際上我們僅須給temp跟humd即可，id與updatetime都是sql資料庫直接給值得。這樣比較簡單。

4. 修改MySQL遠端連線設定

因為安全考量，預設MySQL只允許本機登入而不能外部連入，但是我們的Arduino IoT裝置是屬於外部裝置，因此必須將使用者開放外部登入，這裡必須說明，這樣的作法是有安全性問題的，只建議自己建立伺服器來測試，不要拿公司或學校的伺服器來測試。
修改root使用者由原本的localhost改為%，代表該使用者可以從網路上任何地點連進資料庫來進行修改。 完成後按下方的Apply即可存檔。

5. 修改認證方式

因為後續有網友反應資料傳遞失敗，錯誤訊息是「Client does not support authentication protocol requested by server」，經查詢是因為MySQL 8.0的認證方式已經升級，但目前Arduino的MySQL函式庫並未升級，目前的方式，暫時將MySQL的連線認證方式降級，作法為開啟MySQL Command視窗，並輸入以下指令。
ALTER USER 'root' IDENTIFIED WITH mysql_native_password BY 'SQLpassword';
這裡的SQLpassword代表你root的密碼。

二、線路佈置

本部份連接DHT11及ESP32，本請參考前篇：ESP32 溫濕度顯示器(DHT11+1602 LCD)

三、程式開發

本部份則是在Aruino IDE中撰寫程式，如何將資料上傳MySQL，我們將直接使用MySQL的library進行上傳，並說明注意事項。

1. 匯入MySQL Library

安裝"MySQL connector arduino" by Dr. Charles Bell，依照下圖開啟管理函式庫功能。

搜尋關鍵字MySQL ，即可找到所需的library，點選右側的Install安裝按鈕把他安裝起來。

2. 連線測試

接下來就可以先測試將值傳入過程是否正常，先使用以下程式進行測試，其中溫度及濕度是直接鍵入，目的在測試網路連線是否正常。要修改的部份包括無線網路的SSID及密碼，還有SQL資料庫的IP位址及帳號密碼，這裡有一個地方要注意的是server_addr是用「,」做區隔，而不是傳統的「.」做區隔。

---

//MySQL連線測試，手動寫入一個溫度及濕度資料做測試
#include <WiFi.h>
#include <MySQL_Connection.h>
#include <MySQL_Cursor.h>

const char ssid[]     = "SSID";// change to your WIFI SSID
const char password[] = "SSIDPassword";// change to your WIFI Password
IPAddress server_addr(192,168,1,107);// change to you server ip, note its form split by "," not "."
int MYSQLPort =3306;   //mysql port default is 3306
char user[] = "root";// Your MySQL user login username(default is root),and note to change MYSQL user root can access from local to internet(%)
char pass[] = "SQLpassword";// Your MYSQL password

WiFiClient client;            
MySQL_Connection conn((Client *)&client);

void setup() {
  Serial.begin(115200);
  delay(10);
  // We start by connecting to a WiFi network
  Serial.println();
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);
  
  WiFi.begin(ssid, password);  
  //try to connect to WIFI 
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi connected");  
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  
  //try to connect to mysql server
  if (conn.connect(server_addr, 3306, user, pass)) {
     delay(1000);
  }
  else{
    Serial.println("Connection failed.");
  }
  delay(2000);  
  //insert, change database name and values by string and char[]
  char INSERT_SQL[] = "INSERT INTO tempandhumd.datalog (temp,humd) VALUES ('35','60')";//傳入的值固定為溫度,濕度為35,60
  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);  
  cur_mem->execute(INSERT_SQL);//execute SQL
  delete cur_mem;
  conn.close();                  // close the connection
  Serial.println("Data Saved.");
}

void loop() {
//do nothing
}

---

若上傳成功，在資料庫內就會出現剛剛上傳的資料

3. DHT11測試

依據「第九篇 ESP32 溫濕度顯示器(DHT11+1602 LCD)」的方式，將DHT11腳位訊號的腳位接在GPIO 14的位置（麵包板左側8），接下來程式改為每10秒讀取DHT11一次，並上傳資料庫，完成上傳後就立即斷線資料庫，等候下一個Loop。

---

#include <WiFi.h>
#include <MySQL_Connection.h>
#include <MySQL_Cursor.h>
#include <SimpleDHT.h>

const char ssid[]     = "SSID";// change to your WIFI SSID
const char password[] = "SSIDPassword";// change to your WIFI Password

IPAddress server_addr(192,168,1,17); // change to you server ip, note its form split by "," not "."
int MYSQLPort = 3306; //mysql port default is 3306
char user[] = "root";// Your MySQL user login username(default is root),and note to change MYSQL user root can access from local to internet(%)
char pass[] = "SQLpassword";// Your MYSQL password

WiFiClient client;
MySQL_Connection conn((Client *)&client);

int pinDHT11 = 14;
SimpleDHT11 dht11(pinDHT11);
void setup() {
  Serial.begin(115200);
  delay(10);
  // We start by connecting to a WiFi network
  Serial.println();
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);
  //try to connect to WIFI
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());

  //try to connect to mysql server
  if (conn.connect(server_addr, 3306, user, pass)) {
    delay(1000);
  }
  else {
    Serial.println("Connection failed.");
  }
  delay(2000);

}

void loop() {
  //讀取DHT11
  byte temperature = 0;
  byte humidity = 0;
  int err = SimpleDHTErrSuccess;
  if ((err = dht11.read(&temperature, &humidity, NULL)) != SimpleDHTErrSuccess) {
    Serial.print("Read DHT11 failed, err="); Serial.println(err); delay(1000);
    return;
  }
  Serial.print("Sample OK: ");
  Serial.print((int)temperature); Serial.print(" *C, ");
  Serial.print((int)humidity); Serial.println(" H");

  //將溫濕度加入SQL字串
  String INSERT_SQL = "INSERT INTO test.loj (t,h) VALUES ('" + String((int)temperature) + "','" + String((int)humidity) + "')";
  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);
  cur_mem->execute(INSERT_SQL.c_str());//execute SQL
  delete cur_mem;
  conn.close();// close the connection
  Serial.println("Data Saved.");
  delay(10000);
}

---

查看序列視窗，可以發現上傳正常，查看資料庫，也可以發現資料都已經存入資料庫了。