Примеры использования PDO MySQL

Ниже приведены основные примеры работы с расширением PHP PDO. Такие как подключение к БД, получение, изменение и удаление данных.
Для примеров используется таблица `category` с полями `id`, `name` и `parent`.

Подключение к серверу MySQL

  1. $dbh = new PDO('mysql:dbname=db_name;host=localhost', 'логин', 'пароль');

Четвертым параметром конструктора PDO можно указать параметры подключения, например SQL запрос который будет выполнен сразу после подключения:
  1. $dbh = new PDO('
  2. 	mysql:dbname=db_name;host=localhost', 
  3. 	'логин', 
  4. 	'пароль', 
  5. 	array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8'")
  6. );

Чтобы отследить ошибку подключения к БД используется исключение:
  1. try {
  2. 	$dbh = new PDO('mysql:dbname=db_name;host=localhost', 'логин', 'пароль');
  3. } catch (PDOException $e) {
  4. 	die($e->getMessage());
  5. }

  1. SQLSTATE[HY000] [1045] Access denied for user 'логин'@'localhost' (using password: YES)

Выборка из БД
PDO позволяет использовать в запросах псевдопеременные чтобы исключить SQL инъекции. В самом запросе в место данных указывается ? или :id, а в методе execute() указываются реальные значения этих переменных.
  1. $sth = $dbh->prepare("SELECT * FROM `category` WHERE `id` = ?");
  2. $sth->execute(array('21'));
  3. $array = $sth->fetch(PDO::FETCH_ASSOC);
  4. print_r($array);

или
  1. $sth = $dbh->prepare("SELECT * FROM `category` WHERE `id` = :id");
  2. $sth->execute(array('id' => '21'));
  3. $array = $sth->fetch(PDO::FETCH_ASSOC);
  4. print_r($array);

  2. (
  3. 	[id] => 21
  4. 	[parent] => 3
  5. 	[name] => Хурма
  6. )

Данный пример получает всю таблицу в виде ассоциативного массива:

  1. $sth = $dbh->prepare("SELECT * FROM `category` ORDER BY `name`");
  2. $sth->execute();
  3. $array = $sth->fetchAll(PDO::FETCH_ASSOC);
  4. print_r($array);

  2. (
  3. 	[0] => Array (
  4. 		[id] => 16
  5. 		[parent] => 3
  6. 		[name] => Абрикос
  7. 	)
  8. 	[1] => Array (
  9. 		[id] => 28
  10. 		[parent] => 3
  11. 		[name] => Авокадо
  12. 	)
  13. 	...
  14. )

Получить значение поля одной записи
  1. $sth = $dbh->prepare("SELECT `name` FROM `category` WHERE `id` = ?");
  2. $sth->execute(array('21'));
  3. $value = $sth->fetch(PDO::FETCH_COLUMN);
  4. echo $value; // Выведет "Хурма"

Пример получает все значения поля `name` из таблицы `category`.

  1. $sth = $dbh->prepare("SELECT `name` FROM `category`");
  2. $sth->execute();
  3. $array = $sth->fetchAll(PDO::FETCH_COLUMN);
  4. print_r($array);

  2. (
  3.     [0] => Мороженое
  4.     [1] => Овощи
  5.     [2] => Фрукты
  6.     [3] => Ягоды
  7.     [4] => Грибы
  8.     [5] => Морепродукты
  9.     [6] => Смеси
  10. 	...
  11. )

Получение структуры таблицы
  1. $sth = $dbh->prepare("SHOW COLUMNS FROM `category`");
  2. $sth->execute();
  3. $array = $sth->fetchAll(PDO::FETCH_ASSOC);
  4. print_r($array);

  2. (
  3.     [0] => Array
  4.         (
  5.             [Field] => id
  6.             [Type] => int(10) unsigned
  7.             [Null] => NO
  8.             [Key] => PRI
  9.             [Default] => 
  10.             [Extra] => auto_increment
  11.         )
  12.     [1] => Array
  13.         (
  14.             [Field] => parent
  15.             [Type] => int(11) unsigned
  16.             [Null] => NO
  17.             [Key] => 
  18.             [Default] => 0
  19.             [Extra] => 
  20.         )
  21.     [2] => Array
  22.         (
  23.             [Field] => name
  24.             [Type] => varchar(255)
  25.             [Null] => NO
  26.             [Key] => 
  27.             [Default] => 
  28.             [Extra] => 
  29.         )
  30. )

Добавление записей в БД
  1. $sth = $dbh->prepare("INSERT INTO `category` SET `parent` = :parent, `name` = :name");
  2. $sth->execute(array('parent' => 1, 'name' => 'Виноград'));
  3.  
  4. // Получаем id вставленной записи
  5. $insert_id = $dbh->lastInsertId();

Изменение записей
  1. $sth = $dbh->prepare("UPDATE `category` SET `name` = :name WHERE `id` = :id");
  2. $sth->execute(array('name' => 'Виноград', 'id' => 22));

Удаление из БД
  1. $count = $dbh->exec("DELETE FROM `category` WHERE `parent` = 1");
  2. echo 'Удалено ' . $count . ' строк.';

Или метод c псевдопеременными:

  1. $sth = $dbh->prepare("DELETE FROM `category` WHERE `parent` = :parent");
  2. $sth->execute(array('parent' => 1));

Обработка ошибок
  1. // Таблицы `category_new` нет в БД.
  2. $sth = $dbh->prepare("INSERT INTO `category_new` SET `parent` = :parent, `name` = :name");
  3. $sth->execute(array('parent' => 1, 'name' => 'Виноград'));
  4.  
  5. $info = $sth->errorInfo();
  6. print_r($info);

  2. (
  3.     [0] => 42S02
  4.     [1] => 1146
  5.     [2] => Table 'database.category_new' doesn't exist
  6. )

  27.01.24 / 15:29 | MySQL |   82 | 3   0