Основы взаимодействия PHP с MySQL: от подключения к продвинутым техникам

Расширенные примеры работы с MySQL в PHP

1. Использование PDO с именованными и позиционными плейсхолдерами

// Именованные плейсхолдеры
$stmt = $pdo->prepare("SELECT * FROM users WHERE name = :name AND email = :email");
$stmt->execute([':name' => 'Иван', ':email' => 'ivan@example.com']);
$user = $stmt->fetch();

// Позиционные плейсхолдеры (знак вопроса)
$stmt = $pdo->prepare("SELECT * FROM users WHERE name = ? AND email = ?");
$stmt->execute(['Иван', 'ivan@example.com']);
$user = $stmt->fetch();

Array
(
    [id] => 1
    [name] => Иван
    [email] => ivan@example.com
)

Разница: именованные читаемее, позиционные компактнее. Выбор зависит от стиля кода.

2. Пакетная вставка множества записей

$data = [
    ['name' => 'Анна', 'email' => 'anna@test.com'],
    ['name' => 'Борис', 'email' => 'boris@test.com'],
    // ... много записей
];

$pdo->beginTransaction();
try {
    $stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");
    foreach ($data as $row) {
        $stmt->execute($row);
    }
    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
    echo "Ошибка: " . $e->getMessage();
}
echo "Вставлено " . count($data) . " записей";

Вставлено 3 записей (если в массиве 3 элемента)

3. Получение результатов в разных форматах

PDO::FETCH_ASSOC, FETCH_NUM, FETCH_OBJ, FETCH_CLASS и др.

// FETCH_OBJ - объект
$stmt = $pdo->query("SELECT * FROM users LIMIT 1");
$user = $stmt->fetch(PDO::FETCH_OBJ);
echo $user->name;

// FETCH_CLASS - в объект указанного класса
class User {
    public $name;
    public $email;
}
$stmt->setFetchMode(PDO::FETCH_CLASS, 'User');
$user = $stmt->fetch();
echo $user->name;

Иван (в обоих случаях)

4. Работа с хранимыми процедурами

// MySQL хранимая процедура
// CREATE PROCEDURE GetUser(IN uid INT) SELECT * FROM users WHERE id = uid;
$stmt = $pdo->prepare("CALL GetUser(:uid)");
$stmt->execute([':uid' => 1]);
$user = $stmt->fetch();
print_r($user);

Array ( [id] => 1 [name] => Иван ... )

Важно: процедуры могут возвращать несколько результирующих наборов. Для работы с ними используется nextRowset().

5. Запрос с объединением таблиц (JOIN) и группировкой

$sql = "
    SELECT u.name, COUNT(o.id) as order_count
    FROM users u
    LEFT JOIN orders o ON u.id = o.user_id
    GROUP BY u.id
    HAVING order_count > 0
    ORDER BY order_count DESC
";
$stmt = $pdo->query($sql);
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($result as $row) {
    echo $row['name'] . ' сделал ' . $row['order_count'] . ' заказов<br>';
}

Иван сделал 3 заказов
Петр сделал 1 заказов

6. Обработка ошибок: получение информации об исключении

try {
    $pdo->exec("INSERT INTO wrong_table (id) VALUES (1)");
} catch (PDOException $e) {
    echo "Код ошибки: " . $e->getCode() . "<br>";
    echo "Сообщение: " . $e->getMessage() . "<br>";
    echo "Файл: " . $e->getFile() . " строка " . $e->getLine();
}

Код ошибки: 42S02
Сообщение: SQLSTATE[42S02]: Base table or view not found: 1146 Table 'test.wrong_table' doesn't exist
Файл: /var/www/example.php строка 5

7. Работа с большими объёмами данных: использование unbuffered query

// Для mysqli можно отключить буферизацию
$mysqli->real_query("SELECT * FROM big_table");
$result = $mysqli->use_result();
while ($row = $result->fetch_assoc()) {
    // обработка каждой строки без загрузки всего в память
}
// Для PDO аналог - использование MYSQL_ATTR_USE_BUFFERED_QUERY = false при создании соединения

Этот подход уменьшает потребление памяти при больших выборках, но блокирует таблицу на время чтения.