migrations/Version20180707231353.php line 1

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DoctrineMigrations;
  6. use Symfony\Component\Console\Output\ConsoleOutput;
  7. use Symfony\Component\Console\Formatter\OutputFormatter;
  9. use Doctrine\DBAL\Schema\Schema;
  10. use Doctrine\Migrations\AbstractMigration;
  11. use Symfony\Component\DependencyInjection\ContainerAwareInterface;
  12. use Symfony\Component\DependencyInjection\ContainerAwareTrait;
  13. use Symfony\Component\DependencyInjection\ContainerInterface;
  14. use App\Customer\Entity\StreetAddress;
  16. /**
  17.  * Auto-generated Migration: Please modify to your needs!
  18.  */
  19. final class Version20180707231353 extends AbstractMigration implements ContainerAwareInterface
  20. {
  21.     use ContainerAwareTrait;
  23.     public function setContainer(ContainerInterface $container = null)
  24.     {
  25.         $this->container = $container;
  26.     }
  28.     public function up(Schema $schema) : void
  29.     {
  30.         // this up() migration is auto-generated, please modify it to your needs
  31.         $this->abortIf($this->connection->getDatabasePlatform()->getName() !== 'mysql', 'Migration can only be executed safely on \'mysql\'.');
  33.         $this->addSql('ALTER TABLE street_address ADD location POINT COMMENT \'(DC2Type:point)\'');
  34.     }
  36.     public function postUp(Schema $schema) : void
  37.     {
  38.         $output = new ConsoleOutput();
  39.         $output->setFormatter(new OutputFormatter(true));
  41.         $output->writeln("\n  <info>++</info> Migrating data");
  43.         // 1. Move lat/lng into the location field
  44.         // just for reference: x = lon, y = lat
  45.         $qb = $this->connection->createQueryBuilder();
  46.         $q = $qb->update('street_address', 'sa')
  47.             ->set('sa.location', 'point(sa.lng, sa.lat)')
  48.             ->where('sa.lat IS NOT NULL')
  49.             ->andWhere('sa.lng IS NOT NULL');
  51.         $output->writeln("\n     <comment>-></comment> " . $q->getSQL());
  52.         $r = $q->execute();
  53.         $output->writeln("     <comment>updated " . $r . " rows</comment>");
  55.         // 2. Disable any addresses without a proper formatted_address (we basically soft-delete any old format address)
  56.         // NOTE: we can't revert this change, not enough information.
  57.         $qb = $this->connection->createQueryBuilder();
  58.         $q = $qb->update('street_address', 'sa')
  59.             ->set('sa.isActive', '0')
  60.             ->set('sa.isVerified', '0')
  61.             ->where('sa.formatted_address is NULL');
  63.         $output->writeln("\n     <comment>-></comment> " . $q->getSQL());
  64.         $r = $q->execute();
  65.         $output->writeln("     <comment>updated " . $r . " rows</comment>");
  67.         // 3. Generate formatted_address for entries without one, using the separate pieces of information
  68.         $qb = $this->connection->createQueryBuilder();
  70.         $sql = "UPDATE street_address LEFT JOIN deliveryZones ON street_address.idDeliveryZone = deliveryZones.id "
  71.               ."SET formatted_address = IF(isGatedCommunity, "
  72.               ."CONCAT(COALESCE(street,''), ' ', COALESCE(number,''), ' P', COALESCE(plot,''), ' H', COALESCE(house,''), ' S', COALESCE(sector,''), ', ', COALESCE(name,'')), "
  73.               ."CONCAT(COALESCE(street,''), ' ', COALESCE(number,''), ' ', COALESCE(floor,''), ' ', COALESCE(apartment,''), ', ', COALESCE(name,''))) "
  74.               ."WHERE formatted_address IS NULL";
  76.         $output->writeln("\n     <comment>-></comment> " . $sql);
  77.         $q = $this->connection->prepare($sql);
  78.         $r = $q->execute();
  79.         $output->writeln("     <comment>updated " . $q->rowCount() . " rows</comment>");
  80.     }
  82.     public function preDown(Schema $schema) : void
  83.     {
  84.         $output = new ConsoleOutput();
  85.         $output->setFormatter(new OutputFormatter(true));
  87.         $qb = $this->connection->createQueryBuilder();
  88.         $q = $qb->update('street_address', 'sa')
  89.             ->set('sa.lat', 'Y(sa.location)')
  90.             ->set('sa.lng', 'X(sa.location)');
  92.         $output->writeln("\n  <info>++</info> Migrating data");
  93.         $output->writeln("\n     <comment>-></comment> " . $q->getSQL());
  95.         $r = $q->execute();
  97.         $output->writeln("     <comment>updated " . $r . " rows</comment>");
  98.     }
  100.     public function down(Schema $schema) : void
  101.     {
  102.         // this down() migration is auto-generated, please modify it to your needs
  103.         $this->abortIf($this->connection->getDatabasePlatform()->getName() !== 'mysql', 'Migration can only be executed safely on \'mysql\'.');
  105.         $this->addSql('ALTER TABLE street_address DROP location');
  106.     }
  107. }