ByJG\DbMigration\Commands\DblibCommand

Complexity

Total Complexity

8

Size/Duplication

Total Lines	67
Duplicated Lines	34.33 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	prepareEnvironment()	9	9	1
A	createDatabase()	7	7	1
A	dropDatabase()	7	7	1
A	createTableIfNotExists()	0	14	1
A	createVersion()	0	8	1
A	executeSql()	0	8	2
A	executeSqlInternal()	0	4	1

<?php

namespace ByJG\DbMigration\Commands;

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

class DblibCommand extends AbstractCommand
{

    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("IF NOT EXISTS(select * from sys.databases where name='$database') CREATE DATABASE $database");
    }

    public function createDatabase()

This method seems to be duplicated in your project.

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

        $this->getDbDriver()->execute("IF NOT EXISTS(select * from sys.databases where name='$database') CREATE DATABASE $database");
        $this->getDbDriver()->execute("USE $database");
    }

    public function dropDatabase()

This method seems to be duplicated in your project.

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

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

    protected function createTableIfNotExists($database, $table, $createTable)
    {
        $this->getDbDriver()->execute("use $database");

        $sql = "IF (NOT EXISTS (SELECT * 
                 FROM INFORMATION_SCHEMA.TABLES 
                 WHERE TABLE_SCHEMA = 'dbo' 
                 AND  TABLE_NAME = '$table'))
            BEGIN
                $createTable
            END";

        $this->getDbDriver()->execute($sql);
    }

    public function createVersion()
    {
        $database = preg_replace('~^/~', '', $this->getDbDriver()->getUri()->getPath());
        $table = 'migration_version';
        $createTable = 'CREATE TABLE migration_version (version int)';
        $this->createTableIfNotExists($database, $table, $createTable);
        $this->checkExistsVersion();
    }

    public function executeSql($sql)
    {
        $statements = explode(";", $sql);

        foreach ($statements as $sql) {
            $this->executeSqlInternal($sql);
        }
    }

    protected function executeSqlInternal($sql)
    {
        $this->getDbDriver()->execute($sql);
    }
}