[[oktatas:programozás:php:php adatbázis|< PHP adatbázis]]

====== MySQLi Objektumokkal ======

  * **Szerző:** Sallai András
  * Copyright (c) Sallai András, 2014, 2015, 2017, 2019, 2020
  * Licenc: GNU Free Documentation License 1.3
  * Web: https://szit.hu

===== Kapcsolódás =====

<code php connect.php>
<?php
$conn = new mysqli('localhost', 'erdo', 'titok', 'erdo');

if($conn->connect_error) {
	die('Hiba a kapcsolódás során!' . $conn->connect_error);
}

$conn->set_charset("utf-8");

echo 'Sikeres kapcsolódás...' . $conn->host_info . "\n";

$conn->close();

</code>

===== Adatbázis létrehozása =====

<code php createdb.php>
<?php

$user = 'erdo';
$pass = 'titok';
$host = 'localhost';

$conn = new mysqli($host, $user, $pass);

if ($conn->connect_error) {
    die("Hiba a kapcsolódás során" . $conn->connect_error);
}

$sql = "create database erdo";

if ($conn->query($sql) === TRUE) {
    echo "Az adatbázis létrejött";
} else {
    echo "Hiba az adatbázis létrehozása során!";
    echo mysqli_error($conn);
}

$conn->close();

</code>

===== Tábla létrehozása =====

<code php createtable.php>
<?php

$user = 'erdo';
$pass = 'titok';
$host = 'localhost';
$dbname = 'erdo';

$conn = new mysqli($host, $user, $pass, $dbname);

if ($conn->connect_error) {
    die("Hiba a kapcsolódás során" . $conn->connect_error);
}

$sql = "create table dolgozok (
	az int not null primary key auto_increment,
	vnev varchar(30),
	knev varchar(30),
	telepules varchar(30),
	fizetes double

)";

if ($conn->query($sql) === TRUE) {
    echo "A tábla létrejött";
} else {
    echo "Hiba a tábla létrehozása során!";
    echo mysqli_error($conn);
}

$conn->close();

</code>
===== Beszúrás =====

<code php>
$sql = "INSERT INTO users (user, pass) VALUES ('kati', 'titok')";
$conn->query($sql);
</code>


Teljes kód, kicsit más mezőkkel:

<code php insert.php>
<?php

$user = 'erdo';
$pass = 'titok';
$host = 'localhost';
$dbname = 'erdo';

$conn = new mysqli($host, $user, $pass, $dbname);

if ($conn->connect_error) {
    die("Hiba a kapcsolódás során" . $conn->connect_error);
}

$sql = "insert into dolgozok
(vnev, knev, telepules, fizetes)
values
('Petri', 'István', 'Szeged', 1950000)
";

if ($conn->query($sql) === TRUE) {
    echo "A beszúrás megtörtént";
} else {
    echo "Hiba a rekord beszúrása során!";
    echo mysqli_error($conn);
}

$conn->close();
</code>

===== Beszúrt rekord azonosítója =====

<code php>
$sql = "INSERT INTO users (user, pass) VALUES ('kati', 'titok')";
$conn->query($sql);

printf ("Új rekord azonosítója: %d.\n", $conn->insert_id);
</code>
Az utolsó printf() függvénnyel -- ez opcionális -- kiíratjuk az automatikusan generált azonosítót. 

===== Beszúrás ellenőrzése =====

Beszúró lekérdezés sikerének ellenőrzése:
<code php>
if ($conn->query("CREATE TEMPORARY TABLE Városom LIKE Város") === TRUE) {
    printf("A Városom tábla sikeresen létrejött\n");
}
</code>

===== Előkészített beszúrás =====

Angolosan: Prepared Statements. Előkészítem az SQL utasítás, de nem adom meg
az adatokat, csak később. 

<code php elokeszitett.php>
<?php

$conn = new mysqli('localhost', 'erdo', 'titok', 'erdo');

if($conn->connect_error) {
	die('Hiba a kapcsolódás sorána!' . $conn->connect_error);
}

$sql = <<<EOT
insert into termekek
(nev, ar, mennyiseg)
values
(?,?,?)
EOT;

$stmt = $conn->prepare($sql);
$stmt->bind_param("sdd", $nev, $ar, $mennyiseg);

$nev="áfonya"; $ar=370; $mennyiseg=310;
$stmt->execute();

$nev="dió"; $ar=870; $mennyiseg=210;
$stmt->execute();

$stmt->close();
$conn->close();
echo "Az adatok felvéve";

</code>


Vegyük észre az SQL utasításban a kérdőjeleket.

<code sql>
insert into termekek
(nev, ar, mennyiseg)
values
(?,?,?)
</code>

===== Lekérdezés =====

<code php index.php>
<?php

$conn = new mysqli("localhost", "userName", "titok", "dbName");

if($conn->connect_error)
    die("Hiba a kapcsolódás során (" . $conn->connect_errno . ")"
    . $conn->connect_error);

echo "Sikeres kapcsolódás...<br>";

$conn->set_charset("utf8");

$sql = "SELECT eloadoNev FROM `Előadó`";
if($result = $conn->query($sql)) {
    while($sor = $result->fetch_assoc()) {
	echo $sor["eloadoNev"] . "<br>";
    }
    $result->free();
} else {
	echo "Lekérés hiba";
}

$conn->close();

</code>

A karakterkódolás beállítása nagyon fontos, ha ékezetes tábla és mezőnevekkel dolgozunk!

A lekérés során, hány rekordot kaptunk:
<code php>
$darabszam = $result->num_rows;
</code>




===== SQL paraméterek asszociatív tömbből =====

<code php>
$sql = "insert into dolgozok (nev, telepules) values (\"{$data['nev']}\", \"{$data['telepules']}\")";
</code>


Heredoc szintaxis példa:
<code php>
$sql = <<<EOT
insert into dolgozok (nev, telepules)
values
("{$data['nev']}", "{$data['telepules']}") 
</code>

===== Adatbázis kezelő függvények =====

<code php database.php>
<?php
require "config.php";

function insertDolgozo($conn, $data) {
	$sql = "insert into dolgozok (nev, telepules) values (\"{$data['nev']}\", \"{$data['telepules']}\")";
	$conn->query($sql);
}

function dbopen() {
	global $db;
	$conn = new mysqli($db['host'], $db['user'], $db['pass'], $db['dbname']);
	if($conn->connect_error)
		die("Hiba a kapcsolódás során (" . $conn->connect_errno . ")"
		. $conn->connect_error);
	$conn->set_charset("utf8");	
	return $conn;	
}

function dbclose($mysqli) {
	$conn->close();
}

</code>

A data egy tömb. A tömböt átadjuk paraméterként, meg a megnyitott kapcsolatobjektumot:
Így hívjuk meg:

<code php>
$conn = dbopen();

$data = array(
	nev => $_POST['nev'],
	telepules => $_POST['telepules']	
);

insertDolgozo($con, $data);
</code>



<code php config.php>
<?php

$db['host'] = "localhost";
$db['user'] = "username";
$db['pass'] = "titok";
$db['dbname'] = "dbnev";

</code>

===== Hibakezelés =====

<code php>
<?php

$conn = new mysqli("localhost", "username", "titok", "dbnev");

if($conn->connect_errno) {
	print "Hiba a kapcsolódás során!";
        printf("A hiba oka: %s\n", $conn->connect_error);
        exit();
}

$sql = "insert into users (user, pass) values ('peti', 'titok')";
$conn->query($sql);

if($conn->sqlstate != 0)
	print "Hiba a lekérdezéseben!";
$conn->close();

</code>


===== Iterátor használata =====

<code php>
<?php

$conn = new mysqli("localhost", "user_nev", "jelszo", "db_nev");

if($conn->connect_error) {
	die('Hiba a kapcsolódás sorána!' . $conn->connect_error);
}

$sql = "select nev, telepules from szemelyek";

foreach( $conn->query($sql) as $row) {
	printf("%s %s\n, $row['nev'], $row['telepules']);
}

$conn->close();

</code>

===== Egysoros iteráció =====

<code php>
<?php

function getDataAsArray() {

	$conn = new mysqli("localhost", "user_nev", "jelszo", "db_nev");

	$sql = "select nev, telepules from szemelyek";

	$res = $conn->query($sql);

	for( $datar = array(); $row = $res->fetch_assoc(); $datar[] = $row);

	$conn->close();
	
	return $datar;
}
</code>

===== Real escape =====

A biztonság érdekében felhasználók által bevitt adatokat átalakítjuk:
<code>
$user = $conn->real_escape_string($_POST['user']);
</code>



Teljes példakód:
<code php>
<?php
$conn = new mysqli("localhost","felhasznalo","jelszó","dbnev");

// Kapcsolat ellenőrzése:
if($conn->connect_errno) {
    print "Hiba a kapcsolódás során!";
    printf("A hiba oka: %s\n", $conn->connect_error);
    exit();
}


$user = $conn->real_escape_string($_POST['user']);
$name = $conn->real_escape_string($_POST['name']);

$sql="insert into dolgozok
(user, name)
VALUES ('$user', '$name')";


if ($conn->query($sql) === TRUE) {
    printf("A végrehajtás sikeres\n");
}

$conn->close();
</code>

  * http://php.net/manual/en/mysqli.real-escape-string.php