Fix Mongo cursor pagination, SQL tenant-per-document pre-filter, and revert deferred relationships

- Mongo: set batchSize and iterate with getMore to handle >101 existing UIDs
- SQL: group by per-document tenant in pre-filter when tenantPerDocument is true
- Revert deferred relationship creation — createDocumentRelationships must run
  before INSERT to prepare the document structure

Author: premtsd-code

src/Database/Adapter/Mongo.php

@@ -1492,16 +1492,28 @@ public function createDocuments(Document $collection, array $documents, bool $ig
         if ($ignore && !empty($records)) {
             $uids = \array_filter(\array_map(fn ($r) => $r['_uid'] ?? null, $records));
             if (!empty($uids)) {
-                $findOptions = $this->getTransactionOptions(['projection' => ['_uid' => 1]]);
-                $filters = ['_uid' => ['$in' => \array_values($uids)]];
+                $uidValues = \array_values(\array_unique($uids));
+                $findOptions = $this->getTransactionOptions([
+                    'projection' => ['_uid' => 1],
+                    'batchSize' => \count($uidValues),
+                ]);
+                $filters = ['_uid' => ['$in' => $uidValues]];
                 if ($this->sharedTables) {
                     $filters['_tenant'] = $this->getTenantFilters($collection->getId());
                 }
-                $result = $this->client->find($name, $filters, $findOptions);
+                $response = $this->client->find($name, $filters, $findOptions);
                 $existingUids = [];
-                foreach ($result->cursor->firstBatch ?? [] as $doc) {
+                foreach ($response->cursor->firstBatch ?? [] as $doc) {
                     $existingUids[$doc->_uid] = true;
                 }
+                $cursorId = $response->cursor->id ?? null;
+                while ($cursorId && $cursorId !== 0) {
+                    $more = $this->client->getMore((int)$cursorId, $name, \count($uidValues));
+                    foreach ($more->cursor->nextBatch ?? [] as $doc) {
+                        $existingUids[$doc->_uid] = true;
+                    }
+                    $cursorId = (int)($more->cursor->id ?? 0);
+                }
 
                 if (!empty($existingUids)) {
                     $filteredRecords = [];

src/Database/Adapter/SQL.php

@@ -2495,11 +2495,26 @@ public function createDocuments(Document $collection, array $documents, bool $ig
 
                 $tenantFilter = '';
                 if ($this->sharedTables) {
-                    $tenantFilter = ' AND _tenant = :_dup_tenant';
-                    $binds[':_dup_tenant'] = $this->getTenant();
+                    if ($this->tenantPerDocument) {
+                        // In tenant-per-document mode, check against all distinct tenants in the batch
+                        $tenants = \array_values(\array_unique(\array_filter(
+                            \array_map(fn (Document $doc) => $doc->getTenant(), $documents)
+                        )));
+                        $tenantPlaceholders = [];
+                        foreach ($tenants as $j => $tenant) {
+                            $tKey = ':_dup_tenant_' . $j;
+                            $tenantPlaceholders[] = $tKey;
+                            $binds[$tKey] = $tenant;
+                        }
+                        $tenantFilter = ' AND _tenant IN (' . \implode(', ', $tenantPlaceholders) . ')';
+                    } else {
+                        $tenantFilter = ' AND _tenant = :_dup_tenant';
+                        $binds[':_dup_tenant'] = $this->getTenant();
+                    }
                 }
 
-                $sql = 'SELECT _uid FROM ' . $this->getSQLTable($name)
+                $tenantSelect = $this->sharedTables && $this->tenantPerDocument ? ', _tenant' : '';
+                $sql = 'SELECT _uid' . $tenantSelect . ' FROM ' . $this->getSQLTable($name)
                     . ' WHERE _uid IN (' . \implode(', ', $placeholders) . ')'
                     . $tenantFilter;
 
@@ -2508,10 +2523,21 @@ public function createDocuments(Document $collection, array $documents, bool $ig
                     $stmt->bindValue($k, $v, $this->getPDOType($v));
                 }
                 $stmt->execute();
-                $existingUids = \array_flip(\array_column($stmt->fetchAll(), '_uid'));
+                $rows = $stmt->fetchAll();
                 $stmt->closeCursor();
 
-                if (!empty($existingUids)) {
+                if ($this->sharedTables && $this->tenantPerDocument) {
+                    // Build composite keys for tenant-per-document lookups
+                    $existingKeys = [];
+                    foreach ($rows as $row) {
+                        $existingKeys[$row['_tenant'] . ':' . $row['_uid']] = true;
+                    }
+                    $documents = \array_values(\array_filter(
+                        $documents,
+                        fn (Document $doc) => !isset($existingKeys[$doc->getTenant() . ':' . $doc->getId()])
+                    ));
+                } else {
+                    $existingUids = \array_flip(\array_column($rows, '_uid'));
                     $documents = \array_values(\array_filter(
                         $documents,
                         fn (Document $doc) => !isset($existingUids[$doc->getId()])