Реализация класса для работы с базой данных в PHP: от простого к продвинутому

Как создать простой класс для PDO?

Наиболее современный и универсальный вариант - использование расширения PDO, которое поддерживает множество СУБД. Класс оборачивает PDO и добавляет удобные методы.

class Database {
    private $pdo;
    public function __construct($dsn, $user, $pass) {
        try {
            $this->pdo = new PDO($dsn, $user, $pass);
            $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        } catch (PDOException $e) {
            die('Connection failed: ' . $e->getMessage());
        }
    }
    public function select($sql, $params = []) {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt->fetchAll(PDO::FETCH_ASSOC);
    }
    public function insert($table, $data) {
        $keys = implode(',', array_keys($data));
        $placeholders = ':' . implode(',:', array_keys($data));
        $sql = "INSERT INTO $table ($keys) VALUES ($placeholders)";
        $this->pdo->prepare($sql)->execute($data);
        return $this->pdo->lastInsertId();
    }
    public function update($table, $data, $where, $whereParams = []) {
        $set = '';
        foreach ($data as $key => $value) {
            $set .= "$key = :$key,";
        }
        $set = rtrim($set, ',');
        $sql = "UPDATE $table SET $set WHERE $where";
        $stmt = $this->pdo->prepare($sql);
        return $stmt->execute(array_merge($data, $whereParams));
    }
    public function delete($table, $where, $params = []) {
        $sql = "DELETE FROM $table WHERE $where";
        $stmt = $this->pdo->prepare($sql);
        return $stmt->execute($params);
    }
}
  

Php db class (класс для работы с базой данных в php)

Пример использования:

$db = new Database('mysql:host=localhost;dbname=test', 'root', '');
$users = $db->select('SELECT * FROM users WHERE age > :age', ['age' => 18]);
  

Как реализовать класс для mysqli объектно?

Если проект жестко привязан к MySQL, можно использовать расширение mysqli. Его объектный стиль похож на PDO, но специфичен для MySQL.

class MySQL {
    private $mysqli;
    public function __construct($host, $user, $pass, $db) {
        $this->mysqli = new mysqli($host, $user, $pass, $db);
        if ($this->mysqli->connect_error) {
            die('Connect Error: ' . $this->mysqli->connect_error);
        }
        $this->mysqli->set_charset('utf8');
    }
    public function query($sql) {
        $result = $this->mysqli->query($sql);
        if (!$result) {
            throw new Exception('Query failed: ' . $this->mysqli->error);
        }
        return $result->fetch_all(MYSQLI_ASSOC);
    }
    public function prepareAndExecute($sql, $params) {
        $stmt = $this->mysqli->prepare($sql);
        if (!$stmt) {
            throw new Exception('Prepare failed: ' . $this->mysqli->error);
        }
        $types = str_repeat('s', count($params)); // упрощённо, все строки
        $stmt->bind_param($types, ...$params);
        $stmt->execute();
        $result = $stmt->get_result();
        return $result ? $result->fetch_all(MYSQLI_ASSOC) : [];
    }
}
  

Как сделать класс с паттерном Одиночка (Singleton) для соединения?

Одиночка гарантирует единственный экземпляр подключения к БД, что экономит ресурсы при многократных запросах в одном скрипте. Однако это затрудняет тестирование и создание нескольких разных соединений.

class DB {
    private static $instance = null;
    private $pdo;
    private function __construct() {
        $dsn = 'mysql:host=localhost;dbname=test';
        $this->pdo = new PDO($dsn, 'root', '');
    }
    public static function getInstance() {
        if (self::$instance === null) {
            self::$instance = new self();
        }
        return self::$instance;
    }
    public function getConnection() {
        return $this->pdo;
    }
}
  

Использование:

$pdo = DB::getInstance()->getConnection();
  

Как построить класс Repository для отделения логики?

Repository - это паттерн, который изолирует логику работы с данными. Класс репозитория принимает объект DatabaseManager и предоставляет специфичные методы, например, getUserById() или saveUser(). Это улучшает организацию кода, но увеличивает количество классов.

class UserRepository {
    private DatabaseManager $db;
    public function __construct(DatabaseManager $db) {
        $this->db = $db;
    }
    public function findById(int $id): ?array {
        $result = $this->db->select('users', ['*'], ['id' => $id]);
        return $result[0] ?? null;
    }
    public function findAllActive(): array {
        return $this->db->select('users', ['*'], ['status' => 'active']);
    }
    public function save(array $user): int {
        if (isset($user['id'])) {
            $this->db->update('users', $user, ['id' => $user['id']]);
            return $user['id'];
        } else {
            return $this->db->insert('users', $user);
        }
    }
}