ESP32 Forum

Code: Select all

// LOAD CLASSES
#include "time.h"
#include <TimeAlarms.h>
#include <MySQL_Connection.h>
#include <MySQL_Cursor.h>
#include <WiFi.h>


//LOAD CONFIGRATION
#include "default.h"
#include "setup.h"
#include "db.h"

WiFiServer  server(80);


void setup(){
  //DEFINE IO's
  
  pinMode(ACTIV_LED, OUTPUT);
  pinMode(ACTION_LINE1, INPUT);
  pinMode(ACTION_LINE2, INPUT);
  pinMode(ACTION_LINE3, INPUT);
  pinMode(ACTION_LINE4, INPUT);
  
  pinMode(ACTIVELINE1, OUTPUT);
  pinMode(ACTIVELINE2, OUTPUT);
  pinMode(ACTIVELINE3, OUTPUT);
  pinMode(ACTIVELINE4, OUTPUT);
  pinMode(ALARM_ACTIV, OUTPUT);


  //ACTIVATE SERIAL MONITORING
  Serial.begin(115200);
  delay(10);
  Serial.println("setup - ok");
  Serial.println("connect to the network... ");

  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  delay(2000);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
   Serial.println(" connection established !");

   Serial.println("\n read timestamp from ntpServer ...");
   configTime(gmtOffset_sec, daylightOffset_sec, ntpServer);
   printLocalTime();

   getConfiguration();
}



void loop(){
  
}

Code: Select all

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

const char* ssid = "your wifi name";
const char* password = "your wifi password";

char user[] = "root"; // MySQL user login username
char passwordSQL[] = ""; // MySQL user login password

char INSERT_SQL[] = "INSERT INTO dbi.PARAMETRO(CANTEIRO, TIPO, HORA_INICIO, HORA_FIM, UMIDADE_INICIO, UMIDADE_FIM) VALUES ('CENTRAL ESP32', 'UMIDADE', '11:00:00', '12:30:00', '50', '70');";

IPAddress server_addr(your MySQL ip like (8, 8, 8, 8); // IP of the MySQL server here


WiFiServer  server(80);
void setup() {
  //Código de configuração aqui
  Serial.begin(115200);

  connectToNetwork();
  mySqlLoop();
}

void loop() {
}
void connectToNetwork() {
  WiFi.begin(ssid, password);
 
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Establishing connection to WiFi..");
  }
 
  Serial.println("Connected to network");
 
}
void mySqlLoop(){
  WiFiClient client;
  MySQL_Connection conn((Client *)&client);
  if (conn.connect(server_addr, 3306, user, passwordSQL)) {
    Serial.println("Database connected.");
  }
  else{
    Serial.println("Connection failed.");
    Serial.println("Recording data.");
  }
  // Initiate the query class instance
  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);
  // Execute the query
  cur_mem->execute(INSERT_SQL);
  // Note: since there are no results, we do not need to read any data
  // Deleting the cursor also frees up memory used
  delete cur_mem;
  Serial.println("closing connection\n");
  //client.stop();
}

Code: Select all

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

const int soilMoisturePin = 34; // Replace with your actual pin
int soilMoistureValue;

const char *ssid = "JANINA";
const char *password = "sayma01720";
const char *host = "localhost";
const char *user = "fafafa";
const char *password_mysql = "Asif@0172";
const char *database = "dibl_projects";

IPAddress server_addr(44,206,65,171); // Replace with your MySQL server IP address

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

void setup() {
    Serial.begin(115200);
    delay(1000);
    
    // Connect to Wi-Fi
    WiFi.begin(ssid, password);
    while (WiFi.status() != WL_CONNECTED) {
        delay(1000);
        Serial.println("Connecting to WiFi...");
    }
    Serial.println("Connected to WiFi");

    // Connect to MySQL database
    Serial.println("Connecting to MySQL Server...");
    if (conn.connect(server_addr, 3306, const_cast<char*>(user), const_cast<char*>(password_mysql), const_cast<char*>(database))) {
        Serial.println("MySQL Connected!");
    } else {
        Serial.println("Connection failed.");
        return;
    }

    pinMode(soilMoisturePin, INPUT);
}

void loop() {
    soilMoistureValue = analogRead(soilMoisturePin);
    int moisturePercentage = map(soilMoistureValue, 0, 4095, 0, 100);

    if (isnan(moisturePercentage)) {
        Serial.println("Failed to read moisture data!");
        return;
    }

    Serial.println("Moisture Percentage: " + String(moisturePercentage));

    updateDatabase(moisturePercentage);

    delay(2000); // Adjust delay as needed
}

void updateDatabase(int moisturePercentage) {
    String query = "UPDATE phec_livedata SET ph_value='" + String(moisturePercentage) + "' WHERE user_id=3";
    
    Serial.println("Query: " + query);

    MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);
    cur_mem->execute(query.c_str());
    delete cur_mem;
}