AbstractEndpointRepository::readRaw() - Code Metrics - Inspection of "Merge pull request #11 from Maelstrome26/staging" - Maelstromeous/ps2alerts-api - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 5e6003...ff6361 )

by Matthew

created 2016-01-18 01:44 UTC

AbstractEndpointRepository::readRaw() A

↳ Parent: AbstractEndpointRepository

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	1	Features	1

Metric	Value
c	2
b	1
f	1
dl	0
loc	10
rs	9.4285
cc	2
eloc	5
nc	2
nop	2

<?php

namespace Ps2alerts\Api\Repository;

use Aura\SqlQuery\AbstractQuery;
use Aura\SqlQuery\QueryFactory;
use Ps2alerts\Api\Contract\DatabaseAwareInterface;
use Ps2alerts\Api\Contract\DatabaseAwareTrait;
use Ps2alerts\Api\Contract\RedisAwareInterface;
use Ps2alerts\Api\Contract\RedisAwareTrait;
use Ps2alerts\Api\Contract\UuidAwareInterface;
use Ps2alerts\Api\Contract\UuidAwareTrait;

abstract class AbstractEndpointRepository implements
    DatabaseAwareInterface,
    RedisAwareInterface,
    UuidAwareInterface
{
    use DatabaseAwareTrait;
    use RedisAwareTrait;
    use UuidAwareTrait;

    /**
     * Determines the table that the DB is interfacing with
     *
     * @return string
     */
    abstract public function getTable();

    /**
     * Determines the primary key of the table
     *
     * @return string
     */
    abstract public function getPrimaryKey();

    /**
     * Determines the Result key of the table
     *
     * @return string
     */
    abstract public function getResultKey();

    /**
     * Builds a new query factory ready for use with the QueryObjects
     *
     * @return \Aura\SqlQuery\AbstractQuery
     */
    public function newQuery()
    {
        $factory = new QueryFactory('mysql');

        $query = $factory->newSelect(); // Suspect I'll only ever need this one
        $query->from($this->getTable());

        return $query;
    }

    /**
     * Executes the statement to the DB and returns the results
     *
     * @param  \Aura\SqlQuery\AbstractQuery $query
     * @param  boolean                      $single
     *
     * @return array
     */
    public function fireStatementAndReturn($query, $single = false)
    {
        $pdo = $this->getDatabaseDriver();

        if ($single === false) {
            return $pdo->fetchAll($query->getStatement(), $query->getBindValues());
        }

        return $pdo->fetchOne($query->getStatement(), $query->getBindValues());
    }

    /**
     * Allows for Raw SQL firing without the query builder
     *
     * @param  string  $sql
     * @param  boolean $single
     *
     * @return array
     */
    public function readRaw($sql, $single = false)
    {
        $pdo = $this->getDatabaseDriver();

        if ($single === false) {
            return $pdo->fetchAll($sql);
        }

        return $pdo->fetchOne($sql);
    }

    /**
     * Reads a single record from the database
     *
     * @param  string $id
     *
     * @return array
     */
    public function readSinglebyId($id, $keyType = 'primary')

    {
        $query = $this->newQuery();
        $key = $this->returnKeyType($keyType);

        $query->cols(['*'])
              ->where("`{$key}` = '{$id}'");

        return $this->fireStatementAndReturn($query, true);
    }

    /**
     * Reads all related records from the database
     *
     * @param  string $id
     *
     * @return array
     */
    public function readAllById($id, $keyType = 'primary')

    {
        $query = $this->newQuery();
        $key = $this->returnKeyType($keyType);

        $query->cols(['*'])
              ->where("`{$key}` = '{$id}'");

        return $this->fireStatementAndReturn($query);
    }

    /**
     * Reads all records based off a simple where statement
     *
     * @param  array $fields
     *
     * @return array
     */
    public function readAllByFields($fields)
    {
        $query = $this->newQuery();

        $query->cols(['*']);

        foreach ($fields as $field => $value) {
            $query->where("`{$field}` = '{$value}'");
        }

        return $this->fireStatementAndReturn($query);
    }

    /**
     * Reads the count of records based off a where statement
     *
     * @param  array $fields
     *
     * @return array
     */
    public function readCountByFields($fields)
    {
        $query = $this->newQuery();
        $key   = $this->returnKeyType('primary');

        $query->cols(["COUNT({$key}) as COUNT"]);

        foreach ($fields as $field => $value) {
            $query->where("`{$field}` = '{$value}'");
        }

        $result = $this->fireStatementAndReturn($query);

        // Done this to prevent the need for clients to also do this. Returns a single number this way.
        return $result[0]["COUNT"];
    }

    /**
     * Sets the proper key to search on based off a string
     *
     * @param  string $key
     *
     * @return string
     */
    public function returnKeyType($key)
    {
        switch ($key) {
            case 'result':
                return $this->getResultKey();
            case 'primary':
            default:
                return $this->getPrimaryKey();
        }
    }
}


1			<?php
2
3			namespace Ps2alerts\Api\Repository;
4
5			use Aura\SqlQuery\AbstractQuery;
6			use Aura\SqlQuery\QueryFactory;
7			use Ps2alerts\Api\Contract\DatabaseAwareInterface;
8			use Ps2alerts\Api\Contract\DatabaseAwareTrait;
9			use Ps2alerts\Api\Contract\RedisAwareInterface;
10			use Ps2alerts\Api\Contract\RedisAwareTrait;
11			use Ps2alerts\Api\Contract\UuidAwareInterface;
12			use Ps2alerts\Api\Contract\UuidAwareTrait;
13
14			abstract class AbstractEndpointRepository implements
15			DatabaseAwareInterface,
16			RedisAwareInterface,
17			UuidAwareInterface
18			{
19			use DatabaseAwareTrait;
20			use RedisAwareTrait;
21			use UuidAwareTrait;
22
23			/**
24			* Determines the table that the DB is interfacing with
25			*
26			* @return string
27			*/
28			abstract public function getTable();
29
30			/**
31			* Determines the primary key of the table
32			*
33			* @return string
34			*/
35			abstract public function getPrimaryKey();
36
37			/**
38			* Determines the Result key of the table
39			*
40			* @return string
41			*/
42			abstract public function getResultKey();
43
44			/**
45			* Builds a new query factory ready for use with the QueryObjects
46			*
47			* @return \Aura\SqlQuery\AbstractQuery
48			*/
49			public function newQuery()
50			{
51			$factory = new QueryFactory('mysql');
52
53			$query = $factory->newSelect(); // Suspect I'll only ever need this one
54			$query->from($this->getTable());
55
56			return $query;
57			}
58
59			/**
60			* Executes the statement to the DB and returns the results
61			*
62			* @param \Aura\SqlQuery\AbstractQuery $query
63			* @param boolean $single
64			*
65			* @return array
66			*/
67			public function fireStatementAndReturn($query, $single = false)
68			{
69			$pdo = $this->getDatabaseDriver();
70
71			if ($single === false) {
72			return $pdo->fetchAll($query->getStatement(), $query->getBindValues());
73			}
74
75			return $pdo->fetchOne($query->getStatement(), $query->getBindValues());
76			}
77
78			/**
79			* Allows for Raw SQL firing without the query builder
80			*
81			* @param string $sql
82			* @param boolean $single
83			*
84			* @return array
85			*/
86			public function readRaw($sql, $single = false)
87			{
88			$pdo = $this->getDatabaseDriver();
89
90			if ($single === false) {
91			return $pdo->fetchAll($sql);
92			}
93
94			return $pdo->fetchOne($sql);
95			}
96
97			/**
98			* Reads a single record from the database
99			*
100			* @param string $id
101			*
102			* @return array
103			*/
104			public function readSinglebyId($id, $keyType = 'primary')
			0 ignored issues – show Duplication introduced 2016-01-17 00:22 UTC by Report Bug Copy Issue Report This method seems to be duplicated in 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...
105			{
106			$query = $this->newQuery();
107			$key = $this->returnKeyType($keyType);
108
109			$query->cols(['*'])
110			->where("`{$key}` = '{$id}'");
111
112			return $this->fireStatementAndReturn($query, true);
113			}
114
115			/**
116			* Reads all related records from the database
117			*
118			* @param string $id
119			*
120			* @return array
121			*/
122			public function readAllById($id, $keyType = 'primary')
			0 ignored issues – show Duplication introduced 2016-01-17 00:22 UTC by Report Bug Copy Issue Report This method seems to be duplicated in 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...
123			{
124			$query = $this->newQuery();
125			$key = $this->returnKeyType($keyType);
126
127			$query->cols(['*'])
128			->where("`{$key}` = '{$id}'");
129
130			return $this->fireStatementAndReturn($query);
131			}
132
133			/**
134			* Reads all records based off a simple where statement
135			*
136			* @param array $fields
137			*
138			* @return array
139			*/
140			public function readAllByFields($fields)
141			{
142			$query = $this->newQuery();
143
144			$query->cols(['*']);
145
146			foreach ($fields as $field => $value) {
147			$query->where("`{$field}` = '{$value}'");
148			}
149
150			return $this->fireStatementAndReturn($query);
151			}
152
153			/**
154			* Reads the count of records based off a where statement
155			*
156			* @param array $fields
157			*
158			* @return array
159			*/
160			public function readCountByFields($fields)
161			{
162			$query = $this->newQuery();
163			$key = $this->returnKeyType('primary');
164
165			$query->cols(["COUNT({$key}) as COUNT"]);
166
167			foreach ($fields as $field => $value) {
168			$query->where("`{$field}` = '{$value}'");
169			}
170
171			$result = $this->fireStatementAndReturn($query);
172
173			// Done this to prevent the need for clients to also do this. Returns a single number this way.
174			return $result[0]["COUNT"];
175			}
176
177			/**
178			* Sets the proper key to search on based off a string
179			*
180			* @param string $key
181			*
182			* @return string
183			*/
184			public function returnKeyType($key)
185			{
186			switch ($key) {
187			case 'result':
188			return $this->getResultKey();
189			case 'primary':
190			default:
191			return $this->getPrimaryKey();
192			}
193			}
194			}
195

Maelstromeous / ps2alerts-api

Push — master ( 5e6003...ff6361 )

AbstractEndpointRepository::readRaw() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like