Do baze podatkov dostopajte iz programskega jezika PHP
V tem zadnjem članku v seriji o Uporaba spletnega strežnika za shranjevanje podatkov iz naprav, povezanih z internetom stvari, pojasnjuje, kako zapisovati v bazo podatkov MySQL informacije, ki jih vozlišča IoT pošljejo strežniku, ki izvaja zahteve HTTP POST. Bralci tega članka ali celotnega bloga morda niso posebej seznanjeni s programiranjem v jezik PHP ampak zagotovo da s programiranjem mikrokrmilniki v jezikih C o C + + tako boste lahko z izjemo nekaterih podrobnosti, kot je znak za dolar ($) pred spremenljivkami, sledili primerom brez dodatnih pojasnil, saj so bili narejeni po zelo nevtralnem slogu programiranja, ki ni specifičen za PHP.
Shranite podatke v bazo podatkov
Kot je pojasnjeno v članku o Shranjevanje podatkov IoT s pošiljanjem zahtev HTTP POST spletnemu strežniku, na koncu glav telo zahteve POST vsebuje podatke, ki so poslani strežniku. Najpogostejši način za pošiljanje teh informacij na strežnik je v obliki navadnega besedila, ker jih je lažje analizirati tudi "ročno". Ko so podatki, poslani na strežnik, zapleteni, jih bo zagotovo priročno strukturirati z uporabo, na primer, formata XML o JSON. Pri običajni uporabi spletnega strežnika za upravljanje informacij iz naprav, povezanih z internetom stvari, ni običajno, da bi potrebovali strukturo podatkov, zato je običajno, da jih pošljete v navadnem besedilu v obliki variable=valor.
V zahtevi HTTP POST v naslednjem primeru je vir (običajno spletna stran) /iot/grabar_temperatura zahtevan od strežnika polaridad.es in poslane so tri spremenljivke: ne, tp in cr, ki vsebujejo vrednosti " 12", "10.26 » in «2.18» Pomembno si je tudi zapomniti, da obstaja prazna vrstica za ločevanje glav od podatkov.
|
1
2
3
4
|
POST /iot/grabar_temperatura HTTP/1.1
Host: polaridad.es
ne=12&tp=10.26&cr=2.18
|
Končni cilj naslednje kode PHP bo poslal strežniku baze podatkov MySQL vrstni red SQL:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
INSERT
INTO `calefacciones`
(
numero_estancia,
temperatura,
corriente
)
VALUES
(
12,
10.26,
2.18
);
|
S katerim bo ustvarjen nov zapis (INSERT)
v podatkovni bazi ogrevanja (INTO )calefacciones
dodeljevanje poljem (numero_estancia,temperatura,corriente)
vrednosti, ki ustrezajo zahtevi HTTP POST VALUES (12, 10.26, 2.18)
Povezava z bazo se izvede s funkcijo mysqli_connect glede na format: mysqli_connect($servidor,$usuario,$clave,$base_datos) ki vrne kazalec na objekt povezave in ki uporablja spremenljivke, ki definirajo dostop (kot so uporabnik, geslo ...) in ki so bile predhodno dodeljene za prihodnje hipotetične uporabe v skriptu.
Za ugotavljanje, ali je bila povezava uspešna, se uporablja funkcija mysqli_connect_errno() ki vrne številko napake, ki se je morda zgodila, ali nič (false), če je bila povezava vzpostavljena pravilno. Za obveščanje o napakah se aplikacija, ki naredi zahtevo HTTP, odzove z vrednostjo nič, v tem primeru program, ki se izvaja v µC vozlišča IoT.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
$fin_linea=PHP_EOL;
$servidor=‘localhost’;
$usuario=‘pelaez’;
$clave=‘1234’;
$base_datos=‘base_datos_temperaturas’;
$conexion=mysqli_connect($servidor,$usuario,$clave,$base_datos);
if(mysqli_connect_errno())
{
echo 0; // Devolver el valor 0 para indicar que se ha producido un error
}
else
{
$numero_estancia=(int)$_POST[‘ne’];
$temperatura=(float)$_POST[‘tp’];
$corriente=(float)$_POST[‘cr’];
$consulta_sql =‘INSERT INTO calefacciones (numero_estancia,temperatura,corriente) ‘;
$consulta_sql.=‘VALUES (‘.$numero_estancia.‘,’.$temperatura.‘,’.$corriente.‘);’;
$resultado=mysqli_query($conexion,$consulta_sql);
if($resultado) // Si no se ha producido un error al realizar la consulta…
{
echo mysqli_insert_id($conexion); // Devolver el índice del nuevo registro (¡>0!)
}
else
{
echo 0; // Devolver el valor 0 para indicar que se ha producido un error
}
mysqli_close($conexion);
}
echo $fin_linea;
|
Pred dodajanjem besedilu, ki je shranjeno v $consulta_sql s katerim je naročilo sestavljeno SQL ki se pošlje strežniku baze podatkov, so informacije, ki so prispele v spremenljivkah zahteve POST, predhodno obdelane najmanj, da se prepreči napad Vbrizgavanje SQL. V prejšnjem primeru je pretvorba v ustrezen podatkovni tip vsiljena (int) (celo število) oz (float) (decimalno s plavajočo vejico), kar bi zadostovalo za odstranitev morebitne zlonamerne kode, dodane v podatke zahteve s strani spletni strežnik.
Kot je razvidno iz jezik PHP Simbol pike (.) se uporablja za povezovanje besedil, ki tvorijo vrstni red SQL ali operator pike in enačaja (.=) za dodajanje besedila na desno od tistega, ki že shranjuje spremenljivko, enojni narekovaj (‘) pa se uporablja tudi za pritrditev besedilnih konstant, ne le znakov. Čeprav je v tem primeru mogoče uporabiti tudi dvojne narekovaje («), v jezik PHP se uporabljajo za obdelavo vsebine, na primer vključno s spremenljivkami znotraj besedila v formatu $texto="Me llamo $nombre"; kot alternativa formatu $texto='Me llamo '.$nombre; prav tako vam omogoča, da narekovaje ene vrste vključite v drugo, ne da bi morali uporabiti znake za izhod, kadar se dvojine izmenjujejo znotraj enoj ali enojne znotraj dvojine, kot v dodelitvi $texto='esto no hay que "escaparlo" en PHP';.
Za izvedbo poizvedbe do strežnika MySQL se uporablja funkcija mysqli_query z obliko mysqli_query($conexion,$consulta_sql) ki za parametre vzame objekt-povezavo z bazo podatkov in besedilo z naročilom SQL ki je bila sestavljena.
Funkcija mysqli_query($conexion,$consulta_sql) vrne kazalec-objekt, ki se lahko uporabi za prečkanje vrnjenih podatkov, če je primerno, ali, kot v zgornjem primeru, za pridobitev informacij o operaciji, zlasti za poznavanje indeksa, dodeljenega novemu zapisu, ki ga je operacija ustvarila v tabeli " grelci" s funkcijo mysqli_insert_id($conexion)
Vrednost, ki jo je vrnil mysqli_query($conexion,$consulta_sql) lahko oceni na false v logični operaciji, da ugotovi, da je prišlo do napake. V prejšnjem primeru se uporablja za vrnitev ničle, kot v primeru napake pri povezavi, aplikaciji, ki naredi zahtevo POST. Na ta način bo program vrnil število, večje od nič, ki predstavlja indeks novega zapisa, če je operacija pravilna, ali nič, če operacija povzroči napako.
Če želite sprostiti vire, ki so bili dodeljeni povezavi baze podatkov, jo "zaprete" s funkcijo mysqli_close($conexion)
Preberite informacije iz baze podatkov
Razen v arhitekturah za računalništvo v megli Večina vozlišč IoT se omeji na pošiljanje informacij, ki jih zajamejo njihovi senzorji, na strežnik, tj. spletni strežnik Z njimi komunicira le za shranjevanje informacij, tako da je s prejšnjim primerom dobršen del primerov, ki bodo nastali v tej aplikaciji, že razrešenih. Naslednji korak bi lahko bil ustvariti spletno stran, ki prikazuje podatke, ki jih spremljajo naprave, povezane z internetom stvari, delo začelje kar je zunaj tega, kar je zajeto v tej seriji vadnic.
Lahko se zgodi, da ima vozlišče IoT določeno interaktivnost in se obnaša drugače na podlagi zgodovinskih podatkov ali predvideva možnost spreminjanja svojega vedenja glede na konfiguracijo, ki pride do njega s strežnika, ali celo vozlišče je zaslon, ki prikazuje graf s podatki, ki so bili nedavno spremljani v primerjavi s podatki, pridobljenimi na prejšnje datume. Za vse te situacije je zanimiva tudi možnost branja podatkov s strežnika MySQL skozi spletni strežnik kot je prikazano v naslednjem primeru, ki simulira pridobivanje seznama datumov stanj alarma, določenih s trenutki, v katerih je temperatura presegla 40 °C
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
$fin_linea=PHP_EOL; // Fin de línea. Usar <br> para HTML si se va a mostrar la salida en algún tipo de pantalla o consola no es necesario
$servidor=‘localhost’;
$usuario=‘pelaez’;
$clave=‘1234’;
$base_datos=‘base_datos_temperaturas’;
$conexion=mysqli_connect($servidor,$usuario,$clave,$base_datos);
if(mysqli_connect_errno())
{
echo ‘Error al conectar a la base de datos: ‘ . mysqli_connect_error();
}
else
{
$consulta_sql=‘SELECT ‘;
$consulta_sql.=‘estancia, temperatura, DAY(fecha), MONTH(fecha), YEAR(fecha), TIME(fecha) ‘;
$consulta_sql.=‘FROM valor_temperaturas ‘;
$consulta_sql.=‘WHERE temperatura>40.0 ‘;
$consulta_sql.=‘ORDER BY fecha DESC;’;
$resultado=mysqli_query($conexion,$consulta_sql); // El tercer parámetro de mysqli_query, no usado, es el modo MYSQLI_STORE_RESULT por defecto o MYSQLI_USE_RESULT para grandes cantidades de datos
if($resultado) // Si no se ha producido un error al realizar la consulta
{
$total_resultado=mysqli_num_rows($resultado);
if($total_resultado) // Si se ha encontrado algún resultado
{
echo ‘Se han encontrado ‘.$total_resultado.‘ estados de alarma:’.$fin_linea;
for($numero_resultado=0;$numero_resultado<$total_resultado) // Recorrer los resultados
{
mysqli_data_seek($resultado,$numero_resultado); // Mover el cursor al registro correspondiente (no tendría por qué ser consecutivo)
$registro=mysqli_fetch_row($resultado); // Almacenar en un vector los datos del registro
echo ‘El ‘.$registro[2]; // Tercer campo de la consulta (día)
echo ‘ del ‘.$registro[3]; // Cuarto campo de la consulta (mes)
echo ‘ de ‘.$registro[4]; // Quinto campo de la consulta (año)
echo ‘ a las ‘.$registro[5]; // Sexto campo de la consulta (hora)
echo ‘ en la estancia “‘.$registro[0].‘”‘; // Primer campo de la consulta (estancia)
echo ‘ la temperatura superó el máximo de 40°C (‘.$registro[1].‘)’; // Segundo campo de la consulta (temperatura)
echo $fin_linea;
}
}
else
{
echo ‘No se ha encontrado ningún estado de alarma’.$fin_linea;
}
mysqli_free_result($resultado);
}
mysqli_close($conexion);
}
|
V zgornjem primeru se za poizvedbo po bazi podatkov uporabi ukaz SQL SELECT glede na osnovni format SELECT campos FROM tabla WHERE condición ORDER BY campo DESC z edino posebnostjo dodajanja funkcij v datumsko polje DAY, MONTH, YEAR y TIME da bi ločeno pridobili dan, številko meseca, leto in uro. Predpisan pogoj je, da je temperatura višja od 40.0 in je razvrščena z uporabo datumskega polja od najvišje (najbolj trenutne) do najnižje (najstarejše), ki jo označuje s klavzulo DESC
Za zanko skozi vrednosti, ki jih vrne poizvedba iz zanke for z znano dimenzijo se uporablja funkcija mysqli_num_rows($resultado) ki označuje število najdenih zapisov. S funkcijo mysqli_data_seek($resultado,$numero_resultado) kurzor rezultatov je mogoče premakniti na določen položaj, izražen s števcem zanke for, $numero_resultado, v primeru.
Za shranjevanje v vektorju polj zapisa, na katera kaže kazalec rezultata, se uporablja funkcija mysqli_fetch_row($resultado) ki je dodeljena spremenljivki $registro ki bodo kasneje uporabljeni za oblikovanje besedne zveze z različnimi vrednostmi, dostop do njih z njihovimi indeksi.
Ko so bile prevožene vse vrednosti, se sprostijo viri, dodeljeni rezultatu poizvedbe SQL s funkcijo mysqli_free_result($resultado)
Obdelajte informacije iz baze podatkov. Primerjaj vrednosti.
V nekaterih primerih je primerno, da je obdelava informacij centralizirana na strežniku, tudi če bi bilo to mogoče storiti v vozliščih IoT v stilu računalništvo v megli. V naslednjem primeru so razlogi, ki so simulirani za to, varnost; Vozlišče ima informacije o svojem ključu (ključavnici) in o zahtevi (ključu), vendar ne ve, ali je primerno dati prednost kombinaciji obeh, zato se mora posvetovati s strežnikom, ki je tisti, ki sprejme odločitev in obvesti vozlišče z odgovorom nič (za navedbo neuspešne primerjave) ali ena (za navedbo, da je bila primerjava uspešna) glede na rezultat poizvedbe v vaši bazi podatkov.
S tem izgovorom si lahko ogledate primer, v katerem so podatki prejeti iz naprave, povezane z internetom stvari (koda ključa in koda za zaklepanje), vrnjen rezultat (ena ali nič, odvisno od tega, ali je rezultat resničen ali napačen) in izvedena je majhna obdelava informacij, ki je sestavljena iz primerjave rezultatov, pridobljenih pri pregledu baze podatkov, s tistimi, ki jih pošlje vozlišče IoT.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
$fin_linea=PHP_EOL;
$servidor=‘localhost’;
$usuario=‘pelaez’;
$clave=‘1234’;
$base_datos=‘base_datos_puertas’;
$conexion=mysqli_connect($servidor,$usuario,$clave,$base_datos);
if(mysqli_connect_errno())
{
echo 0; // Devolver el valor 0 para indicar que la comparación no es válida o que se ha producido un error (en este caso es un error)
}
else
{
$cerradura=hexdec($_POST[“c”]);
$llave=hexdec($_POST[“l”]);
$consulta_sql=‘SELECT llave FROM cerraduras WHERE cerradura=”.$cerradura.“;’;
$resultado=mysqli_query($conexion,$consulta_sql);
if($resultado) // Si no se ha producido un error al realizar la consulta
{
$total_resultado=mysqli_num_rows($resultado);
if($total_resultado) // Si se ha encontrado algún resultado
{
$numero_resultado=0;
$buscando_cerradura=TRUE;
while($buscando_cerradura&&$numero_resultado<$total_resultado)
{
mysqli_data_seek($resultado,$numero_resultado);
$registro=mysqli_fetch_row($resultado);
if($registro[0]==$llave)
{
$buscando_cerradura=FALSE;
}
else
{
$numero_resultado++;
}
}
// echo !$buscando_cerradura;
if($buscando_cerradura)
{
echo 0; // Devolver el valor 0 para indicar que la comparación no es válida (o que se ha producido un error; y aquuí no es el caso)
}
else
{
echo 1; // Devolver el valor 1 para indicar que la comparación SÍ es válida
}
}
else
{
echo 0; // Devolver el valor 0 para indicar que la comparación no es válida o que se ha producido un error
}
}
else
{
echo 0; // Devolver el valor 0 para indicar que la comparación no es válida o que se ha producido un error
}
mysqli_close($conexion);
}
echo $fin_linea;
|
V prejšnjem primeru se funkcija hexdec uporablja za pridobivanje decimalne številke iz besedila, ki predstavlja šestnajstiško številko in je tisto, ki ga pošlje naprava IoT. Dodatna prednost uporabe te funkcije je, da se z dodajanjem kode izognete napadu, kot je bilo razloženo prej SQL zlonamerno za podatke zahteve POST.
po Komentar