Revert "Reapply "Add postgres upsert impl""

This reverts commit a98c369.

Author: abnegate

src/Database/Adapter/MariaDB.php

@@ -1350,7 +1350,6 @@ public function createOrUpdateDocuments(
                         = $document->getTenant();
                 }
 
-                // Enforce deterministic order
                 \ksort($attributes);
 
                 $columns = [];

src/Database/Adapter/Postgres.php

@@ -1400,218 +1400,9 @@ public function updateDocument(string $collection, string $id, Document $documen
      * @param string $attribute
      * @param array<Change> $changes
      * @return array<Document>
-     * @throws DatabaseException
      */
-    public function createOrUpdateDocuments(
-        string $collection,
-        string $attribute,
-        array  $changes
-    ): array {
-        if (empty($changes)) {
-            return $changes;
-        }
-
-        try {
-            $name = $this->filter($collection);
-            $attribute = $this->filter($attribute);
-
-            $attributes = [];
-            $bindIndex = 0;
-            $batchKeys = [];
-            $bindValues = [];
-            $documentIds = [];
-            $documentTenants  = [];
-
-            foreach ($changes as $change) {
-                $document = $change->getNew();
-                $attributes = $document->getAttributes();
-                $attributes['_uid'] = $document->getId();
-                $attributes['_createdAt'] = $document->getCreatedAt();
-                $attributes['_updatedAt'] = $document->getUpdatedAt();
-                $attributes['_permissions'] = \json_encode($document->getPermissions());
-
-                if (!empty($document->getInternalId())) {
-                    $attributes['_id'] = $document->getInternalId();
-                } else {
-                    $documentIds[] = $document->getId();
-                }
-
-                if ($this->sharedTables) {
-                    $attributes['_tenant']
-                        = $documentTenants[]
-                        = $document->getTenant();
-                }
-
-                // Enforce deterministic order
-                \ksort($attributes);
-
-                $columns = [];
-                foreach (\array_keys($attributes) as $key => $attr) {
-                    $columns[$key] = $this->quote($this->filter($attr));
-                }
-                $columns = '(' . \implode(', ', $columns) . ')';
-
-                /** Value list for this row */
-                $bindKeys = [];
-                foreach ($attributes as $attrValue) {
-                    if (\is_array($attrValue)) {
-                        $attrValue = \json_encode($attrValue);
-                    }
-                    $attrValue = (\is_bool($attrValue)) ? (int)$attrValue : $attrValue;
-                    $bindKey = 'key_' . $bindIndex;
-                    $bindKeys[] = ':' . $bindKey;
-                    $bindValues[$bindKey] = $attrValue;
-                    $bindIndex++;
-                }
-
-                $batchKeys[] = '(' . \implode(', ', $bindKeys) . ')';
-            }
-
-            $getUpdateClause = function (string $attribute, bool $increment = false): string {
-                $attribute = $this->quote($this->filter($attribute));
-
-                $newValue  = $increment
-                    ? "{$attribute} + EXCLUDED.{$attribute}"
-                    : "EXCLUDED.{$attribute}";
-
-                // tenant-aware overwrite guard
-                if ($this->sharedTables) {
-                    return "{$attribute} = CASE
-                            WHEN _tenant = EXCLUDED._tenant
-                            THEN {$newValue}
-                            ELSE {$attribute}
-                        END";
-                }
-
-                return "{$attribute} = {$newValue}";
-            };
-
-            if (!empty($attribute)) {
-                $updateColumns = [
-                    $getUpdateClause($attribute, increment: true),
-                    $getUpdateClause('_updatedAt'),
-                ];
-            } else {
-                $updateColumns = [];
-                foreach (\array_keys($attributes) as $attr) {
-                    $updateColumns[] = $getUpdateClause($this->filter($attr));
-                }
-            }
-
-            // Conflict target: _uid, plus _tenant if shared tables
-            $conflictTarget = $this->sharedTables
-                ? '(_uid, _tenant)'
-                : '(_uid)';
-
-            $sql = "
-                INSERT INTO {$this->getSQLTable($name)} {$columns}
-                VALUES " . \implode(', ', $batchKeys) . "
-                ON CONFLICT {$conflictTarget} DO UPDATE SET
-                    " . \implode(', ', $updateColumns);
-
-            $stmt = $this->getPDO()->prepare($sql);
-
-            foreach ($bindValues as $key => $binding) {
-                $stmt->bindValue($key, $binding, $this->getPDOType($binding));
-            }
-
-            $stmt->execute();
-            $stmt->closeCursor();
-
-            $removeQueries = [];
-            $removeBindValues = [];
-            $addQueries = [];
-            $addBindValues = [];
-
-            foreach ($changes as $index => $change) {
-                $old = $change->getOld();
-                $document = $change->getNew();
-
-                $current = [];
-                foreach (Database::PERMISSIONS as $type) {
-                    $current[$type] = $old->getPermissionsByType($type);
-                }
-
-                // Calculate removals
-                foreach (Database::PERMISSIONS as $type) {
-                    $toRemove = \array_diff($current[$type], $document->getPermissionsByType($type));
-                    if (!empty($toRemove)) {
-                        $removeQueries[] = "(
-                            _document = :_uid_{$index}
-                            {$this->getTenantQuery($collection, tenantCount: \count($toRemove))}
-                            AND _type = '{$type}'
-                            AND _permission IN (" . \implode(',', \array_map(fn ($i) => ":remove_{$type}_{$index}_{$i}", \array_keys($toRemove))) . ")
-                        )";
-                        $removeBindValues[":_uid_{$index}"] = $document->getId();
-                        $removeBindValues[":_tenant_{$index}"] = $document->getTenant();
-                        foreach ($toRemove as $i => $perm) {
-                            $removeBindValues[":remove_{$type}_{$index}_{$i}"] = $perm;
-                        }
-                    }
-                }
-
-                // Calculate additions
-                foreach (Database::PERMISSIONS as $type) {
-                    $toAdd = \array_diff($document->getPermissionsByType($type), $current[$type]);
-
-                    foreach ($toAdd as $i => $permission) {
-                        $addQuery = "(:_uid_{$index}, '{$type}', :add_{$type}_{$index}_{$i}";
-
-                        if ($this->sharedTables) {
-                            $addQuery .= ", :_tenant_{$index}";
-                        }
-
-                        $addQuery .= ")";
-                        $addQueries[] = $addQuery;
-                        $addBindValues[":_uid_{$index}"] = $document->getId();
-                        $addBindValues[":add_{$type}_{$index}_{$i}"] = $permission;
-
-                        if ($this->sharedTables) {
-                            $addBindValues[":_tenant_{$index}"] = $document->getTenant();
-                        }
-                    }
-                }
-            }
-
-            // Execute permission removals
-            if (!empty($removeQueries)) {
-                $removeQuery = \implode(' OR ', $removeQueries);
-                $stmtRemovePermissions = $this->getPDO()->prepare("DELETE FROM {$this->getSQLTable($name . '_perms')} WHERE {$removeQuery}");
-                foreach ($removeBindValues as $key => $value) {
-                    $stmtRemovePermissions->bindValue($key, $value, $this->getPDOType($value));
-                }
-                $stmtRemovePermissions->execute();
-            }
-
-            // Execute permission additions
-            if (!empty($addQueries)) {
-                $sqlAddPermissions = "INSERT INTO {$this->getSQLTable($name . '_perms')} (_document, _type, _permission";
-                if ($this->sharedTables) {
-                    $sqlAddPermissions .= ", _tenant";
-                }
-                $sqlAddPermissions .= ") VALUES " . \implode(', ', $addQueries);
-                $stmtAddPermissions = $this->getPDO()->prepare($sqlAddPermissions);
-                foreach ($addBindValues as $key => $value) {
-                    $stmtAddPermissions->bindValue($key, $value, $this->getPDOType($value));
-                }
-                $stmtAddPermissions->execute();
-            }
-
-            $internalIds = $this->getInternalIds(
-                $collection,
-                $documentIds,
-                $documentTenants
-            );
-
-            foreach ($changes as $change) {
-                if (isset($internalIds[$change->getNew()->getId()])) {
-                    $change->getNew()->setAttribute('$internalId', $internalIds[$change->getNew()->getId()]);
-                }
-            }
-        } catch (\PDOException $e) {
-            throw $this->processException($e);
-        }
-
+    public function createOrUpdateDocuments(string $collection, string $attribute, array $changes): array
+    {
         return \array_map(fn ($change) => $change->getNew(), $changes);
     }
 
@@ -2334,7 +2125,7 @@ public function getSupportForSchemaAttributes(): bool
 
     public function getSupportForUpserts(): bool
     {
-        return true;
+        return false;
     }
 
     /**