make use of projection not found exception

prooph · Jun 24, 2017 · 68174e1 · 68174e1
1 parent e714393
commit 68174e1
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 1 deletion.
diff --git a/composer.json b/composer.json
@@ -18,7 +18,7 @@
     "prefer-stable": true,
     "require": {
         "php": "^7.1",
-        "prooph/event-store": "^7.1.2"
+        "prooph/event-store": "^7.1.3"
     },
     "require-dev": {
         "sandrokeil/interop-config": "^2.0.1",

diff --git a/src/Projection/MariaDbProjectionManager.php b/src/Projection/MariaDbProjectionManager.php
@@ -134,6 +134,10 @@ public function deleteProjection(string $name, bool $deleteEmittedEvents): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function resetProjection(string $name): void
@@ -155,6 +159,10 @@ public function resetProjection(string $name): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function stopProjection(string $name): void
@@ -176,6 +184,10 @@ public function stopProjection(string $name): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function fetchProjectionNames(?string $filter, int $limit = 20, int $offset = 0): array

diff --git a/src/Projection/MySqlProjectionManager.php b/src/Projection/MySqlProjectionManager.php
@@ -134,6 +134,10 @@ public function deleteProjection(string $name, bool $deleteEmittedEvents): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function resetProjection(string $name): void
@@ -155,6 +159,10 @@ public function resetProjection(string $name): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function stopProjection(string $name): void
@@ -176,6 +184,10 @@ public function stopProjection(string $name): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function fetchProjectionNames(?string $filter, int $limit = 20, int $offset = 0): array

diff --git a/src/Projection/PostgresProjectionManager.php b/src/Projection/PostgresProjectionManager.php
@@ -134,6 +134,10 @@ public function deleteProjection(string $name, bool $deleteEmittedEvents): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function resetProjection(string $name): void
@@ -155,6 +159,10 @@ public function resetProjection(string $name): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function stopProjection(string $name): void
@@ -176,6 +184,10 @@ public function stopProjection(string $name): void
         if ($statement->errorCode() !== '00000') {
             throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
         }
+
+        if (0 === $statement->rowCount()) {
+            throw ProjectionNotFound::withName($name);
+        }
     }
 
     public function fetchProjectionNames(?string $filter, int $limit = 20, int $offset = 0): array