@@ -347,13 +347,4 @@ |
||
347 | 347 | */ |
348 | 348 | public function down(\$schema) |
349 | 349 | { |
350 | - {$down} |
|
351 | - } |
|
352 | - |
|
353 | - }; |
|
354 | - |
|
355 | - MIGRATION |
|
356 | - ); |
|
357 | - } |
|
358 | - |
|
359 | -})->_exec(); |
|
350 | + {$down} |
|
360 | 351 | \ No newline at end of file |
@@ -347,13 +347,4 @@ |
||
347 | 347 | */ |
348 | 348 | public function down(\$schema) |
349 | 349 | { |
350 | - {$down} |
|
351 | - } |
|
352 | - |
|
353 | - }; |
|
354 | - |
|
355 | - MIGRATION |
|
356 | - ); |
|
357 | - } |
|
358 | - |
|
359 | -})->_exec(); |
|
350 | + {$down} |
|
360 | 351 | \ No newline at end of file |
@@ -347,13 +347,4 @@ |
||
347 | 347 | */ |
348 | 348 | public function down(\$schema) |
349 | 349 | { |
350 | - {$down} |
|
351 | - } |
|
352 | - |
|
353 | - }; |
|
354 | - |
|
355 | - MIGRATION |
|
356 | - ); |
|
357 | - } |
|
358 | - |
|
359 | -})->_exec(); |
|
350 | + {$down} |
|
360 | 351 | \ No newline at end of file |
@@ -347,13 +347,4 @@ |
||
347 | 347 | */ |
348 | 348 | public function down(\$schema) |
349 | 349 | { |
350 | - {$down} |
|
351 | - } |
|
352 | - |
|
353 | - }; |
|
354 | - |
|
355 | - MIGRATION |
|
356 | - ); |
|
357 | - } |
|
358 | - |
|
359 | -})->_exec(); |
|
350 | + {$down} |
|
360 | 351 | \ No newline at end of file |
@@ -347,13 +347,4 @@ |
||
347 | 347 | */ |
348 | 348 | public function down(\$schema) |
349 | 349 | { |
350 | - {$down} |
|
351 | - } |
|
352 | - |
|
353 | - }; |
|
354 | - |
|
355 | - MIGRATION |
|
356 | - ); |
|
357 | - } |
|
358 | - |
|
359 | -})->_exec(); |
|
350 | + {$down} |
|
360 | 351 | \ No newline at end of file |
@@ -131,7 +131,7 @@ discard block |
||
131 | 131 | */ |
132 | 132 | public static function slots(array $columns): array |
133 | 133 | { |
134 | - return array_combine($columns, array_map(function (string $column) { |
|
134 | + return array_combine($columns, array_map(function(string $column) { |
|
135 | 135 | return ':' . str_replace('.', '__', $column); |
136 | 136 | }, $columns)); |
137 | 137 | } |
@@ -175,7 +175,7 @@ discard block |
||
175 | 175 | $this->exec("SET time_zone = 'UTC'"); |
176 | 176 | } elseif ($this->isSQLite()) { |
177 | 177 | // polyfill sqlite functions |
178 | - $this->sqliteCreateFunctions([ // deterministic functions |
|
178 | + $this->sqliteCreateFunctions([// deterministic functions |
|
179 | 179 | // https://www.sqlite.org/lang_mathfunc.html |
180 | 180 | 'ACOS' => 'acos', |
181 | 181 | 'ASIN' => 'asin', |
@@ -201,7 +201,7 @@ discard block |
||
201 | 201 | 'SIGN' => fn($x) => ($x > 0) - ($x < 0), |
202 | 202 | ]); |
203 | 203 | |
204 | - $this->sqliteCreateFunctions([ // non-deterministic |
|
204 | + $this->sqliteCreateFunctions([// non-deterministic |
|
205 | 205 | 'RAND' => fn() => mt_rand() / mt_getrandmax(), |
206 | 206 | ], false); |
207 | 207 | } |
@@ -49,7 +49,7 @@ discard block |
||
49 | 49 | */ |
50 | 50 | public function down(string $to = null): ?string |
51 | 51 | { |
52 | - return $this->db->transact(function () use ($to) { |
|
52 | + return $this->db->transact(function() use ($to) { |
|
53 | 53 | $current = $this->getCurrent(); |
54 | 54 | // walk newest to oldest |
55 | 55 | foreach (array_reverse($this->glob(), true) as $sequence => $file) { |
@@ -135,7 +135,7 @@ discard block |
||
135 | 135 | */ |
136 | 136 | public function up(string $to = null): ?string |
137 | 137 | { |
138 | - return $this->db->transact(function () use ($to) { |
|
138 | + return $this->db->transact(function() use ($to) { |
|
139 | 139 | $current = $this->getCurrent(); |
140 | 140 | // walk oldest to newest |
141 | 141 | foreach ($this->glob() as $sequence => $file) { |
@@ -39,7 +39,7 @@ discard block |
||
39 | 39 | */ |
40 | 40 | public function exists(int $id, string $attribute): bool |
41 | 41 | { |
42 | - $statement = $this->cache(__FUNCTION__, function () { |
|
42 | + $statement = $this->cache(__FUNCTION__, function() { |
|
43 | 43 | return $this->select(['COUNT(*) > 0'])->where('entity = ? AND attribute = ?')->prepare(); |
44 | 44 | }); |
45 | 45 | $exists = (bool)$statement([$id, $attribute])->fetchColumn(); |
@@ -89,7 +89,7 @@ discard block |
||
89 | 89 | */ |
90 | 90 | public function load(int $id): array |
91 | 91 | { |
92 | - $statement = $this->cache(__FUNCTION__, function () { |
|
92 | + $statement = $this->cache(__FUNCTION__, function() { |
|
93 | 93 | $select = $this->select(['attribute', 'value']); |
94 | 94 | $select->where('entity = ?'); |
95 | 95 | $select->order('attribute'); |
@@ -151,7 +151,7 @@ discard block |
||
151 | 151 | } |
152 | 152 | |
153 | 153 | // upsert each |
154 | - $statement = $this->cache(__FUNCTION__, function () { |
|
154 | + $statement = $this->cache(__FUNCTION__, function() { |
|
155 | 155 | if ($this->db->isSQLite()) { |
156 | 156 | return $this->db->prepare( |
157 | 157 | "INSERT INTO {$this} (entity,attribute,value) VALUES (?,?,?)" |
@@ -136,7 +136,7 @@ |
||
136 | 136 | public function select() |
137 | 137 | { |
138 | 138 | return Select::factory($this->db, $this->qualifier, [$this->name]) |
139 | - ->setFetcher(function (Statement $statement) { |
|
139 | + ->setFetcher(function(Statement $statement) { |
|
140 | 140 | while (false !== $value = $statement->fetchColumn()) { |
141 | 141 | yield $value; |
142 | 142 | } |
@@ -488,7 +488,7 @@ discard block |
||
488 | 488 | */ |
489 | 489 | public function load(int $id) |
490 | 490 | { |
491 | - $statement = $this->cache(__FUNCTION__, function () { |
|
491 | + $statement = $this->cache(__FUNCTION__, function() { |
|
492 | 492 | return $this->select()->where('id = ?')->prepare(); |
493 | 493 | }); |
494 | 494 | $values = $statement([$id])->fetch(); |
@@ -509,7 +509,7 @@ discard block |
||
509 | 509 | */ |
510 | 510 | public function loadAll() |
511 | 511 | { |
512 | - return $this->select()->setFetcher(function (Statement $statement) { |
|
512 | + return $this->select()->setFetcher(function(Statement $statement) { |
|
513 | 513 | yield from $this->fetchEach($statement); |
514 | 514 | }); |
515 | 515 | } |
@@ -568,7 +568,7 @@ discard block |
||
568 | 568 | */ |
569 | 569 | protected function saveInsert(EntityInterface $entity): void |
570 | 570 | { |
571 | - $statement = $this->cache(__FUNCTION__, function () { |
|
571 | + $statement = $this->cache(__FUNCTION__, function() { |
|
572 | 572 | $slots = $this->db->slots(array_keys($this->columns)); |
573 | 573 | unset($slots['id']); |
574 | 574 | $columns = implode(',', array_keys($slots)); |
@@ -588,7 +588,7 @@ discard block |
||
588 | 588 | */ |
589 | 589 | protected function saveUpdate(EntityInterface $entity): void |
590 | 590 | { |
591 | - $statement = $this->cache(__FUNCTION__, function () { |
|
591 | + $statement = $this->cache(__FUNCTION__, function() { |
|
592 | 592 | $slots = $this->db->slotsEqual(array_keys($this->columns)); |
593 | 593 | unset($slots['id']); |
594 | 594 | $slots = implode(', ', $slots); |
@@ -144,16 +144,16 @@ discard block |
||
144 | 144 | // bool |
145 | 145 | 'BOOLEAN' => 'bool', |
146 | 146 | // int |
147 | - 'BIGINT' => 'int', // mysql |
|
147 | + 'BIGINT' => 'int', // mysql |
|
148 | 148 | 'INTEGER' => 'int', // sqlite (must be this type to allow AUTOINCREMENT) |
149 | 149 | // float |
150 | 150 | 'DOUBLE PRECISION' => 'float', |
151 | 151 | // string <= 255 |
152 | 152 | 'VARCHAR(255)' => 'string', |
153 | 153 | // string <= 64k |
154 | - 'TEXT' => 'String', // @var String |
|
154 | + 'TEXT' => 'String', // @var String |
|
155 | 155 | // string > 64k |
156 | - 'BLOB' => 'STRING', // @var STRING (sqlite) |
|
156 | + 'BLOB' => 'STRING', // @var STRING (sqlite) |
|
157 | 157 | 'LONGBLOB' => 'STRING', // @var STRING (mysql) |
158 | 158 | // DateTime |
159 | 159 | 'DATETIME' => 'DateTime', |
@@ -456,7 +456,7 @@ discard block |
||
456 | 456 | */ |
457 | 457 | protected function sortColumns(array $types): array |
458 | 458 | { |
459 | - uksort($types, function (string $a, string $b) use ($types) { |
|
459 | + uksort($types, function(string $a, string $b) use ($types) { |
|
460 | 460 | // descending type constant, ascending name |
461 | 461 | return $types[$b] <=> $types[$a] ?: $a <=> $b; |
462 | 462 | }); |
@@ -90,9 +90,11 @@ |
||
90 | 90 | * @param string|ValueInterface $else |
91 | 91 | * @return $this |
92 | 92 | */ |
93 | - public function else($else) |
|
93 | + public function else { |
|
94 | + ($else) |
|
94 | 95 | { |
95 | 96 | $this->else = isset($else) ? $this->db->quote($else) : null; |
97 | + } |
|
96 | 98 | return $this; |
97 | 99 | } |
98 | 100 |
@@ -322,7 +322,7 @@ |
||
322 | 322 | * @param array $values `[when => then]` |
323 | 323 | * @return Choice |
324 | 324 | */ |
325 | - public function switch(array $values = []) |
|
325 | + public function switch (array $values = []) |
|
326 | 326 | { |
327 | 327 | return Choice::factory($this->db, "{$this}", $values); |
328 | 328 | } |