Batch Deletes

src/Database/Adapter.php

@@ -617,6 +617,16 @@ abstract public function updateDocuments(string $collection, array $documents, i
      */
     abstract public function deleteDocument(string $collection, string $id): bool;
 
+    /**
+     * Delete Documents
+     *
+     * @param string $collection
+     * @param array<\Utopia\Database\Query> $queries
+     *
+     * @return bool
+     */
+    abstract public function deleteDocuments(string $collection, array $queries): bool;
+
     /**
      * Find Documents
      *

src/Database/Adapter/MariaDB.php

@@ -1632,6 +1632,57 @@ public function deleteDocument(string $collection, string $id): bool
         return $deleted;
     }
 
+    /**
+     * Delete Documents
+     *
+     * @param string $collection
+     * @param array<\Utopia\Database\Query> $queries
+     *
+     * @return bool
+     */
+    public function deleteDocuments(string $collection, array $queries): bool
+    {
+        $name = $this->filter($collection);
+        $where = [];
+
+        $queries = array_map(fn ($query) => clone $query, $queries);
+
+        $conditions = $this->getSQLConditions($queries);
+        if (!empty($conditions)) {
+            $where[] = $conditions;
+        }
+
+        if ($this->sharedTables) {
+            $where[] = "table_main._tenant = :_tenant";
+        }
+
+        $sqlWhere = !empty($where) ? 'WHERE ' . implode(' AND ', $where) : '';
+
+        $sql = "
+            DELETE FROM {$this->getSQLTable($name)}
+            {$sqlWhere};
+        ";
+
+        $sql = $this->trigger(Database::EVENT_DOCUMENT_DELETE, $sql);
+
+        $stmt = $this->getPDO()->prepare($sql);
+
+        foreach ($queries as $query) {
+            $this->bindConditionValue($stmt, $query);
+        }
+        if ($this->sharedTables) {
+            $stmt->bindValue(':_tenant', $this->tenant);
+        }
+
+        try {
+            $stmt->execute();
+        } catch (PDOException $e) {
+            $this->processException($e);
+        }
+
+        return true;
+    }
+
     /**
      * Find Documents
      *

src/Database/Adapter/Mongo.php

@@ -908,6 +908,44 @@ public function deleteDocument(string $collection, string $id): bool
         return (!!$result);
     }
 
+    /**
+     * Delete Documents
+     *
+     * @param string $collection
+     * @param array<\Utopia\Database\Query> $queries
+     *
+     * @return bool
+     */
+    public function deleteDocuments(string $collection, array $queries): bool
+    {
+        $name = $this->getNamespace() . '_' . $this->filter($collection);
+        $queries = array_map(fn ($query) => clone $query, $queries);
+
+        $filters = $this->buildFilters($queries);
+
+        if ($this->sharedTables) {
+            $filters['_tenant'] = (string)$this->getTenant();
+        }
+
+        $filters = $this->replaceInternalIdsKeys($filters, '$', '_', $this->operators);
+        $filters = $this->timeFilter($filters);
+
+        $options = [];
+
+        try {
+            $res = $this->client->delete(
+                collection: $name,
+                filters: $filters,
+                options: $options,
+                limit: 0
+            );
+        } catch (MongoException $e) {
+            $this->processException($e);
+        }
+
+        return true;
+    }
+
     /**
      * Update Attribute.
      * @param string $collection

src/Database/Adapter/Postgres.php

@@ -1556,6 +1556,58 @@ public function deleteDocument(string $collection, string $id): bool
         return $deleted;
     }
 
+
+    /**
+     * Delete Documents
+     *
+     * @param string $collection
+     * @param array<\Utopia\Database\Query> $queries
+     *
+     * @return bool
+     */
+    public function deleteDocuments(string $collection, array $queries): bool
+    {
+        $name = $this->filter($collection);
+        $where = [];
+
+        $queries = array_map(fn ($query) => clone $query, $queries);
+
+        $conditions = $this->getSQLConditions($queries);
+        if (!empty($conditions)) {
+            $where[] = $conditions;
+        }
+
+        if ($this->sharedTables) {
+            $where[] = "table_main._tenant = :_tenant";
+        }
+
+        $sqlWhere = !empty($where) ? 'WHERE ' . implode(' AND ', $where) : '';
+
+        $sql = "
+            DELETE FROM {$this->getSQLTable($name)}
+            {$sqlWhere}
+        ";
+
+        $sql = $this->trigger(Database::EVENT_DOCUMENT_DELETE, $sql);
+
+        $stmt = $this->getPDO()->prepare($sql);
+
+        foreach ($queries as $query) {
+            $this->bindConditionValue($stmt, $query);
+        }
+        if ($this->sharedTables) {
+            $stmt->bindValue(':_tenant', $this->tenant);
+        }
+
+        try {
+            $stmt->execute();
+        } catch (PDOException $e) {
+            $this->processException($e);
+        }
+
+        return true;
+    }
+
     /**
      * Find Documents
      *

src/Database/Database.php

@@ -4970,6 +4970,85 @@ private function deleteCascade(Document $collection, Document $relatedCollection
         }
     }
 
+    /**
+     * Delete Documents
+     *
+     * Deletes all documents which match the given query, will respect the relationship's onDelete optin.
+     *
+     * @param string $collection
+     * @param array<Query> $queries
+     * @param int $batchSize
+     *
+     * @return bool
+     *
+     * @throws AuthorizationException
+     * @throws DatabaseException
+     * @throws RestrictedException
+     */
+    public function deleteDocuments(string $collection, array $queries = [], int $batchSize = 100): bool
+    {
+        if ($this->adapter->getSharedTables() && empty($this->adapter->getTenant())) {
+            throw new DatabaseException('Missing tenant. Tenant must be set when table sharing is enabled.');
+        }
+
+        $queries = Query::groupByType($queries)['filters'];
+        $collection = $this->silent(fn () => $this->getCollection($collection));
+
+        $deleted = $this->withTransaction(function () use ($collection, $queries, $batchSize) {
+            $lastDocument = null;
+            while (true) {
+                $affectedDocuments = $this->find($collection->getId(), array_merge(
+                    empty($lastDocument) ? [
+                        Query::limit($batchSize),
+                    ] : [
+                        Query::limit($batchSize),
+                        Query::cursorAfter($lastDocument),
+                    ],
+                    $queries,
+                ));
+
+                if (empty($affectedDocuments)) {
+                    break;
+                }
+
+                foreach ($affectedDocuments as $document) {
+                    if ($collection->getId() !== self::METADATA) {
+                        $documentSecurity = $collection->getAttribute('documentSecurity', false);
+                        $isValid = $this->authorization->isValid(new Input(self::PERMISSION_DELETE, [
+                            ...$collection->getDelete(),
+                            ...($documentSecurity ? $document->getDelete() : [])
+                        ]));
+                        if (!$isValid) {
+                            throw new AuthorizationException($this->authorization->getDescription());
+                        }
+                    }
+
+                    // Delete Relationships
+                    if ($this->resolveRelationships) {
+                        $document = $this->silent(fn () => $this->deleteDocumentRelationships($collection, $document));
+                    }
+
+                    // Fire events
+                    $this->trigger(self::EVENT_DOCUMENT_DELETE, $document);
+
+                    $this->purgeRelatedDocuments($collection, $document->getId());
+                    $this->purgeCachedDocument($collection->getId(), $document->getId());
+                }
+
+                if (count($affectedDocuments) < 100) {
+                    break;
+                } else {
+                    $lastDocument = end($affectedDocuments);
+                }
+            }
+
+            // Mass delete using adapter with query
+            return $this->adapter->deleteDocuments($collection->getId(), $queries);
+        });
+
+        return $deleted;
+    }
+
     /**
      * Cleans the all the collection's documents from the cache
      * And the all related cached documents.