🤔 Что такое CQRS?CQRS (Command Query Responsibility Segregation) – это архитектурный паттерн, который разделяет операции чтения (Query) и записи (Command) в приложении. Вместо одной модели данных используется две:
Модель для чтения – оптимизирована для запросов.
Модель для записи – отвечает за изменение данных.
🚩
Зачем нужен CQRS? 🟠
Производительность запросы можно кэшировать, а запись может происходить в другой базе.
🟠
Гибкость можно использовать разные структуры данных для чтения и записи.
🟠
Масштабируемость можно масштабировать чтение и запись отдельно.
🟠
Безопасность можно ограничить доступ к записи.
🚩
Как это работает? В классическом приложении чтение и запись используют одну модель данных
class User {
public $id;
public $name;
public $email;
public function updateEmail($newEmail) {
$this->email = $newEmail;
}
}
Команда (Command) – запись
class UpdateUserEmailCommand {
public int $userId;
public string $newEmail;
public function __construct($userId, $newEmail) {
$this->userId = $userId;
$this->newEmail = $newEmail;
}
}
class UserCommandHandler {
public function handle(UpdateUserEmailCommand $command) {
// Логика обновления в БД
$db = new PDO("mysql:host=localhost;dbname=test", "root", "password");
$stmt = $db->prepare("UPDATE users SET email = :email WHERE id = :id");
$stmt->execute([
':email' => $command->newEmail,
':id' => $command->userId
]);
}
}
Запрос (Query) – чтение
class UserQueryHandler {
public function getUserById($userId) {
$db = new PDO("mysql:host=localhost;dbname=test", "root", "password");
$stmt = $db->prepare("SELECT id, name, email FROM users WHERE id = :id");
$stmt->execute([':id' => $userId]);
return $stmt->fetch(PDO::FETCH_ASSOC);
}
}
🚩
CQRS + Event Sourcing Часто CQRS используется вместе с Event Sourcing – вместо изменения данных мы создаем события.
class UserEmailUpdatedEvent {
public int $userId;
public string $newEmail;
public function __construct($userId, $newEmail) {
$this->userId = $userId;
$this->newEmail = $newEmail;
}
}
Ставь 👍 и забирай 📚 Базу знаний