Pääset tietokantaan PHP-ohjelmointikielellä
Tässä viimeisessä artikkelissa sarjassa Verkkopalvelimen käyttäminen esineiden Internetiin yhdistetyistä laitteista olevien tietojen tallentamiseen, selittää kuinka tallennetaan tietokantaan MySQL tiedot, jotka IoT-solmut lähettävät HTTP POST -pyyntöjä tekevälle palvelimelle. Tämän artikkelin, koko blogin lukijat eivät ehkä ole erityisen perehtyneet ohjelmointiin PHP kieli mutta varmasti kyllä ohjelmoinnin kanssa mikro-ohjaimet kielissä C o C + + joten, lukuun ottamatta joitain yksityiskohtia, kuten dollarimerkin ($) edelle muuttujia, voit seurata esimerkkejä ilman lisäselityksiä, koska ne on tehty noudattaen hyvin neutraalia ohjelmointityyliä, joka ei ole erityistä PHP.
Tallenna tiedot tietokantaan
Kuten artikkelissa selostetaan IoT-tietojen tallennus tekemällä HTTP POST -pyyntöjä verkkopalvelimelle, otsikoiden lopussa POST-pyynnön runko sisältää tiedot, jotka lähetetään palvelimelle. Yleisin tapa lähettää nämä tiedot palvelimelle on tekstimuodossa, koska se on helpompi analysoida jopa "manuaalisesti". Kun palvelimelle lähetettävä data on monimutkaista, se on varmasti kätevää jäsentää esimerkiksi muotoon XML o JSON. Tavanomaisessa web-palvelimen käytössä esineiden Internetiin liitetyistä laitteista tulevien tietojen hallintaan ei ole yleistä tarvita tietorakennetta, joten on normaalia lähettää ne pelkkänä tekstinä muodossa variable=valor.
Seuraavan esimerkin HTTP POST -pyynnössä resurssia (yleensä verkkosivu) /iot/grabar_temperatura pyydetään polaridad.es-palvelimelta ja lähetetään kolme muuttujaa: ne, tp ja cr, jotka vastaavasti sisältävät arvot " 12", "10.26 » ja «2.18» On myös tärkeää muistaa, että otsikot erotetaan tiedoista tyhjällä rivillä.
|
1
2
3
4
|
POST /iot/grabar_temperatura HTTP/1.1
Host: polaridad.es
ne=12&tp=10.26&cr=2.18
|
Seuraavan koodin lopullinen tavoite PHP lähetetään tietokantapalvelimelle MySQL järjestys 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
);
|
jolla luodaan uusi tietue (INSERT)
lämmitystietokannassa (INTO )calefacciones
määrittämällä kenttiin (numero_estancia,temperatura,corriente)
arvot, jotka vastaavat HTTP POST -pyyntöä VALUES (12, 10.26, 2.18)
Yhteys tietokantaan tehdään toiminnolla mysqli_connect muodon mukaan: mysqli_connect($servidor,$usuario,$clave,$base_datos) joka palauttaa osoittimen yhteysobjektiin ja joka käyttää muuttujia, jotka määrittävät pääsyn (kuten käyttäjä, salasana...) ja jotka on aiemmin määritetty tulevaa hypoteettista käyttöä varten komentosarjassa.
Toimintoa käytetään tunnistamaan, onko yhteys onnistunut mysqli_connect_errno() joka palauttaa mahdollisesti tapahtuneen virhenumeron tai nollan (epätosi), jos yhteys muodostettiin oikein. Virheistä ilmoittamiseksi HTTP-pyynnön tekevä sovellus vastaa arvolla nolla, tässä tapauksessa ohjelma, joka suoritetaan µC IoT-solmusta.
|
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;
|
Ennen kuin lisäät tekstiin, joka on tallennettu $consulta_sql jonka kanssa tilaus laaditaan SQL joka lähetetään tietokantapalvelimelle, POST-pyyntömuuttujiin saapuneet tiedot esikäsitellään vähintään, jotta vältytään SQL-injektio. Edellisessä esimerkissä muunnos vastaavaan tietotyyppiin on pakotettu (int) (kokonaisluku) tai (float) (liukuluku desimaali), mikä riittäisi poistamaan mahdollisen haitallisen koodin, joka on lisätty pyyntötietoihin Web-palvelin.
Kuten voidaan nähdä, PHP kieli Pistemerkkiä (.) käytetään ketjuttamaan järjestyksen muodostavat tekstit SQL tai piste- ja yhtäläisyysmerkkioperaattori (.=) lisätäksesi tekstin sen oikealle puolelle, joka jo tallentaa muuttujan, ja lainausmerkkiä (') käytetään myös tekstivakioiden, ei vain merkkien, liittämiseen. Vaikka tässä tapauksessa voidaan käyttää myös lainausmerkkejä («), in PHP kieli käytetään sisällön käsittelemiseen, esimerkiksi sisällyttämällä muuttujat tekstiin muotoon $texto="Me llamo $nombre"; vaihtoehtona formaatille $texto='Me llamo '.$nombre; mahdollistaa myös yhden tyyppisten lainausmerkkien sisällyttämisen toiseen lainausmerkkeihin ilman pakomerkkejä, kun kaksoiskappaleet vuorottelevat sinkkujen sisällä tai sinkkuja kaksoiskappaleiden sisällä, kuten tehtävässä $texto='esto no hay que "escaparlo" en PHP';.
Suorittaaksesi kyselyn palvelimelle MySQL toimintoa käytetään mysqli_query muodossa mysqli_query($conexion,$consulta_sql) joka ottaa parametreiksi objektiyhteyden tietokantaan ja tekstin tilauksen kanssa SQL joka on sävelletty.
Toiminto mysqli_query($conexion,$consulta_sql) palauttaa kohdistinobjektin, jota voidaan käyttää palautettujen tietojen läpikäymiseen tarvittaessa tai, kuten yllä olevassa esimerkissä, saadakseen tietoja operaatiosta, erityisesti saadakseen selville toiminnon taulukossa luomalle uudelle tietueelle osoitetun indeksin " lämmittimet" toiminnolla mysqli_insert_id($conexion)
Palauttama arvo mysqli_query($conexion,$consulta_sql) voi arvioida epätosi loogisessa operaatiossa määrittääkseen, että virhe on tapahtunut. Edellisessä esimerkissä sitä käytetään palauttamaan, kuten yhteysvirheen tapauksessa, nolla sovellukselle, joka tekee POST-pyynnön. Tällä tavalla ohjelma palauttaa nollaa suuremman luvun, joka edustaa uuden tietueen indeksiä, jos toiminto on oikea, tai nollan, jos toiminto tuottaa virheen.
Tietokantayhteydelle osoitettujen resurssien vapauttamiseksi se "suljetaan" toiminnolla mysqli_close($conexion)
Lue tiedot tietokannasta
Paitsi arkkitehtuurissa sumulaskenta Useimmat IoT-solmut rajoittuvat lähettämään anturiensa keräämät tiedot palvelimelle, eli palvelimelle Web-palvelin Se kommunikoi heidän kanssaan vain tallentaakseen tietoja, joten edellisessä esimerkissä suuri osa tässä sovelluksessa esiin tulevista tapauksista on jo ratkaistu. Seuraava askel voisi olla verkkosivuston luominen, joka näyttää esineiden Internetiin yhdistettyjen laitteiden valvomat tiedot. käyttöliittymä joka ei ole tässä opetusohjelmasarjassa käsitellyn asian ulkopuolella.
Mitä voi tapahtua, on se, että IoT-solmulla on tietty vuorovaikutus ja se käyttäytyy eri tavalla historiallisten tietojen perusteella tai ennakoi mahdollisuuden muuttaa käyttäytymistään palvelimelta saapuvan konfiguraation mukaan tai jopa solmu on näyttö, joka näyttää kaavion. äskettäin seurattujen tietojen kanssa verrattuna aikaisempina päivinä hankittuihin tietoihin. Kaikissa näissä tilanteissa on myös mielenkiintoista pystyä lukemaan tietoja palvelimelta MySQL kautta Web-palvelin kuten on havainnollistettu seuraavassa esimerkissä, joka simuloi luettelon saamista hälytystilojen päivämääristä, jotka määritetään hetkillä, jolloin lämpötila ylitti 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);
}
|
Yllä olevassa esimerkissä tietokannan kyselyyn käytetään komentoa SQL SELECT perusmuodon mukaan SELECT campos FROM tabla WHERE condición ORDER BY campo DESC ainoana erikoisuutena on funktioiden lisääminen päivämääräkenttään DAY, MONTH, YEAR y TIME saadaksesi päivän, kuukauden numeron, vuoden ja kellonajan erikseen. Edellytyksenä on, että lämpötila on suurempi kuin 40.0 ja se järjestetään päivämääräkentän avulla korkeimmasta (nykyisin) alimpaan (vanhimpaan) osoittaen sen lausekkeen kanssa DESC
Selaa kyselyn silmukasta palauttamia arvoja for funktiota käytetään tunnetulla mittasuhteella mysqli_num_rows($resultado) joka ilmaisee löydettyjen tietueiden määrän. Toiminnon kanssa mysqli_data_seek($resultado,$numero_resultado) tuloskohdistin voidaan siirtää tiettyyn silmukkalaskurin ilmaisemaan kohtaan for, $numero_resultado, esimerkissä.
Toimintoa käytetään tallentamaan vektoriin ne tietueen kentät, joihin tuloskursori osoittaa mysqli_fetch_row($resultado) joka on määritetty muuttujalle $registro joita käytetään myöhemmin muodostamaan lause, jossa on eri arvoja, ja niitä käytetään niiden indeksien avulla.
Kun kaikki arvot on käyty läpi, kyselytulokselle määritetyt resurssit vapautetaan SQL toiminnolla mysqli_free_result($resultado)
Käsittele tietokannan tiedot. Vertaa arvoja.
Joissain tilanteissa tietojenkäsittely on kätevää keskittää palvelimelle, vaikka se olisi mahdollista tehdä IoT-solmuissa tyylillä sumulaskenta. Seuraavassa esimerkissä simuloituja syitä tähän ovat turvallisuus; Solmulla on tietoa avaimestaan (lukosta) ja pyynnöstä (avaimesta), mutta se ei tiedä, onko tarkoituksenmukaista antaa tietä molempien yhdistelmälle, joten sen on otettava yhteyttä palvelimeen, joka tekee päätöksen ja ilmoittaa solmulle vastaamalla nollaksi (osoittaakseen epäonnistuneen vertailun) tai yhden (osoittaakseen vertailun onnistumisesta) tietokantaan tehdyn kyselyn tuloksen perusteella.
Tällä tekosyyllä näet esimerkin, jossa esineiden Internetiin yhdistetystä laitteesta vastaanotetaan tietoja (avainkoodi ja suojakoodi), palautetaan tulos (yksi tai nolla riippuen siitä, onko tulos tosi vai epätosi) ja Tiedoista suoritetaan pieni prosessointi, jossa verrataan tietokantaa tarkasteltaessa saatuja tuloksia IoT-solmun lähettämiin tuloksiin.
|
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;
|
Edellisessä esimerkissä heksadesimaalilukua käytetään desimaaliluvun saamiseksi tekstistä, joka edustaa heksadesimaalilukua ja on IoT-laitteen lähettämä. Tämän toiminnon lisäetu on välttää, kuten edellä on selitetty, hyökkäys lisäämällä koodia SQL haitallinen POST-pyynnön tiedoille.
Post Comment