LibsqlSchemaBuilder.php

<?php

declare(strict_types=1);

namespace Libsql\Laravel\Database;

use Illuminate\Database\QueryException;
use Illuminate\Support\Arr;
use Illuminate\Support\Str;
use Illuminate\Database\Query\Expression;
use Illuminate\Database\Schema\SQLiteBuilder;
use Libsql\Laravel\Exceptions\FeatureNotSupportedException;

class LibsqlSchemaBuilder extends SQLiteBuilder
{
    public function __construct(protected LibsqlDatabase $db, \Illuminate\Database\Connection $connection)
    {
        parent::__construct($connection);
    }

    public function createDatabase($name)
    {
        throw new FeatureNotSupportedException('Creating database is not supported in LibSQL database.');
    }

    public function dropDatabaseIfExists($name)
    {
        throw new FeatureNotSupportedException('Dropping database is not supported in LibSQL database.');
    }

    protected function dropAllIndexes(): void
    {
        $statement = $this->db->prepare($this->grammar()->compileDropAllIndexes());
        $results = $statement->query();

        collect($results)->each(function (array $query) {
            $query = array_values($query)[0];
            $this->db->query($query);
        });
    }

    public function dropAllTables(): void
    {
        $this->dropAllTriggers();
        $this->dropAllIndexes();

        $this->db->exec($this->grammar()->compileDisableForeignKeyConstraints());

        $statement = $this->db->prepare($this->grammar()->compileDropAllTables());
        $results = $statement->query();

        collect($results)->each(function (array $query) {
            $query = array_values($query)[0];
            $this->db->query($query);
        });

        $this->db->exec($this->grammar()->compileEnableForeignKeyConstraints());
    }

    protected function dropAllTriggers(): void
    {
        $statement = $this->db->prepare($this->grammar()->compileDropAllTriggers());
        $results = $statement->query();

        collect($results)->each(function (array $query) {
            $query = array_values($query)[0];
            $this->db->query($query);
        });
    }

    public function dropAllViews(): void
    {
        $statement = $this->db->prepare($this->grammar()->compileDropAllViews());
        $results = $statement->query();

        collect($results)->each(function (array $query) {
            $query = array_values($query)[0];
            $this->db->query($query);
        });
    }

    public function getColumns($table)
    {
        $table = $this->connection->getTablePrefix() . $table;

        $data = $this->connection->select("PRAGMA table_xinfo('{$table}')");

        $columns = $this->connection->selectOne("SELECT sql FROM sqlite_master WHERE type='table' AND name='{$table}'");

        $pattern = '/(?:\(|,)\s*[\'"`]?([a-zA-Z_][a-zA-Z0-9_]*)[\'"`]?\s+[a-zA-Z]+/i';
        preg_match_all($pattern, $columns->sql, $matches);
        $columnMatches = $matches[1] ?? [];

        $delctypes = stdClassToArray($data);
        foreach ($delctypes as $key => $value) {

            if (isset($delctypes[$key]['name'])) {
                $delctypes[$key]['name'] = $columnMatches[$key];
            }

            if (isset($delctypes[$key]['type'])) {
                $type = strtolower($delctypes[$key]['type']);
                $delctypes[$key]['type'] = $type;
                $delctypes[$key]['type_name'] = $type;
            }

            if (isset($delctypes[$key]['notnull'])) {
                $delctypes[$key]['nullable'] = $delctypes[$key]['notnull'] == 1 ? false : true;
            }

            if (isset($delctypes[$key]['dflt_value'])) {
                $delctypes[$key]['default'] = $delctypes[$key]['dflt_value'] == 'NULL' ? null : new Expression(Str::wrap($delctypes[$key]['dflt_value'], '(', ')'));
            }

            if (isset($delctypes[$key]['pk'])) {
                $delctypes[$key]['auto_increment'] = $delctypes[$key]['pk'] == 1 ? true : false;
            }

            $delctypes[$key]['collation'] = null;
            $delctypes[$key]['comment'] = null;
            $delctypes[$key]['generation'] = null;
        }

        $keyOrder = ['name', 'type_name', 'type', 'collation', 'nullable', 'default', 'auto_increment', 'comment', 'generation', 'pk', 'notnull', 'dflt_value', 'cid', 'hidden'];
        $delctypes = reorderArrayKeys($delctypes, $keyOrder);

        return $delctypes;
    }

    protected function grammar(): LibsqlSchemaGrammar
    {
        return new LibsqlSchemaGrammar($this->connection);
    }
}