QueryExecutor - Code Metrics - mariusbalcytis/database-inconsistency-finder - Measure and Improve Code Quality continuously with Scrutinizer

QueryExecutor A
last analyzed 2019-08-07 08:30 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	163
Duplicated Lines	8.59 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes

Metric	Value
wmc	16
lcom	1
cbo	5
dl	14
loc	163
ccs	73
cts	73
cp	1
rs	10
c	0
b	0
f	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	calculateHashForInterval()	0	24	1
A	calculateHashInRelatedTablesForInterval()	0	29	2
A	prepareIntervalQuery()	0	12	4
A	getIdRange()	0	16	1
A	findAllReferencedByInterval()	7	33	3
A	aggregateReferencesByInterval()	7	36	5

How to fix Duplicated Code

<?php
declare(strict_types=1);

namespace Maba\DatabaseInconsistencyFinder\Database;

use Doctrine\DBAL\FetchMode;
use Maba\DatabaseInconsistencyFinder\Entity\Interval;
use Maba\DatabaseInconsistencyFinder\Entity\ReferencedColumn;
use Maba\DatabaseInconsistencyFinder\Entity\TableReferences;

class QueryExecutor
{
    public function calculateHashForInterval(
        ReferencedColumn $referencedColumn,
        Interval $interval
    ): int {
        return (int)$referencedColumn->getConnection()->fetchColumn(
            strtr(
                '
                    SELECT SUM(CRC32(:idColumn) * :countColumn) 
                    FROM :table 
                    WHERE :intervalQuery
                ',
                [
                    ':table' => $referencedColumn->getTableName(),
                    ':idColumn' => $referencedColumn->getIdColumnName(),
                    ':countColumn' => $referencedColumn->getReferenceNumberColumnName(),
                    ':intervalQuery' => $this->prepareIntervalQuery($interval, $referencedColumn->getIdColumnName()),
                ]
            ),
            [
                ':idLargerThan' => $interval->getFrom(),
                ':idUntil' => $interval->getUntil(),
            ]
        );
    }

    public function calculateHashInRelatedTablesForInterval(
        TableReferences $tableReferences,
        Interval $interval
    ): int {
        $connection = $tableReferences->getConnection();
        $total = 0;
        foreach ($tableReferences->getColumnNames() as $columnName) {
            $total += (int)$connection->fetchColumn(
                strtr(
                    '
                    SELECT SUM(CRC32(:idColumn)) 
                    FROM :table 
                    WHERE :intervalQuery
                ',
                    [
                        ':table' => $tableReferences->getTableName(),
                        ':idColumn' => $columnName,
                        ':intervalQuery' => $this->prepareIntervalQuery($interval, $columnName),
                    ]
                ),
                [
                    ':idLargerThan' => $interval->getFrom(),
                    ':idUntil' => $interval->getUntil(),
                ]
            );
        }

        return $total;
    }

    public function findAllReferencedByInterval(ReferencedColumn $referencedColumn, Interval $interval): array
    {
        $statement = $referencedColumn->getConnection()->executeQuery(
            strtr(
                '
                    SELECT :idColumn, :countColumn
                    FROM :table
                    WHERE :intervalQuery
                ',
                [
                    ':table' => $referencedColumn->getTableName(),
                    ':idColumn' => $referencedColumn->getIdColumnName(),
                    ':countColumn' => $referencedColumn->getReferenceNumberColumnName(),
                    ':intervalQuery' => $this->prepareIntervalQuery($interval, $referencedColumn->getIdColumnName()),
                ]
            ),
            [
                ':idLargerThan' => $interval->getFrom(),
                ':idUntil' => $interval->getUntil(),
            ]
        );

        $result = [];
        while (true) {

            $row = $statement->fetch(FetchMode::NUMERIC);
            if ($row === false) {
                break;
            }
            $result[$row[0]] = (int)$row[1];
        }

        return $result;
    }

    /**
     * @param array|TableReferences[] $tableReferencesList
     * @param Interval $interval
     * @return array
     */
    public function aggregateReferencesByInterval(array $tableReferencesList, Interval $interval): array
    {
        $result = [];
        foreach ($tableReferencesList as $tableReferences) {
            $connection = $tableReferences->getConnection();
            foreach ($tableReferences->getColumnNames() as $columnName) {
                $statement = $connection->executeQuery(
                    strtr(
                        '
                            SELECT :idColumn
                            FROM :table
                            WHERE :intervalQuery
                        ',
                        [
                            ':table' => $tableReferences->getTableName(),
                            ':idColumn' => $columnName,
                            ':intervalQuery' => $this->prepareIntervalQuery($interval, $columnName),
                        ]
                    ),
                    [
                        ':idLargerThan' => $interval->getFrom(),
                        ':idUntil' => $interval->getUntil(),
                    ]
                );
                while (true) {

                    $id = $statement->fetch(FetchMode::COLUMN);
                    if ($id === false) {
                        break;
                    }
                    $result[$id] = ($result[$id] ?? 0) + 1;
                }
            }
        }

        return $result;
    }

    private function prepareIntervalQuery(Interval $interval, string $idColumn): string
    {
        $parts = [];
        if ($interval->getFrom() !== null) {
            $parts[] = sprintf('%s > :idLargerThan', $idColumn);
        }
        if ($interval->getUntil() !== null) {
            $parts[] = sprintf('%s <= :idUntil', $idColumn);
        }

        return count($parts) > 0 ? implode(' AND ', $parts) : 'TRUE';
    }

    public function getIdRange(ReferencedColumn $referencedColumn): Interval
    {
        $result = $referencedColumn->getConnection()->fetchArray(
            strtr(
                '
                    SELECT MIN(:idColumn), MAX(:idColumn)
                    FROM :table
                ',
                [
                    ':table' => $referencedColumn->getTableName(),
                    ':idColumn' => $referencedColumn->getIdColumnName(),
                ]
            )
        );
        return (new Interval())->setFrom((int)$result[0])->setUntil((int)$result[1]);
    }
}


1			<?php
2			declare(strict_types=1);
3
4			namespace Maba\DatabaseInconsistencyFinder\Database;
5
6			use Doctrine\DBAL\FetchMode;
7			use Maba\DatabaseInconsistencyFinder\Entity\Interval;
8			use Maba\DatabaseInconsistencyFinder\Entity\ReferencedColumn;
9			use Maba\DatabaseInconsistencyFinder\Entity\TableReferences;
10
11			class QueryExecutor
12			{
13	8		public function calculateHashForInterval(
14			ReferencedColumn $referencedColumn,
15			Interval $interval
16			): int {
17	8		return (int)$referencedColumn->getConnection()->fetchColumn(
18	8		strtr(
19	8		'
20			SELECT SUM(CRC32(:idColumn) * :countColumn)
21			FROM :table
22			WHERE :intervalQuery
23			',
24			[
25	8		':table' => $referencedColumn->getTableName(),
26	8		':idColumn' => $referencedColumn->getIdColumnName(),
27	8		':countColumn' => $referencedColumn->getReferenceNumberColumnName(),
28	8		':intervalQuery' => $this->prepareIntervalQuery($interval, $referencedColumn->getIdColumnName()),
29			]
30			),
31			[
32	8		':idLargerThan' => $interval->getFrom(),
33	8		':idUntil' => $interval->getUntil(),
34			]
35			);
36			}
37
38	8		public function calculateHashInRelatedTablesForInterval(
39			TableReferences $tableReferences,
40			Interval $interval
41			): int {
42	8		$connection = $tableReferences->getConnection();
43	8		$total = 0;
44	8		foreach ($tableReferences->getColumnNames() as $columnName) {
45	8		$total += (int)$connection->fetchColumn(
46	8		strtr(
47	8		'
48			SELECT SUM(CRC32(:idColumn))
49			FROM :table
50			WHERE :intervalQuery
51			',
52			[
53	8		':table' => $tableReferences->getTableName(),
54	8		':idColumn' => $columnName,
55	8		':intervalQuery' => $this->prepareIntervalQuery($interval, $columnName),
56			]
57			),
58			[
59	8		':idLargerThan' => $interval->getFrom(),
60	8		':idUntil' => $interval->getUntil(),
61			]
62			);
63			}
64
65	8		return $total;
66			}
67
68	7		public function findAllReferencedByInterval(ReferencedColumn $referencedColumn, Interval $interval): array
69			{
70	7		$statement = $referencedColumn->getConnection()->executeQuery(
71	7		strtr(
72	7		'
73			SELECT :idColumn, :countColumn
74			FROM :table
75			WHERE :intervalQuery
76			',
77			[
78	7		':table' => $referencedColumn->getTableName(),
79	7		':idColumn' => $referencedColumn->getIdColumnName(),
80	7		':countColumn' => $referencedColumn->getReferenceNumberColumnName(),
81	7		':intervalQuery' => $this->prepareIntervalQuery($interval, $referencedColumn->getIdColumnName()),
82			]
83			),
84			[
85	7		':idLargerThan' => $interval->getFrom(),
86	7		':idUntil' => $interval->getUntil(),
87			]
88			);
89
90	7		$result = [];
91	7	View Code Duplication	while (true) {
			0 ignored issues – show Duplication introduced 2019-08-07 08:23 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
92	7		$row = $statement->fetch(FetchMode::NUMERIC);
93	7		if ($row === false) {
94	7		break;
95			}
96	7		$result[$row[0]] = (int)$row[1];
97			}
98
99	7		return $result;
100			}
101
102			/**
103			* @param array\|TableReferences[] $tableReferencesList
104			* @param Interval $interval
105			* @return array
106			*/
107	7		public function aggregateReferencesByInterval(array $tableReferencesList, Interval $interval): array
108			{
109	7		$result = [];
110	7		foreach ($tableReferencesList as $tableReferences) {
111	7		$connection = $tableReferences->getConnection();
112	7		foreach ($tableReferences->getColumnNames() as $columnName) {
113	7		$statement = $connection->executeQuery(
114	7		strtr(
115	7		'
116			SELECT :idColumn
117			FROM :table
118			WHERE :intervalQuery
119			',
120			[
121	7		':table' => $tableReferences->getTableName(),
122	7		':idColumn' => $columnName,
123	7		':intervalQuery' => $this->prepareIntervalQuery($interval, $columnName),
124			]
125			),
126			[
127	7		':idLargerThan' => $interval->getFrom(),
128	7		':idUntil' => $interval->getUntil(),
129			]
130			);
131	7	View Code Duplication	while (true) {
			0 ignored issues – show Duplication introduced 2019-08-07 08:23 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
132	7		$id = $statement->fetch(FetchMode::COLUMN);
133	7		if ($id === false) {
134	7		break;
135			}
136	7		$result[$id] = ($result[$id] ?? 0) + 1;
137			}
138			}
139			}
140
141	7		return $result;
142			}
143
144	12		private function prepareIntervalQuery(Interval $interval, string $idColumn): string
145			{
146	12		$parts = [];
147	12		if ($interval->getFrom() !== null) {
148	6		$parts[] = sprintf('%s > :idLargerThan', $idColumn);
149			}
150	12		if ($interval->getUntil() !== null) {
151	6		$parts[] = sprintf('%s <= :idUntil', $idColumn);
152			}
153
154	12		return count($parts) > 0 ? implode(' AND ', $parts) : 'TRUE';
155			}
156
157	4		public function getIdRange(ReferencedColumn $referencedColumn): Interval
158			{
159	4		$result = $referencedColumn->getConnection()->fetchArray(
160	4		strtr(
161	4		'
162			SELECT MIN(:idColumn), MAX(:idColumn)
163			FROM :table
164			',
165			[
166	4		':table' => $referencedColumn->getTableName(),
167	4		':idColumn' => $referencedColumn->getIdColumnName(),
168			]
169			)
170			);
171	4		return (new Interval())->setFrom((int)$result[0])->setUntil((int)$result[1]);
172			}
173			}
174

mariusbalcytis / database-inconsistency-finder

QueryExecutor A last analyzed 2019-08-07 08:30 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Test Coverage

Importance

6 Methods

How to fix Duplicated Code

Duplicated Code

Duplication Side-by-Side

Filter issues like

QueryExecutor A
last analyzed 2019-08-07 08:30 UTC