ByJG\DbMigration\Database\MySqlDatabase

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	41.03 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	prepareEnvironment()	9	9	1
A	createDatabase()	7	7	1
A	dropDatabase()	0	6	1
A	createVersion()	0	5	1
A	executeSql()	0	4	1

<?php

namespace ByJG\DbMigration\Database;

use ByJG\AnyDataset\Factory;
use ByJG\Util\Uri;

class MySqlDatabase extends AbstractDatabase
{

    public static function prepareEnvironment(Uri $uri)

This method seems to be duplicated in your project.

    {
        $database = preg_replace('~^/~', '', $uri->getPath());

        $customUri = new Uri($uri->__toString());

        $dbDriver = Factory::getDbRelationalInstance($customUri->withPath('/')->__toString());
        $dbDriver->execute("CREATE SCHEMA IF NOT EXISTS `$database` DEFAULT CHARACTER SET utf8 ;");
    }

    public function createDatabase()

This method seems to be duplicated in your project.

    {
        $database = preg_replace('~^/~', '', $this->getDbDriver()->getUri()->getPath());

        $this->getDbDriver()->execute("CREATE SCHEMA IF NOT EXISTS `$database` DEFAULT CHARACTER SET utf8 ;");
        $this->getDbDriver()->execute("USE `$database`");
    }

    public function dropDatabase()
    {
        $database = preg_replace('~^/~', '', $this->getDbDriver()->getUri()->getPath());

        $this->getDbDriver()->execute("drop database `$database`");
    }

    public function createVersion()
    {
        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS migration_version (version int, status varchar(20))');
        $this->checkExistsVersion();
    }

    public function executeSql($sql)
    {
        $this->getDbDriver()->execute($sql);
    }
}