MichaelRubel\SqlFunctionRepository\Repositories\PostgresqlFunctionRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

26.32%

Importance

Changes	3
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	3
A	buildSqlFunction()	0	14	2
A	runDatabaseFunction()	0	5	1

<?php

declare(strict_types=1);

namespace MichaelRubel\SqlFunctionRepository\Repositories;

use Illuminate\Support\Facades\DB;
use MichaelRubel\SqlFunctionRepository\SqlFunctionRepository;

class PostgresqlFunctionRepository implements SqlFunctionRepository
{
    /**
     * @param string|null $connection
     * @param string|null $select
     */
    public function __construct(
        public ?string $connection = null,
        public ?string $select = null,
    ) {
        if (is_null($this->connection)) {
            $this->connection = config('sql-function-repository.connection', DB::getDefaultConnection());
        }

        if (is_null($this->select)) {
            $this->select = config('sql-function-repository.select', 'select * from ');
        }
    }

    /**
     * Execute the database function.
     *
     * @param string $name
     * @param array  $parameters
     * @param string $as
     *
     * @return array
     */
    public function runDatabaseFunction(string $name, array $parameters = [], string $as = ''): array
    {
        return DB::connection($this->connection)->select(
            $this->buildSqlFunction($name, $parameters, $as),
            $parameters
        );
    }

    /**
     * @param string $name
     * @param array  $parameters
     * @param string $as
     *
     * @return string
     */
    protected function buildSqlFunction(string $name, array $parameters, string $as): string
    {
        $prepareForBindings = collect($parameters)->implode(fn () => '?, ');

$parameters of type array is incompatible with the type Illuminate\Contracts\Support\Arrayable expected by parameter $value of collect().

        $function = str($prepareForBindings)
            ->replaceLast(', ', '')
            ->start('(')
            ->finish(')');

        if (! empty($as)) {
            $function = $function->finish(' as ' . $as);
        }

        return $this->select . $name . $function;
    }
}