byjg / migration

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

    }

    public function createDatabase()

    {

        $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->getDbDriver()->execute("USE $database");

    }

    public function dropDatabase()

    {

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

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

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

    }

    protected function createTableIfNotExists($database, $createTable)

    {

     * @throws \ByJG\DbMigration\Exception\DatabaseNotVersionedException

     * @throws \ByJG\DbMigration\Exception\OldVersionSchemaException

     */

    public function createVersion()

    {

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

        $createTable = 'CREATE TABLE ' . $this->getMigrationTable() . ' (version int, status varchar(20))';

        $this->createTableIfNotExists($database, $createTable);

        $this->checkExistsVersion();

    }

    public function executeSql($sql)

    {

        $dbDriver->execute("CREATE SCHEMA IF NOT EXISTS `$database` DEFAULT CHARACTER SET utf8 ;");

    }

    public function createDatabase()

    {

        $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()

    {