JsonStatement.php

<?php

declare(strict_types=1);

namespace Tempest\Database\QueryStatements;

use Tempest\Database\Config\DatabaseDialect;
use Tempest\Database\Exceptions\DefaultValueWasInvalid;
use Tempest\Database\QueryStatement;

final readonly class JsonStatement implements QueryStatement
{
    public function __construct(
        private string $name,
        private bool $nullable = false,
        private ?string $default = null,
    ) {}

    public function compile(DatabaseDialect $dialect): string
    {
        if ($this->default && json_validate($this->default) === false) {
            throw new DefaultValueWasInvalid($this->name, $this->default);
        }

        $name = $dialect->quoteIdentifier($this->name);

        return match ($dialect) {
            DatabaseDialect::MYSQL => sprintf(
                '%s JSON %s',
                $name,
                $this->nullable ? '' : 'NOT NULL',
            ),
            DatabaseDialect::SQLITE => sprintf(
                '%s TEXT %s %s',
                $name,
                $this->default !== null ? "DEFAULT '{$this->default}'" : '',
                $this->nullable ? '' : 'NOT NULL',
            ),
            DatabaseDialect::POSTGRESQL => sprintf(
                '%s JSONB %s %s',
                $name,
                $this->default !== null ? "DEFAULT ('{$this->default}')" : '',
                $this->nullable ? '' : 'NOT NULL',
            ),
        };
    }
}