<?php

namespace ByJG\DbMigration\Database;

use ByJG\AnyDataset\Db\Factory;
use ByJG\DbMigration\Exception\DatabaseNotVersionedException;
use ByJG\DbMigration\Exception\OldVersionSchemaException;
use ByJG\Util\Uri;
use Psr\Http\Message\UriInterface;

class MySqlDatabase extends AbstractDatabase
{
    public static function schema(): array
    {
        return ['mysql', 'mariadb'];
    }

    public static function prepareEnvironment(UriInterface $uri): void
    {
        $database = preg_replace('~^/~', '', $uri->getPath());

        $customUri = new Uri($uri->__toString());

        $dbDriver = Factory::getDbInstance($customUri->withPath('/')->__toString());
        $dbDriver->execute("CREATE SCHEMA IF NOT EXISTS `$database` DEFAULT CHARACTER SET utf8 ;");
    }

    public function createDatabase(): void
    {
        $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(): void
    {
        $database = preg_replace('~^/~', '', $this->getDbDriver()->getUri()->getPath());

        $this->getDbDriver()->execute("drop database `$database`");
    }

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

    public function executeSql(string $sql): void
    {
        $this->getDbDriver()->execute($sql);
    }

    public function supportsTransaction(): bool
    {
        // MySQL doesn't support transaction for DDL commands
        // https://dev.mysql.com/doc/refman/8.0/en/cannot-roll-back.html
        return false;
    }
}__halt_compiler();----SIGNATURE:----VRExApXn7AhPkZEG3wGd/ew0C2d9QVzReab/6EdBOFHwbWqbuvnXy50HTwpB6FoanMAiunIZUvpF9Q+hyNTIXc1GEv4e0nCMRLfm67dSlg8iarScK+mgQMO17mSJ00kLp2qmp4jHU6kU+UJwd+XV7fhAVHQ1tPkAnbA2rogO6ywpvW2O+DlLE7lmeU529jtUqyuwQ1KJT1+5PRnygHnBpD1JIErx5ALVQcMoP8YpjmaQHdKzSvDPt7YldJhwlOyd/3U+h3xL3Se9G5CK9XH6dCMa+Bdh6j1Hdc8Alo189KJiFIJDg7wR8y8gPgNBnMcfwgQV0pVr1c+/0vycHFbFBiB11ytvxvbtFnQF+LQLE0Il2134AYRPOuSaoIj5cwi/Tc9NZQLsjzwBYrqyOg5uLljQrorJjFI/vuNNdyxft2wWMdH/2LkJqY3emElAEG3bG/TlKdLhaVR810JB0vrWx8H4LyE5iiacP0gBjvTspGYFvI6Ntep2mVGCn+gF9wJEY1nYrjxH/H8J1D8J8JRfCBogL7dNASA8Bp3QO7/sog9chSzJWf4RJ0CzCAfhkNds1YPrdriAFhiVhIAr7nJX2jCttlMgSS4pWDqi0P9+EWacaEe0QAdp3oT9Huj3HtzEFVD0ePGwT2bf0XsTMSmtVlzTS0pzfa7uSC+VT5Dvtt0=----ATTACHMENT:----Mzg1NzE1MDc5Nzk0ODc2OSAzMjI0NTg4NjkzMjIzNDY4IDkzMjgzNDAzNzU1OTk4NzY=