MultiResult::add() - Code Metrics - b2pweb/bdf-prime - Measure and Improve Code Quality continuously with Scrutinizer

MultiResult::add() A
last analyzed 2023-02-02 15:35 UTC

↳ Parent: MultiResult

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	1
dl	0
loc	3
ccs	2
cts	2
cp	1
rs	10
c	1
b	0
f	0
cc	1
nc	1
nop	1
crap	1

<?php

namespace Bdf\Prime\Sharding;

use ArrayIterator;
use Doctrine\DBAL\Driver\Result as DriverResult;
use Doctrine\DBAL\Result;
use IteratorAggregate;

/**
 * Aggregation of query results
 * This class handle results of multiple shards query
 */
final class MultiResult implements IteratorAggregate, DriverResult
{
    /**
     * @var list<Result>
filter:
    dependency_paths: ["lib/*"]
     */
    private array $results;

    /**
     * @var int
     */
    private int $current = 0;

    /**
     * @param list<Result> $results The connection query Result instances
     */
    public function __construct(array $results = [])
    {
        $this->results = $results;

    }

    /**
     * Add a query Result into the sharding result
     */
    public function add(Result $result): void
    {
        $this->results[] = $result;
    }

    /**
     * {@inheritdoc}
     */
    public function free(): void
    {
        foreach ($this->results as $result) {
            $result->free();
        }

        unset($this->results);
    }

    /**
     * {@inheritdoc}
     */
    public function columnCount(): int
    {
        if (!isset($this->results[0])) {
            return 0;
        }

        return $this->results[0]->columnCount();
    }

    /**
     * {@inheritdoc}
     */
    public function getIterator(): \Iterator
    {
        return new ArrayIterator($this->fetchAllAssociative());
    }

    /**
     * {@inheritdoc}
     */
    public function fetchNumeric()
    {
        return $this->fetch(__FUNCTION__);

    }

    /**
     * {@inheritdoc}
     */
    public function fetchAssociative()
    {
        return $this->fetch(__FUNCTION__);
    }

    /**
     * {@inheritdoc}
     */
    public function fetchOne()
    {
        return $this->fetch(__FUNCTION__);
    }

    /**
     * {@inheritdoc}
     */
    public function fetchAllNumeric(): array
    {
        return $this->fetchAll(__FUNCTION__);

    }

    /**
     * {@inheritdoc}
     */
    public function fetchAllAssociative(): array
    {
        return $this->fetchAll(__FUNCTION__);

    }

    /**
     * {@inheritdoc}
     */
    public function fetchFirstColumn(): array
    {
        return $this->fetchAll(__FUNCTION__);

    }

    /**
     * {@inheritdoc}
     */
    public function rowCount(): int
    {
        $count = 0;

        foreach ($this->results as $statement) {
            $count += $statement->rowCount();
        }

        return $count;
    }

    /**
     * @param string $method
     *
     * @return false|mixed False if there is no more results, or the current row value
     */
    private function fetch(string $method)
    {
        for (;; ++$this->current) {
            // Stop the fetch if there is no statement
            if (!isset($this->results[$this->current])) {
                return false;
            }

            $result = $this->results[$this->current]->$method();

            if ($result) {
                return $result;
            }
        }
    }

    /**
     * @param string $method
     * @return list<mixed>
     */
    private function fetchAll(string $method)
    {
        $result = [];

        foreach ($this->results as $statement) {
            $result = array_merge($result, $statement->$method());
        }

        return $result;

    }
}


1		<?php
2
3		namespace Bdf\Prime\Sharding;
4
5		use ArrayIterator;
6		use Doctrine\DBAL\Driver\Result as DriverResult;
7		use Doctrine\DBAL\Result;
8		use IteratorAggregate;
9
10		/**
11		* Aggregation of query results
12		* This class handle results of multiple shards query
13		*/
14		final class MultiResult implements IteratorAggregate, DriverResult
15		{
16		/**
17		* @var list<Result>
		0 ignored issues – show Bug introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report The type `Bdf\Prime\Sharding\list` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
18		*/
19		private array $results;
20
21		/**
22		* @var int
23		*/
24		private int $current = 0;
25
26		/**
27		* @param list<Result> $results The connection query Result instances
28		*/
29	90	public function __construct(array $results = [])
30		{
31	90	$this->results = $results;
		0 ignored issues – show Documentation Bug introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report It seems like `$results` of type `array` is incompatible with the declared type `Bdf\Prime\Sharding\list` of property `$results`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
32		}
33
34		/**
35		* Add a query Result into the sharding result
36		*/
37	84	public function add(Result $result): void
38		{
39	84	$this->results[] = $result;
40		}
41
42		/**
43		* {@inheritdoc}
44		*/
45	17	public function free(): void
46		{
47	17	foreach ($this->results as $result) {
48	17	$result->free();
49		}
50
51	17	unset($this->results);
52		}
53
54		/**
55		* {@inheritdoc}
56		*/
57	3	public function columnCount(): int
58		{
59	3	if (!isset($this->results[0])) {
60	1	return 0;
61		}
62
63	2	return $this->results[0]->columnCount();
64		}
65
66		/**
67		* {@inheritdoc}
68		*/
69	3	public function getIterator(): \Iterator
70		{
71	3	return new ArrayIterator($this->fetchAllAssociative());
72		}
73
74		/**
75		* {@inheritdoc}
76		*/
77	3	public function fetchNumeric()
78		{
79	3	return $this->fetch(__FUNCTION__);
		0 ignored issues – show Bug Best Practice introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report The expression `return $this->fetch(__FUNCTION__)` also could return the type `false` which is incompatible with the return type mandated by `Doctrine\DBAL\Driver\Result::fetchNumeric()` of `Doctrine\DBAL\Driver\list`. Loading history...
80		}
81
82		/**
83		* {@inheritdoc}
84		*/
85	12	public function fetchAssociative()
86		{
87	12	return $this->fetch(__FUNCTION__);
88		}
89
90		/**
91		* {@inheritdoc}
92		*/
93	3	public function fetchOne()
94		{
95	3	return $this->fetch(__FUNCTION__);
96		}
97
98		/**
99		* {@inheritdoc}
100		*/
101	3	public function fetchAllNumeric(): array
102		{
103	3	return $this->fetchAll(__FUNCTION__);
		0 ignored issues – show Bug Best Practice introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report The expression `return $this->fetchAll(__FUNCTION__)` returns the type `Bdf\Prime\Sharding\list` which is incompatible with the type-hinted return `array`. Loading history...
104		}
105
106		/**
107		* {@inheritdoc}
108		*/
109	84	public function fetchAllAssociative(): array
110		{
111	84	return $this->fetchAll(__FUNCTION__);
		0 ignored issues – show Bug Best Practice introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report The expression `return $this->fetchAll(__FUNCTION__)` returns the type `Bdf\Prime\Sharding\list` which is incompatible with the type-hinted return `array`. Loading history...
112		}
113
114		/**
115		* {@inheritdoc}
116		*/
117	4	public function fetchFirstColumn(): array
118		{
119	4	return $this->fetchAll(__FUNCTION__);
		0 ignored issues – show Bug Best Practice introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report The expression `return $this->fetchAll(__FUNCTION__)` returns the type `Bdf\Prime\Sharding\list` which is incompatible with the type-hinted return `array`. Loading history...
120		}
121
122		/**
123		* {@inheritdoc}
124		*/
125	3	public function rowCount(): int
126		{
127	3	$count = 0;
128
129	3	foreach ($this->results as $statement) {
130	2	$count += $statement->rowCount();
131		}
132
133	3	return $count;
134		}
135
136		/**
137		* @param string $method
138		*
139		* @return false\|mixed False if there is no more results, or the current row value
140		*/
141	12	private function fetch(string $method)
142		{
143	12	for (;; ++$this->current) {
144		// Stop the fetch if there is no statement
145	12	if (!isset($this->results[$this->current])) {
146	12	return false;
147		}
148
149	11	$result = $this->results[$this->current]->$method();
150
151	11	if ($result) {
152	11	return $result;
153		}
154		}
155		}
156
157		/**
158		* @param string $method
159		* @return list<mixed>
160		*/
161	88	private function fetchAll(string $method)
162		{
163	88	$result = [];
164
165	88	foreach ($this->results as $statement) {
166	87	$result = array_merge($result, $statement->$method());
167		}
168
169	88	return $result;
		0 ignored issues – show Bug Best Practice introduced 2022-05-16 10:34 UTC by Report Bug Copy Issue Report The expression `return $result` returns the type `array` which is incompatible with the documented return type `Bdf\Prime\Sharding\list`. Loading history...
170		}
171		}
172

b2pweb / bdf-prime

MultiResult::add() A last analyzed 2023-02-02 15:35 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MultiResult::add() A
last analyzed 2023-02-02 15:35 UTC