Skip relationship writes for duplicates in ignore mode, chunk find queries by maxQueryValues

When ignore=true, pre-fetch existing document IDs so
createDocumentRelationships() is skipped for duplicates that
will be silently ignored by the adapter.

Also chunk the batch find() in upsertDocumentsWithIncrease
by maxQueryValues to avoid exceeding query parameter limits.

Author: premtsd-code

src/Database/Database.php

@@ -5655,6 +5655,29 @@ public function createDocuments(
         $time = DateTime::now();
         $modified = 0;
 
+        // When ignore mode is on and relationships are being resolved,
+        // pre-fetch existing document IDs so we skip relationship writes for duplicates
+        $preExistingIds = [];
+        if ($ignore && $this->resolveRelationships) {
+            $inputIds = \array_values(\array_unique(\array_filter(
+                \array_map(fn (Document $doc) => $doc->getId(), $documents)
+            )));
+
+            foreach (\array_chunk($inputIds, $this->maxQueryValues) as $idChunk) {
+                $existing = $this->authorization->skip(fn () => $this->silent(fn () => $this->find(
+                    $collection->getId(),
+                    [
+                        Query::equal('$id', $idChunk),
+                        Query::select(['$id']),
+                        Query::limit(\count($idChunk)),
+                    ]
+                )));
+                foreach ($existing as $doc) {
+                    $preExistingIds[$doc->getId()] = true;
+                }
+            }
+        }
+
         foreach ($documents as $document) {
             $createdAt = $document->getCreatedAt();
             $updatedAt = $document->getUpdatedAt();
@@ -5694,7 +5717,7 @@ public function createDocuments(
                 }
             }
 
-            if ($this->resolveRelationships) {
+            if ($this->resolveRelationships && !isset($preExistingIds[$document->getId()])) {
                 $document = $this->silent(fn () => $this->createDocumentRelationships($collection, $document));
             }
 
@@ -7135,22 +7158,26 @@ public function upsertDocumentsWithIncrease(
                 }
                 foreach ($idsByTenant as $tenant => $tenantIds) {
                     $tenantIds = \array_values(\array_unique($tenantIds));
-                    $fetched = $this->authorization->skip(fn () => $this->withTenant($tenant, fn () => $this->silent(fn () => $this->find(
+                    foreach (\array_chunk($tenantIds, $this->maxQueryValues) as $idChunk) {
+                        $fetched = $this->authorization->skip(fn () => $this->withTenant($tenant, fn () => $this->silent(fn () => $this->find(
+                            $collection->getId(),
+                            [Query::equal('$id', $idChunk), Query::limit(\count($idChunk))],
+                        ))));
+                        foreach ($fetched as $doc) {
+                            $existingDocs[$doc->getId()] = $doc;
+                        }
+                    }
+                }
+            } else {
+                foreach (\array_chunk($uniqueIds, $this->maxQueryValues) as $idChunk) {
+                    $fetched = $this->authorization->skip(fn () => $this->silent(fn () => $this->find(
                         $collection->getId(),
-                        [Query::equal('$id', $tenantIds), Query::limit(\count($tenantIds))],
-                    ))));
+                        [Query::equal('$id', $idChunk), Query::limit(\count($idChunk))],
+                    )));
                     foreach ($fetched as $doc) {
                         $existingDocs[$doc->getId()] = $doc;
                     }
                 }
-            } else {
-                $fetched = $this->authorization->skip(fn () => $this->silent(fn () => $this->find(
-                    $collection->getId(),
-                    [Query::equal('$id', $uniqueIds), Query::limit(\count($uniqueIds))],
-                )));
-                foreach ($fetched as $doc) {
-                    $existingDocs[$doc->getId()] = $doc;
-                }
             }
         }