RunsQueries::cursor() - Code Metrics - LaravelFreelancerNL/laravel-arangodb - Measure and Improve Code Quality continuously with Scrutinizer

RunsQueries::cursor() A
last analyzed 2025-05-12 04:25 UTC

↳ Parent: RunsQueries
Complexity

Conditions	3
Paths	1
Size

Total Lines	17
Code Lines	8
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	12
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
cc	3
eloc	8
c	1
b	0
f	0
nc	1
nop	3
dl	0
loc	17
ccs	0
cts	9
cp	0
crap	12
rs	10
<?php

declare(strict_types=1);

namespace LaravelFreelancerNL\Aranguent\Concerns;

use Closure;
use Exception;
use LaravelFreelancerNL\Aranguent\Exceptions\NoArangoClientException;
use LaravelFreelancerNL\Aranguent\Query\Builder as QueryBuilder;
use LaravelFreelancerNL\Aranguent\Exceptions\QueryException;
use LaravelFreelancerNL\FluentAQL\QueryBuilder as FluentAqlBuilder;
use stdClass;
use LaravelFreelancerNL\Aranguent\Exceptions\UniqueConstraintViolationException;

trait RunsQueries
{
    /**
     * Determine if the given database exception was caused by a unique constraint violation.
     *
     * @param  \Exception  $exception
     * @return bool
     */
    protected function isUniqueConstraintError(Exception $exception)
    {
        return boolval(preg_match('/409 - AQL: unique constraint violated/i', $exception->getMessage()));
    }

    /**
     * Run a select statement against the database and returns a generator.
     *
     * @param  string  $query
     * @param  array<mixed>  $bindings
     * @param  bool  $useReadPdo
     * @return \Generator
     * @SuppressWarnings("PHPMD.BooleanArgumentFlag")
     */
    public function cursor($query, $bindings = [], $useReadPdo = true)
    public function cursor($query, $bindings = [], /** @scrutinizer ignore-unused */ $useReadPdo = true)
    {

        // Usage of a separate DB to read date isn't supported at this time
        $useReadPdo = null;


        return $this->run($query, $bindings, function ($query, $bindings) {
            if ($this->pretending()) {
            if ($this->/** @scrutinizer ignore-call */ pretending()) {
                return [];
            }

            if ($this->arangoClient === null) {
                throw new NoArangoClientException();
            }
            $statement = $this->arangoClient->prepare($query, $bindings);

            return $statement->execute();
        });
    }

    /**
     * Execute an SQL statement and return the boolean result.
     *
     * @param  string  $query
     * @param  array<mixed>  $bindings
     * @return bool
     */
    public function statement($query, $bindings = [])
    {
        [$query, $bindings] = $this->handleQueryBuilder(
            $query,
            $bindings,
        );

        return $this->run($query, $bindings, function ($query, $bindings) {
            if ($this->pretending()) {
                return true;
            }

            if ($this->arangoClient === null) {
                throw new NoArangoClientException();
            }
            $statement = $this->arangoClient->prepare($query, $bindings);

            $statement->execute();

            $affectedDocumentCount = $statement->getWritesExecuted();

            $this->recordsHaveBeenModified($changed = $affectedDocumentCount > 0);
                   recordsHaveBeenModified($changed = $affectedDocumentCount > 0);

            return $changed;
        });
    }

    /**
     * Run an SQL statement and get the number of rows affected.
     *
     * @param  string  $query
     * @param  array<mixed>  $bindings
     * @return int
     */
    public function affectingStatement($query, $bindings = [])
    {
        [$query, $bindings] = $this->handleQueryBuilder(
            $query,
            $bindings,
        );

        return $this->run($query, $bindings, function () use ($query, $bindings) {
            if ($this->pretending()) {
                return 0;
            }

            if ($this->arangoClient === null) {
                throw new NoArangoClientException();
            }

            // For update or delete statements, we want to get the number of rows affected
            // by the statement and return that back to the developer. We'll first need
            // to execute the statement and get the executed writes from the extra.
            $statement = $this->arangoClient->prepare($query, $bindings);

            $statement->execute();

            $affectedDocumentCount = $statement->getWritesExecuted();

            $this->recordsHaveBeenModified($affectedDocumentCount > 0);

            return $affectedDocumentCount;
        });
    }

    /**
     * Run a raw, unprepared query against the connection.
     *
     * @param  string  $query
     */
    public function unprepared($query): bool
    {
        return $this->run($query, [], function ($query) {
            if ($this->pretending()) {
                return true;
            }

            $statement = $$this->arangoClient->prepare($query);
            $statement->execute();
            $affectedDocumentCount = $statement->getWritesExecuted();
            $change = $affectedDocumentCount > 0;

            $this->recordsHaveBeenModified($change);

            return $change;
        });
    }

    /**
     * Returns the query execution plan. The query will not be executed.
     *
     * @param  string  $query
     * @param  array<mixed>  $bindings
     */
    public function explain(string|FluentAqlBuilder $query, $bindings = []): stdClass
    {
        [$query, $bindings] = $this->handleQueryBuilder(
            $query,
            $bindings,
        );

        if ($this->arangoClient === null) {
            throw new NoArangoClientException();
        }
        $statement = $this->arangoClient->prepare($query, $bindings);

        return $statement->explain();
    }

    /**
     * @param FluentAqlBuilder|string|QueryBuilder $query
     * @param array<mixed> $bindings
     * @return array<mixed>
     */
    protected function handleQueryBuilder($query, array $bindings): array
    {

        if ($query instanceof FluentAqlBuilder) {
            $bindings = $query->binds;
            $query = $query->query;
        }

        if ($query instanceof QueryBuilder) {
            $bindings = $query->getBindings();
            $query = $query->toSql();
        }

        return [$query, $bindings];
    }

    /**
     * Run a select statement against the database.
     *
     * @SuppressWarnings("PHPMD.BooleanArgumentFlag")
     *
     * @param  string|FluentAqlBuilder  $query
     * @param  array<mixed>  $bindings
     * @param  bool  $useReadPdo
     * @return mixed
     */
    public function select($query, $bindings = [], $useReadPdo = true)
    {
        return $this->execute($query, $bindings, $useReadPdo);
    }

    /**
     * Run an AQL query against the database and return the results.
     *
     * @SuppressWarnings("PHPMD.BooleanArgumentFlag")
     *
     * @param  string|FluentAqlBuilder  $query
     * @param  array<mixed>  $bindings
     * @param  bool  $useReadPdo
     * @return mixed
     */
    public function execute($query, array $bindings = [], $useReadPdo = true)
    public function execute($query, array $bindings = [], /** @scrutinizer ignore-unused */ $useReadPdo = true)
    {
        // Usage of a separate DB to read date isn't supported at this time
        $useReadPdo = null;


        [$query, $bindings] = $this->handleQueryBuilder(
            $query,
            $bindings,
        );

        return $this->run($query, $bindings, function () use ($query, $bindings) {
            if ($this->pretending()) {
                return [];
            }

            if ($this->arangoClient === null) {
                throw new NoArangoClientException();
            }

            $statement = $this->arangoClient->prepare($query, $bindings);

            $statement->execute();

            return $statement->fetchAll();
        });
    }

    /**
     * Get a new query builder instance.
     */
    public function query(): QueryBuilder
    {
        return new QueryBuilder(
            $this,
            /** @scrutinizer ignore-type */ $this,
            $this->getQueryGrammar(),
                   getQueryGrammar(),
            $this->getPostProcessor(),
                   getPostProcessor(),
        );
    }

    /**
     * Run a SQL statement and log its execution context.
     *
     * @param  string  $query
     * @param  array<mixed>  $bindings
     * @return mixed
     *
     * @throws QueryException
     */
    protected function run($query, $bindings, Closure $callback)
    {
        foreach ($this->beforeExecutingCallbacks as $beforeExecutingCallback) {
            $beforeExecutingCallback($query, $bindings, $this);
        }

        $this->reconnectIfMissingConnection();
               reconnectIfMissingConnection();

        $start = microtime(true);

        // Here we will run this query. If an exception occurs we'll determine if it was
        // caused by a connection that has been lost. If that is the cause, we'll try
        // to re-establish connection and re-run the query with a fresh connection.
        try {
            $result = $this->runQueryCallback($query, $bindings, $callback);
        } catch (QueryException $e) {
            $result = $this->handleQueryException(
            $result = $this->handleQueryException(
                $e,
                $query,
                $bindings,
                $callback,
            );
        }

        // Once we have run the query we will calculate the time that it took to run and
        // then log the query, bindings, and execution time so we will report them on
        // the event that the developer needs them. We'll log time in milliseconds.
        $this->logQuery(
               logQuery(
            $query,
            $bindings,
            $this->getElapsedTime($start),
                   getElapsedTime($start),
        );

        return $result;
    }

    /**
     * Run a SQL statement.
     *
     * @param  string  $query
     * @param  array<mixed>  $bindings
     * @return mixed
     *
     * @throws QueryException
     */
    protected function runQueryCallback($query, $bindings, Closure $callback)
    {
        // To execute the statement, we'll simply call the callback, which will actually
        // run the SQL against the PDO connection. Then we can calculate the time it
        // took to execute and log the query SQL, bindings and time in our memory.
        try {
            return $callback($query, $bindings);
        } catch (Exception $e) {
            // If an exception occurs when attempting to run a query, we'll format the error
            // message to include the bindings with SQL, which will make this exception a
            // lot more helpful to the developer instead of just the database's errors.

            if ($this->isUniqueConstraintError($e)) {
                throw new UniqueConstraintViolationException(
                    (string) $this->getName(),
                    (string) $this->/** @scrutinizer ignore-call */ getName(),
                    $query,
                    $this->prepareBindings($bindings),
                           prepareBindings($bindings),
                    $e,
                );
            }

            throw new QueryException(
                (string) $this->getName(),
                $query,
                $this->prepareBindings($bindings),
                $e,
            );
        }
    }
}

LaravelFreelancerNL / laravel-arangodb

RunsQueries::cursor() A last analyzed 2025-05-12 04:25 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

RunsQueries::cursor() A
last analyzed 2025-05-12 04:25 UTC
