TableGateway - Code Metrics - Inspection of "Fix some issues (code intelligence)" - Pleets/dronephp - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 800486...f6d51e )

by Darío

created 2018-08-17 13:56 UTC

TableGateway F

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	412
Duplicated Lines	0 %

Importance

Changes

Metric	Value
eloc	197
dl	0
loc	412
rs	3.12
c	0
b	0
f	0
wmc	66

How to fix Complexity

<?php
/**
 * DronePHP (http://www.dronephp.com)
 *
 * @link      http://github.com/Pleets/DronePHP
 * @copyright Copyright (c) 2016-2018 Pleets. (http://www.pleets.org)
 * @license   http://www.dronephp.com/license
 * @author    Darío Rivera <[email protected]>
 */

namespace Drone\Db\TableGateway;

use Drone\Db\Entity;
use Drone\Db\SQLFunction;
use Drone\Exception;

/**
 * TableGateway class
 *
 * This class is a query builder for CRUD (create, read, update, delete)
 */
class TableGateway extends AbstractTableGateway implements TableGatewayInterface
{
    /**
     * Entity instance
     *
     * @var Entity
     */
    private $entity;

    /**
     * Returns the entity
     *
     * @return Entity
     */
    public function getEntity()
    {
        return $this->entity;
    }

    /**
     * Constructor
     *
     * @param Entity $entity
     * @param boolean $auto_connect
     */
    public function __construct(Entity $entity, $auto_connect = true)
    {
        parent::__construct($entity->getConnectionIdentifier(), $auto_connect);
        $this->entity = $entity;
    }

    /**
     * Select statement
     *
     * @param array $where
     *
     * @return array With all results
     */
    public function select(Array $where = [])
    {
        $bind_values = [];

        $driver = $this->getDriver()->getDriverName();

        if (count($where))
        {
            $parsed_where = [];

            $k = 0;

            foreach ($where as $key => $value)
            {
                $k++;

                if (is_null($value))
                    $parsed_where[] = "$key IS NULL";
                elseif ($value instanceof SQLFunction)
                    $parsed_where[] = "$key = " . $value->getStatement();
                elseif (is_array($value))
                {
                    $parsed_in = [];

                    foreach ($value as $in_value)
                    {
                        switch ($driver)
                        {
                            case 'Oci8':
                                $parsed_in[] = ":$k";
                                $bind_values[":$k"] = $in_value;
                                break;

                            case 'Mysqli' || 'Sqlsrv':
                                $parsed_in[] = "?";
                                $bind_values[] = $in_value;
                                break;
                        }

                        $k++;
                    }

                    $parsed_where[] = "$key IN (" . implode(", ", $parsed_in) . ")";
                }
                else
                {
                    switch ($driver)
                    {
                        case 'Oci8':
                            $parsed_where[] = "$key = :$k";
                            $bind_values[":$k"] = $value;
                            break;

                        case 'Mysqli' || 'Sqlsrv':
                            $parsed_where[] = "$key = ?";
                            $bind_values[] = $value;
                            break;
                    }
                }
            }

            $where = "WHERE \r\n\t" . implode(" AND\r\n\t", $parsed_where);
        }
        else
            $where = "";

        $table = $this->entity->getTableName();

        $sql = "SELECT * \r\nFROM {$table}\r\n$where";

        if (count($bind_values))
            $this->getDriver()->getDb()->execute($sql, $bind_values)
        else

            $this->getDriver()->getDb()->execute($sql);

        return $this->getDriver()->getDb()->getArrayResult();
    }

    /**
     * Insert statement
     *
     * @param array $data
     *
     * @throws RuntimeException from internal execute()
     * @throws LogicException
     *
     * @return resource|object
     */
    public function insert(Array $data)
    {
        if (!count($data))
            throw new \LogicException("Missing values for INSERT statement!");

        $bind_values = [];

        $driver = $this->getDriver()->getDriverName();

        $k = 0;

        $null_keys = [];

        foreach ($data as $key => $value)
        {
            $k++;

            # insert NULL values cause problems when BEFORE INSERT triggers are
            # defined to assigns values over fields. For SQLServer is better not
            # pass NULL values
            if ($driver == 'Sqlsrv' && is_null($value))
            {
                $null_keys[] = $key;
                continue;
            }

            if (is_null($value))
                $value = "NULL";
            elseif ($value instanceof SQLFunction)
                $value = $value->getStatement();
            else {

                switch ($driver)
                {
                    case 'Oci8':
                        $bind_values[":$k"] = $value;
                        $value = ":$k";
                        break;

                    case 'Mysqli' || 'Sqlsrv':
                        $bind_values[] = $value;
                        $value = "?";
                        break;
                }
            }

            $data[$key] = $value;
        }

        foreach ($null_keys as $key)
        {
            unset($data[$key]);
        }

        $cols = implode(",\r\n\t", array_keys($data));
        $vals = implode(",\r\n\t", array_values($data));

        $table = $this->entity->getTableName();

        $sql = "INSERT INTO {$table} \r\n(\r\n\t$cols\r\n) \r\nVALUES \r\n(\r\n\t$vals\r\n)";

        return $this->getDriver()->getDb()->execute($sql, $bind_values);
    }

    /**
     * Update statement
     *
     * @param array $set
     * @param array $where
     *
     * @throws RuntimeException from internal execute()
     * @throws LogicException
     * @throws SecurityException
     *
     * @return resource|object
     */
    public function update(Array $set, Array $where)
    {
        $parsed_set = [];

        if (!count($set))
            throw new \LogicException("You cannot update rows without SET clause");

        if (!count($where))
            throw new SecurityException("You cannot update rows without WHERE clause!");

        $bind_values = [];

        $driver = $this->getDriver()->getDriverName();

        $k = 0;

        foreach ($set as $key => $value)
        {
            $k++;

            if (is_null($value))
                $parsed_set[] = "$key = NULL";
            elseif ($value instanceof SQLFunction)
                $parsed_set[] = "$key = " . $value->getStatement();
            elseif (is_array($value))
            {
                $parsed_in = [];

                foreach ($value as $in_value)
                {
                    switch ($driver)
                    {
                        case 'Oci8':

                            # [POSSIBLE BUG] - To Future revision (What about non-string values ?)
                            if (is_string($in_value))
                                $parsed_in[] = ":$k";

                            $bind_values[":$k"] = $in_value;
                            break;

                        case 'Mysqli' || 'Sqlsrv':
                            $parsed_in[] = "?";
                            $bind_values[] = $in_value;
                            break;
                    }

                    $k++;
                }

                $parsed_set[] = "$key IN (" . implode(", ", $parsed_in) . ")";
            }
            else
            {
                switch ($driver)
                {
                    case 'Oci8':
                        $parsed_set[] = "$key = :$k";
                        $bind_values[":$k"] = $value;
                        break;

                    case 'Mysqli' || 'Sqlsrv':
                        $parsed_set[] = "$key = ?";
                        $bind_values[] = $value;
                        break;
                }
            }
        }

        $parsed_set = implode(",\r\n\t", $parsed_set);

        $parsed_where = [];

        foreach ($where as $key => $value)
        {
            $k++;

            if (is_null($value))
                $parsed_where[] = "$key IS NULL";
            elseif ($value instanceof SQLFunction)
                $parsed_where[] = "$key = " . $value->getStatement();
            elseif (is_array($value))
            {
                $parsed_in = [];

                foreach ($value as $in_value)
                {
                    switch ($driver)
                    {
                        case 'Oci8':
                            $parsed_in[] = ":$k";
                            $bind_values[":$k"] = $in_value;
                            break;

                        case 'Mysqli' || 'Sqlsrv':
                            $parsed_in[] = "?";
                            $bind_values[] = $in_value;
                            break;
                    }

                    $k++;
                }

                $parsed_where[] = "$key IN (" . implode(", ", $parsed_in) . ")";
            }
            else
            {
                switch ($driver)
                {
                    case 'Oci8':
                        $parsed_where[] = "$key = :$k";
                        $bind_values[":$k"] = $value;
                        break;

                    case 'Mysqli' || 'Sqlsrv':
                        $parsed_where[] = "$key = ?";
                        $bind_values[] = $value;
                        break;
                }
            }
        }

        $parsed_where = implode(" AND\r\n\t", $parsed_where);

        $table = $this->entity->getTableName();

        $sql = "UPDATE {$table} \r\nSET \r\n\t$parsed_set \r\nWHERE \r\n\t$parsed_where";

        return $this->getDriver()->getDb()->execute($sql, $bind_values);
    }

    /**
     * Delete statement
     *
     * @param array $where
     *
     * @throws RuntimeException from internal execute()
     * @throws SecurityException
     *
     * @return resource|object
     */
    public function delete(Array $where)
    {
        if (count($where))
        {
            $parsed_where = [];

            $bind_values = [];

            $driver = $this->getDriver()->getDriverName();

            $k = 0;

            foreach ($where as $key => $value)
            {
                $k++;

                if (is_null($value))
                    $parsed_where[] = "$key IS NULL";
                elseif ($value instanceof SQLFunction)
                    $parsed_where[] = "$key = " . $value->getStatement();
                elseif (is_array($value))
                {
                    $parsed_in = [];

                    foreach ($value as $in_value)
                    {
                        switch ($driver)
                        {
                            case 'Oci8':
                                $parsed_in[] = ":$k";
                                $bind_values[":$k"] = $in_value;
                                break;

                            case 'Mysqli' || 'Sqlsrv':
                                $parsed_in[] = "?";
                                $bind_values[] = $in_value;
                                break;
                        }

                        $k++;
                    }

                    $parsed_where[] = "$key IN (" . implode(", ", $parsed_in) . ")";
                }
                else
                {
                    switch ($driver)
                    {
                        case 'Oci8':
                            $parsed_where[] = "$key = :$k";
                            $bind_values[":$k"] = $value;
                            break;

                        case 'Mysqli' || 'Sqlsrv':
                            $parsed_where[] = "$key = ?";
                            $bind_values[] = $value;
                            break;
                    }
                }
            }

            $where = "\r\nWHERE \r\n\t" . implode(" AND\r\n\t", $parsed_where);
        }
        else
            throw new SecurityException("You cannot delete rows without WHERE clause!. Use TRUNCATE statement instead.");

        $table = $this->entity->getTableName();

        $sql = "DELETE FROM {$table} $where";

        return $this->getDriver()->getDb()->execute($sql, $bind_values);
    }
}

1			<?php
2			/**
3			* DronePHP (http://www.dronephp.com)
4			*
5			* @link http://github.com/Pleets/DronePHP
6			* @copyright Copyright (c) 2016-2018 Pleets. (http://www.pleets.org)
7			* @license http://www.dronephp.com/license
8			* @author Darío Rivera <[email protected]>
9			*/
10
11			namespace Drone\Db\TableGateway;
12
13			use Drone\Db\Entity;
14			use Drone\Db\SQLFunction;
15			use Drone\Exception;
16
17			/**
18			* TableGateway class
19			*
20			* This class is a query builder for CRUD (create, read, update, delete)
21			*/
22			class TableGateway extends AbstractTableGateway implements TableGatewayInterface
23			{
24			/**
25			* Entity instance
26			*
27			* @var Entity
28			*/
29			private $entity;
30
31			/**
32			* Returns the entity
33			*
34			* @return Entity
35			*/
36			public function getEntity()
37			{
38			return $this->entity;
39			}
40
41			/**
42			* Constructor
43			*
44			* @param Entity $entity
45			* @param boolean $auto_connect
46			*/
47			public function __construct(Entity $entity, $auto_connect = true)
48			{
49			parent::__construct($entity->getConnectionIdentifier(), $auto_connect);
50			$this->entity = $entity;
51			}
52
53			/**
54			* Select statement
55			*
56			* @param array $where
57			*
58			* @return array With all results
59			*/
60			public function select(Array $where = [])
61			{
62			$bind_values = [];
63
64			$driver = $this->getDriver()->getDriverName();
65
66			if (count($where))
67			{
68			$parsed_where = [];
69
70			$k = 0;
71
72			foreach ($where as $key => $value)
73			{
74			$k++;
75
76			if (is_null($value))
77			$parsed_where[] = "$key IS NULL";
78			elseif ($value instanceof SQLFunction)
79			$parsed_where[] = "$key = " . $value->getStatement();
80			elseif (is_array($value))
81			{
82			$parsed_in = [];
83
84			foreach ($value as $in_value)
85			{
86			switch ($driver)
87			{
88			case 'Oci8':
89			$parsed_in[] = ":$k";
90			$bind_values[":$k"] = $in_value;
91			break;
92
93			case 'Mysqli' \|\| 'Sqlsrv':
94			$parsed_in[] = "?";
95			$bind_values[] = $in_value;
96			break;
97			}
98
99			$k++;
100			}
101
102			$parsed_where[] = "$key IN (" . implode(", ", $parsed_in) . ")";
103			}
104			else
105			{
106			switch ($driver)
107			{
108			case 'Oci8':
109			$parsed_where[] = "$key = :$k";
110			$bind_values[":$k"] = $value;
111			break;
112
113			case 'Mysqli' \|\| 'Sqlsrv':
114			$parsed_where[] = "$key = ?";
115			$bind_values[] = $value;
116			break;
117			}
118			}
119			}
120
121			$where = "WHERE \r\n\t" . implode(" AND\r\n\t", $parsed_where);
122			}
123			else
124			$where = "";
125
126			$table = $this->entity->getTableName();
127
128			$sql = "SELECT * \r\nFROM {$table}\r\n$where";
129
130			if (count($bind_values))
131			$this->getDriver()->getDb()->execute($sql, $bind_values)
132			else
			0 ignored issues – show Bug introduced 2018-08-17 13:58 UTC by Report Bug Copy Issue Report A parse error occurred: Syntax error, unexpected T_ELSE on line 132 at column 8 Loading history...
133			$this->getDriver()->getDb()->execute($sql);
134
135			return $this->getDriver()->getDb()->getArrayResult();
136			}
137
138			/**
139			* Insert statement
140			*
141			* @param array $data
142			*
143			* @throws RuntimeException from internal execute()
144			* @throws LogicException
145			*
146			* @return resource\|object
147			*/
148			public function insert(Array $data)
149			{
150			if (!count($data))
151			throw new \LogicException("Missing values for INSERT statement!");
152
153			$bind_values = [];
154
155			$driver = $this->getDriver()->getDriverName();
156
157			$k = 0;
158
159			$null_keys = [];
160
161			foreach ($data as $key => $value)
162			{
163			$k++;
164
165			# insert NULL values cause problems when BEFORE INSERT triggers are
166			# defined to assigns values over fields. For SQLServer is better not
167			# pass NULL values
168			if ($driver == 'Sqlsrv' && is_null($value))
169			{
170			$null_keys[] = $key;
171			continue;
172			}
173
174			if (is_null($value))
175			$value = "NULL";
176			elseif ($value instanceof SQLFunction)
177			$value = $value->getStatement();
178			else {
179
180			switch ($driver)
181			{
182			case 'Oci8':
183			$bind_values[":$k"] = $value;
184			$value = ":$k";
185			break;
186
187			case 'Mysqli' \|\| 'Sqlsrv':
188			$bind_values[] = $value;
189			$value = "?";
190			break;
191			}
192			}
193
194			$data[$key] = $value;
195			}
196
197			foreach ($null_keys as $key)
198			{
199			unset($data[$key]);
200			}
201
202			$cols = implode(",\r\n\t", array_keys($data));
203			$vals = implode(",\r\n\t", array_values($data));
204
205			$table = $this->entity->getTableName();
206
207			$sql = "INSERT INTO {$table} \r\n(\r\n\t$cols\r\n) \r\nVALUES \r\n(\r\n\t$vals\r\n)";
208
209			return $this->getDriver()->getDb()->execute($sql, $bind_values);
210			}
211
212			/**
213			* Update statement
214			*
215			* @param array $set
216			* @param array $where
217			*
218			* @throws RuntimeException from internal execute()
219			* @throws LogicException
220			* @throws SecurityException
221			*
222			* @return resource\|object
223			*/
224			public function update(Array $set, Array $where)
225			{
226			$parsed_set = [];
227
228			if (!count($set))
229			throw new \LogicException("You cannot update rows without SET clause");
230
231			if (!count($where))
232			throw new SecurityException("You cannot update rows without WHERE clause!");
233
234			$bind_values = [];
235
236			$driver = $this->getDriver()->getDriverName();
237
238			$k = 0;
239
240			foreach ($set as $key => $value)
241			{
242			$k++;
243
244			if (is_null($value))
245			$parsed_set[] = "$key = NULL";
246			elseif ($value instanceof SQLFunction)
247			$parsed_set[] = "$key = " . $value->getStatement();
248			elseif (is_array($value))
249			{
250			$parsed_in = [];
251
252			foreach ($value as $in_value)
253			{
254			switch ($driver)
255			{
256			case 'Oci8':
257
258			# [POSSIBLE BUG] - To Future revision (What about non-string values ?)
259			if (is_string($in_value))
260			$parsed_in[] = ":$k";
261
262			$bind_values[":$k"] = $in_value;
263			break;
264
265			case 'Mysqli' \|\| 'Sqlsrv':
266			$parsed_in[] = "?";
267			$bind_values[] = $in_value;
268			break;
269			}
270
271			$k++;
272			}
273
274			$parsed_set[] = "$key IN (" . implode(", ", $parsed_in) . ")";
275			}
276			else
277			{
278			switch ($driver)
279			{
280			case 'Oci8':
281			$parsed_set[] = "$key = :$k";
282			$bind_values[":$k"] = $value;
283			break;
284
285			case 'Mysqli' \|\| 'Sqlsrv':
286			$parsed_set[] = "$key = ?";
287			$bind_values[] = $value;
288			break;
289			}
290			}
291			}
292
293			$parsed_set = implode(",\r\n\t", $parsed_set);
294
295			$parsed_where = [];
296
297			foreach ($where as $key => $value)
298			{
299			$k++;
300
301			if (is_null($value))
302			$parsed_where[] = "$key IS NULL";
303			elseif ($value instanceof SQLFunction)
304			$parsed_where[] = "$key = " . $value->getStatement();
305			elseif (is_array($value))
306			{
307			$parsed_in = [];
308
309			foreach ($value as $in_value)
310			{
311			switch ($driver)
312			{
313			case 'Oci8':
314			$parsed_in[] = ":$k";
315			$bind_values[":$k"] = $in_value;
316			break;
317
318			case 'Mysqli' \|\| 'Sqlsrv':
319			$parsed_in[] = "?";
320			$bind_values[] = $in_value;
321			break;
322			}
323
324			$k++;
325			}
326
327			$parsed_where[] = "$key IN (" . implode(", ", $parsed_in) . ")";
328			}
329			else
330			{
331			switch ($driver)
332			{
333			case 'Oci8':
334			$parsed_where[] = "$key = :$k";
335			$bind_values[":$k"] = $value;
336			break;
337
338			case 'Mysqli' \|\| 'Sqlsrv':
339			$parsed_where[] = "$key = ?";
340			$bind_values[] = $value;
341			break;
342			}
343			}
344			}
345
346			$parsed_where = implode(" AND\r\n\t", $parsed_where);
347
348			$table = $this->entity->getTableName();
349
350			$sql = "UPDATE {$table} \r\nSET \r\n\t$parsed_set \r\nWHERE \r\n\t$parsed_where";
351
352			return $this->getDriver()->getDb()->execute($sql, $bind_values);
353			}
354
355			/**
356			* Delete statement
357			*
358			* @param array $where
359			*
360			* @throws RuntimeException from internal execute()
361			* @throws SecurityException
362			*
363			* @return resource\|object
364			*/
365			public function delete(Array $where)
366			{
367			if (count($where))
368			{
369			$parsed_where = [];
370
371			$bind_values = [];
372
373			$driver = $this->getDriver()->getDriverName();
374
375			$k = 0;
376
377			foreach ($where as $key => $value)
378			{
379			$k++;
380
381			if (is_null($value))
382			$parsed_where[] = "$key IS NULL";
383			elseif ($value instanceof SQLFunction)
384			$parsed_where[] = "$key = " . $value->getStatement();
385			elseif (is_array($value))
386			{
387			$parsed_in = [];
388
389			foreach ($value as $in_value)
390			{
391			switch ($driver)
392			{
393			case 'Oci8':
394			$parsed_in[] = ":$k";
395			$bind_values[":$k"] = $in_value;
396			break;
397
398			case 'Mysqli' \|\| 'Sqlsrv':
399			$parsed_in[] = "?";
400			$bind_values[] = $in_value;
401			break;
402			}
403
404			$k++;
405			}
406
407			$parsed_where[] = "$key IN (" . implode(", ", $parsed_in) . ")";
408			}
409			else
410			{
411			switch ($driver)
412			{
413			case 'Oci8':
414			$parsed_where[] = "$key = :$k";
415			$bind_values[":$k"] = $value;
416			break;
417
418			case 'Mysqli' \|\| 'Sqlsrv':
419			$parsed_where[] = "$key = ?";
420			$bind_values[] = $value;
421			break;
422			}
423			}
424			}
425
426			$where = "\r\nWHERE \r\n\t" . implode(" AND\r\n\t", $parsed_where);
427			}
428			else
429			throw new SecurityException("You cannot delete rows without WHERE clause!. Use TRUNCATE statement instead.");
430
431			$table = $this->entity->getTableName();
432
433			$sql = "DELETE FROM {$table} $where";
434
435			return $this->getDriver()->getDb()->execute($sql, $bind_values);
436			}
437			}

Pleets / dronephp

Push — master ( 800486...f6d51e )

TableGateway F

Complexity

Size/Duplication

Importance

How to fix Complexity

Complex Class

Duplication Side-by-Side

Filter issues like