ByJG\DbMigration\Commands\MySqlCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	3
Bugs	1	Features	2

5 Methods

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

<?php

namespace ByJG\DbMigration\Commands;

use ByJG\AnyDataset\ConnectionManagement;
use ByJG\AnyDataset\Repository\DBDataset;

class MySqlCommand extends AbstractCommand
{

    public static function prepareEnvironment(ConnectionManagement $connection)
    {
        $database = $connection->getDatabase();

        $newConnection = new ConnectionManagement(str_replace("/$database", "/", $connection->getDbConnectionString()));
        $dbDataset = new DBDataset($newConnection->getDbConnectionString());
        $dbDataset->execSQL("CREATE SCHEMA IF NOT EXISTS `$database` DEFAULT CHARACTER SET utf8 ;");
    }

    public function createDatabase()
    {
        $database = $this->getDbDataset()->getConnectionManagement()->getDatabase();

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

    public function dropDatabase()
    {
        $database = $this->getDbDataset()->getConnectionManagement()->getDatabase();

        $this->getDbDataset()->execSQL("drop database `$database`");
    }

    public function createVersion()
    {
        $this->getDbDataset()->execSQL('CREATE TABLE IF NOT EXISTS migration_version (version int)');
        $this->checkExistsVersion();
    }

    public function executeSql($sql)
    {
        $this->getDbDataset()->execSQL($sql);
    }
}