<?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:----F4PESy6jQpnrfQhkwRetWZXKNpyb0LsFbxQRRlSPI/ZxuY7AoeIR8yvgd73J6iFTfPk1YLX3AqirHrkc77cO6aqFq3v9QI54YP9XdAWT/pND3AUukuy+at9uE/PUQbbBpt/QCMdvlK1CsR1PcxCUcakvXkHCfLCDzvsG/c62aIJKZSKWfR0E7rgQK1wJ3Cn4xJdNkEQYUzrVOEAycMS89DALNGRWluPHxQ/9QwiwKkLtRYO7q7OosxidljIvbtm85gQN+oRRiOnI00so6tQK+7QBwk4PJhPXPASikBvNlRGnfkTBN1unKxCbTsyR09Bs6XJa8u2pFQ/QUHaKr7p9Fy0EfbnH8Kzg+5Le4JO30AsxR/CofSmoYtOG0iB8Cb8TMalh9XgTliHhVAZNPu2qcP7fkLxsua25+tfjRJSevtQeoq33OMhE2tIIGbNsB+Z4YjxtJuv6C1TZN7nsw5BYajSDbHJTU3LWKE8y6qVYUwfgwj287nMAxXv/cjn+0sGdIrdEa9cfCRG7e7S0tRrEWKhVWdfMymNVRhfQgkmcFidiC7ZQRPLgC0VLojjFZhhCI26f9h26cY3V4cbyEJLd2NSKRh1x6BR02hvDNROGPLY/F3+qgR/A/De+U6bS6X0nU9IWr122b1ctIxOWVVSPMWP4V7neCB4NnzwzRud8A5M=----ATTACHMENT:----OTIxMTczMjIyODQ5NTk5MyA0NzI0ODc4NzMwNDgyNzcgNzA1MzQyMjI1MTc4OTM3OQ==