Příklady použití PDO
Nastavení připojení k MySQL:
try { $db = new PDO('mysql:host=localhost;dbname=testdb', $login, $passwd); } catch (PDOException $e) { echo $e->getMessage(); } // закрытия соединения и освобождение ресурсов $db = NULL;
připojení s ohledem na kódování:
$db = new PDO('mysql:host=xxxx.ua;dbname=xxxx', $this->login, $this->passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8"));
PDO poskytuje dva způsoby provedení dotazu:
- příprava proměnných – doporučeno pro rychlost && bezpečnost
- přímé provedení
Dotazy, které modifikují data, se provádějí pomocí metody exec():
$db->exec(“INSERT INTO users (login) VALUES(‘john’)”); $id = $db->lastInsertId(); $db->exec(“UPDATE user SET login=‘alex’”)
Metoda exec vrací hodnotu – počet ovlivněných řádků, nebo FALSE v případě chyby.
Dotazy, které získávají data, se provádějí pomocí metody query():
$res = $db->query(“SELECT * FROM users”);
Vrací FALSE v případě chyby.
Escapování speciálních znaků (odstřihování hodnot): $db->quote($_POST[‘login’])
Možné způsoby načítání dat:
- pole (číselné nebo asociativní indexy)
- řetězec (pro sloupec)
- objekty
- callback funkce
- lenivé načítání
- lenivé načítání
- iterátory
Načtení do pole:
$res = $db->query(“SELECT * FROM users”); while ($row = $res->fetch(PDO::FETCH_NUM)){ // $row - массив с числовыми ключами } $res = $db->query(“SELECT * FROM users”); while ($row = $res->fetch(PDO::FETCH_ASSOC)){ // $row - ассоциативный массив значений, ключи - названия столбцов } $res = $db->query(“SELECT * FROM users”); while ($row = $res->fetch(PDO::FETCH_BOTH)){ // $row - числовой и ассоиативный массив }
Načtení jednoho sloupce:
$column = $db->query(“SELECT id FROM users WHERE login=‘login’ AND password=‘password’”); $user = $column->fetchColumn())
Načtení jako objekt:
$res = $db->query(“SELECT * FROM users”); while ($obj = $res->fetch(PDO::FETCH_OBJ)) { // $obj - экземпляр объекта stdClass, имена столбцов - свойства объекта }
Načtení jako iterátor (rozhraní Iterator)
$res = $db->query(“SELECT * FROM users”, PDO::FETCH_ASSOC); foreach ($res as $row) { // $row - ассоциативный массив значений }
Lenivé načítání – vrací výsledek jako objekt, ale skutečné naplnění objektu hodnotou probíhá až při prvním přístupu k tomuto poli:
$res = $db->query(“SELECT * FROM users”, PDO::FETCH_LAZY); foreach ($res as $row) { echo $row[‘name’]; // получение значения }
Získání všech hodnot výsledku najednou:
$qry = “SELECT * FROM users”; $res = $db->query($qry)->fetchAll(PDO::FETCH_ASSOC); // $res - массив всей выборки, каждая строка представлена ассоциативным массивом
Zpracování výsledku pomocí callback funkce:
function add_salt($login,$passw) { … } $res = $db->query(“SELECT * FROM users”); $res->fetchAll(PDO::FETCH_FUNC, “add_salt”);
Možnosti dotazů s předem připraveným provedením:
- zkompiluje se jednou, provede se potřebný početkrát
- jasné oddělení mezi strukturou a vstupními daty (prevence SQL injekcí)
- rychlé provedení ve srovnání s query()/exec(), dokonce i pro jednorázové provedení
Příklad dotazu:
$stmt = $db->prepare(“SELECT * FROM users WHERE id=?”); $stmt->execute(array($_GET[‘id’])); $stmt->fetch(PDO::FETCH_ASSOC);
Parametry pro dotaz mohou být zadány jako jména a svázány s proměnnými:
$db->prepare('SELECT * FROM users WHERE name=:name AND email=:email'); $db->execute(array(':name'=>john,':email'=>'john@domain.com')); $result = $db->fetchAll(); print_r($result); $dbh->execute(array(':name'=>'alex',':email'=>'alex@domain.com')); print_r($result); // пример использования метода bindParam() try{ $sql = $db->prepare("INSERT INTO USERS(name,email) VALUES (:name,:email)"); $sql->bindParam(':name',$name); $sql->bindParam(':email',$email); // назначение значений и вставка новой строки $name='Joy'; $email='joy@domain.com'; $dbh->exec(); $name='debian'; $email='debian@domain.com'; $dbh->exec(); } catch(PDOException $e) { $dbh->rollBack(); echo 'Error : '.$e->getMessage(); }
Transakce. Téměř všechny ovladače PDO mohou pracovat s transakcemi:
$db->beginTransaction(); if ($db->exec($qry) === FALSE) { $db->rollback(); } $db->commit();
Získání meta informací o dotazu – počet sloupců a informace o všech sloupcích:
$res = $db->query($qry); $ncols = $res->columnCount(); for ($i=0; $i < $ncols; $i++) { $meta_data = $res->getColumnMeta($i); }
Rozšíření možností PDO:
class DB extends PDO { function query($qry, $mode=NULL) { $res = parent::query($qry, $mode); if (!$res) { var_dump($qry, $this->errorInfo()); return null; } else { return $res; } } }
