Delete by InternalId

Author: fogelito

src/Database/Adapter/MariaDB.php

@@ -1294,10 +1294,12 @@ public function updateDocument(string $collection, string $id, Document $documen
                 $bindIndex++;
             }
 
+            $sqlInternalId = empty($document->getInternalId()) ? '' : ' and _id=:_internalId';
+
             $sql = "
                 UPDATE {$this->getSQLTable($name)}
                 SET {$columns} _uid = :_newUid
-                WHERE _uid = :_existingUid
+                WHERE _uid = :_existingUid {$sqlInternalId}
                 {$this->getTenantQuery($collection)}
 			";
 
@@ -1307,6 +1309,9 @@ public function updateDocument(string $collection, string $id, Document $documen
 
             $stmt->bindValue(':_existingUid', $id);
             $stmt->bindValue(':_newUid', $document->getId());
+            if (!empty($document->getInternalId())) {
+                $stmt->bindValue(':_internalId', $document->getInternalId());
+            }
 
             if ($this->sharedTables) {
                 $stmt->bindValue(':_tenant', $this->tenant);

src/Database/Adapter/Postgres.php

@@ -1334,10 +1334,12 @@ public function updateDocument(string $collection, string $id, Document $documen
             $bindIndex++;
         }
 
+        $sqlInternalId = empty($document->getInternalId()) ? '' : ' and _id=:_internalId';
+
         $sql = "
 			UPDATE {$this->getSQLTable($name)}
 			SET {$columns} _uid = :_newUid 
-			WHERE _uid = :_existingUid
+			WHERE _uid = :_existingUid {$sqlInternalId}
 			{$this->getTenantQuery($collection)}
 		";
 
@@ -1347,6 +1349,9 @@ public function updateDocument(string $collection, string $id, Document $documen
 
         $stmt->bindValue(':_existingUid', $id);
         $stmt->bindValue(':_newUid', $document->getId());
+        if (!empty($document->getInternalId())) {
+            $stmt->bindValue(':_internalId', $document->getInternalId());
+        }
 
         if ($this->sharedTables) {
             $stmt->bindValue(':_tenant', $this->tenant);