AbstractDataTablesDatabase::getResponse() - Code Metrics - webservco/framework - Measure and Improve Code Quality continuously with Scrutinizer

AbstractDataTablesDatabase::getResponse() B
last analyzed 2024-04-15 08:40 UTC

↳ Parent: AbstractDataTablesDatabase

Complexity

Conditions	6
Paths	8

Size

Total Lines	48
Code Lines	31

Duplication

Lines	0
Ratio	0 %

Importance

Changes	6
Bugs	0	Features	0

Metric	Value
eloc	31
c	6
b	0
f	0
dl	0
loc	48
rs	8.8017
cc	6
nc	8
nop	1

<?php

declare(strict_types=1);

namespace WebServCo\Framework\DataTables;

use WebServCo\Framework\Database\Order as DatabaseOrder;
use WebServCo\Framework\Exceptions\DatabaseException;
use WebServCo\Framework\Interfaces\ArrayObjectInterface;
use WebServCo\Framework\Interfaces\DatabaseInterface;

abstract class AbstractDataTablesDatabase implements \WebServCo\Framework\Interfaces\DataTablesInterface
{
    protected DatabaseInterface $db;

    /**
    * @param string $orderPart,
    */
    abstract protected function getQuery(string $searchPart, string $orderPart, string $limitPart): string;

    abstract protected function getRecordsTotalQuery(): string;

    public function __construct(DatabaseInterface $db)
    {
        $this->db = $db;
    }

    public function getResponse(Request $request): Response
    {
        $params = [];
        $limitPart = '';

        $columnArrayObject = $request->getColumns();
        [$searchPart, $searchParams] = $this->getSearchQueryPart($columnArrayObject);

        if (!\is_string($searchPart)) {

            throw new \InvalidArgumentException('"searchQueryPart" is not a string');
        }
        if (!\is_array($searchParams)) {

            throw new \InvalidArgumentException('"searchParams" is not an array');
        }

        $params = \array_merge($params, $searchParams);

        $orderArrayObject = $request->getOrder();
        $orderPart = $this->getOrderQueryPart($columnArrayObject, $orderArrayObject);

        $length = $request->getLength();
        if (-1 !== $length) {
            $limitPart = 'LIMIT ?, ?';
            $params[] = $request->getStart();
            $params[] = $length;
        }
        $query = $this->getQuery($searchPart, $orderPart, $limitPart);
        try {
            $pdoStatement = $this->db->query($query, $params);
        } catch (DatabaseException $e) {
            // Rethrow in order to pinpoint the query location in the logs.
            throw new DatabaseException($e->getMessage(), $e);
        }

        $data = $this->getData($columnArrayObject, $pdoStatement);

        $recordsFiltered = $this->getRecordsFiltered();

        // Extra query for total only if there is a search, otherwise the total is equal to the $recordsFiltered
        $recordsTotal = $searchPart
            ? $this->getRecordsTotal()
            : $recordsFiltered;

        return new Response(
            $request->getDraw(),
            $recordsTotal,
            $recordsFiltered,
            $data,
        );
    }

    protected function assertColumnArrayObject(ArrayObjectInterface $arrayObject): bool
    {
        if (!$arrayObject instanceof ColumnArrayObject) {
            throw new \InvalidArgumentException(\sprintf('Object is not an instance of %s.', 'ColumnArrayObject'));
        }
        return true;
    }

    protected function assertOrderArrayObject(ArrayObjectInterface $arrayObject): bool
    {
        if (!$arrayObject instanceof OrderArrayObject) {
            throw new \InvalidArgumentException(\sprintf('Object is not an instance of %s.', 'OrderArrayObject'));
        }
        return true;
    }

    /**
    * @return array<int,array<int|string,mixed>>
    */
    protected function getData(ArrayObjectInterface $columnArrayObject, \PDOStatement $pdoStatement): array
    {
        $this->assertColumnArrayObject($columnArrayObject);
        $data = [];
        while ($row = $pdoStatement->fetch(\PDO::FETCH_ASSOC)) {
            $item = [];
            foreach ($columnArrayObject as $column) {
                $name = $column->getData();
                $item[$name] = $row[$name] ?? null;
            }
            $data[] = $item;
        }
        return $data;
    }

    protected function getDatabaseColumnName(string $dataTablesColumnName): string
    {
        try {
            return $this->db->escapeIdentifier($dataTablesColumnName);
        } catch (DatabaseException $e) {
            // Rethrow in order to pinpoint the query location in the logs.
            throw new DatabaseException($e->getMessage(), $e);
        }
    }

    protected function getOrderQueryPart(
        ArrayObjectInterface $columnArrayObject,
        ArrayObjectInterface $orderArrayObject
    ): string {
        $this->assertColumnArrayObject($columnArrayObject);
        $this->assertOrderArrayObject($orderArrayObject);
        $items = [];
        foreach ($orderArrayObject as $order) {
            $columnKey = (string) $order->getColumn();
            $column = $columnArrayObject->offsetGet($columnKey);
            if (!($column instanceof Column)) {
                continue;
            }

            if (!$column->getOrderable()) {
                continue;
            }

            $dir = \strtoupper($order->getDir());
            $dir = \in_array($dir, [DatabaseOrder::ASC, DatabaseOrder::DESC], true)
                ? $dir
                : DatabaseOrder::ASC;
            $columnName = $this->getDatabaseColumnName($column->getData());
            $items[] = \sprintf(' %s %s', $columnName, $dir);
        }
        if (!$items) {
            // No order, or none of the columns are actually orderable
            return '';
        }
        return \sprintf(
            'ORDER BY%s',
            \implode(",", $items),
        );
    }

    protected function getRecordsFiltered(): int
    {
        try {
            return (int) $this->db->getColumn("SELECT FOUND_ROWS()", [], 0);
        } catch (DatabaseException $e) {
            // Rethrow in order to pinpoint the query location in the logs.
            throw new DatabaseException($e->getMessage(), $e);
        }
    }

    protected function getRecordsTotal(): int
    {
        try {
            return (int) $this->db->getColumn( // grand total - query without the search, order, limits
                $this->getRecordsTotalQuery(),
                [],
            );
        } catch (DatabaseException $e) {
            // Rethrow in order to pinpoint the query location in the logs.
            throw new DatabaseException($e->getMessage(), $e);
        }
    }

    /**
    * @return array<int,array<int,string>|string>
    */
    protected function getSearchQueryPart(ArrayObjectInterface $columnArrayObject): array
    {
        $this->assertColumnArrayObject($columnArrayObject);
        $query = '';
        $params = [];
        foreach ($columnArrayObject as $column) {
            if (!$column->getSearchable()) {
                continue;
            }

            $search = $column->getSearch();
            $searchValue = $search->getValue();
            if ('' === $searchValue) {
                continue;
            }
            // make sure it works also for "0"
            $query .= \sprintf(
                " AND %s LIKE ?",
                $this->getDatabaseColumnName($column->getData()),
            );
            $params[] = \sprintf('%%%s%%', $searchValue);
        }
        return [$query, $params];
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace WebServCo\Framework\DataTables;
6
7			use WebServCo\Framework\Database\Order as DatabaseOrder;
8			use WebServCo\Framework\Exceptions\DatabaseException;
9			use WebServCo\Framework\Interfaces\ArrayObjectInterface;
10			use WebServCo\Framework\Interfaces\DatabaseInterface;
11
12			abstract class AbstractDataTablesDatabase implements \WebServCo\Framework\Interfaces\DataTablesInterface
13			{
14			protected DatabaseInterface $db;
15
16			/**
17			* @param string $orderPart,
18			*/
19			abstract protected function getQuery(string $searchPart, string $orderPart, string $limitPart): string;
20
21			abstract protected function getRecordsTotalQuery(): string;
22
23			public function __construct(DatabaseInterface $db)
24			{
25			$this->db = $db;
26			}
27
28			public function getResponse(Request $request): Response
29			{
30			$params = [];
31			$limitPart = '';
32
33			$columnArrayObject = $request->getColumns();
34			[$searchPart, $searchParams] = $this->getSearchQueryPart($columnArrayObject);
35
36			if (!\is_string($searchPart)) {
			0 ignored issues – show introduced 2021-03-23 11:25 UTC by Report Bug Copy Issue Report The condition `is_string($searchPart)` is always `true`. Loading history...
37			throw new \InvalidArgumentException('"searchQueryPart" is not a string');
38			}
39			if (!\is_array($searchParams)) {
			0 ignored issues – show introduced 2021-03-23 11:25 UTC by Report Bug Copy Issue Report The condition `is_array($searchParams)` is always `true`. Loading history...
40			throw new \InvalidArgumentException('"searchParams" is not an array');
41			}
42
43			$params = \array_merge($params, $searchParams);
44
45			$orderArrayObject = $request->getOrder();
46			$orderPart = $this->getOrderQueryPart($columnArrayObject, $orderArrayObject);
47
48			$length = $request->getLength();
49			if (-1 !== $length) {
50			$limitPart = 'LIMIT ?, ?';
51			$params[] = $request->getStart();
52			$params[] = $length;
53			}
54			$query = $this->getQuery($searchPart, $orderPart, $limitPart);
55			try {
56			$pdoStatement = $this->db->query($query, $params);
57			} catch (DatabaseException $e) {
58			// Rethrow in order to pinpoint the query location in the logs.
59			throw new DatabaseException($e->getMessage(), $e);
60			}
61
62			$data = $this->getData($columnArrayObject, $pdoStatement);
63
64			$recordsFiltered = $this->getRecordsFiltered();
65
66			// Extra query for total only if there is a search, otherwise the total is equal to the $recordsFiltered
67			$recordsTotal = $searchPart
68			? $this->getRecordsTotal()
69			: $recordsFiltered;
70
71			return new Response(
72			$request->getDraw(),
73			$recordsTotal,
74			$recordsFiltered,
75			$data,
76			);
77			}
78
79			protected function assertColumnArrayObject(ArrayObjectInterface $arrayObject): bool
80			{
81			if (!$arrayObject instanceof ColumnArrayObject) {
82			throw new \InvalidArgumentException(\sprintf('Object is not an instance of %s.', 'ColumnArrayObject'));
83			}
84			return true;
85			}
86
87			protected function assertOrderArrayObject(ArrayObjectInterface $arrayObject): bool
88			{
89			if (!$arrayObject instanceof OrderArrayObject) {
90			throw new \InvalidArgumentException(\sprintf('Object is not an instance of %s.', 'OrderArrayObject'));
91			}
92			return true;
93			}
94
95			/**
96			* @return array<int,array<int\|string,mixed>>
97			*/
98			protected function getData(ArrayObjectInterface $columnArrayObject, \PDOStatement $pdoStatement): array
99			{
100			$this->assertColumnArrayObject($columnArrayObject);
101			$data = [];
102			while ($row = $pdoStatement->fetch(\PDO::FETCH_ASSOC)) {
103			$item = [];
104			foreach ($columnArrayObject as $column) {
105			$name = $column->getData();
106			$item[$name] = $row[$name] ?? null;
107			}
108			$data[] = $item;
109			}
110			return $data;
111			}
112
113			protected function getDatabaseColumnName(string $dataTablesColumnName): string
114			{
115			try {
116			return $this->db->escapeIdentifier($dataTablesColumnName);
117			} catch (DatabaseException $e) {
118			// Rethrow in order to pinpoint the query location in the logs.
119			throw new DatabaseException($e->getMessage(), $e);
120			}
121			}
122
123			protected function getOrderQueryPart(
124			ArrayObjectInterface $columnArrayObject,
125			ArrayObjectInterface $orderArrayObject
126			): string {
127			$this->assertColumnArrayObject($columnArrayObject);
128			$this->assertOrderArrayObject($orderArrayObject);
129			$items = [];
130			foreach ($orderArrayObject as $order) {
131			$columnKey = (string) $order->getColumn();
132			$column = $columnArrayObject->offsetGet($columnKey);
133			if (!($column instanceof Column)) {
134			continue;
135			}
136
137			if (!$column->getOrderable()) {
138			continue;
139			}
140
141			$dir = \strtoupper($order->getDir());
142			$dir = \in_array($dir, [DatabaseOrder::ASC, DatabaseOrder::DESC], true)
143			? $dir
144			: DatabaseOrder::ASC;
145			$columnName = $this->getDatabaseColumnName($column->getData());
146			$items[] = \sprintf(' %s %s', $columnName, $dir);
147			}
148			if (!$items) {
149			// No order, or none of the columns are actually orderable
150			return '';
151			}
152			return \sprintf(
153			'ORDER BY%s',
154			\implode(",", $items),
155			);
156			}
157
158			protected function getRecordsFiltered(): int
159			{
160			try {
161			return (int) $this->db->getColumn("SELECT FOUND_ROWS()", [], 0);
162			} catch (DatabaseException $e) {
163			// Rethrow in order to pinpoint the query location in the logs.
164			throw new DatabaseException($e->getMessage(), $e);
165			}
166			}
167
168			protected function getRecordsTotal(): int
169			{
170			try {
171			return (int) $this->db->getColumn( // grand total - query without the search, order, limits
172			$this->getRecordsTotalQuery(),
173			[],
174			);
175			} catch (DatabaseException $e) {
176			// Rethrow in order to pinpoint the query location in the logs.
177			throw new DatabaseException($e->getMessage(), $e);
178			}
179			}
180
181			/**
182			* @return array<int,array<int,string>\|string>
183			*/
184			protected function getSearchQueryPart(ArrayObjectInterface $columnArrayObject): array
185			{
186			$this->assertColumnArrayObject($columnArrayObject);
187			$query = '';
188			$params = [];
189			foreach ($columnArrayObject as $column) {
190			if (!$column->getSearchable()) {
191			continue;
192			}
193
194			$search = $column->getSearch();
195			$searchValue = $search->getValue();
196			if ('' === $searchValue) {
197			continue;
198			}
199			// make sure it works also for "0"
200			$query .= \sprintf(
201			" AND %s LIKE ?",
202			$this->getDatabaseColumnName($column->getData()),
203			);
204			$params[] = \sprintf('%%%s%%', $searchValue);
205			}
206			return [$query, $params];
207			}
208			}
209

webservco / framework

AbstractDataTablesDatabase::getResponse() B last analyzed 2024-04-15 08:40 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

AbstractDataTablesDatabase::getResponse() B
last analyzed 2024-04-15 08:40 UTC