#include <dht11.h>
#include <MySQL_Connection.h>
#include <MySQL_Cursor.h>
#include <ESP8266WiFi.h>
#include <WiFiClient.h>

#define DHT11PIN 5

const char* ssid = "TP-LINK";
const char* password_wifi = "&o7=wa-y&4xx";

WiFiClient client;
dht11 DHT11;

MySQL_Connection conn((Client *)&client);

char UPDATE_SQL[] = "UPDATE esp_db.esp_table SET item_temp = '%d', item_hum = '%d' WHERE item_id = 1";

char query[128];

IPAddress server_addr(192, 168 ,1, 7);

char user[] = "user";
char password[] = "123";

void setup() {
  pinMode(LED_BUILTIN, OUTPUT);

  Serial.begin(115200);

  WiFi.begin(ssid, password_wifi);

  Serial.println("Connecting to database");

  while (conn.connect(server_addr, 3306, user, password) != true) {
      delay(200);
      Serial.print ( "." );
  }

  Serial.println("");
  Serial.println("Connected to SQL Server!");
}


void loop() {
  delay(1000);

  DHT11.read(DHT11PIN);  //odczyt z czujnika

  int temp = DHT11.temperature;
  int hum = DHT11.humidity;

  sprintf(query, UPDATE_SQL, temp, hum);

  Serial.println("Recording data.");
  Serial.println(query);

  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);

  cur_mem->execute(query);

  delete cur_mem;  //usuniecie pamieci
}