aboutsummaryrefslogtreecommitdiffstats
path: root/lib/private/DB
diff options
context:
space:
mode:
authorBenjamin Gaussorgues <benjamin.gaussorgues@nextcloud.com>2024-06-05 11:20:45 +0200
committerBenjamin Gaussorgues <benjamin.gaussorgues@nextcloud.com>2024-06-25 11:28:37 +0200
commit1e19566aa4fa6f08f01ebad8a7d21ebb0974ae01 (patch)
treebbf3101e0f7bc6dfb652e14631dc94ad6599fc63 /lib/private/DB
parent4680bc47c21d3a42f20ee970032ecc7d26db0f1c (diff)
downloadnextcloud-server-1e19566aa4fa6f08f01ebad8a7d21ebb0974ae01.tar.gz
nextcloud-server-1e19566aa4fa6f08f01ebad8a7d21ebb0974ae01.zip
feat(dbal): add proper insert ignore conflict method for MySQL
Signed-off-by: Benjamin Gaussorgues <benjamin.gaussorgues@nextcloud.com>
Diffstat (limited to 'lib/private/DB')
-rw-r--r--lib/private/DB/AdapterMySQL.php28
1 files changed, 28 insertions, 0 deletions
diff --git a/lib/private/DB/AdapterMySQL.php b/lib/private/DB/AdapterMySQL.php
index 8e854769e1f..598dbc4de20 100644
--- a/lib/private/DB/AdapterMySQL.php
+++ b/lib/private/DB/AdapterMySQL.php
@@ -35,4 +35,32 @@ class AdapterMySQL extends Adapter {
return $this->collation;
}
+
+ public function insertIgnoreConflict(string $table, array $values): int {
+ $builder = $this->conn->getQueryBuilder();
+ $builder->insert($table);
+ $updates = [];
+ foreach ($values as $key => $value) {
+ $builder->setValue($key, $builder->createNamedParameter($value));
+ }
+
+ /*
+ * We can't use ON DUPLICATE KEY UPDATE here because Nextcloud use the CLIENT_FOUND_ROWS flag
+ * With this flag the MySQL returns the number of selected rows
+ * instead of the number of affected/modified rows
+ * It's impossible to change this behaviour at runtime or for a single query
+ * Then, the result is 1 if a row is inserted and also 1 if a row is updated with same or different values
+ *
+ * With INSERT IGNORE, the result is 1 when a row is inserted, 0 otherwise
+ *
+ * Risk: it can also ignore other errors like type mismatch or truncated data…
+ */
+ $res = $this->conn->executeStatement(
+ preg_replace('/^INSERT/i', 'INSERT IGNORE', $builder->getSQL()),
+ $builder->getParameters(),
+ $builder->getParameterTypes()
+ );
+
+ return $res;
+ }
}