EZP-30296: Introduced bulk document deleting using deleteByQuery

ezsystems · Sep 24, 2019 · caee711 · caee711
1 parent af22427
commit caee711
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/lib/Handler.php b/lib/Handler.php
@@ -45,6 +45,8 @@
  */
 class Handler implements SearchHandlerInterface, Capable
 {
+    const SOLR_BULK_REMOVE_LIMIT = 1000;
+
     /**
      * Content locator gateway.
      *
@@ -340,9 +342,15 @@ protected function deleteAllItemsWithoutAdditionalLocation($locationId)
             $this->gateway->searchAllEndpoints($query)
         );
 
+        $contentDocumentIds = [];
+
         foreach ($searchResult->searchHits as $hit) {
-            $idPrefix = $this->mapper->generateContentDocumentId($hit->valueObject->id);
-            $this->gateway->deleteByQuery("_root_:{$idPrefix}*");
+            $contentDocumentIds[] = $this->mapper->generateContentDocumentId($hit->valueObject->id) . '*';
+        }
+
+        foreach (\array_chunk($contentDocumentIds, self::SOLR_BULK_REMOVE_LIMIT) as $ids) {
+            $query = '_root_:(' . implode(' OR ', $ids) . ')';
+            $this->gateway->deleteByQuery($query);
         }
     }