<?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:----wr2n1q2LUGoIPNwpY91HPsZukmx0TwmnDyEHTFIKUCv4ajCjR0cohjQB46yaykD9EqCtRhN4sy/8aXGhamAWEGCdoahNB/GE+7GFrVCrjc3OARjknP6ubTHddULd/Eps20SO3g5TOGwJ2voYle7EyNsEKss/6s/ZD6DTWbGoBokhVp3vxeaj5E9vnlhBKriDHK/Nw7TB6c5ymAw5/SThwBhp2TFYRGAtuaJnpKA8cgp99upMZxtYG0/EHj3YV2WtJwW8auPji6qIKk2h/5gkoTnI0qfGLOtZr88FKFya3L85kKzxP0ebhDVmYhxGQXUBIIhaZ75/w4ikQjcjHQaZimvgpLnk9+bd4hsSgXYJdTm3RMx+hFrJJZiO2D268Jp3BvlZiR/UMpI54g9ChqIxRo9xZ7TEY6YMa7VQgtFIWLEEBT+rQx2VO07Yxs7NCqZFae/TTGF9ZzN2tJxsaLgQeMjRuknRDJsxGdhhmqit4gVvhb+pKD1eF/mH+M/1AGTSUgYwmjd6gYQpTkvtFsF0+B7RpaXsLOtHwnuF3CO/1UAYcYO4WJifFuzJc7xwMbNdroaunj+tWAXo+yQER+LoFibkHn7v6ArNsBy6DeXcKNkmrzuSQwos0Hf2BzE7W5+NO/PacSn0xosLFdp7RzgHOZ3NHhdC758Vpd+2xVHPkJI=----ATTACHMENT:----NTMwMTI4Mjg4NDE2MzI3MSA4MTk0MDE3MzU1MTMzMjUyIDE4NTYyMDgxMjEwMTI1NTE=