@@ -2,7 +2,7 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace Bdf\Prime\Query; |
| 4 | 4 | |
| 5 | -require_once __DIR__ . '/../_files/BenchData.php'; |
|
| 5 | +require_once __DIR__.'/../_files/BenchData.php'; |
|
| 6 | 6 | |
| 7 | 7 | use Bdf\Prime\Bench\BenchData; |
| 8 | 8 | use Bdf\Prime\Bench\User; |
@@ -2,7 +2,7 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace Bdf\Prime\Query; |
| 4 | 4 | |
| 5 | -require_once __DIR__ . '/../_files/BenchData.php'; |
|
| 5 | +require_once __DIR__.'/../_files/BenchData.php'; |
|
| 6 | 6 | |
| 7 | 7 | use Bdf\Prime\Bench\BenchData; |
| 8 | 8 | use Bdf\Prime\Bench\User as BenchUser; |
@@ -2,7 +2,7 @@ discard block |
||
| 2 | 2 | |
| 3 | 3 | namespace Bdf\Prime\Query; |
| 4 | 4 | |
| 5 | -require_once __DIR__ . '/../_files/BenchData.php'; |
|
| 5 | +require_once __DIR__.'/../_files/BenchData.php'; |
|
| 6 | 6 | |
| 7 | 7 | use Bdf\Prime\Bench\BenchData; |
| 8 | 8 | use Bdf\Prime\Bench\User; |
@@ -208,7 +208,7 @@ discard block |
||
| 208 | 208 | */ |
| 209 | 209 | public function bench_insert_transaction() |
| 210 | 210 | { |
| 211 | - $this->repository->transaction(function () { |
|
| 211 | + $this->repository->transaction(function() { |
|
| 212 | 212 | /** @var BulkInsertQuery $insert */ |
| 213 | 213 | $insert = $this->repository->queries()->make(BulkInsertQuery::class); |
| 214 | 214 | |
@@ -232,7 +232,7 @@ discard block |
||
| 232 | 232 | */ |
| 233 | 233 | public function bench_insert_builder() |
| 234 | 234 | { |
| 235 | - $this->repository->transaction(function () { |
|
| 235 | + $this->repository->transaction(function() { |
|
| 236 | 236 | for ($i = 0; $i < 100; ++$i) { |
| 237 | 237 | $this->repository->builder()->insert([ |
| 238 | 238 | 'id' => 6000000 + $i, |
@@ -2,7 +2,7 @@ discard block |
||
| 2 | 2 | |
| 3 | 3 | namespace Bdf\Prime; |
| 4 | 4 | |
| 5 | -require_once __DIR__ . '/_files/BenchData.php'; |
|
| 5 | +require_once __DIR__.'/_files/BenchData.php'; |
|
| 6 | 6 | |
| 7 | 7 | use Bdf\Prime\Bench\BenchData; |
| 8 | 8 | use Bdf\Prime\Bench\User as BenchUser; |
@@ -115,7 +115,7 @@ discard block |
||
| 115 | 115 | } |
| 116 | 116 | |
| 117 | 117 | function convert($size) { |
| 118 | - return number_format($size/1024).' kb'; |
|
| 118 | + return number_format($size / 1024).' kb'; |
|
| 119 | 119 | } |
| 120 | 120 | |
| 121 | 121 | function profile($callback, $times) { |
@@ -135,9 +135,9 @@ discard block |
||
| 135 | 135 | |
| 136 | 136 | $delta = ($end - $start); |
| 137 | 137 | |
| 138 | - $bench['time'] = $delta; |
|
| 139 | - $bench['queries'] = $times / $delta; |
|
| 140 | - $bench['memory'] = memory_get_usage(true) - $memory; |
|
| 138 | + $bench['time'] = $delta; |
|
| 139 | + $bench['queries'] = $times / $delta; |
|
| 140 | + $bench['memory'] = memory_get_usage(true) - $memory; |
|
| 141 | 141 | |
| 142 | 142 | return $bench; |
| 143 | 143 | } |
| 144 | 144 | \ No newline at end of file |
@@ -2,7 +2,7 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace Bdf\Prime\Query; |
| 4 | 4 | |
| 5 | -require_once __DIR__ . '/../_files/BenchData.php'; |
|
| 5 | +require_once __DIR__.'/../_files/BenchData.php'; |
|
| 6 | 6 | |
| 7 | 7 | use Bdf\Prime\Bench\BenchData; |
| 8 | 8 | use Bdf\Prime\Bench\User; |
@@ -2,7 +2,7 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace Bdf\Prime\Query; |
| 4 | 4 | |
| 5 | -require_once __DIR__ . '/../_files/BenchData.php'; |
|
| 5 | +require_once __DIR__.'/../_files/BenchData.php'; |
|
| 6 | 6 | |
| 7 | 7 | use Bdf\Prime\Bench\BenchData; |
| 8 | 8 | use Bdf\Prime\Bench\User; |
@@ -186,7 +186,7 @@ discard block |
||
| 186 | 186 | foreach ($query->statements['tables'] as $table) { |
| 187 | 187 | return $query->state()->compiled = 'UPDATE ' |
| 188 | 188 | . $this->quoteIdentifier($query, $table['table']) |
| 189 | - . ' SET ' . implode(', ', $values) |
|
| 189 | + . ' SET '.implode(', ', $values) |
|
| 190 | 190 | . $this->compileWhere($query) |
| 191 | 191 | ; |
| 192 | 192 | } |
@@ -524,7 +524,7 @@ discard block |
||
| 524 | 524 | $from['sql'] = $this->quoteIdentifier($query, $databasePrefix.$from['table']); |
| 525 | 525 | $compiled[$from['table']] = $from; |
| 526 | 526 | } else { |
| 527 | - $from['sql'] = $this->quoteIdentifier($query, $databasePrefix.$from['table']) . ' ' . $this->quoteIdentifier($query, $from['alias']); |
|
| 527 | + $from['sql'] = $this->quoteIdentifier($query, $databasePrefix.$from['table']).' '.$this->quoteIdentifier($query, $from['alias']); |
|
| 528 | 528 | $compiled[$from['alias']] = $from; |
| 529 | 529 | } |
| 530 | 530 | } |
@@ -697,7 +697,7 @@ discard block |
||
| 697 | 697 | if (is_array($value)) { |
| 698 | 698 | return $this->compileIntoExpression($query, $value, $column, 'REGEXP', $converted); |
| 699 | 699 | } |
| 700 | - return $this->quoteIdentifier($query, $column).' REGEXP '.$this->compileExpressionValue($query, (string)$value, $converted); |
|
| 700 | + return $this->quoteIdentifier($query, $column).' REGEXP '.$this->compileExpressionValue($query, (string) $value, $converted); |
|
| 701 | 701 | |
| 702 | 702 | case ':like': |
| 703 | 703 | if (is_array($value)) { |
@@ -761,7 +761,7 @@ discard block |
||
| 761 | 761 | return $this->quoteIdentifier($query, $column).' = '.$this->compileExpressionValue($query, $value, $converted); |
| 762 | 762 | |
| 763 | 763 | default: |
| 764 | - throw new UnexpectedValueException("Unsupported operator '" . $operator . "' in WHERE clause"); |
|
| 764 | + throw new UnexpectedValueException("Unsupported operator '".$operator."' in WHERE clause"); |
|
| 765 | 765 | } |
| 766 | 766 | } |
| 767 | 767 | |
@@ -849,7 +849,7 @@ discard block |
||
| 849 | 849 | $sql = '('.$this->compileSelect($query).')'; |
| 850 | 850 | |
| 851 | 851 | if ($alias) { |
| 852 | - $sql = $sql . ' as ' . $this->quoteIdentifier($clause, $alias); |
|
| 852 | + $sql = $sql.' as '.$this->quoteIdentifier($clause, $alias); |
|
| 853 | 853 | } |
| 854 | 854 | |
| 855 | 855 | $this->addQueryBindings($clause, $query); |
@@ -1007,12 +1007,12 @@ discard block |
||
| 1007 | 1007 | if ($lock !== null && !$query->statements['aggregate']) { |
| 1008 | 1008 | // Lock for update |
| 1009 | 1009 | if ($lock === LockMode::PESSIMISTIC_WRITE) { |
| 1010 | - return ' ' . $this->platform()->grammar()->getWriteLockSQL(); |
|
| 1010 | + return ' '.$this->platform()->grammar()->getWriteLockSQL(); |
|
| 1011 | 1011 | } |
| 1012 | 1012 | |
| 1013 | 1013 | // Shared Lock: other process can read the row but not update it. |
| 1014 | 1014 | if ($lock === LockMode::PESSIMISTIC_READ) { |
| 1015 | - return ' ' . $this->platform()->grammar()->getReadLockSQL(); |
|
| 1015 | + return ' '.$this->platform()->grammar()->getReadLockSQL(); |
|
| 1016 | 1016 | } |
| 1017 | 1017 | } |
| 1018 | 1018 | |