Merge pull request #140 from prooph/fix_projection_managers

fix multiple calls to reset/stop/delete projection
prooph · Mar 26, 2018 · 4431fa6 · 4431fa6
2 parents b89aad8 + 84826f2
commit 4431fa6
Show file tree

Hide file tree

Showing 2 changed files with 102 additions and 6 deletions.
diff --git a/src/Projection/MariaDbProjectionManager.php b/src/Projection/MariaDbProjectionManager.php
@@ -138,7 +138,23 @@ public function deleteProjection(string $name, bool $deleteEmittedEvents): void
         }
 
         if (0 === $statement->rowCount()) {
-            throw ProjectionNotFound::withName($name);
+            $sql = <<<EOT
+SELECT * FROM `$this->projectionsTable` WHERE name = ? LIMIT 1;
+EOT;
+            $statement = $this->connection->prepare($sql);
+            try {
+                $statement->execute([$name]);
+            } catch (PDOException $exception) {
+                // ignore and check error code
+            }
+
+            if ($statement->errorCode() !== '00000') {
+                throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
+            }
+
+            if (0 === $statement->rowCount()) {
+                throw ProjectionNotFound::withName($name);
+            }
         }
     }
 
@@ -163,7 +179,23 @@ public function resetProjection(string $name): void
         }
 
         if (0 === $statement->rowCount()) {
-            throw ProjectionNotFound::withName($name);
+            $sql = <<<EOT
+SELECT * FROM `$this->projectionsTable` WHERE name = ? LIMIT 1;
+EOT;
+            $statement = $this->connection->prepare($sql);
+            try {
+                $statement->execute([$name]);
+            } catch (PDOException $exception) {
+                // ignore and check error code
+            }
+
+            if ($statement->errorCode() !== '00000') {
+                throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
+            }
+
+            if (0 === $statement->rowCount()) {
+                throw ProjectionNotFound::withName($name);
+            }
         }
     }
 
@@ -188,7 +220,23 @@ public function stopProjection(string $name): void
         }
 
         if (0 === $statement->rowCount()) {
-            throw ProjectionNotFound::withName($name);
+            $sql = <<<EOT
+SELECT * FROM `$this->projectionsTable` WHERE name = ? LIMIT 1;
+EOT;
+            $statement = $this->connection->prepare($sql);
+            try {
+                $statement->execute([$name]);
+            } catch (PDOException $exception) {
+                // ignore and check error code
+            }
+
+            if ($statement->errorCode() !== '00000') {
+                throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
+            }
+
+            if (0 === $statement->rowCount()) {
+                throw ProjectionNotFound::withName($name);
+            }
         }
     }
 

diff --git a/src/Projection/MySqlProjectionManager.php b/src/Projection/MySqlProjectionManager.php
@@ -138,7 +138,23 @@ public function deleteProjection(string $name, bool $deleteEmittedEvents): void
         }
 
         if (0 === $statement->rowCount()) {
-            throw ProjectionNotFound::withName($name);
+            $sql = <<<EOT
+SELECT * FROM `$this->projectionsTable` WHERE name = ? LIMIT 1;
+EOT;
+            $statement = $this->connection->prepare($sql);
+            try {
+                $statement->execute([$name]);
+            } catch (PDOException $exception) {
+                // ignore and check error code
+            }
+
+            if ($statement->errorCode() !== '00000') {
+                throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
+            }
+
+            if (0 === $statement->rowCount()) {
+                throw ProjectionNotFound::withName($name);
+            }
         }
     }
 
@@ -163,7 +179,23 @@ public function resetProjection(string $name): void
         }
 
         if (0 === $statement->rowCount()) {
-            throw ProjectionNotFound::withName($name);
+            $sql = <<<EOT
+SELECT * FROM `$this->projectionsTable` WHERE name = ? LIMIT 1;
+EOT;
+            $statement = $this->connection->prepare($sql);
+            try {
+                $statement->execute([$name]);
+            } catch (PDOException $exception) {
+                // ignore and check error code
+            }
+
+            if ($statement->errorCode() !== '00000') {
+                throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
+            }
+
+            if (0 === $statement->rowCount()) {
+                throw ProjectionNotFound::withName($name);
+            }
         }
     }
 
@@ -188,7 +220,23 @@ public function stopProjection(string $name): void
         }
 
         if (0 === $statement->rowCount()) {
-            throw ProjectionNotFound::withName($name);
+            $sql = <<<EOT
+SELECT * FROM `$this->projectionsTable` WHERE name = ? LIMIT 1;
+EOT;
+            $statement = $this->connection->prepare($sql);
+            try {
+                $statement->execute([$name]);
+            } catch (PDOException $exception) {
+                // ignore and check error code
+            }
+
+            if ($statement->errorCode() !== '00000') {
+                throw Exception\RuntimeException::fromStatementErrorInfo($statement->errorInfo());
+            }
+
+            if (0 === $statement->rowCount()) {
+                throw ProjectionNotFound::withName($name);
+            }
         }
     }