Application\Migrations\Version20201123090099::up()

Complexity

Conditions	1
Paths	1

Size

Total Lines	8
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	Version20201228090100::up()	0	3	1

<?php

namespace Application\Migrations;

use Azine\MailgunWebhooksBundle\Entity\MailgunEvent;
use Azine\MailgunWebhooksBundle\Entity\MailgunMessageSummary;
use Doctrine\DBAL\Migrations\AbortMigrationException;

The type Doctrine\DBAL\Migrations\AbortMigrationException was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\DBAL\Migrations\AbstractMigration;

The type Doctrine\DBAL\Migrations\AbstractMigration was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\DBAL\Schema\Schema;
use Doctrine\ORM\EntityManager;
use Symfony\Component\DependencyInjection\ContainerAwareInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;

/**
 * Update your db-table structure before applying this migration (doctrine:migration:diff && doctrine:migration:migrate).
 *
 * Important Note: doctrine:migration: diff will suggest to add a foreign key constraint like this:
 *                 "ALTER TABLE mailgun_event ADD CONSTRAINT FK_1271933F537A1329 FOREIGN KEY (message_id) REFERENCES mailgun_message_summary (id) ON DELETE CASCADE".
 *                 !!! BUT this constraint can only be added after the migration below ran successfully. !!!
 *
 * Add MessageSummary Entity to keep track and summarize what happened with a sent email.
 * Rename table email_traffic_statistics to mailgun_email_traffic_statistics
 */
class Version20201228090100 extends AbstractMigration implements ContainerAwareInterface
{
    /** @var EntityManager */
    private $manager;

    public function setContainer(ContainerInterface $container = null)
    {
        $this->manager = $container->get('doctrine.orm.entity_manager');

The method get() does not exist on null.

    }

    /**
     * @param Schema $schema
     * @throws AbortMigrationException
     */
    public function up(Schema $schema)
    {
        $this->abortIf('mysql' != $this->connection->getDatabasePlatform()->getName(), 'Migration can only be executed safely on \'mysql\'.');
    }

    /**
     * @param Schema $schema
     * @throws \Doctrine\ORM\OptimisticLockException
     */
    public function postUp(Schema $schema)
    {
        $repository = $this->manager->getRepository(MailgunMessageSummary::class);
        $processing = true;
        $page=0;
        $pageSize=100;
        while($processing) {
            $query = $this->manager->createQuery("select e from " . MailgunEvent::class . " e");
            $query->setFirstResult($page*$pageSize);
            $query->setMaxResults($pageSize);
            $iterableResult = $query->iterate();
            $counter = 0;
            foreach ($iterableResult as $row) {
                $repository->createOrUpdateMessageSummary($row[0]);
                $this->manager->flush();
                $counter++;
            }
            $this->manager->commit();
            $this->manager->clear();
            $processing = $counter == $pageSize;
            $this->manager->beginTransaction();
            $page++;
        }
    }

    /**
     * @param Schema $schema
     * @throws AbortMigrationException
     */
    public function down(Schema $schema)
    {
        $this->abortIf('mysql' != $this->connection->getDatabasePlatform()->getName(), 'Migration can only be executed safely on \'mysql\'.');
    }
}