Clean cache per batch

Author: abnegate

src/Database/Database.php

@@ -4746,40 +4746,31 @@ public function createOrUpdateDocumentsWithIncrease(
             /**
              * @var array<Change> $chunk
              */
-            \array_push(
-                $stack,
-                ...$this->withTransaction(fn () => Authorization::skip(fn () => $this->adapter->createOrUpdateDocuments(
-                    $collection->getId(),
-                    $attribute,
-                    $chunk
-                )))
-            );
-        }
-
-        $documents = $stack;
-
-        /**
-         * @var array<Document> $documents
-         */
-        foreach ($documents as $key => $document) {
-            /**
-             * @var Document $document
-             */
-            if ($this->resolveRelationships) {
-                $document = $this->silent(fn () => $this->populateDocumentRelationships($collection, $document));
-            }
+            $batch = $this->withTransaction(fn () => Authorization::skip(fn () => $this->adapter->createOrUpdateDocuments(
+                $collection->getId(),
+                $attribute,
+                $chunk
+            )));
 
-            $documents[$key] = $this->decode($collection, $document);
+            foreach ($batch as $document) {
+                if ($this->resolveRelationships) {
+                    $document = $this->silent(fn () => $this->populateDocumentRelationships($collection, $document));
+                }
 
-            if ($this->getSharedTables() && $this->getTenantPerDocument()) {
-                $this->withTenant($document->getTenant(), function () use ($collection, $document) {
+                if ($this->getSharedTables() && $this->getTenantPerDocument()) {
+                    $this->withTenant($document->getTenant(), function () use ($collection, $document) {
+                        $this->purgeCachedDocument($collection->getId(), $document->getId());
+                    });
+                } else {
                     $this->purgeCachedDocument($collection->getId(), $document->getId());
-                });
-            } else {
-                $this->purgeCachedDocument($collection->getId(), $document->getId());
+                }
+
+                $stack[] = $document;
             }
         }
 
+        $documents = $stack;
+
         $this->trigger(self::EVENT_DOCUMENTS_UPSERT, new Document([
             '$collection' => $collection->getId(),
             'modified' => \count($documents)