migrations/Version20260120145848.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use Doctrine\DBAL\Schema\Schema;
  8. use Doctrine\Migrations\AbstractMigration;
  10. final class Version20260120145848 extends AbstractMigration
  11. {
  12.     public function getDescription(): string
  13.     {
  14.         return 'Add unique constraint for sku per shop';
  15.     }
  17.     public function preUp(Schema $schema): void
  18.     {
  19.         $this->handleDuplicateSkus();
  20.     }
  22.     public function up(Schema $schema): void
  23.     {
  24.         $this->addSql('CREATE UNIQUE INDEX sku_shop ON product (shop_id, sku)');
  25.     }
  27.     public function down(Schema $schema): void
  28.     {
  29.         $this->addSql('DROP INDEX sku_shop ON `product`');
  30.     }
  32.     private function handleDuplicateSkus(): void
  33.     {
  34.         $sql = 'SELECT shop_id, sku, COUNT(*) as count 
  35.                 FROM product 
  36.                 WHERE product.sku IS NOT NULL AND product.sku != ""
  37.                 GROUP BY shop_id, sku 
  38.                 HAVING count > 1';
  40.         $duplicates = $this->connection->fetchAllAssociative($sql);
  41.         foreach ($duplicates as $duplicate) {
  42.             $shopId = $duplicate['shop_id'];
  43.             $sku = $duplicate['sku'];
  45.             $sql = "SELECT id FROM product WHERE product.shop_id = ? AND product.sku = ? ORDER BY product.id LIMIT 18446744073709551615 OFFSET 1";
  46.             $products = $this->connection->fetchAllAssociative($sql, [$shopId, $sku]);
  47.             foreach ($products as $index => $product) {
  48.                 $newSku = $sku . $index;
  49.                 $this->addSql('UPDATE product SET product.sku = ? WHERE product.id = ?', [$newSku, $product['id']]);
  50.             }
  51.            
  52.         }
  53.     }
  54. }