mheinzerling/php-databaseutils

<?php
declare(strict_types = 1);

namespace mheinzerling\commons\database\structure\builder;


use mheinzerling\commons\database\DatabaseUtils;
use mheinzerling\commons\database\structure\Database;
use mheinzerling\commons\database\structure\Table;
use mheinzerling\commons\StringUtils;

class DatabaseBuilder
{
    /**
     * @var Database
     */
    private $database;
    /**
     * @var string|null
     */
    private $defaultEngine;
    /**
     * @var string|null
     */
    private $defaultCharset;
    /**
     * @var string|null
     */
    private $defaultCollation;

    public function __construct(string $name)
    {
        $this->database = new Database($name);
    }

    public function build(): Database
    {
        $this->database->resolveLazyIndexes();
        return $this->database;
    }

    public function table(string $name): TableBuilder
    {
        return new TableBuilder($this, $name);
    }

    public function defaultEngine(string $defaultEngine): DatabaseBuilder
    {
        $this->defaultEngine = $defaultEngine;
        return $this;
    }

    public function defaultCharset(string $defaultCharset): DatabaseBuilder
    {
        $this->defaultCharset = $defaultCharset;
        return $this;
    }

    public function defaultCollation(string $defaultCollation): DatabaseBuilder
    {
        $this->defaultCollation = $defaultCollation;
        return $this;
    }


    public function getName(): string
    {
        return $this->database->getName();
    }


    public function getDefaultEngine():?string
    {
        return $this->defaultEngine;
    }

    public function getDefaultCharset():?string
    {
        return $this->defaultCharset;
    }

    public function getDefaultCollation():?string
    {
        return $this->defaultCollation;
    }

    public function addTable(Table $table): void
    {
        $this->database->addTable($table);
    }


    /**
     * @param \PDO $pdo
     * @param string[] $booleanFields
     * @return Database
     */
    public static function fromDatabase(\PDO $pdo, array $booleanFields = []): Database
    {
        $dbName = $pdo->query("SELECT DATABASE();")->fetchColumn();
        $db = new DatabaseBuilder($dbName);
        $tables = DatabaseUtils::exec($pdo, 'SELECT * FROM information_schema.TABLES WHERE TABLE_SCHEMA=?', [$dbName]);
        /** @noinspection PhpAssignmentInConditionInspection */
        while ($table = $tables->fetch(\PDO::FETCH_ASSOC)) {
            TableBuilder::fromDatabase($pdo, $db, $table['TABLE_NAME'], $table['ENGINE'], $table['TABLE_COLLATION'], $table['AUTO_INCREMENT'], $booleanFields);
        }
        return $db->build();
    }

    public static function fromSql(string $sql): Database
    {
        $db = new DatabaseBuilder(""); //TODO parse create database / use
        $queries = StringUtils::trimExplode(';', $sql); // TODO more stable
        foreach ($queries as $createStatement) {
            if (StringUtils::startsWith($createStatement, "CREATE TABLE")) {
                TableBuilder::fromSqlCreate($db, $createStatement);
            }
            //TODO ALTER statements
        }
        return $db->build();
    }


}