SamAsEnd\QueryDiagnosis\QueryDiagnosisImpl

Complexity

Total Complexity

14

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Test Coverage

Coverage

94.59%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	boot()	0	15	3
A	shouldBeDiagnosed()	0	4	2
A	preventFullDatabaseScanQueries()	0	3	1
A	diagnoseQuery()	0	15	4
A	preventFullIndexScanQueries()	0	3	1
A	customQueryDiagnosis()	0	5	1
A	__construct()	0	6	1
A	preventUnionSelectTypes()	0	3	1

<?php

namespace SamAsEnd\QueryDiagnosis;

use Illuminate\Database\Events\QueryExecuted;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;
use SamAsEnd\QueryDiagnosis\Enums\JoinType;
use SamAsEnd\QueryDiagnosis\Exceptions\UnsupportedDatabaseDriverException;
use SamAsEnd\QueryDiagnosis\Strategies\JoinTypeQueryDiagnosis;
use SamAsEnd\QueryDiagnosis\Strategies\QueryDiagnosisContract;
use SamAsEnd\QueryDiagnosis\Strategies\SelectTypeContainsQueryDiagnosis;

class QueryDiagnosisImpl
{
    private const SELECT = 'select ';

    private const EXPLAIN = 'explain ';

    private const UNION = 'UNION';

    protected readonly Collection $queryDiagnoses;

    protected readonly Collection $queriesCache;

    protected bool $booted = false;

    public function __construct()
    {
        $this->queryDiagnoses = Collection::make();

The property queryDiagnoses is declared read-only in SamAsEnd\QueryDiagnosis\QueryDiagnosisImpl.

        $this->queriesCache = Collection::make();

The property queriesCache is declared read-only in SamAsEnd\QueryDiagnosis\QueryDiagnosisImpl.

        $this->booted = false;
    }

    public function preventUnionSelectTypes(): void
    {
        $this->customQueryDiagnosis(new SelectTypeContainsQueryDiagnosis(self::UNION));
    }

    public function preventFullDatabaseScanQueries(): void
    {
        $this->customQueryDiagnosis(new JoinTypeQueryDiagnosis(JoinType::ALL));
    }

    public function preventFullIndexScanQueries(): void
    {
        $this->customQueryDiagnosis(new JoinTypeQueryDiagnosis(JoinType::INDEX));
    }

    public function customQueryDiagnosis(QueryDiagnosisContract $queryDiagnosis): void
    {
        $this->boot();

        $this->queryDiagnoses->push($queryDiagnosis);
    }

    protected function boot(): void
    {
        if (! $this->booted) {
            $this->booted = true;

            DB::listen(function (QueryExecuted $executedQuery) {
                $query = Str::of($executedQuery->sql)
                    ->lower()
                    ->trim('()') // laravel sometime group the queries as (select...)
                    ->trim()
                    ->value();

                if (static::shouldBeDiagnosed($query)) {

The method SamAsEnd\QueryDiagnosis\QueryDiagnosisImpl::shouldBeDiagnosed() is not static, but was called statically.

                    $this->queriesCache->push($query);

$query of type string is incompatible with the type Illuminate\Support\TValue expected by parameter $values of Illuminate\Support\Collection::push().

                    static::diagnoseQuery($executedQuery);

The method SamAsEnd\QueryDiagnosis\QueryDiagnosisImpl::diagnoseQuery() is not static, but was called statically.

                }
            });
        }
    }

    protected function shouldBeDiagnosed(string $query): bool
    {
        return Str::startsWith($query, static::SELECT)
            && $this->queriesCache->doesntContain($query);
    }

    protected function diagnoseQuery(QueryExecuted $queryExecuted): void
    {
        if ('mysql' !== ($driver = $queryExecuted->connection->getDriverName())) {
            throw new UnsupportedDatabaseDriverException($driver);
        }

        $explainResults = collect($queryExecuted->connection->select(

$queryExecuted->connection->select(self::EXPLAIN . $queryExecuted->sql, $queryExecuted->bindings) of type array is incompatible with the type Illuminate\Contracts\Support\Arrayable expected by parameter $value of collect().

            self::EXPLAIN.$queryExecuted->sql,
            $queryExecuted->bindings
        ));

        /** @var QueryDiagnosisContract $queryDiagnosis */
        foreach ($this->queryDiagnoses as $queryDiagnosis) {
            if ($queryDiagnosis->match($queryExecuted, $explainResults)) {
                $queryDiagnosis->report($queryExecuted, $explainResults);
            }
        }
    }
}