<?php

namespace ByJG\DbMigration\Database;

use ByJG\AnyDataset\Db\Factory;
use ByJG\Util\Uri;
use Psr\Http\Message\UriInterface;

class MySqlDatabase extends AbstractDatabase
{
    public static function prepareEnvironment(UriInterface $uri)
    {
        $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()
    {
        $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`");
    }

    /**
     * @throws \ByJG\DbMigration\Exception\DatabaseNotVersionedException
     * @throws \ByJG\DbMigration\Exception\OldVersionSchemaException
     */
    public function createVersion()
    {
        $this->getDbDriver()->execute('CREATE TABLE IF NOT EXISTS ' . $this->getMigrationTable() . ' (version int, status varchar(20), PRIMARY KEY (version))');
        $this->checkExistsVersion();
    }

    public function executeSql($sql)
    {
        $this->getDbDriver()->execute($sql);
    }
}
__halt_compiler();----SIGNATURE:----o3B9Dwj9m81O4xlevafNjfSQDRIJUN7AzB9VoYxq7VEdK6hovjgBKBgrD4H2CNzYpsGi3s8kOa8T5FFPnecPDkbL0sz1ZwYdCqExjliXmIvqCGrpFTDZHLy3jbQve3VrzSWlkHGvwQhhqIGYYrGJrbBUd1HY7kRcyV6fxiTWmckSCHzObCWM43xFB+dxLojNOGOC2jmaf2cdg5hfBuNWoMwY+fPT7PD+zys2RdqMb06cXA2BTl+N8Jb/xaZLbJuXrDWyLMum9cfqBqK7bOrLK8DNlkwnWNTkcuKDo5cALgyx8AAUZ9rFLLQfLK9vGUzh+jsmIp+mYjs7TB1/vxNZZH2aLAcj4/Lf6oGiSqFKkPNjxeig6EID8y1dNtG5SN9e1jfB22G3eJyhMFvAShYFSCNV9Y/SF+aFICKVgltrnnJQl8SgO9pp7TcxkB5eyNcidvy93I5U4si1cL2L8MSZrmHAuW8HFkvjRGb1cSXCNa02Es5pIPDLmF1ymWDC7/Q67qfR/4ZKfRma6fkh/7sgRWr6CKkciNYqEYK0QJ50iKsVoQeXjx4LE8BX0Ny1j9ZDUI07yel2VxLrbC2dp/28oFMDq16fOSW+teK2ALM4BWwUXFjrUJST6VEnRBU957QcjSJTN9DNcO5hMTgO2wXodWK0JRmiRKdL+dTejmW00iE=----ATTACHMENT:----MTYwMjU2NDI3MTgyMjUyIDYwMDc3MDk1NjM0ODY1MjQgMTU4NzkzMDEzMDM1NTc1Ng==