Практическое руководство по PHP скриптам для MySQL

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

Пример 1: Класс-обёртка для работы с БД через PDO

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

class Database {
    private static ?PDO $instance = null;
    private static array $config = [
        'host' => 'localhost',
        'dbname' => 'testdb',
        'user' => 'username',
        'password' => 'password',
        'charset' => 'utf8mb4'
    ];

    public static function getInstance(): PDO {
        if (self::$instance === null) {
            $dsn = 'mysql:host=' . self::$config['host'] . ';dbname=' . self::$config['dbname'] . ';charset=' . self::$config['charset'];
            self::$instance = new PDO($dsn, self::$config['user'], self::$config['password'], [
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                PDO::ATTR_EMULATE_PREPARES => false,
            ]);
        }
        return self::$instance;
    }

    public static function query(string $sql, array $params = []): PDOStatement {
        $stmt = self::getInstance()->prepare($sql);
        $stmt->execute($params);
        return $stmt;
    }

    public static function fetchAll(string $sql, array $params = []): array {
        return self::query($sql, $params)->fetchAll();
    }

    public static function fetchOne(string $sql, array $params = []): ?array {
        $row = self::query($sql, $params)->fetch();
        return $row ?: null;
    }

    public static function insert(string $table, array $data): int {
        $columns = implode(', ', array_keys($data));
        $placeholders = ':' . implode(', :', array_keys($data));
        $sql = "INSERT INTO $table ($columns) VALUES ($placeholders)";
        self::query($sql, $data);
        return (int) self::getInstance()->lastInsertId();
    }

    public static function update(string $table, array $data, string $where, array $whereParams = []): int {
        $set = implode(', ', array_map(fn($col) => "$col = :$col", array_keys($data)));
        $sql = "UPDATE $table SET $set WHERE $where";
        $params = array_merge($data, $whereParams);
        $stmt = self::query($sql, $params);
        return $stmt->rowCount();
    }

    public static function delete(string $table, string $where, array $params = []): int {
        $sql = "DELETE FROM $table WHERE $where";
        $stmt = self::query($sql, $params);
        return $stmt->rowCount();
    }
}

$users = Database::fetchAll('SELECT * FROM users WHERE status = :status', [':status' => 'active']);
$newId = Database::insert('users', ['name' => 'Петр Петров', 'email' => 'petr@example.com', 'status' => 'active']);
Database::update('users', ['status' => 'inactive'], 'id = :id', [':id' => $newId]);
echo 'Затронуто строк: ' . Database::delete('users', 'status = :status', [':status' => 'inactive']);

// Результат: (при наличии данных) массив активных пользователей, новый ID, 1 строка обновлена, количество удаленных.

Пояснение: класс использует статическое подключение (singleton) для избежания множественных соединений. Методы принимают именованные параметры, что повышает читаемость и безопасность.

Пример 2: Сложный запрос с JOIN, группировкой и фильтрацией

Требуется получить список заказов с информацией о клиентах и суммой заказа для тех, у кого сумма превышает 1000.

$sql = "SELECT c.name, c.email, SUM(o.total) AS total_spent
        FROM customers c
        LEFT JOIN orders o ON c.id = o.customer_id
        WHERE c.status = :status
        GROUP BY c.id
        HAVING total_spent > :min_total
        ORDER BY total_spent DESC";
$params = [':status' => 'active', ':min_total' => 1000];
$result = Database::fetchAll($sql, $params);
foreach ($result as $row) {
    echo "{$row['name']} ({$row['email']}) - {$row['total_spent']} руб.\n";
}

Иванов Иван (ivan@example.com) - 4500 руб.
Петрова Анна (anna@example.com) - 2300 руб.

Пояснение: LEFT JOIN гарантирует включение клиентов без заказов (сумма NULL преобразуется в 0, но они не попадут в HAVING). Группировка по c.id, условие HAVING применяется после группировки.

Пример 3: Вызов хранимой процедуры с несколькими результирующими наборами

Процедура возвращает два набора: список пользователей и общую статистику.

$pdo = Database::getInstance();
$stmt = $pdo->prepare('CALL GetUsersAndStats(:status)');
$stmt->execute([':status' => 'active']);

$users = $stmt->fetchAll();
echo "Пользователи:\n";
foreach ($users as $user) {
    echo $user['name'] . "\n";
}

$stmt->nextRowset();
$stats = $stmt->fetchAll();
echo "Статистика:\n";
foreach ($stats as $stat) {
    echo "Всего выбрано: " . $stat['total'] . "\n";
}
$stmt->closeCursor();

Пользователи:
Иван
Мария
Статистика:
Всего выбрано: 2

Пояснение: nextRowset() позволяет переключаться между наборами. Важно обработать каждый набор, иначе может возникнуть ошибка "Commands out of sync".