ByJG\DbMigration\Database\SqliteDatabase

Complexity

Total Complexity

10

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	prepareEnvironment()	0	3	1
A	createDatabase()	0	3	1
A	dropDatabase()	0	14	2
A	createVersion()	0	5	1
A	executeSql()	0	8	2
A	executeSqlInternal()	0	4	1
A	isTableExists()	0	11	1
A	isDatabaseVersioned()	0	4	1

<?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("
            select 
                'drop table ' || name || ';' as command 
            from sqlite_master 
            where type = 'table' 
              and name <> 'sqlite_sequence';
        ");

        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))');
        $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)
    {
        $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());
    }
}