<?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:----y0viDd6+Ai8qVSr5OJ7BG9N46vQAfY8F7qATt4G0dv3NsXCKJ599jlwgIgxqBU1N3hWZRNRn8lHc4QFDLjn8bG3cloMrPbzPREmU3rzXnupfBDeFeC2w5v69KT1Ehyw0OvLwplSSH/6r7auMIf/dPW0lBztO+KNEWnI3VCaf9x1BSXjKsvsl6krg/MUObeLCSS7fYGdr3FoMtZHDaOuMag87xqQg+Ieys7qD4j4nZU6LxrikLxklkWMPQQqgUh78oAjlzb5RAavNqwcowLDUorgdtumICmo1pDghXVSVrlgEJFMySrRxy5Yis14IPoxj67W7uwfAw4vsFTFRl70sVMFLTe7TJiB12et37Q0MuR5LnQY0TQkkgPfxUtdfe06ADyjveYclwGA6GPX40RUgAtITUKg1TTMFqMWFH4uvMhlBG58uC5+6b+cJoPbIcEhmmf4h17YrUCkm69GUP0tpQjdA8P684bozoFi1F/tQ/al927KSijUjWYCIk/n3lYW/KStJK/7c0B+13qQTCmUZLgdhoKYNtN+I0ZVjVGZ35z4Dqqkig46ljXcX8MlTtkzxCxx2RHXdMQkQjYeqBP0Zxe4V/JMp8wZ96JzrflZq2EV4BBlK5FjFjjENQGVGLsmPVICg4k7Q9wuhM752lu3LAeRZloyRvnIgGhPhfvtwoUQ=----ATTACHMENT:----NDczODAzODE2ODczOTgxOSA0MzU0MjY0OTkwMDMyMzcgNjY5NzQ4ODgzNTE0MDM1Ng==