Конфигурация подключения к БД в PHP: от основ до сложных решений

Расширенные примеры настройки и использования подключения к БД

Пример 1: Конфигурационный файл с поддержкой окружений

Файл config.php может определять настройки в зависимости от среды (development/production).

<?php
$env = getenv('APP_ENV') ?: 'development';

$config = [
    'development' => [
        'host' => 'localhost',
        'dbname' => 'dev_db',
        'user' => 'dev',
        'pass' => 'dev',
        'options' => [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_EMULATE_PREPARES => true,
        ],
    ],
    'production' => [
        'host' => 'db.example.com',
        'dbname' => 'prod_db',
        'user' => 'prod_user',
        'pass' => 'prod_pass',
        'options' => [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_EMULATE_PREPARES => false,
        ],
    ],
];

return $config[$env];

Результат: при вызове require 'config.php' возвращается массив, соответствующий окружению.

Пример 2: Класс Database с методами для транзакций и пагинации

<?php
class AdvancedDatabase
{
    private PDO $pdo;

    public function __construct(PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    public function beginTransaction(): void
    {
        $this->pdo->beginTransaction();
    }

    public function commit(): void
    {
        $this->pdo->commit();
    }

    public function rollback(): void
    {
        $this->pdo->rollBack();
    }

    public function fetchPage(string $table, int $page, int $perPage): array
    {
        $offset = ($page - 1) * $perPage;
        $stmt = $this->pdo->prepare("SELECT * FROM $table LIMIT :limit OFFSET :offset");
        $stmt->bindValue(':limit', $perPage, PDO::PARAM_INT);
        $stmt->bindValue(':offset', $offset, PDO::PARAM_INT);
        $stmt->execute();
        return $stmt->fetchAll();
    }
}

$db = new AdvancedDatabase(Database::getInstance());
$users = $db->fetchPage('users', 1, 10);
print_r($users);

Результат: вывод массива из 10 записей таблицы users, начиная с первой страницы.

Пример 3: Обработка ошибок с логированием

<?php
function connectWithErrorHandling(): PDO
{
    try {
        $config = require 'config.php';
        $dsn = "{$config['driver']}:host={$config['host']};dbname={$config['dbname']}";
        $pdo = new PDO($dsn, $config['username'], $config['password'], $config['options']);
        return $pdo;
    } catch (PDOException $e) {
        // Логирование в файл
        error_log("Database connection failed: " . $e->getMessage(), 3, '/var/log/php_errors.log');
        // Пользователю показываем общее сообщение
        die('Извините, произошла ошибка базы данных. Пожалуйста, попробуйте позже.');
    }
}

try {
    $pdo = connectWithErrorHandling();
    $stmt = $pdo->query('SELECT 1');
    echo "Соединение установлено";
} catch (Exception $e) {
    echo "Не удалось выполнить запрос";
}

Результат: если соединение не удалось, в лог записывается детальная ошибка, а пользователь видит общее сообщение.

Пример 4: Использование разных драйверов PDO (SQLite, PostgreSQL)

<?php
$drivers = [
    'sqlite' => 'sqlite:/path/to/database.sqlite',
    'pgsql' => 'pgsql:host=localhost;dbname=mydb',
    'mysql' => 'mysql:host=localhost;dbname=mydb',
];

$driver = 'sqlite'; // можно менять
$pdo = new PDO($drivers[$driver], $driver === 'sqlite' ? null : 'user', $driver === 'sqlite' ? null : 'pass');
$stmt = $pdo->query('SELECT sqlite_version()');
$row = $stmt->fetch(PDO::FETCH_NUM);
echo "Версия SQLite: " . $row[0];

Результат: Версия SQLite: 3.31.1 (зависит от установленной версии).

Пример 5: Работа с пулом соединений через многократный вызов getInstance

<?php
$pdo1 = Database::getInstance();
$pdo2 = Database::getInstance();
var_dump($pdo1 === $pdo2); // bool(true)
// Доказательство единого подключения
$stmt = $pdo1->prepare('SELECT ? + ? AS sum');
$stmt->execute([10, 20]);
echo $stmt->fetchColumn(); // 30

Результат: на экран выводится bool(true) и 30.