Drop collection only if it exists

proophsoftware · Jul 24, 2018 · 9480bae · 9480bae
1 parent e76ff8f
commit 9480bae
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Projecting/AggregateProjector.php b/src/Projecting/AggregateProjector.php
@@ -130,7 +130,9 @@ public function prepareForRun(string $appVersion, string $projectionName): void
 
     public function deleteReadModel(string $appVersion, string $projectionName): void
     {
-        $this->documentStore->dropCollection($this->generateCollectionName($appVersion, $projectionName));
+        if ($this->documentStore->hasCollection(self::generateCollectionName($appVersion, $projectionName))) {
+            $this->documentStore->dropCollection(self::generateCollectionName($appVersion, $projectionName));
+        }
     }
 
     private function assertProjectionNameMatchesWithAggregateType(string $projectionName, string $aggregateType): void