DbVersionRepository::createSchema() - Code Metrics - Inspection of "[FRAM-68] Handle by combine query on walker with K..." - b2pweb/bdf-prime - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — 2.0 ( 21259a...8b13d0 )

by Sébastien

created 2022-12-23 12:54 UTC

DbVersionRepository::createSchema() A

↳ Parent: DbVersionRepository

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	2.0054

Importance

Changes

Metric	Value
eloc	7
dl	0
loc	15
ccs	8
cts	9
cp	0.8889
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	0
crap	2.0054

<?php

namespace Bdf\Prime\Migration\Version;

use Bdf\Prime\Connection\ConnectionInterface;
use Bdf\Prime\Exception\PrimeException;
use Bdf\Prime\Migration\VersionRepositoryInterface;
use Bdf\Prime\Schema\Manager\TableManagerInterface;

/**
 * DbVersionRepository
 *
 * Contains the version of all upgraded migration
 */
class DbVersionRepository implements VersionRepositoryInterface
{
    /**
     * The db connection
     *
     * @var ConnectionInterface&\Doctrine\DBAL\Connection
     */
    private $connection;

    /**
     * The table name
     *
     * @var string
     */
    private $tableName;

    /**
     * Check whether the table exists
     *
     * @var boolean
     *
     * @internal
     */
    private $hasSchema;

    /**
     * Cache of version
     *
     * @var array
     *
     * @internal
     */
    private $cached;

    /**
     * Constructor
     *
     * @param ConnectionInterface&\Doctrine\DBAL\Connection $connection
     * @param string $tableName
     */
    public function __construct(ConnectionInterface $connection, string $tableName)
    {
        $this->connection = $connection;
        $this->tableName  = $tableName;
    }

    /**
     * Get the connection
     *
     * @return ConnectionInterface&\Doctrine\DBAL\Connection
     */
    public function getConnection(): ConnectionInterface
    {
        return $this->connection;
    }

    /**
     * Get the table name
     *
     * @return string
     */
    public function getTable(): string
    {
        return $this->tableName;
    }

    /**
     * {@inheritDoc}
     */
    public function newIdentifier(): string
    {
        return date('YmdHis');
    }

    /**
     * {@inheritDoc}
     */
    public function has(string $version): bool
    {
        return in_array($version, $this->all());
    }

    /**
     * {@inheritDoc}
     */
    public function current(): string
    {
        $versions = $this->all();

        return (string)end($versions);
    }

    /**
     * {@inheritDoc}
     */
    public function all(): array
    {
        if ($this->cached !== null) {
            return $this->cached;
        }

        $this->prepare();

        /** @psalm-suppress UndefinedInterfaceMethod */
        return $this->cached = $this->connection->from($this->tableName)->order('version')->inRows('version');
        return $this->cached = $this->connection->from($this->tableName)->/** @scrutinizer ignore-call */ order('version')->inRows('version');
    }

    /**
     * {@inheritDoc}
     */
    public function add(string $version)
    {
        $this->prepare();

        $this->connection->insert($this->tableName, [
            'version' => $version,
        ]);

        $this->cached = null;

        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function remove(string $version)
    {
        $this->prepare();

        $this->connection->delete($this->tableName, [
            'version' => $version,
        ]);

        $this->cached = null;

        return $this;
    }

    /**
     * Prepare the repository
     * @throws PrimeException
     */
    public function prepare(): void
    {
        if (!$this->hasSchema()) {
            $this->createSchema();
        }
    }

    /**
     * Is the schema ready?
     *
     * @return boolean
     * @throws PrimeException
     */
    public function hasSchema(): bool
    {
        if (null === $this->hasSchema) {
            $this->hasSchema = $this->connection->schema()->has($this->tableName);
        }

        return $this->hasSchema;
    }

    /**
     * Create Schema
     *
     * @return $this
     * @throws PrimeException
     */
    public function createSchema()
    {
        $schemaManager = $this->connection->schema();

        if (!$schemaManager instanceof TableManagerInterface) {
            throw new \LogicException('The connection "' . $this->connection->getName() . '" do not supports table configuration');
        }

        $schemaManager->table($this->tableName, function ($table) {
            $table->string('version');
        });

        $this->hasSchema = true;

        return $this;
    }
}


b2pweb / bdf-prime

Push — 2.0 ( 21259a...8b13d0 )

DbVersionRepository::createSchema() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like