<?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:----HNY5BI7irPedLsg1pcyzpdqWGoxLzv04gB0tvimTO5r23HxvlOfgd+QOqT7XO1+/jYTXAOr9LpJCvk0Xe1ff41YI/4k7bmw92mq3S5bxFB4HRHFYFBc+bCtvhlzucKoC2K6wBo92YdHo7FK941339QEz9NGZaK1nsRqezRk0DUCsLM5W/pZBOVzSEa0C571+6rgRhENzHdcEVVGkaLaWIB7PipOgfqPEdncaCfZHfpMniXvGwiGjK9claAPgWOK9y6yXlDWkVh+y4NoHU/VDQTeBpIzzGYmm4bdB334k5If3D/AUlFSl2G4VS3YnWnT8TBiU3oEsNzs2hrBkUKwcSlKLIOzmJIcdDFy6lUnLna9QDrgb6jG+vV4DnCFlcdTbNIHpMuGps7hyXo40xESSJPjWjaBLuHX4QcDe0k5PfpBqTLCDmV6bpz/lbGvB95mxoWWY+22BXB4A6hnNOFGFfdwbodtH62tHsJeqZqrXjIFpyHOBYhuOSVbBn6rH6giyeFC5afAxr3P18tOC1QB29VVKK8P19WZqxro7LlL285I0fwCkum7h5DTSWjvu/lSZPAF0fHHfzTUDtMoJVTOpnKbRhC2xiAy9ghf3F3uwRBVe8i3AYj4SvEx+3+ey+I+C4ifdFEfUFhazUNUQ7cZOXhW4897WA2R2di0XgLhVUyY=----ATTACHMENT:----OTU0NzYyNzE3NzA2Nzk1NCA5MTE5NDI3ODEwMzk0MDUgNzQxNTAzODcxMTE1MjMxNA==