DatabaseService::create() - Code Metrics - Inspection of "Merge branch '1.0' into 1.1" - SebastianBerc/Repositories - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.1 ( 79c689...9d0254 )

by Sebastian

created 2016-01-13 14:38 UTC

DatabaseService::create() A

↳ Parent: DatabaseService

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	4
ccs	2
cts	2
cp	1
rs	10
cc	1
eloc	2
nc	1
nop	1
crap	1

<?php

namespace SebastianBerc\Repositories\Services;

use Illuminate\Contracts\Container\Container as Application;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Database\Eloquent\Model as Eloquent;
use Illuminate\Pagination\LengthAwarePaginator;
use SebastianBerc\Repositories\Contracts\ServiceInterface;
use SebastianBerc\Repositories\Repository;
use SebastianBerc\Repositories\Traits\Filterable;
use SebastianBerc\Repositories\Traits\Sortable;

/**
 * Class DatabaseService.
 *
 * @author    Sebastian Berć <[email protected]>
 * @copyright Copyright (c) Sebastian Berć
 */
class DatabaseService implements ServiceInterface
{
    use Filterable, Sortable;

    /**
     * Contains Laravel Application instance.
     *
     * @var Application
     */
    protected $app;

    /**
     * Contains a repository instance.
     *
     * @var Repository
     */
    protected $repository;

    /**
     * Contains model instance for fetch, and simple fetch methods.
     *
     * @var mixed
     */
    protected $instance;

    /**
     * Create a new database service instance.
     *
     * @param Application $app
     * @param Repository  $repository
     */
    public function __construct(Application $app, Repository $repository)
    {
        $this->app        = $app;
        $this->repository = $repository;
    }

    /**
     * Get all of the models from the database.
     *
     * @param string[] $columns
     *
     * @return Collection
     */
    public function all(array $columns = ['*'])
    {
        return $this->repository->makeQuery()->get($columns);
    }

    /**
     * Create a new basic where query clause on model.
     *
     * @param string|array $column
     * @param string       $operator
     * @param mixed        $value
     * @param string       $boolean
     * @param string[]     $columns
     *
     * @return Collection
     */
    public function where($column, $operator = '=', $value = null, $boolean = 'and', array $columns = ['*'])
    {
        return $this->repository->makeQuery()->where($column, $operator, $value, $boolean, $columns)->get($columns);
    }

    /**
     * Paginate the given query.
     *
     * @param int      $perPage
     * @param string[] $columns
     *
     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
     */
    public function paginate($perPage = 15, array $columns = ['*'])
    {
        return $this->repository->makeQuery()->paginate($perPage, $columns);
    }

    /**
     * Save a new model and return the instance.
     *
     * @param array $attributes
     *
     * @return Eloquent
     */
    public function create(array $attributes = [])
    {
        return $this->repository->makeModel()->create($attributes);
    }

    /**
     * Save or update the model in the database.
     *
     * @param mixed $identifier
     * @param array $attributes
     *
     * @return Eloquent
     */
    public function update($identifier, array $attributes = [])
    {
        $instance = $identifier instanceof Eloquent
            ? $identifier
            : $this->repository->makeQuery()->findOrFail($identifier);

        $instance->fill($attributes);
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}

        if ($instance->isDirty()) {
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}
            $instance->save();
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}
        }

        return $instance;
    }

    /**
     * Delete the model from the database.
     *
     * @param int $identifier
     *
     * @return bool|null
     */
    public function delete($identifier)
    {
        return $this->repository->makeQuery()
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}
            ->findOrFail($identifier, [$this->repository->makeModel()->getKeyName()])
            ->delete();
    }

    /**
     * Find a model by its primary key.
     *
     * @param int      $identifier
     * @param string[] $columns
     *
     * @return Eloquent
     */
    public function find($identifier, array $columns = ['*'])
    {
        return $this->repository->makeQuery()->find($identifier, $columns);
    }

    /**
     * Find a model by its specified column and value.
     *
     * @param mixed    $column
     * @param mixed    $value
     * @param string[] $columns
     *
     * @return Eloquent
     */
    public function findBy($column, $value, array $columns = ['*'])
    {
        return $this->where([$column => $value], '=', null, 'and', $columns)->first();
    }

    /**
     * Find a model by its specified columns and values presented as array.
     *
     * @param array    $wheres
     * @param string[] $columns
     *
     * @return Eloquent
     */
    public function findWhere(array $wheres, array $columns = ['*'])
    {
        return $this->where($wheres, '=', null, 'and', $columns)->first();
    }

    /**
     * Find a models by its primary key.
     *
     * @param array    $identifiers
     * @param string[] $columns
     *
     * @return Collection
     */
    public function findMany($identifiers, array $columns = ['*'])
    {
        return $this->repository->makeQuery()->findMany($identifiers, $columns);
    }

    /**
     * Search the models in search of words in a given phrase to the specified columns.
     *
     * @param string $search
     * @param array  $columns
     * @param float  $threshold
     *
     * @return Builder
     */
    public function search($search, array $columns = [], $threshold = null)
    {
        $searchable = empty($columns) ? $columns : $this->repository->getSearchableFields();
        $service    = new SearchService($this->repository->makeQuery(), $searchable, $threshold);

        return $service->search($search);
    }

    /**
     * Returns total count of whole collection.
     *
     * @return int
     */
    public function count()
    {
        $countBy = "{$this->repository->makeModel()->getTable()}.{$this->repository->makeModel()->getKeyName()}";

        return $this->repository->makeQuery()->count($countBy);
    }

    /**
     * Fetch collection ordered and filtrated by specified columns for specified page as paginator.
     *
     * @param int    $page
     * @param int    $perPage
     * @param array  $columns
     * @param array  $filter
     * @param array  $sort
     * @param string $search
     *
     * @return LengthAwarePaginator
     */
    public function fetch(
        $page = 1,
        $perPage = 15,
        array $columns = ['*'],
        array $filter = [],
        array $sort = [],
        $search = null
    ) {
        if (empty($search)) {

            $this->instance = $this->repository->makeQuery();
            $this->multiFilterBy($filter)->multiSortBy($sort);
        } else {
            $this->instance = $this->repository->search($search);
        }

        $this->parseAliases($this->instance);

        $count = $this->countResults($this->instance);
        $items = $this->instance->forPage($page, $perPage)->get($columns);

        $options = [
            'path'  => $this->app->make('request')->url(),
            'query' => compact('page', 'perPage'),
        ];

        return new LengthAwarePaginator($items, $count, $perPage, $page, $options);
    }

    /**
     * Fetch collection ordered and filtrated by specified columns for specified page.
     *
     * @param int    $page
     * @param int    $perPage
     * @param array  $columns
     * @param array  $filter
     * @param array  $sort
     * @param string $search
     *
     * @return Collection
     */
    public function simpleFetch(
        $page = 1,
        $perPage = 15,
        array $columns = ['*'],
        array $filter = [],
        array $sort = [],
        $search = null
    ) {
        if (is_null($search)) {

            $this->instance = $this->repository->makeQuery();
            $this->multiFilterBy($filter)->multiSortBy($sort);
        } else {
            $this->instance = $this->repository->search($search);
        }

        $this->parseAliases($this->instance);

        return $this->instance->forPage($page, $perPage)->get($columns);
    }

    /**
     * Counts results for given query.
     *
     * @param Builder $query
     *
     * @return int
     */
    protected function countResults(Builder $query)
    {
        $query = clone $query;

        $query->getQuery()->aggregate = ['function' => 'count', 'columns' => $columns = ['*']];
        $query->getQuery()->orders    = null;


        $results = $query->getQuery()->get($columns);

        if (isset($results[0])) {
            return array_change_key_case((array) $results[0])['aggregate'];
        }
    }

    /**
     * Replace alias name in where closure with sub-queries from select.
     *
     * Example:
     *
     * SELECT table.*, (SELECT 1 FROM other_table ot WHERE ot.id = table.id) AS exists
     * WHERE exists = 1;
     *
     * Will be converted to:
     *
     * SELECT table.*, (SELECT 1 FROM other_table ot WHERE ot.id = table.id) AS exists
     * WHERE (SELECT 1 FROM other_table ot WHERE ot.id = table.id) = 1;
     *
     * @param Builder $query
     *
     * @return Builder
     */
    protected function parseAliases(Builder $query)
    {
        $aliases = [];

        if (!empty($query->getQuery()->columns)) {
            $aliases = $this->getAliases($query);
        }

        if (!empty($aliases) && !empty($query->getQuery()->wheres)) {
            $this->replaceAliases($query, $aliases);
        }

        return $query;
    }

    /**
     * Get sub queries and aliases from select statement.
     *
     * @param Builder $query
     *
     * @return array
     */
    protected function getAliases(Builder $query)
    {
        $aliases = [];

        foreach ($query->getQuery()->columns as $column) {
            if (preg_match("~AS (\w+)~i", $column, $matches)) {
                $aliases[$matches[1]] = \DB::raw(str_replace($matches[0], '', $column));
            }
        }

        return $aliases;
    }

    /**
     * Replace aliases in where statement with sub queries.
     *
     * @param Builder $query
     * @param array   $aliases
     *
     * @return void
     */
    protected function replaceAliases(Builder $query, $aliases)
    {
        foreach ($query->getQuery()->wheres as $key => $value) {
            if (in_array($value['column'], array_keys($aliases))) {
                $query->getQuery()->wheres[$key]['column'] = $aliases[$value['column']];
            }
        }
    }
}


GitHub Access Token became invalid

Push — 1.1 ( 79c689...9d0254 )

DatabaseService::create() A

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Available Fixes

Available Fixes

1			<?php
2
3			namespace SebastianBerc\Repositories\Services;
4
5			use Illuminate\Contracts\Container\Container as Application;
6			use Illuminate\Database\Eloquent\Builder;
7			use Illuminate\Database\Eloquent\Collection;
8			use Illuminate\Database\Eloquent\Model as Eloquent;
9			use Illuminate\Pagination\LengthAwarePaginator;
10			use SebastianBerc\Repositories\Contracts\ServiceInterface;
11			use SebastianBerc\Repositories\Repository;
12			use SebastianBerc\Repositories\Traits\Filterable;
13			use SebastianBerc\Repositories\Traits\Sortable;
14
15			/**
16			* Class DatabaseService.
17			*
18			* @author Sebastian Berć <[email protected]>
19			* @copyright Copyright (c) Sebastian Berć
20			*/
21			class DatabaseService implements ServiceInterface
22			{
23			use Filterable, Sortable;
24
25			/**
26			* Contains Laravel Application instance.
27			*
28			* @var Application
29			*/
30			protected $app;
31
32			/**
33			* Contains a repository instance.
34			*
35			* @var Repository
36			*/
37			protected $repository;
38
39			/**
40			* Contains model instance for fetch, and simple fetch methods.
41			*
42			* @var mixed
43			*/
44			protected $instance;
45
46			/**
47			* Create a new database service instance.
48			*
49			* @param Application $app
50			* @param Repository $repository
51			*/
52	120		public function __construct(Application $app, Repository $repository)
53			{
54	120		$this->app = $app;
55	120		$this->repository = $repository;
56	120		}
57
58			/**
59			* Get all of the models from the database.
60			*
61			* @param string[] $columns
62			*
63			* @return Collection
64			*/
65	12		public function all(array $columns = ['*'])
66			{
67	12		return $this->repository->makeQuery()->get($columns);
68			}
69
70			/**
71			* Create a new basic where query clause on model.
72			*
73			* @param string\|array $column
74			* @param string $operator
75			* @param mixed $value
76			* @param string $boolean
77			* @param string[] $columns
78			*
79			* @return Collection
80			*/
81	20		public function where($column, $operator = '=', $value = null, $boolean = 'and', array $columns = ['*'])
82			{
83	20		return $this->repository->makeQuery()->where($column, $operator, $value, $boolean, $columns)->get($columns);
84			}
85
86			/**
87			* Paginate the given query.
88			*
89			* @param int $perPage
90			* @param string[] $columns
91			*
92			* @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
93			*/
94	8		public function paginate($perPage = 15, array $columns = ['*'])
95			{
96	8		return $this->repository->makeQuery()->paginate($perPage, $columns);
97			}
98
99			/**
100			* Save a new model and return the instance.
101			*
102			* @param array $attributes
103			*
104			* @return Eloquent
105			*/
106	6		public function create(array $attributes = [])
107			{
108	6		return $this->repository->makeModel()->create($attributes);
109			}
110
111			/**
112			* Save or update the model in the database.
113			*
114			* @param mixed $identifier
115			* @param array $attributes
116			*
117			* @return Eloquent
118			*/
119	6		public function update($identifier, array $attributes = [])
120			{
121			$instance = $identifier instanceof Eloquent
122	6		? $identifier
123	6		: $this->repository->makeQuery()->findOrFail($identifier);
124
125	6		$instance->fill($attributes);
			0 ignored issues – show Bug introduced 2015-11-25 16:47 UTC by Report Bug Copy Issue Report The method `fill` does only exist in `Illuminate\Database\Eloquent\Model`, but not in `Illuminate\Database\Eloq...ase\Eloquent\Collection`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
126
127	6		if ($instance->isDirty()) {
			0 ignored issues – show Bug introduced 2015-11-25 16:47 UTC by Report Bug Copy Issue Report The method `isDirty` does only exist in `Illuminate\Database\Eloquent\Model`, but not in `Illuminate\Database\Eloq...ase\Eloquent\Collection`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
128	6		$instance->save();
			0 ignored issues – show Bug introduced 2015-11-25 16:47 UTC by Report Bug Copy Issue Report The method `save` does only exist in `Illuminate\Database\Eloquent\Model`, but not in `Illuminate\Database\Eloq...ase\Eloquent\Collection`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
129	6		}
130
131	6		return $instance;
132			}
133
134			/**
135			* Delete the model from the database.
136			*
137			* @param int $identifier
138			*
139			* @return bool\|null
140			*/
141	6		public function delete($identifier)
142			{
143	6		return $this->repository->makeQuery()
			0 ignored issues – show Bug introduced 2015-11-25 22:26 UTC by Report Bug Copy Issue Report The method `delete` does only exist in `Illuminate\Database\Eloq...Database\Eloquent\Model`, but not in `Illuminate\Database\Eloquent\Collection`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
144	6		->findOrFail($identifier, [$this->repository->makeModel()->getKeyName()])
145	6		->delete();
146			}
147
148			/**
149			* Find a model by its primary key.
150			*
151			* @param int $identifier
152			* @param string[] $columns
153			*
154			* @return Eloquent
155			*/
156	28		public function find($identifier, array $columns = ['*'])
157			{
158	28		return $this->repository->makeQuery()->find($identifier, $columns);
159			}
160
161			/**
162			* Find a model by its specified column and value.
163			*
164			* @param mixed $column
165			* @param mixed $value
166			* @param string[] $columns
167			*
168			* @return Eloquent
169			*/
170	8		public function findBy($column, $value, array $columns = ['*'])
171			{
172	8		return $this->where([$column => $value], '=', null, 'and', $columns)->first();
173			}
174
175			/**
176			* Find a model by its specified columns and values presented as array.
177			*
178			* @param array $wheres
179			* @param string[] $columns
180			*
181			* @return Eloquent
182			*/
183	8		public function findWhere(array $wheres, array $columns = ['*'])
184			{
185	8		return $this->where($wheres, '=', null, 'and', $columns)->first();
186			}
187
188			/**
189			* Find a models by its primary key.
190			*
191			* @param array $identifiers
192			* @param string[] $columns
193			*
194			* @return Collection
195			*/
196			public function findMany($identifiers, array $columns = ['*'])
197			{
198			return $this->repository->makeQuery()->findMany($identifiers, $columns);
199			}
200
201			/**
202			* Search the models in search of words in a given phrase to the specified columns.
203			*
204			* @param string $search
205			* @param array $columns
206			* @param float $threshold
207			*
208			* @return Builder
209			*/
210			public function search($search, array $columns = [], $threshold = null)
211			{
212			$searchable = empty($columns) ? $columns : $this->repository->getSearchableFields();
213			$service = new SearchService($this->repository->makeQuery(), $searchable, $threshold);
214
215			return $service->search($search);
216			}
217
218			/**
219			* Returns total count of whole collection.
220			*
221			* @return int
222			*/
223	4		public function count()
224			{
225	4		$countBy = "{$this->repository->makeModel()->getTable()}.{$this->repository->makeModel()->getKeyName()}";
226
227	4		return $this->repository->makeQuery()->count($countBy);
228			}
229
230			/**
231			* Fetch collection ordered and filtrated by specified columns for specified page as paginator.
232			*
233			* @param int $page
234			* @param int $perPage
235			* @param array $columns
236			* @param array $filter
237			* @param array $sort
238			* @param string $search
239			*
240			* @return LengthAwarePaginator
241			*/
242	12		public function fetch(
243			$page = 1,
244			$perPage = 15,
245			array $columns = ['*'],
246			array $filter = [],
247			array $sort = [],
248			$search = null
249			) {
250	12	View Code Duplication	if (empty($search)) {
			0 ignored issues – show Duplication introduced 2015-11-25 22:47 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...
251	12		$this->instance = $this->repository->makeQuery();
252	12		$this->multiFilterBy($filter)->multiSortBy($sort);
253	12		} else {
254			$this->instance = $this->repository->search($search);
255	2		}
256
257	12		$this->parseAliases($this->instance);
258
259	12		$count = $this->countResults($this->instance);
260	12		$items = $this->instance->forPage($page, $perPage)->get($columns);
261
262			$options = [
263	12		'path' => $this->app->make('request')->url(),
264	12		'query' => compact('page', 'perPage'),
265	12		];
266
267	12		return new LengthAwarePaginator($items, $count, $perPage, $page, $options);
268			}
269
270			/**
271			* Fetch collection ordered and filtrated by specified columns for specified page.
272			*
273			* @param int $page
274			* @param int $perPage
275			* @param array $columns
276			* @param array $filter
277			* @param array $sort
278			* @param string $search
279			*
280			* @return Collection
281			*/
282	4		public function simpleFetch(
283			$page = 1,
284			$perPage = 15,
285			array $columns = ['*'],
286			array $filter = [],
287			array $sort = [],
288			$search = null
289			) {
290	4	View Code Duplication	if (is_null($search)) {
			0 ignored issues – show Duplication introduced 2015-11-25 22:47 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...
291	4		$this->instance = $this->repository->makeQuery();
292	4		$this->multiFilterBy($filter)->multiSortBy($sort);
293	4		} else {
294			$this->instance = $this->repository->search($search);
295			}
296
297	4		$this->parseAliases($this->instance);
298
299	4		return $this->instance->forPage($page, $perPage)->get($columns);
300			}
301
302			/**
303			* Counts results for given query.
304			*
305			* @param Builder $query
306			*
307			* @return int
308			*/
309	12		protected function countResults(Builder $query)
310			{
311	12		$query = clone $query;
312
313	12		$query->getQuery()->aggregate = ['function' => 'count', 'columns' => $columns = ['*']];
314	12		$query->getQuery()->orders = null;
			0 ignored issues – show Documentation Bug introduced 2015-11-25 22:47 UTC by Report Bug Copy Issue Report It seems like `null` of type `null` is incompatible with the declared type `array` of property `$orders`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
315
316	12		$results = $query->getQuery()->get($columns);
317
318	12		if (isset($results[0])) {
319	12		return array_change_key_case((array) $results[0])['aggregate'];
320			}
321			}
322
323			/**
324			* Replace alias name in where closure with sub-queries from select.
325			*
326			* Example:
327			*
328			* SELECT table.*, (SELECT 1 FROM other_table ot WHERE ot.id = table.id) AS exists
329			* WHERE exists = 1;
330			*
331			* Will be converted to:
332			*
333			* SELECT table.*, (SELECT 1 FROM other_table ot WHERE ot.id = table.id) AS exists
334			* WHERE (SELECT 1 FROM other_table ot WHERE ot.id = table.id) = 1;
335			*
336			* @param Builder $query
337			*
338			* @return Builder
339			*/
340	16		protected function parseAliases(Builder $query)
341			{
342	16		$aliases = [];
343
344	16		if (!empty($query->getQuery()->columns)) {
345	2		$aliases = $this->getAliases($query);
346	2		}
347
348	16		if (!empty($aliases) && !empty($query->getQuery()->wheres)) {
349			$this->replaceAliases($query, $aliases);
350			}
351
352	16		return $query;
353			}
354
355			/**
356			* Get sub queries and aliases from select statement.
357			*
358			* @param Builder $query
359			*
360			* @return array
361			*/
362	2		protected function getAliases(Builder $query)
363			{
364	2		$aliases = [];
365
366	2		foreach ($query->getQuery()->columns as $column) {
367	2		if (preg_match("~AS (\w+)~i", $column, $matches)) {
368			$aliases[$matches[1]] = \DB::raw(str_replace($matches[0], '', $column));
369			}
370	2		}
371
372	2		return $aliases;
373			}
374
375			/**
376			* Replace aliases in where statement with sub queries.
377			*
378			* @param Builder $query
379			* @param array $aliases
380			*
381			* @return void
382			*/
383			protected function replaceAliases(Builder $query, $aliases)
384			{
385			foreach ($query->getQuery()->wheres as $key => $value) {
386			if (in_array($value['column'], array_keys($aliases))) {
387			$query->getQuery()->wheres[$key]['column'] = $aliases[$value['column']];
388			}
389			}
390			}
391			}
392

SebastianBerc / Repositories

GitHub Access Token became invalid

Push — 1.1 ( 79c689...9d0254 )

DatabaseService::create() A

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like