Postgres adapter:

Author: fogelito

src/Database/Adapter/Memory.php

@@ -1246,14 +1246,29 @@ public function updateDocument(Document $collection, string $id, Document $docum
             $document->setAttribute($attribute, $value);
         }
 
-        $newId = $document->getId();
+        $newId = $document->offsetExists('$id') ? $document->getId() : $id;
         $newKey = $this->documentKey($newId);
         if ($newId !== $id && isset($this->data[$key]['documents'][$newKey])) {
             throw new DuplicateException('Document already exists');
         }
 
         $update = $this->documentToRow($document);
 
+        // For partial updates, documentToRow unconditionally maps internal fields
+        // ($id → _uid, $createdAt → _createdAt, $permissions → _permissions) from
+        // the partial document, which would overwrite existing row values with
+        // empty defaults. Strip any internal field not actually present in the
+        // document so the sparse array_merge below only touches what the caller set.
+        if (!$document->offsetExists('$id')) {
+            unset($update['_uid']);
+        }
+        if (!$document->offsetExists('$createdAt')) {
+            unset($update['_createdAt']);
+        }
+        if (!$document->offsetExists('$permissions')) {
+            unset($update['_permissions']);
+        }
+
         // Sparse update — MariaDB's UPDATE only sets columns present in the
         // document; absent columns retain their previous values. The wrapper
         // relies on this for relationship updates, where it removes
@@ -1338,6 +1353,9 @@ public function updateDocument(Document $collection, string $id, Document $docum
             if ($newId !== $id) {
                 $this->removePermissionsForDocument($key, $newId, $tenant, $this->sharedTables);
             }
+            if (! $document->offsetExists('$id')) {
+                $document->setAttribute('$id', $newId);
+            }
             $this->writePermissions($key, $document);
         } elseif ($newId !== $id) {
             // Rename-only path: rebind every permission entry whose document

src/Database/Adapter/SQLite.php

@@ -1272,14 +1272,28 @@ public function updateDocument(Document $collection, string $id, Document $docum
         $spatialAttributes = $this->getSpatialAttributes($collection);
         $collection = $collection->getId();
         $attributes = $document->getAttributes();
-        $attributes['_createdAt'] = $document->getCreatedAt();
-        $attributes['_updatedAt'] = $document->getUpdatedAt();
-        $attributes['_permissions'] = json_encode($document->getPermissions());
+
+        if ($document->offsetExists('$updatedAt')) {
+            $attributes['_updatedAt'] = $document->getUpdatedAt();
+        }
+        if ($document->offsetExists('$createdAt')) {
+            $attributes['_createdAt'] = $document->getCreatedAt();
+        }
+        if ($document->offsetExists('$id')) {
+            $attributes['_uid'] = $document->getId();
+        }
+        if ($document->offsetExists('$permissions')) {
+            $attributes['_permissions'] = json_encode($document->getPermissions());
+        }
 
         if ($this->sharedTables) {
             $attributes['_tenant'] = $this->tenant;
         }
 
+        if (empty($attributes)) {
+            return $document;
+        }
+
         $name = $this->filter($collection);
         $columns = '';
 
@@ -1297,7 +1311,7 @@ public function updateDocument(Document $collection, string $id, Document $docum
              * Get current permissions from the database
              */
             $permissionsStmt = $this->getPDO()->prepare($sql);
-            $permissionsStmt->bindValue(':_uid', $document->getId());
+            $permissionsStmt->bindValue(':_uid', $id);
 
             if ($this->sharedTables) {
                 $permissionsStmt->bindValue(':_tenant', $this->tenant);
@@ -1369,7 +1383,7 @@ public function updateDocument(Document $collection, string $id, Document $docum
                 $removeQuery = $this->trigger(Database::EVENT_PERMISSIONS_DELETE, $removeQuery);
 
                 $stmtRemovePermissions = $this->getPDO()->prepare($removeQuery);
-                $stmtRemovePermissions->bindValue(':_uid', $document->getId());
+                $stmtRemovePermissions->bindValue(':_uid', $id);
 
                 if ($this->sharedTables) {
                     $stmtRemovePermissions->bindValue(':_tenant', $this->tenant);
@@ -1404,7 +1418,8 @@ public function updateDocument(Document $collection, string $id, Document $docum
 
                 $stmtAddPermissions = $this->getPDO()->prepare($sql);
 
-                $stmtAddPermissions->bindValue(":_uid", $document->getId());
+                $newUid = $document->offsetExists('$id') ? $document->getId() : $id;
+                $stmtAddPermissions->bindValue(":_uid", $newUid);
                 if ($this->sharedTables) {
                     $stmtAddPermissions->bindValue(":_tenant", $this->tenant);
                 }
@@ -1456,7 +1471,7 @@ public function updateDocument(Document $collection, string $id, Document $docum
 
         $sql = "
 			UPDATE `{$this->getNamespace()}_{$name}`
-			SET {$columns}, _uid = :_newUid
+			SET {$columns}
 			WHERE _uid = :_existingUid
 			{$this->getTenantQuery($collection)}
 		";
@@ -1466,7 +1481,6 @@ public function updateDocument(Document $collection, string $id, Document $docum
         $stmt = $this->getPDO()->prepare($sql);
 
         $stmt->bindValue(':_existingUid', $id);
-        $stmt->bindValue(':_newUid', $document->getId());
 
         if ($this->sharedTables) {
             $stmt->bindValue(':_tenant', $this->tenant);

src/Database/Document.php

@@ -5,6 +5,7 @@
 use ArrayObject;
 use Utopia\Database\Exception as DatabaseException;
 use Utopia\Database\Exception\Structure as StructureException;
+use MongoDB\BSON\UTCDateTime;
 
 /**
  * @extends ArrayObject<string, mixed>
@@ -157,17 +158,17 @@ public function getPermissionsByType(string $type): array
     }
 
     /**
-     * @return string|null
+     * @return string|null|UTCDateTime
      */
-    public function getCreatedAt(): ?string
+    public function getCreatedAt(): string|UTCDateTime|null
     {
         return $this->getAttribute('$createdAt');
     }
 
     /**
-     * @return string|null
+     * @return string|null|UTCDateTime
      */
-    public function getUpdatedAt(): ?string
+    public function getUpdatedAt(): string|UTCDateTime|null
     {
         return $this->getAttribute('$updatedAt');
     }