SlayerBirden\DataFlow\Test\Functional\DbalMigrationTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	141
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	hp$0 ➔ __invoke()	0	4	1
A	hp$1 ➔ __invoke()	0	4	1
B	setUp()	0	62	1
A	getConnection()	0	9	2
A	getTearDownOperation()	0	4	1
A	getDataSet()	0	20	1
A	testDbSimplePipeFlow()	0	19	1
A	testGetSize()	0	6	1

<?php
declare(strict_types=1);

namespace SlayerBirden\DataFlow\Test\Functional;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Driver\PDOConnection;
use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Schema\Schema;
use PHPUnit\DbUnit\Operation\Factory;
use PHPUnit\DbUnit\TestCase;
use SlayerBirden\DataFlow\DataBagInterface;
use SlayerBirden\DataFlow\Emitter\BlackHole;
use SlayerBirden\DataFlow\Pipe\FilterCallbackInterface;
use SlayerBirden\DataFlow\Pipe\MapperCallbackInterface;
use SlayerBirden\DataFlow\PipelineBuilder;
use SlayerBirden\DataFlow\Plumber;
use SlayerBirden\DataFlow\Provider\Dbal;
use SlayerBirden\DataFlow\Test\Functional\Exception\ConnectionException;
use SlayerBirden\DataFlow\Writer\Dbal\UpdateStrategy\UniqueIndexStrategy;
use SlayerBirden\DataFlow\Writer\Dbal\Write;
use SlayerBirden\DataFlow\Writer\Dbal\WriterUtility;

class DbalMigrationTest extends TestCase
{
    /**
     * @var Connection
     */
    private $connection;
    private $emitter;
    private $pipeline;

    protected function setUp(): void
    {
        $params = require __DIR__ . '/config/db-config.php';
        $this->connection = DriverManager::getConnection($params);

        $schema = new Schema();
        // create Heroes Table
        $table = $schema->createTable('heroes');
        $table->addColumn('id', 'integer', [
            'autoincrement' => true,
        ]);
        $table->addColumn('name', 'string');
        $table->addColumn('code', 'string');
        $table->setPrimaryKey(['id']);
        $table->addUniqueIndex(['code']);

        // create Users Table
        $table = $schema->createTable('users');
        $table->addColumn('id', 'integer', [
            'autoincrement' => true,
        ]);
        $table->addColumn('first', 'string');
        $table->addColumn('last', 'string');
        $table->addColumn('code', 'string');
        $table->setPrimaryKey(['id']);
        $table->addUniqueIndex(['code']);

        $currentSchema = $this->connection->getSchemaManager()->createSchema();
        $sql = $currentSchema->getMigrateToSql($schema, $this->connection->getDatabasePlatform());
        array_walk($sql, function ($script) {
            $this->connection->executeUpdate($script);
        });

        parent::setUp();
        $this->emitter = new BlackHole();
        $utility = new WriterUtility($this->connection);
        $this->pipeline = (new PipelineBuilder($this->emitter))
            ->delete(['id'])
            ->filter(new class implements FilterCallbackInterface
            {
                public function __invoke(DataBagInterface $dataBag): bool
                {
                    return !empty($dataBag['code']);
                }
            })
            ->map('name', new class implements MapperCallbackInterface
            {
                public function __invoke($value, DataBagInterface $dataBag)
                {
                    return $dataBag['first'] . ' ' . $dataBag['last'];
                }
            })
            ->addSection(new Write(
                'heroes_write',
                $this->connection,
                'heroes',
                $utility,
                new UniqueIndexStrategy('heroes', $utility),
                $this->emitter
            ))
            ->build();
    }

    /**
     * @inheritdoc
     */
    protected function getConnection()
    {
        $con = $this->connection->getWrappedConnection();
        if ($con instanceof PDOConnection) {
            return $this->createDefaultDBConnection($con);
        }

        throw new ConnectionException('Could not get PDO object.');
    }

    protected function getTearDownOperation()
    {
        return Factory::TRUNCATE();
    }

    /**
     * @inheritdoc
     */
    protected function getDataSet()
    {
        return $this->createArrayDataSet([
            'users' => [
                [
                    'id' => 1,
                    'first' => 'John',
                    'last' => 'Doe',
                    'code' => ''
                ],
                [
                    'id' => 2,
                    'first' => 'Peter',
                    'last' => 'Parker',
                    'code' => 'spiderman'
                ],
            ],
            'heroes' => [],
        ]);
    }

    public function testDbSimplePipeFlow()
    {
        $provider = new Dbal('db_users', $this->connection, 'users');

        (new Plumber($provider, $this->pipeline, $this->emitter))->pour();

        $actual = $this->getConnection()->createQueryTable('heroes', 'SELECT * FROM `heroes`');
        $expected = $this->createArrayDataSet([
            'heroes' => [
                [
                    'id' => 1,
                    'name' => 'Peter Parker',
                    'code' => 'spiderman',
                ],
            ]
        ]);

        $this->assertTablesEqual($expected->getTable('heroes'), $actual);
    }

    public function testGetSize()
    {
        $provider = new Dbal('db_users', $this->connection, 'users');

        $this->assertSame(2, $provider->getEstimatedSize());
    }
}