QueryBuilder::buildQuery() - Code Metrics - Inspection of "fixed coding standards" - CruzerSoftwares/Dolphin - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 2452cb...36c8a5 )

by RN

created 2019-12-29 13:16 UTC

QueryBuilder::buildQuery() A

↳ Parent: QueryBuilder

Complexity

Conditions	4
Paths	8

Size

Total Lines	51
Code Lines	35

Duplication

Lines	0
Ratio	0 %

Importance

Changes	3
Bugs	1	Features	0

Metric	Value
cc	4
eloc	35
c	3
b	1
f	0
nc	8
nop	1
dl	0
loc	51
rs	9.36

How to fix Long Method

<?php
/**
 * The Query builder API.
 *
 * @author RN Kushwaha <[email protected]>
 *
 * @since v0.0.1 <Date: 16th April, 2019>
 */

namespace Dolphin\Builders;

use Dolphin\Connections\Connection;
use \Exception;

/**
 * This class provides the mechanism to build the Queries.
 */
class QueryBuilder
{
    protected $whereAdded = false;

    public function queryPrefix($query)
    {
        return str_replace('#__', Connection::getPrefix(), $query);
    }

    public function getPrefix()
    {
        return Connection::getPrefix();
    }

    public function fetchType($fetchMode = 'FETCH_OBJ')
    {
        switch ($fetchMode) {
            case 'FETCH_ASSOC': $fetch = \PDO::FETCH_ASSOC; break;
            case 'FETCH_NUM': $fetch = \PDO::FETCH_NUM; break;
            case 'FETCH_BOTH': $fetch = \PDO::FETCH_BOTH; break;
            case 'FETCH_BOUND': $fetch = \PDO::FETCH_BOUND; break;
            case 'FETCH_CLASS': $fetch = \PDO::FETCH_CLASS; break;
            default: $fetch = \PDO::FETCH_OBJ;
        }

        return $fetch;
    }

    public function addAlias($tableName)
    {
        $tableAlias = '';

        if (stripos($tableName, ' as ') > 0) {
            $tblName = explode(' as ', $tableName);
            $tableAlias = ' AS '.$this->quote($tblName[1]);
            $tableName = $tblName[0];
        }

        return [$tableName, $tableAlias];
    }

    public function quote($field)
    {
        if (strpos($field, '.') !== false) {
            $field = str_replace('.', '`.`', $field);
        }

        return '`'.$field.'`';
    }
    public function enclose($field)
    {
        return "'".$field."'";
    }

    private function getQueryFields($fields, $tbl){
        $startQuery = join(', ', $fields);
        if (empty($fields)) {
            $startQuery = $this->quote($tbl).'.*';
        }

        return $startQuery;
    }

    private function buildLimitQuery($limit, $offset, $query = []){
      $limitQuery = [];
      if (!empty($limit)) {
          $query[] = 'LIMIT';

          if (!empty($offset)) {
              $query[] = $offset.',';
          }

          $query[] = $limit;
      }

      if (count($limitQuery)) {
          $query = array_merge($query, $limitQuery);
      }
      return $query;
    }

    public function query($query, $fetchRows){
      try {
          $obj = Connection::get()->query($this->queryPrefix($query), \PDO::FETCH_OBJ);

          if ($fetchRows == 'count') {
              $obj = $obj->fetchColumn();
          }

          return $obj;
      } catch (\PDOException $ex) {
          throw new \PDOException($ex->getMessage(), 1);
      } catch (Exception $e) {
          throw new Exception($e->getMessage(), 1);
      }
    }

    public function buildQuery(array $params)
    {
        $jqb    = new JoinQueryBuilder();
        $wqb    = new WhereQueryBuilder();

        $prefix = $this->getPrefix();
        $tblWithPrefix = $params['table'];
        $tbl    = str_replace($prefix, '', $tblWithPrefix);
        $query  = [];

        $query[] = 'SELECT';
        $query[] = $this->getQueryFields($params['fields'], $tbl);
        $query[] = 'FROM';
        $query[] = $this->quote($tblWithPrefix).' AS '.$this->quote($tbl);

        $query = $jqb->buildAllJoinQuery(
                                $params['join'],
                                $params['leftJoin'],
                                $params['rightJoin'],
                                $params['crossJoin'],
                                $query
                            );

        $query = $wqb->buildAllWhereQuery(
                                    $params['where'],
                                    $params['whereRaw'],
                                    $params['whereIn'],
                                    $params['whereNotIn'],
                                    $params['whereNull'],
                                    $params['whereNotNull'],
                                    $query
                                );

        if (!empty($params['groupBy'])) {
            $query[] = 'GROUP BY';
            $query[] = $params['groupBy'];
        }

        if (!empty($params['having'])) {
            $query[] = 'HAVING';
            $query[] = $params['having'];
        }

        if (!empty($params['orderBy'])) {
            $query[] = 'ORDER BY';
            $query[] = $params['orderBy'];
        }

        $query = $this->buildLimitQuery($params['limit'], $params['offset'], $query);

        return $query;
    }

    public function getFields(array $args, bool $quote = true): array{
        $fldAr = [];

        foreach ($args as $arg) {
            foreach (explode(',', $arg) as $ar) {
                $fldAr[] = ($quote === true) ? $this->quote(trim($ar)) : trim($ar);
            }
        }

        return $fldAr;
    }
}


1			<?php
2			/**
3			* The Query builder API.
4			*
5			* @author RN Kushwaha <[email protected]>
6			*
7			* @since v0.0.1 <Date: 16th April, 2019>
8			*/
9
10			namespace Dolphin\Builders;
11
12			use Dolphin\Connections\Connection;
13			use \Exception;
14
15			/**
16			* This class provides the mechanism to build the Queries.
17			*/
18			class QueryBuilder
19			{
20			protected $whereAdded = false;
21
22			public function queryPrefix($query)
23			{
24			return str_replace('#__', Connection::getPrefix(), $query);
25			}
26
27			public function getPrefix()
28			{
29			return Connection::getPrefix();
30			}
31
32			public function fetchType($fetchMode = 'FETCH_OBJ')
33			{
34			switch ($fetchMode) {
35			case 'FETCH_ASSOC': $fetch = \PDO::FETCH_ASSOC; break;
36			case 'FETCH_NUM': $fetch = \PDO::FETCH_NUM; break;
37			case 'FETCH_BOTH': $fetch = \PDO::FETCH_BOTH; break;
38			case 'FETCH_BOUND': $fetch = \PDO::FETCH_BOUND; break;
39			case 'FETCH_CLASS': $fetch = \PDO::FETCH_CLASS; break;
40			default: $fetch = \PDO::FETCH_OBJ;
41			}
42
43			return $fetch;
44			}
45
46			public function addAlias($tableName)
47			{
48			$tableAlias = '';
49
50			if (stripos($tableName, ' as ') > 0) {
51			$tblName = explode(' as ', $tableName);
52			$tableAlias = ' AS '.$this->quote($tblName[1]);
53			$tableName = $tblName[0];
54			}
55
56			return [$tableName, $tableAlias];
57			}
58
59			public function quote($field)
60			{
61			if (strpos($field, '.') !== false) {
62			$field = str_replace('.', '`.`', $field);
63			}
64
65			return '`'.$field.'`';
66			}
67			public function enclose($field)
68			{
69			return "'".$field."'";
70			}
71
72			private function getQueryFields($fields, $tbl){
73			$startQuery = join(', ', $fields);
74			if (empty($fields)) {
75			$startQuery = $this->quote($tbl).'.*';
76			}
77
78			return $startQuery;
79			}
80
81			private function buildLimitQuery($limit, $offset, $query = []){
82			$limitQuery = [];
83			if (!empty($limit)) {
84			$query[] = 'LIMIT';
85
86			if (!empty($offset)) {
87			$query[] = $offset.',';
88			}
89
90			$query[] = $limit;
91			}
92
93			if (count($limitQuery)) {
94			$query = array_merge($query, $limitQuery);
95			}
96			return $query;
97			}
98
99			public function query($query, $fetchRows){
100			try {
101			$obj = Connection::get()->query($this->queryPrefix($query), \PDO::FETCH_OBJ);
102
103			if ($fetchRows == 'count') {
104			$obj = $obj->fetchColumn();
105			}
106
107			return $obj;
108			} catch (\PDOException $ex) {
109			throw new \PDOException($ex->getMessage(), 1);
110			} catch (Exception $e) {
111			throw new Exception($e->getMessage(), 1);
112			}
113			}
114
115			public function buildQuery(array $params)
116			{
117			$jqb = new JoinQueryBuilder();
118			$wqb = new WhereQueryBuilder();
119
120			$prefix = $this->getPrefix();
121			$tblWithPrefix = $params['table'];
122			$tbl = str_replace($prefix, '', $tblWithPrefix);
123			$query = [];
124
125			$query[] = 'SELECT';
126			$query[] = $this->getQueryFields($params['fields'], $tbl);
127			$query[] = 'FROM';
128			$query[] = $this->quote($tblWithPrefix).' AS '.$this->quote($tbl);
129
130			$query = $jqb->buildAllJoinQuery(
131			$params['join'],
132			$params['leftJoin'],
133			$params['rightJoin'],
134			$params['crossJoin'],
135			$query
136			);
137
138			$query = $wqb->buildAllWhereQuery(
139			$params['where'],
140			$params['whereRaw'],
141			$params['whereIn'],
142			$params['whereNotIn'],
143			$params['whereNull'],
144			$params['whereNotNull'],
145			$query
146			);
147
148			if (!empty($params['groupBy'])) {
149			$query[] = 'GROUP BY';
150			$query[] = $params['groupBy'];
151			}
152
153			if (!empty($params['having'])) {
154			$query[] = 'HAVING';
155			$query[] = $params['having'];
156			}
157
158			if (!empty($params['orderBy'])) {
159			$query[] = 'ORDER BY';
160			$query[] = $params['orderBy'];
161			}
162
163			$query = $this->buildLimitQuery($params['limit'], $params['offset'], $query);
164
165			return $query;
166			}
167
168			public function getFields(array $args, bool $quote = true): array{
169			$fldAr = [];
170
171			foreach ($args as $arg) {
172			foreach (explode(',', $arg) as $ar) {
173			$fldAr[] = ($quote === true) ? $this->quote(trim($ar)) : trim($ar);
174			}
175			}
176
177			return $fldAr;
178			}
179			}
180

CruzerSoftwares / Dolphin

Push — master ( 2452cb...36c8a5 )

QueryBuilder::buildQuery() A

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like