migrations/Version20190304025526.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use App\Entity\Customer\Customer;
  8. use Doctrine\DBAL\Schema\Schema;
  9. use Doctrine\Migrations\AbstractMigration;
  10. use Symfony\Component\DependencyInjection\ContainerAwareInterface;
  11. use Symfony\Component\DependencyInjection\ContainerInterface;
  12. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  14. /**
  15.  * Auto-generated Migration: Please modify to your needs!
  16.  */
  17. final class Version20190304025526 extends AbstractMigration implements ContainerAwareInterface
  18. {
  19.     /** @var ContainerInterface */
  20.     private $container;
  22.     /**
  23.      * @param ContainerInterface|null $container
  24.      */
  25.     public function setContainer(ContainerInterface $container = null)
  26.     {
  27.         $this->container = $container;
  28.     }
  30.     public function up(Schema $schema): void
  31.     {
  32.         /** @var UserPasswordEncoderInterface $encoder */
  33.         $encoder = $this->container->get('security.password_encoder');
  35.         $stmt = $this->connection->prepare('SELECT count(1) FROM customer WHERE plain_password IS NOT NULL');
  36.         $stmt->execute();
  38.         // get total entries
  39.         $total = $stmt->fetchColumn();
  41.         // insert using pagination
  42.         for ($i = 0; $i < ceil($total / 500); ++$i) {
  43.             $stmt = $this->connection->prepare(sprintf('SELECT id, plain_password FROM customer WHERE plain_password IS NOT NULL ORDER BY id ASC LIMIT %d, 100', 100 * $i));
  44.             $stmt->execute();
  46.             while ($row = $stmt->fetch(\PDO::FETCH_OBJ)) {
  47.                 $this->addSql('UPDATE customer SET password = :password WHERE id = :id', [
  48.                     'id' => $row->id,
  49.                     'password' => $encoder->encodePassword(new Customer(), $row->plain_password),
  50.                 ]);
  51.             }
  52.         }
  53.     }
  55.     public function down(Schema $schema): void
  56.     {
  57.         $this->addSql('UPDATE customer SET password = SHA1(plain_password) WHERE plain_password IS NOT NULL');
  58.     }
  59. }