INFO: Dieses Forum nutzt Cookies...

abernauer · 29.02.2020, 22:37

Hallo an alle Leser,

ich weiß und mir ist bewusst, dass hier einige Sachen über die Anbindung von div. Adaptern zu einer SQL-Datenbank stehen. Leider sind diese Einträge teilweise nicht mehr aktuell oder es gab änderungen.
Hier nun meine Situation:
Mein Projekt sieht vor mind. 3 RFID+nodemcu+LCD zu installieren.
rfid und lcd laufen am nodemcu. da diese drei Einheiten an Eingangstüren sollen, brauche ich einen Zugriff auf eine Datenbank. Mir selbst wäre es lieb, wenn es direkt ginge und nicht über PHP. Stand jetzt kann ich in die Datenbank schreiben. Jetzt bin ich an dem Punkt, wo ich Daten aus der Datenbank brauche und nicht weiterkomme.
Die Datenbank selbst mariaDB auf einem Raspberry4.

Code:

#include <MySQL_Connection.h>

#include <MySQL_Cursor.h>

#include <ESP8266WiFi.h>

#include <WiFiClient.h>

char ssid[] = "ABK14-24";                 // Network Name

char pass[] = "password";                 // Network Password

byte mac[6];

WiFiServer server(80);

IPAddress ip(192,168,9,1);

IPAddress gateway(192,168,9,1);

IPAddress subnet(255,255,255,0);

WiFiClient client;

MySQL_Connection conn((Client *)&client);

char query[] = "SELECT name, guthaben FROM adrutest.ardu_tabellle1 WHERE `rfid` = '2712'";

//char query[128];

IPAddress server_addr(192,168,9,214);          // MySQL server IP

char user[] = "sqluser";           // MySQL user

char password[] = "sqlpassword";       // MySQL password

void setup() {

  Serial.begin(9600);

  Serial.println("Initialising connection");

  Serial.print(F("Setting static ip to : "));

  Serial.println(ip);

  Serial.println("");

  Serial.println("");

  Serial.print("Connecting to ");

  Serial.println(ssid);

  WiFi.config(ip, gateway, subnet);

  WiFi.begin(ssid, pass);

  while (WiFi.status() != WL_CONNECTED) {

    delay(200);

    Serial.print(".");

  }

  Serial.println("");

  Serial.println("WiFi Connected");

  WiFi.macAddress(mac);

  Serial.print("MAC: ");

  Serial.print(mac[5],HEX);

  Serial.print(":");

  Serial.print(mac[4],HEX);

  Serial.print(":");

  Serial.print(mac[3],HEX);

  Serial.print(":");

  Serial.print(mac[2],HEX);

  Serial.print(":");

  Serial.print(mac[1],HEX);

  Serial.print(":");

  Serial.println(mac[0],HEX);

  Serial.println("");

  Serial.print("Assigned IP: ");

  Serial.print(WiFi.localIP());

  Serial.println("");

  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() {

  row_values *row = NULL;

  long head_count = 0;

  delay(1000);

  Serial.println("1) Demonstrating using a cursor dynamically allocated.");

    MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);// Initiate the query class instance

    cur_mem->execute(query);                        // Execute the query

    column_names *columns = cur_mem->get_columns();   // Fetch the columns (required) but we don't use them.

  do {                                               // Read the row (we are only expecting the one)

    row = cur_mem->get_next_row();

    if (row != NULL) {

      head_count = atol(row->values[0]);

    }

    } while (row != NULL);

   delete cur_mem;                                   // Deleting the cursor also frees up memory used

  Serial.println(query);

  // Show the result

  Serial.print("Name/Guthaben = ");

  Serial.println(head_count);

  delay(500);

  Serial.println("2) Demonstrating using a local, global cursor.");

  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);// Initiate the query class instance

  cur_mem->execute(query);                   // Execute the query

  // Fetch the columns (required) but we don't use them.

  cur_mem->get_columns();

  // Read the row (we are only expecting the one)

  do {

    row = cur_mem->get_next_row();

    if (row != NULL) {

      head_count = atol(row->values[0]);

    }

  } while (row != NULL);

  // Now we close the cursor to free any memory

  delete cur_mem;

  // Show the result but this time do some math on it

  Serial.print("Name/Guthaben: ");

  Serial.println(head_count);

}

Das Ergebnis auf dem Serial-Monitor ist:

Setting static ip to : 192.168.9.1
Connecting to ABK14-24
.
WiFi Connected
MAC: CD:2D:63:BC:FA:EC
Assigned IP: 192.168.9.1
Connecting to database
...
Connected to SQL Server!
1) Demonstrating using a cursor dynamically allocated.
SELECT name, guthaben FROM adrutest.ardu_tabellle1 WHERE `rfid` = '2712'
Name = 0
2) Demonstrating using a local, global cursor.
Exception (9):
epc1=0x40201561 epc2=0x00000000 epc3=0x00000000 excvaddr=0x6563697e depc=0x00000000
>>>stack>>>
ctx: cont
sp: 3ffffdc0 end: 3fffffc0 offset: 01a0
3fffff60: 00000000 0000002e 3ffee5d0 40203b94.....geht hier noch weiter!

Wer kann / könnte mir da weiterhelfen oder einen Tipp geben?
Den SQL-Code habe ich schon in der DB direkt getestet und er funktioniert!

Gruß aus dem Schwarzwald
Andy

Tommy56 · (Dieser Beitrag wurde zuletzt bearbeitet: 29.02.2020 23:14 von Tommy56.)

Du vermischst 2 Beispiele zur Nutzung der Lib.
Lass den Teil

Code:

Serial.println("2) Demonstrating using a local, global cursor.");

  MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);// Initiate the query class instance

  cur_mem->execute(query);                   // Execute the query

  // Fetch the columns (required) but we don't use them.

  cur_mem->get_columns();

  // Read the row (we are only expecting the one)

  do {

    row = cur_mem->get_next_row();

    if (row != NULL) {

      head_count = atol(row->values[0]);

    }

  } while (row != NULL);

  // Now we close the cursor to free any memory

  delete cur_mem;

  // Show the result but this time do some math on it

  Serial.print("Name/Guthaben: ");

  Serial.println(head_count);

weg.
Ergänze folgendes (ungetestet):

Code:

Serial.println("1) Demonstrating using a cursor dynamically allocated.");

    MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);// Initiate the query class instance

    cur_mem->execute(query);                        // Execute the query

    column_names *columns = cur_mem->get_columns();   // Fetch the columns (required) but we don't use them.

 do {                                               // Read the row (we are only expecting the one)

    row = cur_mem->get_next_row();

    if (row != NULL) {

      Serial.print("Name: ");

      Serial.println(row->values[0]);  // <--- der Name als Zeichenkette

      Serial.print("Guthaben: ");

      Serial.println(atof(row->values[1])); // <---- das Guthaben umwandeln in float (du wirst damit rechen wollen)

    }

    } while (row != NULL);

Gruß Tommy

abernauer · 29.02.2020, 23:23

Danke für die rasche Antwort....werde es morgen testen!!!

abernauer · 01.03.2020, 12:15

Hallo Tommy,

ich habe Deine Änderung 1:1 so umgesetzt. Bin absolut begeistert-es funktioniert.

Hier nun auch der komplette code

Code:

#include <MySQL_Connection.h>

#include <MySQL_Cursor.h>

#include <ESP8266WiFi.h>

#include <WiFiClient.h>

char ssid[] = "ABK14-24";                 // Network Name

char pass[] = "abernauer271269#%";                 // Network Password

byte mac[6];

WiFiServer server(80);

IPAddress ip(192,168,9,1);

IPAddress gateway(192,168,9,1);

IPAddress subnet(255,255,255,0);

WiFiClient client;

MySQL_Connection conn((Client *)&client);

char query[] = "SELECT name, guthaben FROM adrutest.ardu_tabellle1 WHERE `rfid` = '2712'";

//char query[128];

IPAddress server_addr(192,168,9,214);          // MySQL server IP

char user[] = "rfid";           // MySQL user

char password[] = "rfid";       // MySQL password

void setup() {

  Serial.begin(9600);

  Serial.println("Initialising connection");

  Serial.print(F("Setting static ip to : "));

  Serial.println(ip);

  Serial.println("");

  Serial.println("");

  Serial.print("Connecting to ");

  Serial.println(ssid);

  WiFi.config(ip, gateway, subnet); 

  WiFi.begin(ssid, pass);

  while (WiFi.status() != WL_CONNECTED) {

    delay(200);

    Serial.print(".");

  }

  Serial.println("");

  Serial.println("WiFi Connected");

  WiFi.macAddress(mac);

  Serial.print("MAC: ");

  Serial.print(mac[5],HEX);

  Serial.print(":");

  Serial.print(mac[4],HEX);

  Serial.print(":");

  Serial.print(mac[3],HEX);

  Serial.print(":");

  Serial.print(mac[2],HEX);

  Serial.print(":");

  Serial.print(mac[1],HEX);

  Serial.print(":");

  Serial.println(mac[0],HEX);

  Serial.println("");

  Serial.print("Assigned IP: ");

  Serial.print(WiFi.localIP());

  Serial.println("");

  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() {

  row_values *row = NULL;

  long head_count = 0;

  delay(1000);

  Serial.println("1) Demonstrating using a cursor dynamically allocated.");

    MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);// Initiate the query class instance

    cur_mem->execute(query);                        // Execute the query

    column_names *columns = cur_mem->get_columns();   // Fetch the columns (required) but we don't use them.

  do {                                               // Read the row (we are only expecting the one)

    row = cur_mem->get_next_row();

    if (row != NULL) {

      Serial.print("Name: ");

      Serial.println(row->values[0]);  // <--- der Name als Zeichenkette

      Serial.print("Guthaben: ");

      Serial.println(atof(row->values[1])); // <---- das Guthaben umwandeln in float (du wirst damit rechen wollen)

    }

    } while (row != NULL);

   delete cur_mem;                                   // Deleting the cursor also frees up memory used

  Serial.println(query);

   delay(500);

}

Lieben Dank für Deine Hilfestellung, nun kann es weitergehen mit meinem Projekt!

Gruß Andy

Tommy56 · 01.03.2020, 12:23

Schön, das es funktioniert und danke für die Rückmeldung.

Gruß Tommy

abernauer · 01.03.2020, 20:01

Hallo,

dank Eure Hilfe bin ich ein ganzen Stück weitergekommen.

Code:

char SELECT[] = "SELECT * FROM RFID.User WHERE `UID` = '017014219821'";

sende ich bisher die Anfrage ab. Nun sollte aber UID variable sein!

Wer könnte da helfen?
Kann auch den ganzen Script mal posten ist aber ziemlich lang!

Gruß
Andy

Tommy56 · (Dieser Beitrag wurde zuletzt bearbeitet: 01.03.2020 20:20 von Tommy56.)

Bei SELECT * solltest Du aufpassen, wenn Du die Tabelle änderst oder nicht alle Felder brauchst.

Ansonsten hast Du 2 Varianten:

1. mit strcpy und strcat (hier habe ich ein paar Infos zur Arbeit mit Zeichenketten geschrieben - die kannst Du trotzdem lesen Wink

)

2. mit snprintf_P (der elegantere Weg)

Code:

// global

char stmt[100]; // <-- Anpassen an Dein längstes Statement

// Deine UserId

char uid[20]= "12343567"; // <---- Länge anpassen

snprintf_P(stmt, sizeof(stmt),PSTR("SELECT * FROM RFID.User WHERE UID = '%s'"),uid);

// in stmt steht Dein komplettes SQL.

Serial.println(stmt);

Hier sind die Formatierungsoptionen der printf-Familie. Float geht auf ESP, aber nicht auf AVR.

PSTR steht im Flash und snprintf_P holt den Formatstring von dort.
Die ' ' um den Feldnamen kannst Du weg lassen.

Gruß Tommy

Edit: Das ganze ungetestet. Wer Tippfehler findet, darf sie behalten.

abernauer · 01.03.2020, 20:49

Macht glaub Sinn mal alles zu Posten.
Danke für die info nur bekomme ich da Fehlermeldungen.

Code:

#include <ESP8266WiFi.h>     //Include Esp library

#include <WiFiClient.h> 

//#include <ESP8266WebServer.h>

#include <ESP8266HTTPClient.h>

#include <SPI.h>

#include <MFRC522.h>        //include RFID library

#include <LiquidCrystal_I2C.h>

//#include <ArduinoJson.h>

#include <MySQL_Connection.h>

#include <MySQL_Cursor.h>

//#include <time.h>

//#include <WiFiUdp.h>

#define SS_PIN D8 //RX slave select

#define RST_PIN D3

MFRC522 mfrc522(SS_PIN, RST_PIN); // Create MFRC522 instance.

LiquidCrystal_I2C lcd(0x27, 20, 4);

/* Set these to your desired credentials. */

const char *ssid = "SSID";  //ENTER YOUR WIFI SETTINGS

const char *password = "PWD";

//Web/Server address to read/write from 

const char *host = "192.168.9.214";   //IP address of server

byte mac[6];

char CardID[20]="0";

char RFID[20]="017014219821";

String Uname="1";

String UBerechtigung="";

String UDatumv="";

String UDatumB="";

int UHET=0;

int UDGT=0;

int UEGT=0;

int Ur1=0;

int Ur2=0;

int Ur3=0;

int Ur4=0;

int Ur5=0;

int Ur6=0;

WiFiClient client;

MySQL_Connection conn((Client *)&client);

//char SELECT[] = "SELECT * FROM RFID.User WHERE `UID` = '017014219821'";

char INSERT_SQL[] = "INSERT RFID.log_anfrage(UID, Door, Datum) VALUES ('017014219821', 'HET', now())";

char INSERT_SQL1[] = "INSERT RFID.log(UID, Door, Name, Ergebnis, wann) VALUES ('017014219821', 'HET', 'Name', 'Ergebnis', now())";

char query[128];

IPAddress server_addr(192,168,9,214);          // MySQL server IP

char user[] = "sqluser";           // MySQL user

char password1[] = "sqlpasswort";       // MySQL password

void setup() {

  delay(1000);

  Serial.begin(115200);

  SPI.begin();  // Init SPI bus

  mfrc522.PCD_Init(); // Init MFRC522 card

  WiFi.mode(WIFI_OFF);        //Prevents reconnection issue (taking too long to connect)

  delay(1000);

  WiFi.mode(WIFI_STA);        //This line hides the viewing of ESP as wifi hotspot  

  WiFi.begin(ssid, password);     //Connect to your WiFi router

  Serial.println("");

  Serial.print("Connecting to ");

  Serial.print(ssid);

  lcd.init();

  lcd.backlight();

  lcd.clear();

  lcd.setCursor(0,0);

  lcd.print("Connecting to: ");

  lcd.setCursor(0,1);

  lcd.print(ssid);

  while (WiFi.status() != WL_CONNECTED) {

  delay(500);

  lcd.print(".");

  }

  SPI.begin();

  while (WiFi.status() != WL_CONNECTED) {

  delay(500);

  Serial.print(".");

  }

  Serial.println("");

  Serial.println("Connected");

  lcd.setCursor(0,2);

  lcd.print("Connected to:");

  lcd.setCursor(0,3);

  lcd.print("IP: ");

  lcd.print(WiFi.localIP());  

  Serial.print("IP address: ");

  Serial.println(WiFi.localIP());  //IP address assigned to your ESP 

  Serial.println("Connecting to database");

  while (conn.connect(server_addr, 3306, user, password1) != true) {

  delay(200);

  Serial.print ( "." );

  lcd.setCursor(0,0);

  lcd.print("Connecting SQL: ");  

  }

  Serial.println("");

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

  lcd.clear();

  lcd.setCursor(0,0);

  lcd.print("mit SQL-Verbunden");

  Serial.println("CARD: ");

  Serial.print(CardID);

}

void loop() {

  row_values *row = NULL;

  long head_count = 0;

  if(WiFi.status() != WL_CONNECTED){

    WiFi.disconnect();

    WiFi.mode(WIFI_STA);

    Serial.print("Reconnecting to ");

    Serial.println(ssid);

    WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {

    delay(500);

    Serial.print(".");

  }

    Serial.println("");

    Serial.println("Connected");

    Serial.print("IP address: ");

    Serial.println(WiFi.localIP());  //IP address assigned to your ESP

  }

if (CardID == "0") {

lcd.clear();

      lcd.setCursor(0, 0);

      lcd.print("    WELCOME/HALLO     ");      

      lcd.setCursor(6, 1);

      lcd.print(":");

      lcd.setCursor(9, 1);

}

  //look for new card

   if ( ! mfrc522.PICC_IsNewCardPresent()) {

  return;//got to start of loop if there is no card present

 }

 // Select one of the cards

 if ( ! mfrc522.PICC_ReadCardSerial()) {

  return;//if read card serial(0) returns 1, the uid struct contians the ID of the read card.

 }

 for (byte i = 0; i < mfrc522.uid.size; i++) {

    CardID += mfrc522.uid.uidByte[i];

 }

if ((CardID) >= "0") { 

    lcd.clear();

    Serial.print("Karte: ");

    Serial.println(CardID);

    lcd.setCursor(0,0);

    lcd.print("Karte: ");

    lcd.print(CardID);

    lcd.setCursor(0,1);

    lcd.print("Bitte warten");

    lcd.setCursor(0,2);

    lcd.print("Datenpruefung!!!");

    Serial.println(RFID);

    Serial.println(INSERT_SQL);

    int soil_hum = 1024;

    delay(2000);

    snprintf_P(SELECT, sizeof(SELECT),PSTR("SELECT * FROM RFID.User WHERE UID = '%s'"),'CardID');

    Serial.println(SELECT);

    Serial.println("Recording data.");

    MySQL_Cursor *cur_mem = new MySQL_Cursor(&conn);

    cur_mem->execute(INSERT_SQL); 

    cur_mem->execute(SELECT);

    column_names *columns = cur_mem->get_columns();

    do {                                           

      row = cur_mem->get_next_row();

     if (row != NULL) {

      Serial.print("lfd_nr: ");

      Serial.println(row->values[0]);  // <--- der Name als Zeichenkette

      Serial.print("UID: ");

      Serial.println(row->values[1]);  // <--- der Name als Zeichenkette

      Serial.print("Name: ");

      Serial.println(row->values[2]);  // <--- der Name als Zeichenkette

      Uname=(row->values[2]);

      Serial.print("Berechtigung: ");

      Serial.println(row->values[3]);  // <--- der Name als Zeichenkette

      UBerechtigung=(row->values[3]);

      Serial.print("Datum von: ");

      Serial.println(row->values[4]);  // <--- der Name als Zeichenkette

//      UDatumv=(row->values[4]);      

      Serial.print("Datum bis: ");

      Serial.println(row->values[5]);  // <--- der Name als Zeichenkette

//      UDatumb=(row->values[5]);      

      Serial.print(("HET: "));

      Serial.println(row->values[6]);  // <--- der Name als Zeichenkette

      UHET=atof((row->values[6]));      

      Serial.print("DGT: ");

      Serial.println(row->values[7]);  // <--- der Name als Zeichenkette

      UDGT=atof((row->values[7]));      

      Serial.print("EGT: ");

      Serial.println(row->values[8]);  // <--- der Name als Zeichenkette

      UEGT=atof((row->values[8]));      

      Serial.print("r1: ");

      Serial.println(row->values[9]);  // <--- der Name als Zeichenkette

      Ur1=atof((row->values[9]));      

      Serial.print(("r2: "));

      Serial.println(row->values[10]);  // <--- der Name als Zeichenkette      

      Ur2=atof((row->values[10]));

      Serial.print("r3: ");

      Serial.println(row->values[11]);  // <--- der Name als Zeichenkette

      Ur3=atof((row->values[11]));

      Serial.print("r4: ");

      Serial.println(row->values[12]);  // <--- der Name als Zeichenkette

      Ur4=atof((row->values[12]));

      Serial.print("r5: ");

      Serial.println(row->values[13]);  // <--- der Name als Zeichenkette

      Ur5=atof((row->values[13]));

      Serial.print("r6: ");

      Serial.println(row->values[14]);  // <--- der Name als Zeichenkette

//      Ur6=atof((row->values14]));

     Serial.println(Uname);

      lcd.setCursor(0,0);

      lcd.print("Karte: gefunden!    ");

      lcd.setCursor(0,3);

      lcd.print("Hallo ");

      lcd.print(Uname);

      lcd.setCursor(0,2);

      lcd.print("Datenpruefung!!!");      

      }

//      Serial.print("Guthaben: ");

//      Serial.println(atof(row->values[1])); // <---- das Guthaben umwandeln in float (du wirst damit rechen wollen)

      } while (row != NULL);

      Serial.println(Uname);

      if (Uname = "1") {

      lcd.setCursor(0,1);

      lcd.print("Karte nicht gefunden");

      lcd.setCursor(0,2);

      lcd.print("Zutritt verweigert!");

      delay(3000);

      }

      delete cur_mem; // Deleting the cursor also frees up memory used

      CardID="0";

}

}

//=======================================================================

Die Fehlermeldung in Arduino ist:
incompatible type in assignment of 'byte {aka unsigned char}' to 'char[20]'
bei dieser Zeile:
CardID += mfrc522.uid.uidByte[i];

Gruß Andy

Möglicherweise verwandte Themen...
Thema:		Verfasser	Antworten:	Ansichten:	Letzter Beitrag
	NodeMCU -KNX	ak68	16	2.766	24.02.2021 17:06 Letzter Beitrag: matty67
	GPS-Synchronisierung mit NodeMCU-ESP8266	Floke4	3	201	22.02.2021 19:33 Letzter Beitrag: rev.antun
	NodeMCU: zyklisch WDT reset	miq19	1	136	21.02.2021 16:30 Letzter Beitrag: miq19
	NodeMCU-ESP8266	Floke4	13	774	25.01.2021 18:17 Letzter Beitrag: hotsystems
	Mit NodeMCU-V3 L9110S Schrittmotor steuern	ICookie	14	858	19.01.2021 12:05 Letzter Beitrag: ICookie
	NodeMCU GPIO15 Transistor Ansteuern	rev.antun	14	1.146	06.01.2021 20:42 Letzter Beitrag: rev.antun
	Variablen NodeMCU ESP8266-E Speicher Sparen	rev.antun	47	2.880	17.12.2020 00:58 Letzter Beitrag: rev.antun
	NodeMCU ESP8266 - IDE Verbindungsprobleme bei D0-Reset Verbindung	ayykaramba	8	1.025	14.12.2020 12:09 Letzter Beitrag: N1d45
	Welche Einstellungen in Arduino IDE für NodeMCU	frankmehlhop	20	1.694	20.11.2020 08:06 Letzter Beitrag: Beinhardt
	NodeMCU ESP12-E und Nextion - ein anderer Weg	rev.antun	1	438	14.11.2020 17:55 Letzter Beitrag: miq19


Baumstrukturmodus \| Linearer Modus NODEMCU - SQL-Datenbank