diff options
author | Benjamin Gaussorgues <benjamin.gaussorgues@nextcloud.com> | 2024-06-05 11:20:45 +0200 |
---|---|---|
committer | Benjamin Gaussorgues <benjamin.gaussorgues@nextcloud.com> | 2024-06-25 11:28:37 +0200 |
commit | 1e19566aa4fa6f08f01ebad8a7d21ebb0974ae01 (patch) | |
tree | bbf3101e0f7bc6dfb652e14631dc94ad6599fc63 /lib/private/DB | |
parent | 4680bc47c21d3a42f20ee970032ecc7d26db0f1c (diff) | |
download | nextcloud-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.php | 28 |
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; + } } |