@@ -12,7 +12,7 @@ discard block |
||
12 | 12 | * @param scalar[] $values |
13 | 13 | * @return Value |
14 | 14 | */ |
15 | - public function coalesce (array $values) { |
|
15 | + public function coalesce(array $values) { |
|
16 | 16 | array_unshift($values, $this); |
17 | 17 | $values = $this->db->quoteList($values); |
18 | 18 | return Value::factory($this->db, "COALESCE({$values})"); |
@@ -25,7 +25,7 @@ discard block |
||
25 | 25 | * @param int $to |
26 | 26 | * @return Text |
27 | 27 | */ |
28 | - public function toBase (int $from, int $to) { |
|
28 | + public function toBase(int $from, int $to) { |
|
29 | 29 | return Text::factory($this->db, "CONV({$this},{$from},{$to})"); |
30 | 30 | } |
31 | 31 | |
@@ -35,7 +35,7 @@ discard block |
||
35 | 35 | * @param int $from |
36 | 36 | * @return Num |
37 | 37 | */ |
38 | - public function toBase10 (int $from) { |
|
38 | + public function toBase10(int $from) { |
|
39 | 39 | return Num::factory($this->db, "CONV({$this},{$from},10)"); |
40 | 40 | } |
41 | 41 | |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | * @param int $from |
48 | 48 | * @return Text |
49 | 49 | */ |
50 | - public function toBase16 (int $from) { |
|
50 | + public function toBase16(int $from) { |
|
51 | 51 | return $this->toBase($from, 16); |
52 | 52 | } |
53 | 53 | |
@@ -57,7 +57,7 @@ discard block |
||
57 | 57 | * @param int $from |
58 | 58 | * @return Text |
59 | 59 | */ |
60 | - public function toBase2 (int $from) { |
|
60 | + public function toBase2(int $from) { |
|
61 | 61 | return $this->toBase($from, 2); |
62 | 62 | } |
63 | 63 | |
@@ -67,7 +67,7 @@ discard block |
||
67 | 67 | * @param int $from |
68 | 68 | * @return Text |
69 | 69 | */ |
70 | - public function toBase8 (int $from) { |
|
70 | + public function toBase8(int $from) { |
|
71 | 71 | return $this->toBase($from, 8); |
72 | 72 | } |
73 | 73 | |
@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | * |
77 | 77 | * @return Num |
78 | 78 | */ |
79 | - public function toFloat () { |
|
79 | + public function toFloat() { |
|
80 | 80 | if ($this->db->isSQLite()) { |
81 | 81 | return Num::factory($this->db, "CAST({$this} AS REAL)"); |
82 | 82 | } |
@@ -88,7 +88,7 @@ discard block |
||
88 | 88 | * |
89 | 89 | * @return Num |
90 | 90 | */ |
91 | - public function toInt () { |
|
91 | + public function toInt() { |
|
92 | 92 | if ($this->db->isSQLite()) { |
93 | 93 | return Num::factory($this->db, "CAST({$this} AS INTEGER)"); |
94 | 94 | } |
@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | * |
101 | 101 | * @return Text |
102 | 102 | */ |
103 | - public function toText () { |
|
103 | + public function toText() { |
|
104 | 104 | if ($this->db->isSQLite()) { |
105 | 105 | return Text::factory($this->db, "CAST({$this} AS TEXT)"); |
106 | 106 | } |
@@ -25,7 +25,7 @@ discard block |
||
25 | 25 | * @return Predicate |
26 | 26 | * @internal |
27 | 27 | */ |
28 | - protected function _isRelational ($arg, string $oper, string $multi) { |
|
28 | + protected function _isRelational($arg, string $oper, string $multi) { |
|
29 | 29 | static $inverse = [ |
30 | 30 | '<' => '>=', |
31 | 31 | '<=' => '>', |
@@ -54,7 +54,7 @@ discard block |
||
54 | 54 | * @param null|scalar|Select $arg |
55 | 55 | * @return Predicate |
56 | 56 | */ |
57 | - public function is ($arg): Predicate { |
|
57 | + public function is($arg): Predicate { |
|
58 | 58 | if ($arg instanceof Select) { |
59 | 59 | if ($this->db->isSQLite()) { |
60 | 60 | return Select::factory($this->db, $arg, [$arg[0]]) |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | * @param number $max |
83 | 83 | * @return Predicate |
84 | 84 | */ |
85 | - public function isBetween ($min, $max) { |
|
85 | + public function isBetween($min, $max) { |
|
86 | 86 | $min = $this->db->quote($min); |
87 | 87 | $max = $this->db->quote($max); |
88 | 88 | return Predicate::factory($this->db, "{$this} BETWEEN {$min} AND {$max}"); |
@@ -94,7 +94,7 @@ discard block |
||
94 | 94 | * @param scalar|array|Select $arg |
95 | 95 | * @return Predicate |
96 | 96 | */ |
97 | - public function isEqual ($arg) { |
|
97 | + public function isEqual($arg) { |
|
98 | 98 | return $this->db->match($this, $arg); |
99 | 99 | } |
100 | 100 | |
@@ -103,7 +103,7 @@ discard block |
||
103 | 103 | * |
104 | 104 | * @return Predicate |
105 | 105 | */ |
106 | - public function isFalse () { |
|
106 | + public function isFalse() { |
|
107 | 107 | return Predicate::factory($this->db, "{$this} IS FALSE"); |
108 | 108 | } |
109 | 109 | |
@@ -113,7 +113,7 @@ discard block |
||
113 | 113 | * @param number|string|Select $arg |
114 | 114 | * @return Predicate |
115 | 115 | */ |
116 | - public function isGt ($arg) { |
|
116 | + public function isGt($arg) { |
|
117 | 117 | return $this->_isRelational($arg, '>', 'ALL'); |
118 | 118 | } |
119 | 119 | |
@@ -123,7 +123,7 @@ discard block |
||
123 | 123 | * @param Select $select |
124 | 124 | * @return Predicate |
125 | 125 | */ |
126 | - public function isGtAny (Select $select) { |
|
126 | + public function isGtAny(Select $select) { |
|
127 | 127 | return $this->_isRelational($select, '>', 'ANY'); |
128 | 128 | } |
129 | 129 | |
@@ -133,7 +133,7 @@ discard block |
||
133 | 133 | * @param number|string|Select $arg |
134 | 134 | * @return Predicate |
135 | 135 | */ |
136 | - public function isGte ($arg) { |
|
136 | + public function isGte($arg) { |
|
137 | 137 | return $this->_isRelational($arg, '>=', 'ALL'); |
138 | 138 | } |
139 | 139 | |
@@ -143,7 +143,7 @@ discard block |
||
143 | 143 | * @param Select $select |
144 | 144 | * @return Predicate |
145 | 145 | */ |
146 | - public function isGteAny (Select $select) { |
|
146 | + public function isGteAny(Select $select) { |
|
147 | 147 | return $this->_isRelational($select, '>=', 'ANY'); |
148 | 148 | } |
149 | 149 | |
@@ -153,7 +153,7 @@ discard block |
||
153 | 153 | * @param string $pattern |
154 | 154 | * @return Predicate |
155 | 155 | */ |
156 | - public function isLike (string $pattern) { |
|
156 | + public function isLike(string $pattern) { |
|
157 | 157 | $pattern = $this->db->quote($pattern); |
158 | 158 | return Predicate::factory($this->db, "{$this} LIKE {$pattern}"); |
159 | 159 | } |
@@ -164,7 +164,7 @@ discard block |
||
164 | 164 | * @param number|string|Select $arg |
165 | 165 | * @return Predicate |
166 | 166 | */ |
167 | - public function isLt ($arg) { |
|
167 | + public function isLt($arg) { |
|
168 | 168 | return $this->_isRelational($arg, '<', 'ALL'); |
169 | 169 | } |
170 | 170 | |
@@ -174,7 +174,7 @@ discard block |
||
174 | 174 | * @param Select $select |
175 | 175 | * @return Predicate |
176 | 176 | */ |
177 | - public function isLtAny (Select $select) { |
|
177 | + public function isLtAny(Select $select) { |
|
178 | 178 | return $this->_isRelational($select, '<', 'ANY'); |
179 | 179 | } |
180 | 180 | |
@@ -184,7 +184,7 @@ discard block |
||
184 | 184 | * @param number|string|Select $arg |
185 | 185 | * @return Predicate |
186 | 186 | */ |
187 | - public function isLte ($arg) { |
|
187 | + public function isLte($arg) { |
|
188 | 188 | return $this->_isRelational($arg, '<=', 'ALL'); |
189 | 189 | } |
190 | 190 | |
@@ -194,7 +194,7 @@ discard block |
||
194 | 194 | * @param Select $select |
195 | 195 | * @return Predicate |
196 | 196 | */ |
197 | - public function isLteAny (Select $select) { |
|
197 | + public function isLteAny(Select $select) { |
|
198 | 198 | return $this->_isRelational($select, '<=', 'ANY'); |
199 | 199 | } |
200 | 200 | |
@@ -204,7 +204,7 @@ discard block |
||
204 | 204 | * @param null|scalar|Select $arg |
205 | 205 | * @return Predicate |
206 | 206 | */ |
207 | - public function isNot ($arg) { |
|
207 | + public function isNot($arg) { |
|
208 | 208 | return $this->is($arg)->not(); |
209 | 209 | } |
210 | 210 | |
@@ -215,7 +215,7 @@ discard block |
||
215 | 215 | * @param number $max |
216 | 216 | * @return Predicate |
217 | 217 | */ |
218 | - public function isNotBetween ($min, $max) { |
|
218 | + public function isNotBetween($min, $max) { |
|
219 | 219 | $min = $this->db->quote($min); |
220 | 220 | $max = $this->db->quote($max); |
221 | 221 | return Predicate::factory($this->db, "{$this} NOT BETWEEN {$min} AND {$max}"); |
@@ -227,7 +227,7 @@ discard block |
||
227 | 227 | * @param scalar|array|Select $arg |
228 | 228 | * @return Predicate |
229 | 229 | */ |
230 | - public function isNotEqual ($arg) { |
|
230 | + public function isNotEqual($arg) { |
|
231 | 231 | if ($arg instanceof Select) { |
232 | 232 | return Predicate::factory($this->db, "{$this} NOT IN ({$arg->toSql()})"); |
233 | 233 | } |
@@ -243,7 +243,7 @@ discard block |
||
243 | 243 | * @param string $pattern |
244 | 244 | * @return Predicate |
245 | 245 | */ |
246 | - public function isNotLike (string $pattern) { |
|
246 | + public function isNotLike(string $pattern) { |
|
247 | 247 | $pattern = $this->db->quote($pattern); |
248 | 248 | return Predicate::factory($this->db, "{$this} NOT LIKE {$pattern}"); |
249 | 249 | } |
@@ -253,7 +253,7 @@ discard block |
||
253 | 253 | * |
254 | 254 | * @return Predicate |
255 | 255 | */ |
256 | - public function isNotNull () { |
|
256 | + public function isNotNull() { |
|
257 | 257 | return Predicate::factory($this->db, "{$this} IS NOT NULL"); |
258 | 258 | } |
259 | 259 | |
@@ -263,7 +263,7 @@ discard block |
||
263 | 263 | * @param string $pattern |
264 | 264 | * @return Predicate |
265 | 265 | */ |
266 | - public function isNotRegExp (string $pattern) { |
|
266 | + public function isNotRegExp(string $pattern) { |
|
267 | 267 | $pattern = $this->db->quote($pattern); |
268 | 268 | return Predicate::factory($this->db, "{$this} NOT REGEXP {$pattern}"); |
269 | 269 | } |
@@ -273,7 +273,7 @@ discard block |
||
273 | 273 | * |
274 | 274 | * @return Predicate |
275 | 275 | */ |
276 | - public function isNull () { |
|
276 | + public function isNull() { |
|
277 | 277 | return Predicate::factory($this->db, "{$this} IS NULL"); |
278 | 278 | } |
279 | 279 | |
@@ -283,7 +283,7 @@ discard block |
||
283 | 283 | * @param string $pattern |
284 | 284 | * @return Predicate |
285 | 285 | */ |
286 | - public function isRegExp (string $pattern) { |
|
286 | + public function isRegExp(string $pattern) { |
|
287 | 287 | $pattern = $this->db->quote($pattern); |
288 | 288 | return Predicate::factory($this->db, "{$this} REGEXP {$pattern}"); |
289 | 289 | } |
@@ -33,7 +33,7 @@ discard block |
||
33 | 33 | * |
34 | 34 | * @param DB $db |
35 | 35 | */ |
36 | - public function __construct (DB $db) { |
|
36 | + public function __construct(DB $db) { |
|
37 | 37 | $this->db = $db; |
38 | 38 | $db->beginTransaction(); |
39 | 39 | } |
@@ -41,7 +41,7 @@ discard block |
||
41 | 41 | /** |
42 | 42 | * Rolls back if the instance wasn't committed. |
43 | 43 | */ |
44 | - public function __destruct () { |
|
44 | + public function __destruct() { |
|
45 | 45 | if (!$this->committed) { |
46 | 46 | $this->db->rollBack(); |
47 | 47 | } |
@@ -54,14 +54,14 @@ discard block |
||
54 | 54 | * |
55 | 55 | * @return true |
56 | 56 | */ |
57 | - public function commit (): bool { |
|
57 | + public function commit(): bool { |
|
58 | 58 | return $this->committed or $this->committed = $this->db->commit(); |
59 | 59 | } |
60 | 60 | |
61 | 61 | /** |
62 | 62 | * @return bool |
63 | 63 | */ |
64 | - final public function wasCommitted (): bool { |
|
64 | + final public function wasCommitted(): bool { |
|
65 | 65 | return $this->committed; |
66 | 66 | } |
67 | 67 | } |
68 | 68 | \ No newline at end of file |
@@ -42,7 +42,7 @@ discard block |
||
42 | 42 | * @param string $name |
43 | 43 | * @param string[] $columns |
44 | 44 | */ |
45 | - public function __construct (DB $db, string $name, array $columns) { |
|
45 | + public function __construct(DB $db, string $name, array $columns) { |
|
46 | 46 | parent::__construct($db); |
47 | 47 | $this->name = $name; |
48 | 48 | foreach ($columns as $column) { |
@@ -55,7 +55,7 @@ discard block |
||
55 | 55 | * |
56 | 56 | * @return string |
57 | 57 | */ |
58 | - final public function __toString () { |
|
58 | + final public function __toString() { |
|
59 | 59 | return $this->name; |
60 | 60 | } |
61 | 61 | |
@@ -65,7 +65,7 @@ discard block |
||
65 | 65 | * @param array $values |
66 | 66 | * @return int Rows affected. |
67 | 67 | */ |
68 | - public function apply (array $values): int { |
|
68 | + public function apply(array $values): int { |
|
69 | 69 | $columns = implode(',', array_keys($values)); |
70 | 70 | $values = $this->db->quoteList($values); |
71 | 71 | if ($this->db->isSQLite()) { |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | * @param Closure $prepare `():Statement` |
86 | 86 | * @return Statement |
87 | 87 | */ |
88 | - protected function cache (string $key, Closure $prepare) { |
|
88 | + protected function cache(string $key, Closure $prepare) { |
|
89 | 89 | return $this->_cache[$key] ??= $prepare->__invoke(); |
90 | 90 | } |
91 | 91 | |
@@ -93,7 +93,7 @@ discard block |
||
93 | 93 | * @param array $match `[a => b]` |
94 | 94 | * @return int |
95 | 95 | */ |
96 | - public function count (array $match = []) { |
|
96 | + public function count(array $match = []) { |
|
97 | 97 | $select = $this->select(['COUNT(*)']); |
98 | 98 | foreach ($match as $a => $b) { |
99 | 99 | $select->where($this->db->match($this[$a] ?? $a, $b)); |
@@ -109,7 +109,7 @@ discard block |
||
109 | 109 | * @param array $match |
110 | 110 | * @return int Rows affected. |
111 | 111 | */ |
112 | - public function delete (array $match): int { |
|
112 | + public function delete(array $match): int { |
|
113 | 113 | foreach ($match as $a => $b) { |
114 | 114 | $match[$a] = $this->db->match($this[$a] ?? $a, $b); |
115 | 115 | } |
@@ -120,14 +120,14 @@ discard block |
||
120 | 120 | /** |
121 | 121 | * @return Column[] |
122 | 122 | */ |
123 | - public function getColumns () { |
|
123 | + public function getColumns() { |
|
124 | 124 | return $this->columns; |
125 | 125 | } |
126 | 126 | |
127 | 127 | /** |
128 | 128 | * @return string |
129 | 129 | */ |
130 | - final public function getName (): string { |
|
130 | + final public function getName(): string { |
|
131 | 131 | return $this->name; |
132 | 132 | } |
133 | 133 | |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | * @param array $values |
138 | 138 | * @return Statement |
139 | 139 | */ |
140 | - public function insert (array $values) { |
|
140 | + public function insert(array $values) { |
|
141 | 141 | $columns = implode(',', array_keys($values)); |
142 | 142 | $values = $this->db->quoteList($values); |
143 | 143 | return $this->db->query("INSERT INTO {$this} ($columns) VALUES ($values)"); |
@@ -147,7 +147,7 @@ discard block |
||
147 | 147 | * @param int|string $column |
148 | 148 | * @return Column |
149 | 149 | */ |
150 | - public function offsetGet ($column) { |
|
150 | + public function offsetGet($column) { |
|
151 | 151 | if (is_int($column)) { |
152 | 152 | return current(array_slice($this->columns, $column, 1)) ?: null; |
153 | 153 | } |
@@ -160,7 +160,7 @@ discard block |
||
160 | 160 | * @param string[] $columns |
161 | 161 | * @return Select|array[] |
162 | 162 | */ |
163 | - public function select (array $columns = ['*']) { |
|
163 | + public function select(array $columns = ['*']) { |
|
164 | 164 | return Select::factory($this->db, $this, $columns); |
165 | 165 | } |
166 | 166 | |
@@ -170,7 +170,7 @@ discard block |
||
170 | 170 | * @param string $name |
171 | 171 | * @return Table |
172 | 172 | */ |
173 | - public function setName (string $name) { |
|
173 | + public function setName(string $name) { |
|
174 | 174 | $clone = clone $this; |
175 | 175 | $clone->name = $name; |
176 | 176 | foreach ($this->columns as $name => $column) { |
@@ -188,7 +188,7 @@ discard block |
||
188 | 188 | * @param array $match |
189 | 189 | * @return int Rows affected. |
190 | 190 | */ |
191 | - public function update (array $values, array $match): int { |
|
191 | + public function update(array $values, array $match): int { |
|
192 | 192 | foreach ($this->db->quoteArray($values) as $key => $value) { |
193 | 193 | $values[$key] = "{$key} = {$value}"; |
194 | 194 | } |
@@ -16,20 +16,20 @@ discard block |
||
16 | 16 | * |
17 | 17 | * @return string |
18 | 18 | */ |
19 | - abstract public function __toString (); |
|
19 | + abstract public function __toString(); |
|
20 | 20 | |
21 | 21 | /** |
22 | 22 | * Columns keyed by name/alias. |
23 | 23 | * |
24 | 24 | * @return Column[] |
25 | 25 | */ |
26 | - abstract public function getColumns (); |
|
26 | + abstract public function getColumns(); |
|
27 | 27 | |
28 | 28 | /** |
29 | 29 | * @param int|string $column |
30 | 30 | * @return null|Column |
31 | 31 | */ |
32 | - abstract public function offsetGet ($column); |
|
32 | + abstract public function offsetGet($column); |
|
33 | 33 | |
34 | 34 | /** |
35 | 35 | * @var DB |
@@ -39,7 +39,7 @@ discard block |
||
39 | 39 | /** |
40 | 40 | * @param DB $db |
41 | 41 | */ |
42 | - public function __construct (DB $db) { |
|
42 | + public function __construct(DB $db) { |
|
43 | 43 | $this->db = $db; |
44 | 44 | } |
45 | 45 | |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | * @param int|string $column |
48 | 48 | * @return bool |
49 | 49 | */ |
50 | - public function offsetExists ($column): bool { |
|
50 | + public function offsetExists($column): bool { |
|
51 | 51 | return $this->offsetGet($column) !== null; |
52 | 52 | } |
53 | 53 | |
@@ -58,7 +58,7 @@ discard block |
||
58 | 58 | * @param void $value |
59 | 59 | * @throws Exception |
60 | 60 | */ |
61 | - final public function offsetSet ($offset, $value): void { |
|
61 | + final public function offsetSet($offset, $value): void { |
|
62 | 62 | throw new Exception('Tables are immutable.'); |
63 | 63 | } |
64 | 64 | |
@@ -68,7 +68,7 @@ discard block |
||
68 | 68 | * @param void $name |
69 | 69 | * @throws Exception |
70 | 70 | */ |
71 | - final public function offsetUnset ($name): void { |
|
71 | + final public function offsetUnset($name): void { |
|
72 | 72 | $this->offsetSet($name, null); |
73 | 73 | } |
74 | 74 | } |
75 | 75 | \ No newline at end of file |
@@ -125,7 +125,7 @@ discard block |
||
125 | 125 | * @param string|AbstractTable $table |
126 | 126 | * @param string[] $columns |
127 | 127 | */ |
128 | - public function __construct (DB $db, $table, array $columns = ['*']) { |
|
128 | + public function __construct(DB $db, $table, array $columns = ['*']) { |
|
129 | 129 | static $autoAlias = 0; |
130 | 130 | $autoAlias++; |
131 | 131 | parent::__construct($db); |
@@ -152,7 +152,7 @@ discard block |
||
152 | 152 | * @param array $args |
153 | 153 | * @return Statement |
154 | 154 | */ |
155 | - public function __invoke (array $args = []) { |
|
155 | + public function __invoke(array $args = []) { |
|
156 | 156 | return $this->execute($args); |
157 | 157 | } |
158 | 158 | |
@@ -161,7 +161,7 @@ discard block |
||
161 | 161 | * |
162 | 162 | * @return string |
163 | 163 | */ |
164 | - final public function __toString () { |
|
164 | + final public function __toString() { |
|
165 | 165 | return $this->alias; |
166 | 166 | } |
167 | 167 | |
@@ -171,7 +171,7 @@ discard block |
||
171 | 171 | * @param array $args Execution arguments. |
172 | 172 | * @return int |
173 | 173 | */ |
174 | - public function count (array $args = []): int { |
|
174 | + public function count(array $args = []): int { |
|
175 | 175 | $clone = clone $this; |
176 | 176 | $clone->_columns = 'COUNT(*)'; |
177 | 177 | $clone->_order = ''; |
@@ -184,7 +184,7 @@ discard block |
||
184 | 184 | * @param array $args |
185 | 185 | * @return Statement |
186 | 186 | */ |
187 | - public function execute (array $args = []) { |
|
187 | + public function execute(array $args = []) { |
|
188 | 188 | if (empty($args)) { |
189 | 189 | return $this->db->query($this->toSql()); |
190 | 190 | } |
@@ -199,14 +199,14 @@ discard block |
||
199 | 199 | * @param array $args Execution arguments. |
200 | 200 | * @return array |
201 | 201 | */ |
202 | - public function getAll (array $args = []): array { |
|
202 | + public function getAll(array $args = []): array { |
|
203 | 203 | return iterator_to_array($this->fetcher->__invoke($this->execute($args))); |
204 | 204 | } |
205 | 205 | |
206 | 206 | /** |
207 | 207 | * @return Column[] |
208 | 208 | */ |
209 | - public function getColumns () { |
|
209 | + public function getColumns() { |
|
210 | 210 | return $this->refs; |
211 | 211 | } |
212 | 212 | |
@@ -219,7 +219,7 @@ discard block |
||
219 | 219 | * @param array $args Execution arguments. |
220 | 220 | * @return Generator |
221 | 221 | */ |
222 | - public function getEach (array $args = []) { |
|
222 | + public function getEach(array $args = []) { |
|
223 | 223 | yield from $this->fetcher->__invoke($this->execute($args)); |
224 | 224 | } |
225 | 225 | |
@@ -231,7 +231,7 @@ discard block |
||
231 | 231 | * @param array $args |
232 | 232 | * @return mixed |
233 | 233 | */ |
234 | - public function getFirst (array $args = []) { |
|
234 | + public function getFirst(array $args = []) { |
|
235 | 235 | return $this->getEach($args)->current(); |
236 | 236 | } |
237 | 237 | |
@@ -242,7 +242,7 @@ discard block |
||
242 | 242 | * |
243 | 243 | * @return Generator |
244 | 244 | */ |
245 | - public function getIterator () { |
|
245 | + public function getIterator() { |
|
246 | 246 | yield from $this->getEach(); |
247 | 247 | } |
248 | 248 | |
@@ -252,7 +252,7 @@ discard block |
||
252 | 252 | * |
253 | 253 | * @return null|mixed |
254 | 254 | */ |
255 | - public function getResult (array $args = []) { |
|
255 | + public function getResult(array $args = []) { |
|
256 | 256 | return $this->execute($args)->fetchColumn(); |
257 | 257 | } |
258 | 258 | |
@@ -262,7 +262,7 @@ discard block |
||
262 | 262 | * @param string $column |
263 | 263 | * @return $this |
264 | 264 | */ |
265 | - public function group (string $column) { |
|
265 | + public function group(string $column) { |
|
266 | 266 | if (!strlen($this->_group)) { |
267 | 267 | $this->_group = " GROUP BY {$column}"; |
268 | 268 | } |
@@ -278,7 +278,7 @@ discard block |
||
278 | 278 | * @param string ...$conditions |
279 | 279 | * @return $this |
280 | 280 | */ |
281 | - public function having (string ...$conditions) { |
|
281 | + public function having(string ...$conditions) { |
|
282 | 282 | assert(count($conditions) > 0); |
283 | 283 | $conditions = implode(' AND ', $conditions); |
284 | 284 | if (!strlen($this->_having)) { |
@@ -298,7 +298,7 @@ discard block |
||
298 | 298 | * @param Select $select |
299 | 299 | * @return $this |
300 | 300 | */ |
301 | - public function intersect (Select $select) { |
|
301 | + public function intersect(Select $select) { |
|
302 | 302 | if ($this->db->isMySQL()) { |
303 | 303 | // to be standards compliant, this hack must fail if they don't have the same cols. |
304 | 304 | assert(count($this->refs) === count($select->refs) and !array_diff_key($this->refs, $select->refs)); |
@@ -319,7 +319,7 @@ discard block |
||
319 | 319 | * |
320 | 320 | * @return Predicate |
321 | 321 | */ |
322 | - public function isEmpty () { |
|
322 | + public function isEmpty() { |
|
323 | 323 | return Predicate::factory($this->db, "NOT EXISTS ({$this->toSql()})"); |
324 | 324 | } |
325 | 325 | |
@@ -328,7 +328,7 @@ discard block |
||
328 | 328 | * |
329 | 329 | * @return Predicate |
330 | 330 | */ |
331 | - public function isNotEmpty () { |
|
331 | + public function isNotEmpty() { |
|
332 | 332 | return Predicate::factory($this->db, "EXISTS ({$this->toSql()})"); |
333 | 333 | } |
334 | 334 | |
@@ -339,7 +339,7 @@ discard block |
||
339 | 339 | * @param string ...$conditions |
340 | 340 | * @return $this |
341 | 341 | */ |
342 | - public function join ($table, string ...$conditions) { |
|
342 | + public function join($table, string ...$conditions) { |
|
343 | 343 | assert(count($conditions) > 0); |
344 | 344 | if ($table instanceof Select) { |
345 | 345 | $table = $table->toSubquery(); |
@@ -356,7 +356,7 @@ discard block |
||
356 | 356 | * @param string ...$conditions |
357 | 357 | * @return $this |
358 | 358 | */ |
359 | - public function joinLeft ($table, string ...$conditions) { |
|
359 | + public function joinLeft($table, string ...$conditions) { |
|
360 | 360 | assert(count($conditions) > 0); |
361 | 361 | if ($table instanceof Select) { |
362 | 362 | $table = $table->toSubquery(); |
@@ -373,7 +373,7 @@ discard block |
||
373 | 373 | * @param int $offset |
374 | 374 | * @return $this |
375 | 375 | */ |
376 | - public function limit (int $limit, int $offset = 0) { |
|
376 | + public function limit(int $limit, int $offset = 0) { |
|
377 | 377 | if ($limit == 0) { |
378 | 378 | $this->_limit = ''; |
379 | 379 | } |
@@ -392,7 +392,7 @@ discard block |
||
392 | 392 | * @param int|string $ref Ordinal or reference name. |
393 | 393 | * @return null|Column |
394 | 394 | */ |
395 | - public function offsetGet ($ref) { |
|
395 | + public function offsetGet($ref) { |
|
396 | 396 | if (is_int($ref)) { |
397 | 397 | return current(array_slice($this->refs, $ref, 1)) ?: null; |
398 | 398 | } |
@@ -405,7 +405,7 @@ discard block |
||
405 | 405 | * @param string $order |
406 | 406 | * @return $this |
407 | 407 | */ |
408 | - public function order (string $order) { |
|
408 | + public function order(string $order) { |
|
409 | 409 | if (strlen($order)) { |
410 | 410 | $order = " ORDER BY {$order}"; |
411 | 411 | } |
@@ -416,7 +416,7 @@ discard block |
||
416 | 416 | /** |
417 | 417 | * @return Statement |
418 | 418 | */ |
419 | - public function prepare () { |
|
419 | + public function prepare() { |
|
420 | 420 | return $this->db->prepare($this->toSql()); |
421 | 421 | } |
422 | 422 | |
@@ -424,7 +424,7 @@ discard block |
||
424 | 424 | * @param string $alias |
425 | 425 | * @return $this |
426 | 426 | */ |
427 | - public function setAlias (string $alias) { |
|
427 | + public function setAlias(string $alias) { |
|
428 | 428 | $this->alias = $alias; |
429 | 429 | foreach ($this->refs as $k => $column) { |
430 | 430 | $this->refs[$k] = $column->setQualifier($alias); |
@@ -441,7 +441,7 @@ discard block |
||
441 | 441 | * @param string[] $expressions Keyed by alias if applicable. |
442 | 442 | * @return $this |
443 | 443 | */ |
444 | - public function setColumns (array $expressions = ['*']) { |
|
444 | + public function setColumns(array $expressions = ['*']) { |
|
445 | 445 | if ($expressions === ['*']) { |
446 | 446 | $expressions = array_keys($this->table->getColumns()); |
447 | 447 | } |
@@ -469,7 +469,7 @@ discard block |
||
469 | 469 | * @param Closure $fetcher |
470 | 470 | * @return $this |
471 | 471 | */ |
472 | - public function setFetcher (Closure $fetcher) { |
|
472 | + public function setFetcher(Closure $fetcher) { |
|
473 | 473 | $this->fetcher = $fetcher; |
474 | 474 | return $this; |
475 | 475 | } |
@@ -479,7 +479,7 @@ discard block |
||
479 | 479 | * |
480 | 480 | * @return string |
481 | 481 | */ |
482 | - public function toSql (): string { |
|
482 | + public function toSql(): string { |
|
483 | 483 | $sql = "SELECT {$this->_columns} FROM {$this->_table}"; |
484 | 484 | $sql .= $this->_join; |
485 | 485 | $sql .= $this->_where; |
@@ -496,7 +496,7 @@ discard block |
||
496 | 496 | * |
497 | 497 | * @return string |
498 | 498 | */ |
499 | - public function toSubquery (): string { |
|
499 | + public function toSubquery(): string { |
|
500 | 500 | return "({$this->toSql()}) AS {$this->alias}"; |
501 | 501 | } |
502 | 502 | |
@@ -506,7 +506,7 @@ discard block |
||
506 | 506 | * @param Select $select |
507 | 507 | * @return $this |
508 | 508 | */ |
509 | - public function union (Select $select) { |
|
509 | + public function union(Select $select) { |
|
510 | 510 | $select = clone $select; |
511 | 511 | $select->_order = ''; |
512 | 512 | $select->_limit = ''; |
@@ -520,7 +520,7 @@ discard block |
||
520 | 520 | * @param Select $select |
521 | 521 | * @return $this |
522 | 522 | */ |
523 | - public function unionAll (Select $select) { |
|
523 | + public function unionAll(Select $select) { |
|
524 | 524 | $select = clone $select; |
525 | 525 | $select->_order = ''; |
526 | 526 | $select->_limit = ''; |
@@ -534,7 +534,7 @@ discard block |
||
534 | 534 | * @param string ...$conditions |
535 | 535 | * @return $this |
536 | 536 | */ |
537 | - public function where (string ...$conditions) { |
|
537 | + public function where(string ...$conditions) { |
|
538 | 538 | assert(count($conditions) > 0); |
539 | 539 | $conditions = implode(' AND ', $conditions); |
540 | 540 | if (!strlen($this->_where)) { |
@@ -31,11 +31,11 @@ |
||
31 | 31 | * @param Schema $schema |
32 | 32 | * @return void |
33 | 33 | */ |
34 | - public function down ($schema); |
|
34 | + public function down($schema); |
|
35 | 35 | |
36 | 36 | /** |
37 | 37 | * @param Schema $schema |
38 | 38 | * @return void |
39 | 39 | */ |
40 | - public function up ($schema); |
|
40 | + public function up($schema); |
|
41 | 41 | } |
42 | 42 | \ No newline at end of file |
@@ -34,7 +34,7 @@ discard block |
||
34 | 34 | * @param string $interface |
35 | 35 | * @return Junction |
36 | 36 | */ |
37 | - public static function fromInterface (DB $db, string $interface) { |
|
37 | + public static function fromInterface(DB $db, string $interface) { |
|
38 | 38 | $ref = new ReflectionClass($interface); |
39 | 39 | assert($ref->isInterface()); |
40 | 40 | $doc = $ref->getDocComment(); |
@@ -49,7 +49,7 @@ discard block |
||
49 | 49 | * @param string $table |
50 | 50 | * @param string[] $classes |
51 | 51 | */ |
52 | - public function __construct (DB $db, string $table, array $classes) { |
|
52 | + public function __construct(DB $db, string $table, array $classes) { |
|
53 | 53 | parent::__construct($db, $table, array_keys($classes)); |
54 | 54 | $this->classes = $classes; |
55 | 55 | } |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | * @param array $match Keyed by junction column. |
64 | 64 | * @return Select|EntityInterface[] |
65 | 65 | */ |
66 | - public function findAll (string $key, array $match = []) { |
|
66 | + public function findAll(string $key, array $match = []) { |
|
67 | 67 | $record = $this->getRecord($key); |
68 | 68 | $select = $record->loadAll(); |
69 | 69 | $select->join($this, $this[$key]->isEqual($record['id'])); |
@@ -77,14 +77,14 @@ discard block |
||
77 | 77 | * @param string $column |
78 | 78 | * @return string |
79 | 79 | */ |
80 | - final public function getClass (string $column): string { |
|
80 | + final public function getClass(string $column): string { |
|
81 | 81 | return $this->classes[$column]; |
82 | 82 | } |
83 | 83 | |
84 | 84 | /** |
85 | 85 | * @return string[] |
86 | 86 | */ |
87 | - final public function getClasses () { |
|
87 | + final public function getClasses() { |
|
88 | 88 | return $this->classes; |
89 | 89 | } |
90 | 90 | |
@@ -92,14 +92,14 @@ discard block |
||
92 | 92 | * @param string $column |
93 | 93 | * @return Record |
94 | 94 | */ |
95 | - public function getRecord (string $column) { |
|
95 | + public function getRecord(string $column) { |
|
96 | 96 | return $this->db->getRecord($this->classes[$column]); |
97 | 97 | } |
98 | 98 | |
99 | 99 | /** |
100 | 100 | * @return Record[] |
101 | 101 | */ |
102 | - public function getRecords () { |
|
102 | + public function getRecords() { |
|
103 | 103 | return array_map(fn($class) => $this->db->getRecord($class), $this->classes); |
104 | 104 | } |
105 | 105 | |
@@ -109,7 +109,7 @@ discard block |
||
109 | 109 | * @param int[] $ids Keyed by column. |
110 | 110 | * @return int Rows affected. |
111 | 111 | */ |
112 | - public function link (array $ids): int { |
|
112 | + public function link(array $ids): int { |
|
113 | 113 | $statement = $this->cache(__FUNCTION__, function() { |
114 | 114 | $columns = implode(',', array_keys($this->columns)); |
115 | 115 | $slots = implode(',', $this->db->slots(array_keys($this->columns))); |
@@ -132,7 +132,7 @@ discard block |
||
132 | 132 | * @param array $ids Keyed by Column |
133 | 133 | * @return int Rows affected |
134 | 134 | */ |
135 | - public function unlink (array $ids): int { |
|
135 | + public function unlink(array $ids): int { |
|
136 | 136 | return $this->delete($ids); |
137 | 137 | } |
138 | 138 | } |
139 | 139 | \ No newline at end of file |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | * @param string $name |
48 | 48 | * @param string $qualifier |
49 | 49 | */ |
50 | - public function __construct (DB $db, string $name, string $qualifier = '') { |
|
50 | + public function __construct(DB $db, string $name, string $qualifier = '') { |
|
51 | 51 | $this->db = $db; |
52 | 52 | $this->name = $name; |
53 | 53 | $this->qualifier = $qualifier; |
@@ -58,7 +58,7 @@ discard block |
||
58 | 58 | * |
59 | 59 | * @return string |
60 | 60 | */ |
61 | - public function __toString () { |
|
61 | + public function __toString() { |
|
62 | 62 | if (strlen($this->qualifier)) { |
63 | 63 | return "{$this->qualifier}.{$this->name}"; |
64 | 64 | } |
@@ -68,14 +68,14 @@ discard block |
||
68 | 68 | /** |
69 | 69 | * @return string |
70 | 70 | */ |
71 | - final public function getName (): string { |
|
71 | + final public function getName(): string { |
|
72 | 72 | return $this->name; |
73 | 73 | } |
74 | 74 | |
75 | 75 | /** |
76 | 76 | * @return string |
77 | 77 | */ |
78 | - final public function getQualifier (): string { |
|
78 | + final public function getQualifier(): string { |
|
79 | 79 | return $this->qualifier; |
80 | 80 | } |
81 | 81 | |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | * @param mixed $value |
86 | 86 | * @return true |
87 | 87 | */ |
88 | - final public function offsetExists ($value) { |
|
88 | + final public function offsetExists($value) { |
|
89 | 89 | return true; |
90 | 90 | } |
91 | 91 | |
@@ -98,7 +98,7 @@ discard block |
||
98 | 98 | * @param string $aggregator |
99 | 99 | * @return null|string |
100 | 100 | */ |
101 | - public function offsetGet ($aggregator) { |
|
101 | + public function offsetGet($aggregator) { |
|
102 | 102 | $aggregator = preg_replace('/[ _()]/', '', $aggregator); // accept a variety of forms |
103 | 103 | $aggregator = $this->{$aggregator}(); // methods are not case sensitive |
104 | 104 | return Select::factory($this->db, $this->qualifier, [$aggregator])->getResult(); |
@@ -111,7 +111,7 @@ discard block |
||
111 | 111 | * @param mixed $value |
112 | 112 | * @throws LogicException |
113 | 113 | */ |
114 | - final public function offsetSet ($offset, $value) { |
|
114 | + final public function offsetSet($offset, $value) { |
|
115 | 115 | throw new LogicException("Column aggregation is read-only"); |
116 | 116 | } |
117 | 117 | |
@@ -121,7 +121,7 @@ discard block |
||
121 | 121 | * @param mixed $offset |
122 | 122 | * @throws LogicException |
123 | 123 | */ |
124 | - final public function offsetUnset ($offset) { |
|
124 | + final public function offsetUnset($offset) { |
|
125 | 125 | throw new LogicException("Column aggregation is read-only"); |
126 | 126 | } |
127 | 127 | |
@@ -130,7 +130,7 @@ discard block |
||
130 | 130 | * |
131 | 131 | * @return Select|scalar[] |
132 | 132 | */ |
133 | - public function select () { |
|
133 | + public function select() { |
|
134 | 134 | return Select::factory($this->db, $this->qualifier, [$this->name]) |
135 | 135 | ->setFetcher(function(Statement $statement) { |
136 | 136 | while (false !== $value = $statement->fetchColumn()) { |
@@ -147,7 +147,7 @@ discard block |
||
147 | 147 | * @param string $name |
148 | 148 | * @return $this |
149 | 149 | */ |
150 | - public function setName (string $name) { |
|
150 | + public function setName(string $name) { |
|
151 | 151 | $clone = clone $this; |
152 | 152 | $clone->name = $name; |
153 | 153 | return $clone; |
@@ -157,7 +157,7 @@ discard block |
||
157 | 157 | * @param string $qualifier |
158 | 158 | * @return $this |
159 | 159 | */ |
160 | - public function setQualifier (string $qualifier) { |
|
160 | + public function setQualifier(string $qualifier) { |
|
161 | 161 | $clone = clone $this; |
162 | 162 | $clone->qualifier = $qualifier; |
163 | 163 | return $clone; |