add benchmark

Author: DavidBadura

tests/Benchmark/BasicImplementation/Events/ProfileCreated.php

@@ -5,6 +5,7 @@
 namespace Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events;
 
 use Patchlevel\EventSourcing\Attribute\Event;
+use Patchlevel\EventSourcing\Attribute\EventTag;
 use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\ProfileId;
 use Patchlevel\Hydrator\Attribute\DataSubjectId;
 use Patchlevel\Hydrator\Attribute\PersonalData;
@@ -14,6 +15,7 @@ final class ProfileCreated
 {
     public function __construct(
         #[DataSubjectId]
+        #[EventTag(prefix: 'profile')]
         public ProfileId $profileId,
         public string $name,
         #[PersonalData]

tests/Benchmark/SimpleSetupTaggableStoreBench.php

@@ -0,0 +1,145 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Tests\Benchmark;
+
+use Patchlevel\EventSourcing\Aggregate\AggregateRootId;
+use Patchlevel\EventSourcing\Message\Message;
+use Patchlevel\EventSourcing\Repository\DefaultRepository;
+use Patchlevel\EventSourcing\Repository\Repository;
+use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
+use Patchlevel\EventSourcing\Serializer\DefaultEventSerializer;
+use Patchlevel\EventSourcing\Store\TaggableDoctrineDbalStore;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Events\ProfileCreated;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\Profile;
+use Patchlevel\EventSourcing\Tests\Benchmark\BasicImplementation\ProfileId;
+use Patchlevel\EventSourcing\Tests\DbalManager;
+use PhpBench\Attributes as Bench;
+
+#[Bench\BeforeMethods('setUp')]
+final class SimpleSetupTaggableStoreBench
+{
+    private TaggableDoctrineDbalStore $store;
+    private Repository $repository;
+
+    private AggregateRootId $singleEventId;
+    private AggregateRootId $multipleEventsId;
+
+    public function setUp(): void
+    {
+        $connection = DbalManager::createConnection();
+
+        $this->store = new TaggableDoctrineDbalStore(
+            $connection,
+            DefaultEventSerializer::createFromPaths([__DIR__ . '/BasicImplementation/Events']),
+        );
+
+        $this->repository = new DefaultRepository($this->store, Profile::metadata());
+
+        $schemaDirector = new DoctrineSchemaDirector(
+            $connection,
+            $this->store,
+        );
+
+        $schemaDirector->create();
+
+        $this->singleEventId = ProfileId::generate();
+        $profile = Profile::create($this->singleEventId, 'Peter');
+        $this->repository->save($profile);
+
+        $this->multipleEventsId = ProfileId::generate();
+        $profile = Profile::create($this->multipleEventsId, 'Peter');
+
+        for ($i = 0; $i < 10_000; $i++) {
+            $profile->changeName('Peter');
+        }
+
+        $this->repository->save($profile);
+    }
+
+    #[Bench\Revs(10)]
+    public function benchLoad1Event(): void
+    {
+        $this->repository->load($this->singleEventId);
+    }
+
+    #[Bench\Revs(10)]
+    public function benchLoad10000Events(): void
+    {
+        $this->repository->load($this->multipleEventsId);
+    }
+
+    #[Bench\Revs(10)]
+    public function benchSave1Event(): void
+    {
+        $profile = Profile::create(ProfileId::generate(), 'Peter');
+        $this->repository->save($profile);
+    }
+
+    #[Bench\Revs(10)]
+    public function benchSave10000Events(): void
+    {
+        $profile = Profile::create(ProfileId::generate(), 'Peter');
+
+        for ($i = 1; $i < 10_000; $i++) {
+            $profile->changeName('Peter');
+        }
+
+        $this->repository->save($profile);
+    }
+
+    #[Bench\Revs(1)]
+    public function benchSave10000Aggregates(): void
+    {
+        for ($i = 1; $i < 10_000; $i++) {
+            $profile = Profile::create(ProfileId::generate(), 'Peter');
+            $this->repository->save($profile);
+        }
+    }
+
+    #[Bench\Revs(10)]
+    public function benchSave10000AggregatesTransaction(): void
+    {
+        $this->store->transactional(function (): void {
+            for ($i = 1; $i < 10_000; $i++) {
+                $profile = Profile::create(ProfileId::generate(), 'Peter');
+                $this->repository->save($profile);
+            }
+        });
+    }
+
+    #[Bench\Revs(10)]
+    public function benchAppend1Event(): void
+    {
+        $messages = [
+            Message::create(
+                new ProfileCreated(
+                    ProfileId::generate(),
+                    'Peter',
+                    null,
+                )
+            )
+        ];
+
+        $this->store->append($messages);
+    }
+
+    #[Bench\Revs(10)]
+    public function benchAppend100Events(): void
+    {
+        $messages = [];
+
+        for ($i = 1; $i < 100; $i++) {
+            $messages[] = Message::create(
+                new ProfileCreated(
+                    ProfileId::generate(),
+                    'Peter',
+                    null,
+                )
+            );
+        }
+
+        $this->store->append($messages);
+    }
+}

tests/DbalManager.php

@@ -7,6 +7,7 @@
 use Doctrine\DBAL\Connection;
 use Doctrine\DBAL\Driver\AbstractSQLiteDriver;
 use Doctrine\DBAL\DriverManager;
+use Doctrine\DBAL\Platforms\PostgreSQLPlatform;
 use Doctrine\DBAL\Tools\DsnParser;
 use Patchlevel\EventSourcing\Console\DoctrineHelper;
 use RuntimeException;
@@ -45,6 +46,14 @@ public static function createConnection(string $dbName = self::DEFAULT_DB_NAME):
         $databases = $schemaManager->listDatabases();
 
         if (in_array($dbName, $databases, true)) {
+            if ($tempConnection->getDatabasePlatform() instanceof PostgreSQLPlatform) {
+                $tempConnection->executeStatement("
+                    SELECT pg_terminate_backend(pid)
+                    FROM pg_stat_activity
+                    WHERE datname = '{$dbName}';
+                ");
+            }
+
             $schemaManager->dropDatabase($dbName);
         }