1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
namespace Sofa\Eloquence\Query; |
4
|
|
|
|
5
|
|
|
use Sofa\Eloquence\Subquery; |
6
|
|
|
|
7
|
|
|
class Builder extends \Illuminate\Database\Query\Builder |
8
|
|
|
{ |
9
|
|
|
/** |
10
|
|
|
* Execute an aggregate function on the database. |
11
|
|
|
* |
12
|
|
|
* @param string $function |
13
|
|
|
* @param array $columns |
14
|
|
|
* @return float|int |
15
|
|
|
*/ |
16
|
|
|
public function aggregate($function, $columns = ['*']) |
17
|
|
|
{ |
18
|
|
|
$this->aggregate = compact('function', 'columns'); |
19
|
|
|
|
20
|
|
|
$previousColumns = $this->columns; |
21
|
|
|
|
22
|
|
|
if (!$this->from instanceof Subquery) { |
23
|
|
|
// We will also back up the select bindings since the select clause will be |
24
|
|
|
// removed when performing the aggregate function. Once the query is run |
25
|
|
|
// we will add the bindings back onto this query so they can get used. |
26
|
|
|
$previousSelectBindings = $this->bindings['select']; |
27
|
|
|
|
28
|
|
|
$this->bindings['select'] = []; |
29
|
|
|
} |
30
|
|
|
|
31
|
|
|
$results = $this->get($columns); |
32
|
|
|
|
33
|
|
|
// Once we have executed the query, we will reset the aggregate property so |
34
|
|
|
// that more select queries can be executed against the database without |
35
|
|
|
// the aggregate value getting in the way when the grammar builds it. |
36
|
|
|
$this->aggregate = null; |
|
|
|
|
37
|
|
|
|
38
|
|
|
$this->columns = $previousColumns; |
39
|
|
|
|
40
|
|
|
if (!$this->from instanceof Subquery) { |
41
|
|
|
$this->bindings['select'] = $previousSelectBindings; |
|
|
|
|
42
|
|
|
} |
43
|
|
|
|
44
|
|
|
if (isset($results[0])) { |
45
|
|
|
$result = array_change_key_case((array) $results[0]); |
46
|
|
|
|
47
|
|
|
return $result['aggregate']; |
48
|
|
|
} |
49
|
|
|
} |
50
|
|
|
|
51
|
|
|
/** |
52
|
|
|
* Backup some fields for the pagination count. |
53
|
|
|
* |
54
|
|
|
* @return void |
55
|
|
|
*/ |
56
|
|
|
protected function backupFieldsForCount() |
57
|
|
|
{ |
58
|
|
|
foreach (['orders', 'limit', 'offset', 'columns'] as $field) { |
59
|
|
|
$this->backups[$field] = $this->{$field}; |
|
|
|
|
60
|
|
|
|
61
|
|
|
$this->{$field} = null; |
62
|
|
|
} |
63
|
|
|
|
64
|
|
|
$bindings = ($this->from instanceof Subquery) ? ['order'] : ['order', 'select']; |
65
|
|
|
|
66
|
|
|
foreach ($bindings as $key) { |
67
|
|
|
$this->bindingBackups[$key] = $this->bindings[$key]; |
|
|
|
|
68
|
|
|
|
69
|
|
|
$this->bindings[$key] = []; |
70
|
|
|
} |
71
|
|
|
} |
72
|
|
|
|
73
|
|
|
/** |
74
|
|
|
* Restore some fields after the pagination count. |
75
|
|
|
* |
76
|
|
|
* @return void |
77
|
|
|
*/ |
78
|
|
|
protected function restoreFieldsForCount() |
79
|
|
|
{ |
80
|
|
|
foreach ($this->backups as $field => $value) { |
81
|
|
|
$this->{$field} = $value; |
82
|
|
|
} |
83
|
|
|
|
84
|
|
|
foreach ($this->bindingBackups as $key => $value) { |
|
|
|
|
85
|
|
|
$this->bindings[$key] = $value; |
86
|
|
|
} |
87
|
|
|
|
88
|
|
|
$this->backups = $this->bindingBackups = []; |
|
|
|
|
89
|
|
|
} |
90
|
|
|
|
91
|
|
|
/** |
92
|
|
|
* Run a pagination count query. |
93
|
|
|
* |
94
|
|
|
* @param array $columns |
95
|
|
|
* @return array |
96
|
|
|
*/ |
97
|
|
|
protected function runPaginationCountQuery($columns = ['*']) |
98
|
|
|
{ |
99
|
|
|
$bindings = $this->from instanceof Subquery ? ['order'] : ['select', 'order']; |
100
|
|
|
|
101
|
|
|
return $this->cloneWithout(['columns', 'orders', 'limit', 'offset']) |
102
|
|
|
->cloneWithoutBindings($bindings) |
103
|
|
|
->setAggregate('count', $this->withoutSelectAliases($columns)) |
104
|
|
|
->get()->all(); |
105
|
|
|
} |
106
|
|
|
} |
107
|
|
|
|
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..