<?php

namespace ByJG\DbMigration\Database;

use Psr\Http\Message\UriInterface;

class SqliteDatabase extends AbstractDatabase
{
    public static function prepareEnvironment(UriInterface $uri)
    {
    }

    public function createDatabase()
    {
    }

    public function dropDatabase()
    {
        $iterator = $this->getDbDriver()->getIterator("\n            select \n                'drop ' || type || ' ' || name || ';' as command \n            from sqlite_master \n            where name <> 'sqlite_sequence' and name not like 'sqlite_autoindex_%'\n            order by CASE type\n                         WHEN 'index' THEN 0\n                         WHEN 'trigger' THEN 1\n                         WHEN 'view' THEN 2\n                         ELSE 99\n                    END;\n        ");

        foreach ($iterator as $row) {
            $this->getDbDriver()->execute($row->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);
    }

    protected function isTableExists($schema, $table)
    {
        $count = $this->getDbDriver()->getScalar(
            "SELECT count(*) FROM sqlite_master WHERE type='table' AND name=[[table]]",
            [
                "table" => $table
            ]
        );

        return (intval($count) !== 0);
    }

    public function isDatabaseVersioned()
    {
        return $this->isTableExists(null, $this->getMigrationTable());
    }
}
__halt_compiler();----SIGNATURE:----rnO5Ehwlojac4oxfB4NYk3mmtSKp6R+JknAwn0icHCONdVDntxrTPzYuHCnd3lsxL54oaXnb0XkKusUNDJN0zPxV9yLZLX/zZPEH83hXT1tqpniiTsRfE72Zl09wuGoMk1o0zmn/GX+CYzM9uqC1D+pJF5r87vRFJtfVozkn4IgT3yboAmU7UlC5lzU3ugGBDRhxKkk9OMIbUnK6uloR+CPrJzren6hZGmX3l9RNCFS//r4Ck/f3tBw3DZVkDqw7wK44lBExzboxtJFxA5k5lpajtWzR1EkMYxOCpTNa0SqDYLvJ6hVyotgswwcqol0C33IJEVtvyb7xcWQZHAmEQABuQaOEHuxpNqoArEMI9OfIxrLxHkY7xn7iZiDPSM0GSNXZ5tXzwzOsWpUO6sKROBYzI2eRpdZiSLNeJetBCF7vRV5myjSoSpjFI4ihhT2nLZnxnda1Zq65FF+1GbQQ5VziIjQqXZ9fGszpxgeW6KImxq24VQMBeMOXOpQIccXwVBIxh+SWjqeR/ZdDdG0RZIOxnfrAKPPJ2MDi5ypVYKRdQCDOl2Y5C2zGnAk7jDWm2L9UXVbV9EufGh8+/dIeoJMBGHbfVKt7An833tmUl5xWY49C7FY9eowCn//f80/XPyVndNO8BdZUZ+FI7YCwO/Dnx0EZaPG1ZIAtHdfuglY=----ATTACHMENT:----ODI2NzA3ODgzOTU0MzM1MyAxODAxMTk1NTQyMTIwMTc0IDY0Mzg4Nzg1ODk2OTk4Mzc=