<?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:----K2nNhvRjpQY7miOFCeAvS5Qr5VdyGPpjavE/pN1OeCH2Rx1bn8Q09xUpkjdeqdAzkD24t2a5PLA/FJA8k0qbPpOlhuh6aP3f6FqZBaEUcpJMINZ2cxeg2+ln6Pw6PcYeUhFzFwiVH7UO+k6bwrp4cnJafX6XGdA3/2c6B44t/CGA+lkU6+pzjBLhI8UqLoVPPzfYhNsBF3BoPXbSoG7TKpbZgdb3V1X4mFVx2xRz7KjnXkVujS6uxU+ORW3E4lODj8pIPBzHK+lF/K+eBIri3dY9ZtYP4NnUPYMFAu848nz3eGLCVDkYYqLUv6O+t1V13PMz03Uyxy17Ql/0miq3L1rrdkYE9fnsRyq+Db7E80IoonkL2R30xJ0XixvRMP4oc6qA8op5qYNEF5iodgAdpuBy3hRNT0zpF6EKSxwehTWxggDeE9cYalBACnwVPtV+GwOBglWkOEvC6upgkyPVXiv3R6Wk1oenqekRjQxg4cfabINYpL22LmskbWR0m/TqsOzZ4Lux0TlG6b34uchURZzdPK2ntCRZby3JsJcKL+fEMMN7tnrzZgC+gTv440adrzZdvKKvh5DSkEcrS6E0gR/TO+wgzE9SEOf+x5CiEi8o7tC8EBIO8q95mUBWcQ4fiC4zkC7Qmshabh+TtvPGaRFjJLkZyH+pTPw5AOwoHiI=----ATTACHMENT:----NzMwNjE3NzY3MDEzOTI1OSA4NTAxNDcwNTk1ODU0NjggNjYxMTQ1NTQ1MTA4NTUzMw==