diff --git a/src/Database/Adapter/MariaDB.php b/src/Database/Adapter/MariaDB.php index 72cec157f..bf594d8e7 100644 --- a/src/Database/Adapter/MariaDB.php +++ b/src/Database/Adapter/MariaDB.php @@ -1297,7 +1297,7 @@ public function updateDocument(string $collection, string $id, Document $documen $sql = " UPDATE {$this->getSQLTable($name)} SET {$columns} _uid = :_newUid - WHERE _uid = :_existingUid + WHERE _id=:_internalId {$this->getTenantQuery($collection)} "; @@ -1305,7 +1305,7 @@ public function updateDocument(string $collection, string $id, Document $documen $stmt = $this->getPDO()->prepare($sql); - $stmt->bindValue(':_existingUid', $id); + $stmt->bindValue(':_internalId', $document->getInternalId()); $stmt->bindValue(':_newUid', $document->getId()); if ($this->sharedTables) { diff --git a/src/Database/Adapter/Postgres.php b/src/Database/Adapter/Postgres.php index 4029f76c8..3d571e240 100644 --- a/src/Database/Adapter/Postgres.php +++ b/src/Database/Adapter/Postgres.php @@ -1337,7 +1337,7 @@ public function updateDocument(string $collection, string $id, Document $documen $sql = " UPDATE {$this->getSQLTable($name)} SET {$columns} _uid = :_newUid - WHERE _uid = :_existingUid + WHERE _id=:_internalId {$this->getTenantQuery($collection)} "; @@ -1345,7 +1345,7 @@ public function updateDocument(string $collection, string $id, Document $documen $stmt = $this->getPDO()->prepare($sql); - $stmt->bindValue(':_existingUid', $id); + $stmt->bindValue(':_internalId', $document->getInternalId()); $stmt->bindValue(':_newUid', $document->getId()); if ($this->sharedTables) {