From e33933e44c82c02792372efe9590c9b8a3a495a0 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Fri, 19 Feb 2021 08:41:32 +0100 Subject: [PATCH] Fix latest migrations We made an historical mistake: we have a unique key on videoId, resolution AND fps. But the filenames and torrent filenames do not have fps in their name Remove these duplicate entries --- server/initializers/constants.ts | 2 +- .../migrations/0600-duplicate-video-files.ts | 33 +++++++++++++++++++ 2 files changed, 34 insertions(+), 1 deletion(-) create mode 100644 server/initializers/migrations/0600-duplicate-video-files.ts diff --git a/server/initializers/constants.ts b/server/initializers/constants.ts index fbedc2164..f0123e87c 100644 --- a/server/initializers/constants.ts +++ b/server/initializers/constants.ts @@ -24,7 +24,7 @@ import { CONFIG, registerConfigChangedHandler } from './config' // --------------------------------------------------------------------------- -const LAST_MIGRATION_VERSION = 595 +const LAST_MIGRATION_VERSION = 600 // --------------------------------------------------------------------------- diff --git a/server/initializers/migrations/0600-duplicate-video-files.ts b/server/initializers/migrations/0600-duplicate-video-files.ts new file mode 100644 index 000000000..92d774a79 --- /dev/null +++ b/server/initializers/migrations/0600-duplicate-video-files.ts @@ -0,0 +1,33 @@ +import * as Sequelize from 'sequelize' + +async function up (utils: { + transaction: Sequelize.Transaction + queryInterface: Sequelize.QueryInterface + sequelize: Sequelize.Sequelize + db: any +}): Promise { + + { + const query = 'DELETE FROM "videoFile" f1 ' + + 'USING (SELECT MIN(id) as id, "torrentFilename" FROM "videoFile" GROUP BY "torrentFilename" HAVING COUNT(*) > 1) f2 ' + + 'WHERE f1."torrentFilename" = f2."torrentFilename" AND f1.id <> f2.id' + await utils.sequelize.query(query) + } + + { + const query = 'DELETE FROM "videoFile" f1 ' + + 'USING (SELECT MIN(id) as id, "filename" FROM "videoFile" GROUP BY "filename" HAVING COUNT(*) > 1) f2 ' + + 'WHERE f1."filename" = f2."filename" AND f1.id <> f2.id' + await utils.sequelize.query(query) + } + +} + +function down (options) { + throw new Error('Not implemented.') +} + +export { + up, + down +}