EdmondsCommerce\DoctrineStaticMeta\Schema\Database

Complexity

Total Complexity

14

Size/Duplication

Total Lines	113
Duplicated Lines	0 %

Test Coverage

Coverage

7.5%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	throwUnsure()	0	3	1
A	__construct()	0	3	1
A	connect()	0	14	3
A	__destruct()	0	3	1
A	create()	0	17	3
A	drop()	0	15	3
A	close()	0	5	2

<?php declare(strict_types=1);

namespace EdmondsCommerce\DoctrineStaticMeta\Schema;

use EdmondsCommerce\DoctrineStaticMeta\ConfigInterface;
use EdmondsCommerce\DoctrineStaticMeta\Exception\DoctrineStaticMetaException;

/**
 * Class Database
 *
 * Drop and Create the Actual Database using raw mysqli
 *
 * @package EdmondsCommerce\DoctrineStaticMeta\Schema
 */
class Database
{

    /**
     * @see https://dev.mysql.com/doc/refman/5.7/en/identifiers.html
     */
    public const MAX_IDENTIFIER_LENGTH = 64;

    /**
     * @var ConfigInterface
     */
    private $config;

    /**
     * @var null|\mysqli
     */
    private $link;

    public function __construct(ConfigInterface $config)
    {
        $this->config = $config;
    }

    /**
     * @return \mysqli
     * @throws DoctrineStaticMetaException
     */
    private function connect(): \mysqli
    {
        if (null === $this->link) {
            $this->link = mysqli_connect(
                $this->config->get(ConfigInterface::PARAM_DB_HOST),
                $this->config->get(ConfigInterface::PARAM_DB_USER),
                $this->config->get(ConfigInterface::PARAM_DB_PASS)
            );
            if (!$this->link) {
                throw new DoctrineStaticMetaException('Failed getting connection in '.__METHOD__);
            }
        }

        return $this->link;
    }

    protected function throwUnsure(): void
    {
        throw new \InvalidArgumentException('You must pass in `true` to show you are sure');
    }

    /**
     * You have to pass in true to confirm you really want to do it
     *
     * @param bool $sure
     *
     * @return Database
     * @throws \InvalidArgumentException
     * @throws DoctrineStaticMetaException
     */
    public function drop($sure): Database
    {
        if (true !== $sure) {
            $this->throwUnsure();
        }
        $link = $this->connect();
        $sql  = "DROP DATABASE IF EXISTS `{$this->config->get(ConfigInterface::PARAM_DB_NAME)}`";
        if (true !== mysqli_query($link, $sql)) {
            throw new DoctrineStaticMetaException(
                'Failed to drop the database '
                .$this->config->get(ConfigInterface::PARAM_DB_NAME)
            );
        }

        return $this;
    }

    /**
     * You have to pass in true to confirm you really want to do it
     *
     * @param bool $sure
     *
     * @return Database
     * @throws \InvalidArgumentException
     * @throws DoctrineStaticMetaException
     */
    public function create($sure): Database
    {
        if (true !== $sure) {
            $this->throwUnsure();
        }
        $link = $this->connect();
        $sql  = 'CREATE DATABASE IF NOT EXISTS `'
                .$this->config->get(ConfigInterface::PARAM_DB_NAME)
                .'` CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci';
        if (true !== mysqli_query($link, $sql)) {
            throw new DoctrineStaticMetaException(
                'Failed to create the database '
                .$this->config->get(ConfigInterface::PARAM_DB_NAME)
            );
        }

        return $this;
    }

    public function close(): void
    {
        if (null !== $this->link) {
            mysqli_close($this->link);
            $this->link = null;
        }
    }

    public function __destruct()
    {
        $this->close();
    }
}