Mostra la font per a Ús de la base de dades MariaDB des de NodeRED

= Accés =
Ha d'haver una base de dades creada al MariaDB amb el nom '''aula508'''

L'usuari '''iot''' amb contrasenya '''iot''' té permisos d''''escriptura i lectura''' sobre la base de dades '''aula508'''

L'usuari '''convidat''' amb contrasenya '''benvingut''' té permisos de '''lectura''' sobre la base de dades '''aula508'''

Explicació detallada a [[Ús de MariaDB per emmagatzemar dades de la Internet de les Coses]]
= Nodes MariaDB a NodeRed =
== Instal·lació ==
[[Image:10MariaDbNodeRed00.png|center|thumb|Instal·lació des nodes de MariaDB (''MySQL'') a NodeRED]]

[https://flows.nodered.org/node/node-red-node-mysql cal instal·lar el conjunt de nodes ''node-red-node-mysql'']

[[Image:11nodoMariaDbNodeRed.png|center|thumb|Aspecte del node MySQL a NodeRED]]
== Configuració de la base de dades al node MySQL ==
* Poseu un node MySQL al tapís Node-RED

* Feu doble clic sobre el node MySQL

[[Image:12nodoMariaDbNodeRed.png|center|thumb|Configuració del node MySQL]]

* Aneu al llapis a la dreta del desplegable ''Add new MySQL database...'' present a la fila ''Database''

[[Image:13nodoMariaDbNodeRed.png|center|thumb|Configuració del nodo MySQL]]

- A '''Host''' escriviu la IP local del servidor ('''127.0.0.1'''). Per seguretat, no permetem a la base de dades que tingui visibilitat externa.

- A '''Port''' escriviu el port TCP ('''3306''') per defecte de las bases de dades MySQL

- A '''User''' escriviu un usuari amb permisos d'escriptura ('''iot'''), perquè volem escriure. Si no calmescriure a la base de dades escriuríem un usuari amb permisos de tan sols lectura (com '''convidat''').

- A '''Password''' escriviu la contrasenya de l'usuari (per a l'usuari '''iot''' és '''iot'''. Per a l'usuari '''convidat''' és '''benvingut''').

- A '''Database''' escriviu la base de dades que volem accedir ('''aula508'''). (A la captura hi surt ''aula206'' i no ''aula508'')

- A '''Charset''' escriviu la codificació de caràcters ('''UTF8''')

== Creació d'una taula a la base de dades MySQL ==
[[Image:14nodoMariaDbNodeRed.png|center|Creació d'una taula]]

Hi ha quatre nodes enllaçats: '''inject''', '''function''', '''mysql''' i '''debug'''.

* Els nodes '''inject''' i '''debug''' no es modifiquen. Deixeu la configuració per defecte.

* El node '''mysql''' ha estat configura al pas anterior.

* El node '''function''' s'ha configurat així:

[[Image:15nodoMariaDbNodeRed.png|center|Creació d'una taula]]

Funció '''CREATE TABLE m28XX_T_RH''':
 msg.topic = `
 CREATE TABLE m'''28XX'''_T_RH (
  time TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
  valueT FLOAT,
  valueRH FLOAT,
  PRIMARY KEY (time));
 `;
 return msg;
== Esborrat d'una taula a la base de dades MySQL ==
[[Image:16nodoMariaDbNodeRed.png|center|Esborrat d'una taula]]

Funció '''DROP TABLE m28XX_T_RH''':
 msg.topic = `DROP TABLE m28XX_T_RH;`;
 return msg;
== Inserció de dades a una taula de la base de dades MySQL ==
=== Configuració de nodes ''inject'' per a generar dades de tipus JSON ===
[[Image:17nodoMariaDbNodeRed.png|center|Nodes ''inject'' per a generar dades de tipus JSON]]
Doble clic sobre el nodo ''inject'' (seleccioneu l'opció '''{}'''):
[[Image:1701nodoMariaDbNodeRed.png|center|Edició del node ''inject'' per a generar dades de tipus JSON]]
Cliqueu sobre '''...''' (els tres puntos):
[[Image:1702nodoMariaDbNodeRed.png|center|Edició del node ''inject'' per a generar dades de tipus JSON]]
En format text:
 {
    "valueT": 17.89,
    "valueRH": 44.32
 }

=== Inserció de dades de tipus JSON a columnes de la taula ===
[[Image:18nodoMariaDbNodeRed.png|center|Inserció de dades de tipus JSON a columnes de la taula]]

Funció '''INSERT DATA''':
 msg.topic = `insert into m28XX_T_RH(valueT,valueRH) values(${msg.payload.valueT},${msg.payload.valueRH})`;
 return msg;
== Lectura de dades a una taula de la base de dades MySQL ==
[[Image:19nodoMariaDbNodeRed.png|center|Exemple de SELECT per a MariaDB]]
Camp '''msg.topic''' del node ''inject'' per a fer un '''SELECT''':
[[Image:20nodoMariaDbNodeRed.png|center|Node ''inject'' per a trametre un ''query'' de tipus ''SELECT'' a MariaDB]]

Camp '''msg.topic''' del node ''inject'' amb nom '''SELECT''' en format text:
 select UNIX_TIMESTAMP(time) as time, valueT, valueRH from m28XX_T_RH
== Creació d'una taula vista a la base de dades MySQL ==
[[Image:21nodoMariaDbNodeRed.png|center|Creació d'una taula vista a partir d'una altra taula a una base de dades MariaDB]]

Funció '''CREATE VIEW m28XX_T_RH_v''':
 msg.topic = `CREATE VIEW '''m28XX'''_T_RH_v AS select UNIX_TIMESTAMP(time) as time, valueT, valueRH from '''m28XX'''_T_RH;`;
 return msg;
== Tractament de dades llegides a la taula ==

[[Image:22nodoMariaDbNodeRed.png|center|Tractament de dades llegides a la taula]]

Afegiu sortides a la funció (a '''Outputs''' s'ha canviat d'1 a 3 sortides):

[[Image:23nodoMariaDbNodeRed.png|center|Afegiu sortides a la funció]]

Codi de la funció '''Tratamiento datos / Últimas entradas''':

[[Image:24nodoMariaDbNodeRed.png|center|Codi de la funció '''Tratamiento datos / Últimas entradas''']]

Funció '''Tratamiento datos / Últimas entradas''' en modo text:
 var a = msg.payload;
 var val = "";
 var lastEntryValueT, lastEntryValueRH;
 a.forEach(function (entry) {
    val += "timestamp: " + entry.time + ", valueT: " + entry.valueT + ", valueRH: " + entry.valueRH + "\r";
    lastEntryValueT = entry.valueT;
    lastEntryValueRH = entry.valueRH;
 });
 msg.payload = val;
 var msg_valT = { payload: lastEntryValueT };
 return [msg, msg_valT, { payload: lastEntryValueRH}];
== Aleatorització controlada pel tauler de control ==
[[Image:25nodoMariaDbNodeRed.png|center|Generació de dades aleatòries]]

Al seleccionar el commutador (''switch'') '''Randomize''' comença la generació de dades aleatòries. Al deseleccionar-ho s'atura la generació de dades.

[[Image:26nodoMariaDbNodeRed.png|center|Generació de dades aleatòries]]

[https://www.binefa.cat/training/upcSchool/2023/20230415/26nodeRedRandomUi.nodered.json Codi per al NodeRED que genera dues dades aleatòries]

Funció '''Randomizing (On/Off)''':
 flow.set("Randomizing",msg.payload);
 return msg;

Funció '''random JSON value in range {"T": <20.0,30.0>,"RH": <45.0,55.0>}''':
 var randomT = parseFloat((200 + Math.floor(Math.random() * 101)) / 10); // value between 20.0 and 30.0
 var randomRH = parseFloat((450 + Math.floor(Math.random() * 101)) / 10); // value between 45.0 and 55.0
 var jsonR = {};
 jsonR["T"] = randomT;
 jsonR["RH"] = randomRH;
 
 var msg_jsonR = { payload: jsonR };
 var msg_valT = { payload: randomT };
 var msg_valRH = { payload: randomRH };
 
 return [msg_jsonR, msg_valT, msg_valRH];

= Escriptura síncrona de múltiples dades asíncrones alhora. Ús del format de dades '''json''' =

[[Image:27nodoMariaDbNodeRed.png|center|Ús del format de dades '''json''']]


[https://www.binefa.cat/training/upcSchool/2023/20230415/27nodeRedJson.nodered.json Codi en NodeRED per a l'ús de Json a MariaDB]

Funció '''T:24.7,RH:74.6,P:1007.2,LDR:47.3''' (aquesta funció s'executa al desplegar el flux, degut a la configuració del node ''inject''):
 flow.set("IoT-02_RH",74.6);
 flow.set("IoT-02_T",24.7);
 flow.set("IoT-02_P",1007.2);
 flow.set("IoT-02_LDR",47.3);
 return msg;

Funció '''T:21.3,RH:48.2,P:1003.5,LDR:89.4''':
 flow.set("IoT-02_RH",48.2);
 flow.set("IoT-02_T",21.3);
 flow.set("IoT-02_P",1003.5);
 flow.set("IoT-02_LDR",89.4);
 return msg;

Funció '''--> json''':
 var json00 = {};
 json00.RH = flow.get("IoT-02_RH");
 json00.T = flow.get("IoT-02_T");
 json00.P = flow.get("IoT-02_P");
 json00.LDR = flow.get("IoT-02_LDR");
 msg.payload = json00;
 return msg;

Funció '''INSERT INTO m28XX_T_RH_P_LDR(valueT,valueRH,valueP,valueLDR)''':
 msg.topic = `insert into m28XX_T_RH_P_LDR(valueT,valueRH,valueP,valueLDR) values(${msg.payload.T},${msg.payload.RH},${msg.payload.P},${msg.payload.LDR})`;
 return msg;

Consulta a MariaDB des del terminal:
 convidat@vps656540:~$ '''mysql -u convidat -p'''
 Enter password: ''(la contraseña es '''benvingut''')''
 Welcome to the MariaDB monitor.  Commands end with ; or \g.
 Your MariaDB connection id is 133
 Server version: 10.3.38-MariaDB-0+deb10u1 Debian 10
 
 Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others. 
 
 Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
 
 MariaDB [(none)]> '''use aula206;'''
 Reading table information for completion of table and column names
 You can turn off this feature to get a quicker startup with -A 
 
 Database changed
 MariaDB [aula206]> '''select * from m28XX_T_RH_P_LDR_v;'''
 +------------+--------+---------+--------+----------+
 | time       | valueT | valueRH | valueP | valueLDR |
 +------------+--------+---------+--------+----------+
 | 1681149647 |   24.7 |    74.6 | 1007.2 |     47.3 |
 | 1681149886 |   21.3 |    48.2 | 1003.5 |     89.4 |
 +------------+--------+---------+--------+----------+
 2 rows in set (0.000 sec)
 
 MariaDB [aula206]> '''quit'''
 Bye