fix: migration unique check (#3754)

Author: rebelchris

bin/migrateKratosUsers.ts

@@ -155,7 +155,7 @@ const migratePasswordAccounts = async (
     const { rowCount } = await dailyPool.query(
       `INSERT INTO ba_account (id, "userId", "providerId", "accountId", password, "createdAt", "updatedAt")
        VALUES ${placeholders.join(', ')}
-       ON CONFLICT (id) DO NOTHING`,
+       ON CONFLICT ("userId", "providerId") DO NOTHING`,
       values,
     );
     total += rowCount ?? 0;
@@ -229,7 +229,7 @@ const migrateOidcAccounts = async (
     const { rowCount } = await dailyPool.query(
       `INSERT INTO ba_account (id, "userId", "providerId", "accountId", "createdAt", "updatedAt")
        VALUES ${placeholders.join(', ')}
-       ON CONFLICT (id) DO NOTHING`,
+       ON CONFLICT ("userId", "providerId") DO NOTHING`,
       values,
     );
     total += rowCount ?? 0;

src/migration/1774400000000-BaAccountUserProviderUnique.ts

@@ -0,0 +1,19 @@
+import type { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class BaAccountUserProviderUnique1774400000000 implements MigrationInterface {
+  name = 'BaAccountUserProviderUnique1774400000000';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(/* sql */ `
+      CREATE UNIQUE INDEX IF NOT EXISTS
+        "IDX_ba_account_userId_providerId"
+        ON "ba_account" ("userId", "providerId")
+    `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(/* sql */ `
+      DROP INDEX IF EXISTS "IDX_ba_account_userId_providerId"
+    `);
+  }
+}