Курс — «Программирование на PHP8 для начинающих» — #23 Взаимодействие с базами данных. Обработка результатов запросов

28.01.202528.01.2025 by Timcore

Здравствуйте, дорогие друзья.

После выполнения SQL-запросов важно правильно обработать результаты, чтобы использовать их в вашем приложении. PHP предоставляет различные методы для обработки результатов запросов, такие как извлечение данных, перебор строк и обработка ошибок. В этом разделе мы рассмотрим, как обрабатывать результаты запросов с использованием PDO.

Извлечение данных

Для извлечения данных из результата запроса можно использовать методы fetch(), fetchAll(), fetchColumn() и fetchObject().

Использование метода fetch():
- Метод fetch() извлекает одну строку из результата запроса.

<?php
$stmt = $pdo->query("SELECT * FROM users");
while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . "<br>";
}
?>

<?php

$stmt = $pdo->query("SELECT * FROM users");

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {

echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . " ";

}

2. Использование метода fetchAll():

Метод fetchAll() извлекает все строки из результата запроса и возвращает их в виде массива.

<?php
$stmt = $pdo->query("SELECT * FROM users");
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($rows as $row) {
    echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . "<br>";
}
?>

<?php

$stmt = $pdo->query("SELECT * FROM users");

$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

foreach ($rows as $row) {

echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . " ";

}

3. Использование метода fetchColumn():

Метод fetchColumn() извлекает значение одного столбца из первой строки результата запроса.

<?php
$stmt = $pdo->query("SELECT COUNT(*) FROM users");
$count = $stmt->fetchColumn();
echo "Количество пользователей: " . $count . "<br>";
?>

<?php

$stmt = $pdo->query("SELECT COUNT(*) FROM users");

$count = $stmt->fetchColumn();

echo "Количество пользователей: " . $count . " ";

4. Использование метода fetchObject():

Метод fetchObject() извлекает одну строку из результата запроса и возвращает её в виде объекта.

<?php
$stmt = $pdo->query("SELECT * FROM users");
while ($row = $stmt->fetchObject()) {
    echo "ID: " . $row->id . " Name: " . $row->name . " Email: " . $row->email . "<br>";
}
?>

<?php

$stmt = $pdo->query("SELECT * FROM users");

while ($row = $stmt->fetchObject()) {

echo "ID: " . $row->id . " Name: " . $row->name . " Email: " . $row->email . " ";

}

Обработка ошибок

Обработка ошибок является важной частью работы с базами данных. PDO предоставляет методы для обработки ошибок, такие как errorInfo() и errorCode().

Использование метода errorInfo():
- Метод errorInfo() возвращает массив с информацией об ошибке.

<?php
$stmt = $pdo->prepare("SELECT * FROM non_existent_table");
if (!$stmt->execute()) {
    $errorInfo = $stmt->errorInfo();
    echo "Ошибка: " . $errorInfo[2] . "<br>";
}
?>

<?php

$stmt = $pdo->prepare("SELECT * FROM non_existent_table");

if (!$stmt->execute()) {

$errorInfo = $stmt->errorInfo();

echo "Ошибка: " . $errorInfo[2] . " ";

}

2. Использование метода errorCode():

Метод errorCode() возвращает код ошибки.

<?php
$stmt = $pdo->prepare("SELECT * FROM non_existent_table");
if (!$stmt->execute()) {
    $errorCode = $stmt->errorCode();
    echo "Код ошибки: " . $errorCode . "<br>";
}
?>

<?php

$stmt = $pdo->prepare("SELECT * FROM non_existent_table");

if (!$stmt->execute()) {

$errorCode = $stmt->errorCode();

echo "Код ошибки: " . $errorCode . " ";

}

Пример полного цикла обработки результатов запросов

<?php
// Подключение к базе данных
$dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8mb4';
$username = 'root';
$password = '';

try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "Подключение к базе данных успешно.<br>";

    // Создание таблицы
    $pdo->exec("CREATE TABLE IF NOT EXISTS users (
        id INT AUTO_INCREMENT PRIMARY KEY,
        name VARCHAR(255) NOT NULL,
        email VARCHAR(255) NOT NULL
    )");

    // Добавление пользователей
    $stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");
    $stmt->bindParam(':name', $name);
    $stmt->bindParam(':email', $email);

    $users = [
        ['John Doe', 'john@example.com'],
        ['Jane Smith', 'jane@example.com'],
        ['Alice Johnson', 'alice@example.com']
    ];

    foreach ($users as $user) {
        $name = $user[0];
        $email = $user[1];
        $stmt->execute();
    }

    echo "Пользователи добавлены успешно.<br>";

    // Выборка пользователей с использованием fetch()
    $stmt = $pdo->query("SELECT * FROM users");
    echo "Использование fetch():<br>";
    while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
        echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . "<br>";
    }

    // Выборка пользователей с использованием fetchAll()
    $stmt = $pdo->query("SELECT * FROM users");
    echo "Использование fetchAll():<br>";
    $rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
    foreach ($rows as $row) {
        echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . "<br>";
    }

    // Выборка количества пользователей с использованием fetchColumn()
    $stmt = $pdo->query("SELECT COUNT(*) FROM users");
    $count = $stmt->fetchColumn();
    echo "Количество пользователей: " . $count . "<br>";

    // Выборка пользователей с использованием fetchObject()
    $stmt = $pdo->query("SELECT * FROM users");
    echo "Использование fetchObject():<br>";
    while ($row = $stmt->fetchObject()) {
        echo "ID: " . $row->id . " Name: " . $row->name . " Email: " . $row->email . "<br>";
    }

    // Обработка ошибок
    $stmt = $pdo->prepare("SELECT * FROM non_existent_table");
    if (!$stmt->execute()) {
        $errorInfo = $stmt->errorInfo();
        echo "Ошибка: " . $errorInfo[2] . "<br>";
    }

} catch (PDOException $e) {
    echo "Ошибка подключения: " . $e->getMessage();
}
?>

<?php

// Подключение к базе данных

$dsn = 'mysql:host=localhost;dbname=testdb;charset=utf8mb4';

$username = 'root';

$password = '';

try {

$pdo = new PDO($dsn, $username, $password);

$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

echo "Подключение к базе данных успешно. ";

// Создание таблицы

$pdo->exec("CREATE TABLE IF NOT EXISTS users (

id INT AUTO_INCREMENT PRIMARY KEY,

name VARCHAR(255) NOT NULL,

email VARCHAR(255) NOT NULL

)");

// Добавление пользователей

$stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");

$stmt->bindParam(':name', $name);

$stmt->bindParam(':email', $email);

$users = [

['John Doe', 'john@example.com'],

['Jane Smith', 'jane@example.com'],

['Alice Johnson', 'alice@example.com']

];

foreach ($users as $user) {

$name = $user[0];

$email = $user[1];

$stmt->execute();

}

echo "Пользователи добавлены успешно. ";

// Выборка пользователей с использованием fetch()

$stmt = $pdo->query("SELECT * FROM users");

echo "Использование fetch(): ";

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {

echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . " ";

}

// Выборка пользователей с использованием fetchAll()

$stmt = $pdo->query("SELECT * FROM users");

echo "Использование fetchAll(): ";

$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

foreach ($rows as $row) {

echo "ID: " . $row['id'] . " Name: " . $row['name'] . " Email: " . $row['email'] . " ";

}

// Выборка количества пользователей с использованием fetchColumn()

$stmt = $pdo->query("SELECT COUNT(*) FROM users");

$count = $stmt->fetchColumn();

echo "Количество пользователей: " . $count . " ";

// Выборка пользователей с использованием fetchObject()

$stmt = $pdo->query("SELECT * FROM users");

echo "Использование fetchObject(): ";

while ($row = $stmt->fetchObject()) {

echo "ID: " . $row->id . " Name: " . $row->name . " Email: " . $row->email . " ";

}

// Обработка ошибок

$stmt = $pdo->prepare("SELECT * FROM non_existent_table");

if (!$stmt->execute()) {

$errorInfo = $stmt->errorInfo();

echo "Ошибка: " . $errorInfo[2] . " ";

}

} catch (PDOException $e) {

echo "Ошибка подключения: " . $e->getMessage();

}

Обработка результатов запросов является важной частью взаимодействия с базами данных. PDO предоставляет мощные и гибкие инструменты для извлечения данных, перебора строк и обработки ошибок. Использование этих методов помогает обеспечить корректную работу с данными и делает ваше приложение более надежным и защищенным.

На этом все. Всем хорошего дня!

Цикл статей по курсу — «Программирование на PHP8 для начинающих».

Свежие записи

Most Used Categories

Этичный хакинг с Михаилом Тарасовым (Timcore)

Курс — «Программирование на PHP8 для начинающих» — #23 Взаимодействие с базами данных. Обработка результатов запросов

Извлечение данных

Обработка ошибок

Добавить комментарий Отменить ответ