Event Sourcing в крайнем случае

 function fetch(PDO $connection): array { $events = []; $tables = [ ProductInvented::class => "event_product_invented", ProductPriced::class => "event_product_priced", OutletOpened::class => "event_outlet_opened", OutletStocked::class => "event_outlet_stocked", ]; foreach ($tables as $type => $table) { $rows = rows($connection, "SELECT * FROM {$table}"); $rows = array_map( function($row) use ($connection, $type) { return $type::from($connection, $row); }, $rows ); $events = array_merge($events, $rows); } usort($events, function(Event $a, Event $b) { return strtotime($a->date()) - strtotime($b->date()); }); return $events; } 

Это из projecting-events.php

Здесь происходит довольно много, поэтому давайте разберемся с этим:

1. Мы определяем список таблиц событий для получения строк.
2. Мы выбираем строки для каждого типа / таблицы и преобразовываем полученные ассоциативные массивы в экземпляры событий.
3. Мы используем date каждого события, чтобы отсортировать их в хронологическом порядке.

Нам нужно добавить эти новые методы from в каждое из наших событий:

 abstract class Event { // ...snip public function withDate(string $date): self { $new = clone $this; $new->date = $date; return $new; } abstract public static function from(PDO $connection, array $data); } 

 final class ProductInvented extends Event { // ...snip public static function from(PDO $connection, array $data) { $new = new static( $data["name"] ); return $new->withDate($data["date"]); } } 

 final class ProductPriced extends Event { // ...snip public static function from(PDO $connection, array $data) { $new = new static( productNameFromId($connection, $data["product"]), $data["cents"] ); return $new->withDate($data["date"]); } } 

 final class OutletOpened extends Event { // ...snip public static function from(PDO $connection, array $data) { $new = new static( $data["name"] ); return $new->withDate($data["date"]); } } 

 final class OutletStocked extends Event { // ...snip public static function from(PDO $connection, array $data) { $new = new static( outletNameFromId($connection, $data["outlet"]), $data["servings"], productNameFromId($connection, $data["product"]) ); return $new->withDate($data["date"]); } } 

Это из events.php

Мы также используем несколько новых глобальных функций:

 function productNameFromId(PDO $connection, int $id): string { $row = row( $connection, "SELECT * FROM event_product_invented WHERE id = :id", ["id" => $id] ); if (!$row) { throw new InvalidArgumentException("Product not found"); } return $row["name"]; } function outletNameFromId(PDO $connection, int $id): string { $row = row( $connection, "SELECT * FROM event_outlet_opened WHERE id = :id", ["id" => $id] ); if (!$row) { throw new InvalidArgumentException("Outlet not found"); } return $row["name"]; } 

Это из projecting-events.php

Причина, по которой нам нужна любая из этих *NameFromId и *IdFromName заключается в том, что мы хотим создавать и представлять события с использованием имен сущностей, но мы хотим сохранить их как внешние ключи в базе данных. Это мое личное предпочтение, и вы можете определять / представлять / хранить их, однако имеет смысл для вас.

Теперь мы можем превратить список событий в строки базы данных и обратно:

 $events = []; $events[] = new ProductInvented("Chocolate"); $events[] = new ProductPriced("Chocolate", 499); $events[] = new OutletOpened("Pismo Beach"); $events[] = new OutletStocked("Pismo Beach", 24, "Chocolate"); store($connection, $events); // ← events stored in database $stored = fetch($connection); // ← events loaded from database assert(json_encode($events) === json_encode($stored)); 

Теперь, как мы можем преобразовать это в нечто полезное? Нам нужно определить еще несколько вспомогательных функций:

 function project(PDO $connection, array $events): array { $entities = [ "products" => [], "outlets" => [], ]; foreach ($events as $event) { $entities = projectOne($connection, $entities, $event); } return $entities; } function projectOne(PDO $connection, array $entities,  Event $event): array { if ($event instanceof ProductInvented) { $entities = projectProductInvented( $connection, $entities, $event ); } if ($event instanceof ProductPriced) { $entities = projectProductPriced( $connection, $entities, $event ); } if ($event instanceof OutletOpened) { $entities = projectOutletOpened( $connection, $entities, $event ); } if ($event instanceof OutletStocked) { $entities = projectOutletStocked( $connection, $entities, $event ); } return $entities; } 

Это из projecting-events.php

Этот код похож на код, который мы используем для хранения событий. Для каждого типа события мы модифицируем массив объектов. После того, как все события были спроектированы, у нас должно быть последнее состояние. Вот как выглядят другие методы проектора:

 function projectProductInvented(PDO $connection,  array $entities, ProductInvented $event): array { $payload = $event->payload(); $entities["products"][] = [ "id" => productIdFromName($connection, $payload["name"]), "name" => $payload["name"], ]; return $entities; } function projectProductPriced(PDO $connection,  array $entities, ProductPriced $event): array { $payload = $event->payload(); foreach ($entities["products"] as $i => $product) { if ($product["name"] === $payload["product"]) { $entities["products"][$i]["price"] =  $payload["cents"]; } } return $entities; } function projectOutletOpened(PDO $connection,  array $entities, OutletOpened $event): array { $payload = $event->payload(); $entities["outlets"][] = [ "id" => outletIdFromName($connection, $payload["name"]), "name" => $payload["name"], "stock" => [], ]; return $entities; } function projectOutletStocked(PDO $connection,  array $entities, OutletStocked $event): array { $payload = $event->payload(); foreach ($entities["outlets"] as $i => $outlet) { if ($outlet["name"] === $payload["outlet"]) { foreach ($entities["products"] as $j => $product) { if ($product["name"] === $payload["product"]) { $entities["outlets"][$i]["stock"][] = [ "product" => &$product, "servings" => $payload["servings"], ]; } } } } return $entities; } 

Это из projecting-events.php

Каждый из этих методов проекции принимает тип события и сортирует его по полезной нагрузке, чтобы оставить свой след в массиве $entities .

На этом этапе мы можем использовать созданную нами структуру для заполнения веб-сайта. Поскольку наши проекторы принимают события, мы можем даже сгенерировать первоначальную проекцию (в начале запроса), а затем применить любые новые события к ним, как они происходят.

Как вы, вероятно, можете догадаться, это не самый эффективный способ запроса базы данных, просто для визуализации веб-сайта. Если вам часто нужны прогнозы, может быть лучше периодически проецировать ваши события и затем сохранять полученную структуру в денормализованных таблицах базы данных.

Таким образом, вы можете захватывать события (через такие вещи, как запросы API или посты форм) и по-прежнему запрашивать «обычные» таблицы базы данных при отображении данных в приложении.

Проектирование конкретно

До сих пор мы видели, как мы можем описывать, хранить и проектировать (до последнего состояния). Проецирование на определенный момент времени — это всего лишь вопрос настройки функций проекции, чтобы они применяли события до или после определенной временной отметки.

Мы рассмотрели намного больше, чем я планировал, поэтому я оставлю это последнее упражнение для вас. Подумайте, как вы могли бы смоделировать традиционную (для приложений CMS) модель черновой / рабочей и опубликованной версий контента.

Резюме

Если вам удалось зайти так далеко; отлично сработано! Это было долгое путешествие, но оно того стоит. Дайте нам знать, что вам нравится или не нравится в этом шаблоне дизайна. Если вы хотите узнать больше о Event Sourcing (или DDD в целом), обязательно ознакомьтесь с книгами, связанными с самого начала.

Код, полный массивов, может стать уродливым, быстрым! Я настоятельно рекомендую вам ознакомиться с книгой Адама Уотана о рефакторинге кода цикла в коллекции .