Shapin\Datagen\DBAL\Processor

Complexity

Total Complexity

16

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

96.88%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	process()	0	10	5
B	flush()	0	28	7
A	getName()	0	4	1
A	resolveOption()	0	8	2

<?php

declare(strict_types=1);

namespace Shapin\Datagen\DBAL;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;
use Shapin\Datagen\FixtureInterface;
use Shapin\Datagen\ProcessorInterface;
use Shapin\Datagen\ReferenceManager;

class Processor implements ProcessorInterface
{
    private $connection;
    private $referenceManager;
    private $schema;

    private $fixturesToLoad = [];

    public function __construct(Connection $connection, ReferenceManager $referenceManager)
    {
        $this->connection = $connection;
        $this->referenceManager = $referenceManager;
        $this->schema = new Schema();
    }

    /**
     * {@inheritdoc}
     */
    public function process(FixtureInterface $fixture, array $options = []): void
    {
        if ($fixture instanceof Table && !$this->resolveOption($options, 'fixtures_only', false)) {
            $fixture->addTableToSchema($this->schema);
        }

        if ($fixture instanceof FixtureCollection && !$this->resolveOption($options, 'schema_only', false)) {
            $this->fixturesToLoad[] = $fixture;
        }
    }

    /**
     * {@inheritdoc}
     */
    public function flush(array $options = []): void
    {
        if (!$this->resolveOption($options, 'fixtures_only', false)) {
            $statements = $this->schema->toSql($this->connection->getDatabasePlatform());
            foreach ($statements as $statement) {
                $this->connection->query($statement);

The method Doctrine\DBAL\Connection::query() has been deprecated with message: Use {@link executeQuery()} instead.

            }

            // Reset schema
            $this->schema = new Schema();
        }

        if ($this->resolveOption($options, 'schema_only', false)) {
            return;
        }

        foreach ($this->fixturesToLoad as $fixtureCollection) {
            foreach ($fixtureCollection->getFixtures() as $key => $fixture) {
                $fields = $this->referenceManager->findAndReplace($fixture->getFields());

                $this->connection->insert($fixture->getTableName(), $fields, $fixture->getTypes());

                if (\is_string($key)) {
                    $this->referenceManager->add($fixture->getTableName(), $key, $fields);
                }
            }
        }
    }

    /**
     * {@inheritdoc}
     */
    public function getName(): string
    {
        return 'dbal';
    }

    private function resolveOption(array $options, string $key, $defaultValue = null)
    {
        if (!\array_key_exists($key, $options)) {
            return $defaultValue;
        }

        return $options[$key];
    }
}