Arduino Uno + Ethernet shield 를 사용하여 DB로 데이터 전송하기(아두이노에서 mariaDB로 데이터보내기)_02

Arduino Uno와 Ethernet shield를 이용하여 측정한 센서값을 PC에 설치된 DB에 전송하려고 한다.

 

사용 제품

 

1.Arduino Uno

2.Arduino Ethernet shield W5100

3.DHT22 온습도센서

 

선행 설치

1.Arduino IDE

2.Mysql or MariaDB

 

---------------------------------------------------------------------------------------------------

본 글은 데이터의 DB전송이 목적이기 때문에 센서에 관한 코딩은 생략한다.

어떤 종류의 센서를 사용해도 된다.

 

1. 아두이노 코드 작성

 

#include <DHT.h>    //라이브러리 불러옴
int pin = 4;          //Signal 이 연결된 아두이노의 핀번호
DHT dht(pin, DHT22);
 
#include <Ethernet.h>
#include <MySQL_Connection.h>
#include <MySQL_Cursor.h>
 
byte mac_addr[] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED };  
 
IPAddress server_addr(xxx,xxx,xxx,xxx);  // mysql 서버 주소를 입력
char user[] = "user";              // mysql user 입력
char password[] = "password";        // mysql password 입력
 
// Sample query
char INSERT_SQL[] = "INSERT INTO TestDB.TestTable (Temp,Humid) VALUES (%d,%d)";
char query[128];
 
EthernetClient client;
MySQL_Connection conn((Client *)&client);
 
 
void setup() {
  Serial.begin(9600);
  Ethernet.begin(mac_addr);
  Serial.println("Connecting...");
  if (conn.connect(server_addr, 3306, user, password)) {
    delay(1000);
  }
  else
    Serial.println("Connection failed.");
}
 
 
void loop() {
  // Initiate the query class instance
  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);
  int temp = dht.readTemperature();
  int humid = dht.readHumidity();
 
  Serial.print(temp);
  Serial.print(" ");
  Serial.println(humid);
 
  sprintf(query, INSERT_SQL, temp, humid);
  cur_mem->execute(query);
  delete cur_mem;
  delay(1000);
}

1) 16번줄에서 쿼리의 value를 변수로 바꿔준다.

2) 45번줄에서 sprintf를 사용해 쿼리의 변수값에 temp, humid 변수값을 대입한다.

 

 

2. DB 결과데이터 확인

DB로 전송된 데이터

 

다른 센서를 사용하거나, 내부에서 생성되는 변수값을 전송할 때에도 동일한 방법으로 사용하면 된다.

 

여러개의 센서(변수)를 사용하고 싶으면 16번 줄의 쿼리를 수정하면 된다.

 

ex)센서 5개 사용 시

"INSERT INTO TestDB.TestTable (Temp,Humid,Light,Co2,Deg) VALUES (%d,%d,%d,%d,%d)"

물론 데이터가 대입되는 45번줄 역시 변경해주어야 한다.

sprintf(query, INSERT_SQL, temp, humid, Light, co2, deg)

 

※아두이노에서 sprintf를 사용할 때 변수값이 float,double일 경우 값이 정상적으로 출력되지 않는다.

이럴 때는 dtostrf()함수를 사용하여 실수를 문자열로 변환 후 대입하면 된다.

 

ex) temp를 float 형식으로 사용 시

float temp = dht.readTemperature();
 
dtostrf(temp, 1, 2, temp_s);
 
sprintf(query, INSERT_SQL, temp_s);