mirror of
https://github.com/wallabag/wallabag.git
synced 2024-11-26 11:01:04 +00:00
migrations: fix duplicate violation during lowercase tag migration
Signed-off-by: Kevin Decherf <kevin@kdecherf.com>
This commit is contained in:
parent
6c5904ba7f
commit
40a63c8b11
1 changed files with 20 additions and 8 deletions
|
@ -31,7 +31,7 @@ class Version20170719231144 extends AbstractMigration implements ContainerAwareI
|
||||||
|
|
||||||
// Find tags which need to be merged
|
// Find tags which need to be merged
|
||||||
$dupTags = $this->connection->query('
|
$dupTags = $this->connection->query('
|
||||||
SELECT LOWER(label)
|
SELECT LOWER(label) AS lower_label
|
||||||
FROM ' . $this->getTable('tag') . '
|
FROM ' . $this->getTable('tag') . '
|
||||||
GROUP BY LOWER(label)
|
GROUP BY LOWER(label)
|
||||||
HAVING COUNT(*) > 1'
|
HAVING COUNT(*) > 1'
|
||||||
|
@ -39,17 +39,18 @@ class Version20170719231144 extends AbstractMigration implements ContainerAwareI
|
||||||
$dupTags->execute();
|
$dupTags->execute();
|
||||||
|
|
||||||
foreach ($dupTags->fetchAll() as $duplicates) {
|
foreach ($dupTags->fetchAll() as $duplicates) {
|
||||||
$label = $duplicates['LOWER(label)'];
|
$label = $duplicates['lower_label'];
|
||||||
|
|
||||||
// Retrieve all duplicate tags for a given tag
|
// Retrieve all duplicate tags for a given tag
|
||||||
$tags = $this->connection->createQuery('
|
$tags = $this->connection->executeQuery('
|
||||||
SELECT id
|
SELECT id
|
||||||
FROM ' . $this->getTable('tag') . "
|
FROM ' . $this->getTable('tag') . '
|
||||||
WHERE LOWER(label) = :label
|
WHERE LOWER(label) = :label
|
||||||
ORDER BY id ASC"
|
ORDER BY id ASC',
|
||||||
|
[
|
||||||
|
'label' => $label,
|
||||||
|
]
|
||||||
);
|
);
|
||||||
$tags->setParameter('label', $label);
|
|
||||||
$tags->execute();
|
|
||||||
|
|
||||||
$first = true;
|
$first = true;
|
||||||
$newId = null;
|
$newId = null;
|
||||||
|
@ -71,7 +72,18 @@ class Version20170719231144 extends AbstractMigration implements ContainerAwareI
|
||||||
$this->addSql('
|
$this->addSql('
|
||||||
UPDATE ' . $this->getTable('entry_tag') . '
|
UPDATE ' . $this->getTable('entry_tag') . '
|
||||||
SET tag_id = ' . $newId . '
|
SET tag_id = ' . $newId . '
|
||||||
WHERE tag_id IN (' . implode(',', $ids) . ')'
|
WHERE tag_id IN (' . implode(',', $ids) . ')
|
||||||
|
AND entry_id NOT IN (
|
||||||
|
SELECT entry_id
|
||||||
|
FROM ' . $this->getTable('entry_tag') . '
|
||||||
|
WHERE tag_id = ' . $newId . '
|
||||||
|
)'
|
||||||
|
);
|
||||||
|
|
||||||
|
// Delete links to unused tags
|
||||||
|
$this->addSql('
|
||||||
|
DELETE FROM ' . $this->getTable('entry_tag') . '
|
||||||
|
WHERE tag_id IN (' . implode(',', $ids) . ')'
|
||||||
);
|
);
|
||||||
|
|
||||||
// Delete unused tags
|
// Delete unused tags
|
||||||
|
|
Loading…
Reference in a new issue