<?php

namespace ByJG\DbMigration\Database;

use ByJG\AnyDataset\Db\Factory;
use ByJG\Util\Uri;
use Psr\Http\Message\UriInterface;

class PgsqlDatabase extends AbstractDatabase
{
    public static function prepareEnvironment(UriInterface $uri)
    {
        $database = preg_replace('~^/~', '', $uri->getPath());
        $dbDriver = static::getDbDriverWithoutDatabase($uri);
        static::createDatabaseIfNotExists($dbDriver, $database);
    }

    protected static function getDbDriverWithoutDatabase(UriInterface $uri)
    {
        $customUri = new Uri($uri->__toString());
        return Factory::getDbRelationalInstance($customUri->withPath('/postgres')->__toString());
    }

    /**
     * @param \ByJG\AnyDataset\Db\DbDriverInterface $dbDriver
     * @param $database
     */
    protected static function createDatabaseIfNotExists($dbDriver, $database)
    {
        $currentDbName = $dbDriver->getScalar(
            "SELECT datname FROM pg_catalog.pg_database WHERE lower(datname) = lower(:dbname)",
            ['dbname' => $database]
        );

        if (empty($currentDbName)) {
            $dbDriver->execute("CREATE DATABASE $database WITH encoding=\"UTF8\";");
        }
    }

    public function createDatabase()
    {
        $database = preg_replace('~^/~', '', $this->getDbDriver()->getUri()->getPath());
        static::createDatabaseIfNotExists($this->getDbDriver(), $database);
    }

    public function dropDatabase()
    {
        $iterator = $this->getDbDriver()->getIterator(
            "select 'drop table if exists \"' || tablename || '\" cascade;' command from pg_tables where schemaname = 'public';"
        );
        foreach ($iterator as $singleRow) {
            $this->getDbDriver()->execute($singleRow->get('command'));
        }
    }

    /**
     * @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)
    {
        $statements = preg_split("/;(\r\n|\r|\n)/", $sql);

        foreach ($statements as $sql) {
            $this->executeSqlInternal($sql);
        }
    }

    protected function executeSqlInternal($sql)
    {
        if (empty(trim($sql))) {
            return;
        }
        $this->getDbDriver()->execute($sql);
    }

    public function isDatabaseVersioned()
    {
        return $this->isTableExists('public', $this->getMigrationTable());
    }
}
__halt_compiler();----SIGNATURE:----GmnN5kbZ1lgoUKzwiaVJ4F6qcSbfZUtkJ/9F+JIB50I5CDnDibIGThpR12pqYHmd8uMVJ8hjl0qn1ofhArk1bpB5BOCr2oEfQF1undtgaJAZ5ECvh4NZZlCt5qKKYI/0AyKwP04hqJG4Nb+JabZMzpuGg/VN07GZGUEM2GwTUjhq2yfoSb9Anmaiaiomxz+YjKyXWG0J9unieLq5BqpazmSXHPJKI+kfUFnjBEWVU76oEJHqt4ohvK7PwgvmjqpNRfrH5SbH1QRAu5Uo8lnZwkCT4XrEa/DTSx8NDbtdWI9cVXpno0gqA5uVwbh7QDfe17LmFoHRqx6ukD6BdkvtTzFZrEa98jp/n95umkU5YEHuqbsXVgkX1EK7rrkUXGSWo3jMjQ3i7rvX5cTOpkMx+kWKLGC4GOuOae/QsbFQcLP5jfX+tWS/7emYfafc0cQGTh8Z0zcCA+Yf0ukPnCMqAsq7/r1PaT+9j9IiOBZAFSnC3klAAybdeGEIOgbT5zGLHwtJfy8m/wWmzkX+pY5hWhQ3HQC4yVcd/LondVFEYczy7B19hqxfkXHPsvL+Eo7y9MaMTISaE373hgk+4Cx0N5yX4DAii6SC+Hk1p6rMqI4hI9hS9tWxLm2uEOE8O/y+KIe7e4XcNaUE9hhf0ywB6+/M7X1aQdStAdrujKiSzos=----ATTACHMENT:----NDAyNzU3MzYxNzkxNzY4OSA1NTQ4ODY5Mzc4MDM1OTY5IDg2MjU0OTc5MDE0OTEzNjE=