voku / simple-mysqli

src/voku/db/ActiveRecordExpressions.php

Spacing +1 added lines, -1 removed lines

@@ -21,6 +21,6 @@
    */
   public function __toString()
   {
-    return $this->source . ' ' . $this->operator . ' ' . $this->target;
+    return $this->source.' '.$this->operator.' '.$this->target;
   }
 }

src/voku/db/Helper.php

Spacing +19 added lines, -19 removed lines

@@ -31,7 +31,7 @@ 
     $optimized = 0;
     if (!empty($tables)) {
       foreach ($tables as $table) {
-        $optimize = 'OPTIMIZE TABLE ' . $dbConnection->quote_string($table);
+        $optimize = 'OPTIMIZE TABLE '.$dbConnection->quote_string($table);
         $result = $dbConnection->query($optimize);
         if ($result) {
           $optimized++;
@@ -59,7 +59,7 @@ 
     $optimized = 0;
     if (!empty($tables)) {
       foreach ($tables as $table) {
-        $optimize = 'REPAIR TABLE ' . $dbConnection->quote_string($table);
+        $optimize = 'REPAIR TABLE '.$dbConnection->quote_string($table);
         $result = $dbConnection->query($optimize);
         if ($result) {
           $optimized++;
@@ -176,23 +176,23 @@ 
 
     $whereSQL = $dbConnection->_parseArrayPair($whereArray, 'AND');
     if ($whereSQL) {
-      $whereSQL = 'AND ' . $whereSQL;
+      $whereSQL = 'AND '.$whereSQL;
     }
 
     if ($databaseName) {
-      $databaseName = $dbConnection->quote_string(trim($databaseName)) . '.';
+      $databaseName = $dbConnection->quote_string(trim($databaseName)).'.';
     }
 
     // get the row
-    $query = 'SELECT ' . $dbConnection->quote_string($searchFieldName) . ', ' . $dbConnection->quote_string($idFieldName) . ' 
-      FROM ' . $databaseName . $dbConnection->quote_string($table) . '
+    $query = 'SELECT '.$dbConnection->quote_string($searchFieldName).', '.$dbConnection->quote_string($idFieldName).' 
+      FROM ' . $databaseName.$dbConnection->quote_string($table).'
       WHERE 1 = 1
-      ' . $whereSQL . '
+      ' . $whereSQL.'
     ';
 
     if ($useCache === true) {
       $cache = new Cache(null, null, false, $useCache);
-      $cacheKey = 'sql-phonetic-search-' . \md5($query);
+      $cacheKey = 'sql-phonetic-search-'.\md5($query);
 
       if (
           $cache->getCacheIsReady() === true
@@ -322,10 +322,10 @@ 
     }
 
     if ($databaseName) {
-      $databaseName = $dbConnection->quote_string(trim($databaseName)) . '.';
+      $databaseName = $dbConnection->quote_string(trim($databaseName)).'.';
     }
 
-    $sql = 'SHOW COLUMNS FROM ' . $databaseName . $dbConnection->escape($table);
+    $sql = 'SHOW COLUMNS FROM '.$databaseName.$dbConnection->escape($table);
     $result = $dbConnection->query($sql);
 
     if ($result && $result->num_rows > 0) {
@@ -371,17 +371,17 @@ 
 
     $whereSQL = $dbConnection->_parseArrayPair($whereArray, 'AND');
     if ($whereSQL) {
-      $whereSQL = 'AND ' . $whereSQL;
+      $whereSQL = 'AND '.$whereSQL;
     }
 
     if ($databaseName) {
-      $databaseName = $dbConnection->quote_string(trim($databaseName)) . '.';
+      $databaseName = $dbConnection->quote_string(trim($databaseName)).'.';
     }
 
     // get the row
-    $query = 'SELECT * FROM ' . $databaseName . $dbConnection->quote_string($table) . '
+    $query = 'SELECT * FROM '.$databaseName.$dbConnection->quote_string($table).'
       WHERE 1 = 1
-      ' . $whereSQL . '
+      ' . $whereSQL.'
     ';
     $result = $dbConnection->query($query);
 
@@ -401,11 +401,11 @@ 
 
           if (!\in_array($fieldName, $ignoreArray, true)) {
             if (\array_key_exists($fieldName, $updateArray)) {
-              $insert_keys .= ',' . $fieldName;
+              $insert_keys .= ','.$fieldName;
               $insert_values .= ',?';
               $bindings[] = $updateArray[$fieldName]; // INFO: do not escape non selected data
             } else {
-              $insert_keys .= ',' . $fieldName;
+              $insert_keys .= ','.$fieldName;
               $insert_values .= ',?';
               $bindings[] = $value; // INFO: do not escape non selected data
             }
@@ -416,10 +416,10 @@ 
         $insert_values = ltrim($insert_values, ',');
 
         // insert the "copied" row
-        $new_query = 'INSERT INTO ' . $databaseName . $dbConnection->quote_string($table) . ' 
-          (' . $insert_keys . ')
+        $new_query = 'INSERT INTO '.$databaseName.$dbConnection->quote_string($table).' 
+          (' . $insert_keys.')
           VALUES 
-          (' . $insert_values . ')
+          (' . $insert_values.')
         ';
 
         return $dbConnection->query($new_query, $bindings);

src/voku/db/Result.php

Spacing +4 added lines, -4 removed lines

@@ -107,7 +107,7 @@ 
         &&
         !$result instanceof \Doctrine\DBAL\Statement
     ) {
-      throw new \InvalidArgumentException('$result must be ' . \mysqli_result::class . ' or ' . \Doctrine\DBAL\Statement::class . ' !');
+      throw new \InvalidArgumentException('$result must be '.\mysqli_result::class.' or '.\Doctrine\DBAL\Statement::class.' !');
     }
 
     $this->_result = $result;
@@ -812,7 +812,7 @@ 
   {
     if ($as_array) {
       return \array_map(
-          function ($object) {
+          function($object) {
             return (array)$object;
           },
           $this->fetch_fields()
@@ -986,7 +986,7 @@ 
     }
 
     return \array_map(
-        function ($values) use ($keys) {
+        function($values) use ($keys) {
           return \array_combine($keys, $values);
         }, $rows
     );
@@ -1102,7 +1102,7 @@ 
           $fieldTmp->{$metadataTmpKey} = $metadataTmpValue;
         }
 
-        $typeNativeTmp = 'MYSQL_TYPE_' . $metadataTmp['native_type'];
+        $typeNativeTmp = 'MYSQL_TYPE_'.$metadataTmp['native_type'];
         $typeTmp = $THIS_CLASS_TMP->getConstant($typeNativeTmp);
         if ($typeTmp) {
           $fieldTmp->type = $typeTmp;

src/voku/db/DB.php

Spacing +31 added lines, -31 removed lines

@@ -427,9 +427,9 @@ 
         }
 
         if ($_connector === 'NOT IN' || $_connector === 'IN') {
-          $_value = '(' . \implode(',', $_value) . ')';
+          $_value = '('.\implode(',', $_value).')';
         } elseif ($_connector === 'NOT BETWEEN' || $_connector === 'BETWEEN') {
-          $_value = '(' . \implode(' AND ', $_value) . ')';
+          $_value = '('.\implode(' AND ', $_value).')';
         }
 
       } else {
@@ -476,7 +476,7 @@ 
           $valueInner = "''";
         }
 
-        $sql .= ' ' . $_glueHelperInner . ' ' . $quoteString . ' ' . $_connector . ' ' . $valueInner . " \n";
+        $sql .= ' '.$_glueHelperInner.' '.$quoteString.' '.$_connector.' '.$valueInner." \n";
         $tmpCounter++;
       }
 
@@ -563,7 +563,7 @@ 
 
       // add ":" if needed
       if (\strpos($name, ':') !== 0) {
-        $nameTmp = ':' . $name;
+        $nameTmp = ':'.$name;
       } else {
         $nameTmp = $name;
       }
@@ -708,7 +708,7 @@ 
           $this->connected = $this->_doctrine_connection->isConnected();
 
           if (!$this->connected) {
-            $error = 'Error connecting to mysql server: ' . $this->_doctrine_connection->errorInfo();
+            $error = 'Error connecting to mysql server: '.$this->_doctrine_connection->errorInfo();
             $this->_debug->displayError($error, false);
             throw new DBConnectException($error, 101);
           }
@@ -772,7 +772,7 @@ 
       );
 
     } catch (\Exception $e) {
-      $error = 'Error connecting to mysql server: ' . $e->getMessage();
+      $error = 'Error connecting to mysql server: '.$e->getMessage();
       $this->_debug->displayError($error, false);
       throw new DBConnectException($error, 100, $e);
     }
@@ -780,7 +780,7 @@ 
 
     $errno = \mysqli_connect_errno();
     if (!$this->connected || $errno) {
-      $error = 'Error connecting to mysql server: ' . \mysqli_connect_error() . ' (' . $errno . ')';
+      $error = 'Error connecting to mysql server: '.\mysqli_connect_error().' ('.$errno.')';
       $this->_debug->displayError($error, false);
       throw new DBConnectException($error, 101);
     }
@@ -821,10 +821,10 @@ 
     }
 
     if ($databaseName) {
-      $databaseName = $this->quote_string(\trim($databaseName)) . '.';
+      $databaseName = $this->quote_string(\trim($databaseName)).'.';
     }
 
-    $sql = 'DELETE FROM ' . $databaseName . $this->quote_string($table) . " WHERE ($WHERE)";
+    $sql = 'DELETE FROM '.$databaseName.$this->quote_string($table)." WHERE ($WHERE)";
 
     return $this->query($sql);
   }
@@ -1007,7 +1007,7 @@ 
 
     if ($useCache === true) {
       $cache = new Cache(null, null, false, $useCache);
-      $cacheKey = 'sql-' . \md5($query);
+      $cacheKey = 'sql-'.\md5($query);
 
       if (
           $cache->getCacheIsReady() === true
@@ -1144,7 +1144,7 @@ 
     }
 
     if (
-        $hostname . $username . $password . $database . $port . $charset == '3306utf8'
+        $hostname.$username.$password.$database.$port.$charset == '3306utf8'
         &&
         null !== $firstInstance
     ) {
@@ -1163,7 +1163,7 @@ 
         } else {
           $extra_config_value_tmp = (string)$extra_config_value;
         }
-        $extra_config_string .= $extra_config_key . $extra_config_value_tmp;
+        $extra_config_string .= $extra_config_key.$extra_config_value_tmp;
       }
     } else {
       // only for backward compatibility
@@ -1171,7 +1171,7 @@ 
     }
 
     $connection = \md5(
-        $hostname . $username . $password . $database . $port . $charset . (int)$exit_on_error . (int)$echo_on_error . $logger_class_name . $logger_level . $extra_config_string
+        $hostname.$username.$password.$database.$port.$charset.(int)$exit_on_error.(int)$echo_on_error.$logger_class_name.$logger_level.$extra_config_string
     );
 
     if (!isset($instance[$connection])) {
@@ -1262,10 +1262,10 @@ 
     $SET = $this->_parseArrayPair($data);
 
     if ($databaseName) {
-      $databaseName = $this->quote_string(\trim($databaseName)) . '.';
+      $databaseName = $this->quote_string(\trim($databaseName)).'.';
     }
 
-    $sql = 'INSERT INTO ' . $databaseName . $this->quote_string($table) . " SET $SET";
+    $sql = 'INSERT INTO '.$databaseName.$this->quote_string($table)." SET $SET";
 
     return $this->query($sql);
   }
@@ -1659,11 +1659,11 @@ 
 
       // exit if we have more then 3 "DB server has gone away"-errors
       if ($RECONNECT_COUNTER > 3) {
-        $this->_debug->mailToAdmin('DB-Fatal-Error', $errorMessage . '(' . $errorNumber . ') ' . ":\n<br />" . $sql, 5);
+        $this->_debug->mailToAdmin('DB-Fatal-Error', $errorMessage.'('.$errorNumber.') '.":\n<br />".$sql, 5);
         throw new DBGoneAwayException($errorMessage);
       }
 
-      $this->_debug->mailToAdmin('DB-Error', $errorMessage . '(' . $errorNumber . ') ' . ":\n<br />" . $sql);
+      $this->_debug->mailToAdmin('DB-Error', $errorMessage.'('.$errorNumber.') '.":\n<br />".$sql);
 
       // reconnect
       $RECONNECT_COUNTER++;
@@ -1677,7 +1677,7 @@ 
       return false;
     }
 
-    $this->_debug->mailToAdmin('SQL-Error', $errorMessage . '(' . $errorNumber . ') ' . ":\n<br />" . $sql);
+    $this->_debug->mailToAdmin('SQL-Error', $errorMessage.'('.$errorNumber.') '.":\n<br />".$sql);
 
     $force_exception_after_error = null; // auto
     if ($this->_in_transaction === true) {
@@ -1685,7 +1685,7 @@ 
     }
     // this query returned an error, we must display it (only for dev) !!!
 
-    $this->_debug->displayError($errorMessage . '(' . $errorNumber . ') ' . ' | ' . $sql, $force_exception_after_error);
+    $this->_debug->displayError($errorMessage.'('.$errorNumber.') '.' | '.$sql, $force_exception_after_error);
 
     return false;
   }
@@ -1708,7 +1708,7 @@ 
         )
     );
 
-    return '`' . $str . '`';
+    return '`'.$str.'`';
   }
 
   /**
@@ -1778,10 +1778,10 @@ 
     $values = \implode(',', $data);
 
     if ($databaseName) {
-      $databaseName = $this->quote_string(\trim($databaseName)) . '.';
+      $databaseName = $this->quote_string(\trim($databaseName)).'.';
     }
 
-    $sql = 'REPLACE INTO ' . $databaseName . $this->quote_string($table) . " ($columns) VALUES ($values)";
+    $sql = 'REPLACE INTO '.$databaseName.$this->quote_string($table)." ($columns) VALUES ($values)";
 
     return $this->query($sql);
   }
@@ -1876,7 +1876,7 @@ 
     $var = $this->escape($var, false, false, null);
 
     if (\is_string($var)) {
-      $var = "'" . \trim($var, "'") . "'";
+      $var = "'".\trim($var, "'")."'";
     }
 
     return $var;
@@ -1913,10 +1913,10 @@ 
     }
 
     if ($databaseName) {
-      $databaseName = $this->quote_string(\trim($databaseName)) . '.';
+      $databaseName = $this->quote_string(\trim($databaseName)).'.';
     }
 
-    $sql = 'SELECT * FROM ' . $databaseName . $this->quote_string($table) . " WHERE ($WHERE)";
+    $sql = 'SELECT * FROM '.$databaseName.$this->quote_string($table)." WHERE ($WHERE)";
 
     return $this->query($sql);
   }
@@ -2003,9 +2003,9 @@ 
 
     $return = mysqli_set_charset($this->link, $charset);
     /** @noinspection PhpUsageOfSilenceOperatorInspection */
-    @\mysqli_query($this->link, 'SET CHARACTER SET ' . $charset);
+    @\mysqli_query($this->link, 'SET CHARACTER SET '.$charset);
     /** @noinspection PhpUsageOfSilenceOperatorInspection */
-    @\mysqli_query($this->link, "SET NAMES '" . $charset . "'");
+    @\mysqli_query($this->link, "SET NAMES '".$charset."'");
 
     return $return;
   }
@@ -2134,7 +2134,7 @@ 
    */
   public function table_exists(string $table): bool
   {
-    $check = $this->query('SELECT 1 FROM ' . $this->quote_string($table));
+    $check = $this->query('SELECT 1 FROM '.$this->quote_string($table));
 
     return $check !== false
            &&
@@ -2165,7 +2165,7 @@ 
       $result = $callback($this);
       if ($result === false) {
         /** @noinspection ThrowRawExceptionInspection */
-        throw new \Exception('call_user_func [' . $callback . '] === false');
+        throw new \Exception('call_user_func ['.$callback.'] === false');
       }
 
       return $this->commit();
@@ -2218,10 +2218,10 @@ 
     }
 
     if ($databaseName) {
-      $databaseName = $this->quote_string(\trim($databaseName)) . '.';
+      $databaseName = $this->quote_string(\trim($databaseName)).'.';
     }
 
-    $sql = 'UPDATE ' . $databaseName . $this->quote_string($table) . " SET $SET WHERE ($WHERE)";
+    $sql = 'UPDATE '.$databaseName.$this->quote_string($table)." SET $SET WHERE ($WHERE)";
 
     return $this->query($sql);
   }

src/voku/db/Prepare.php

Spacing +9 added lines, -9 removed lines

@@ -82,7 +82,7 @@ 
 
     foreach ($this->_boundParams as $param) {
       $arguments[0] .= $param['type'];
-      $arguments[] =& $param['value'];
+      $arguments[] = & $param['value'];
     }
 
     return $arguments;
@@ -105,7 +105,7 @@ 
     $value = $this->_db->escape($value);
 
     if ($type === 's') {
-      $valueForSqlWithBoundParameters = "'" . $value . "'";
+      $valueForSqlWithBoundParameters = "'".$value."'";
     } elseif ($type === 'i') {
       $valueForSqlWithBoundParameters = (int)$value;
     } elseif ($type === 'd') {
@@ -148,7 +148,7 @@ 
     // debug_backtrace returns arguments by reference, see comments at http://php.net/manual/de/function.func-get-args.php
     $trace = \debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
 
-    $args =& $trace[0]['args'];
+    $args = & $trace[0]['args'];
     $typesArray = \str_split($types);
 
     $args_count = \count($args) - 1;
@@ -162,7 +162,7 @@ 
 
     $arg = 1;
     foreach ($typesArray as $typeInner) {
-      $val =& $args[$arg];
+      $val = & $args[$arg];
       $this->_boundParams[] = [
           'type'  => $typeInner,
           'value' => &$val,
@@ -298,7 +298,7 @@ 
     $bool = parent::prepare($query);
 
     if ($bool === false) {
-      $this->_debug->displayError('Can not prepare query: ' . $query . ' | ' . $this->error, false);
+      $this->_debug->displayError('Can not prepare query: '.$query.' | '.$this->error, false);
     }
 
     return $bool;
@@ -386,11 +386,11 @@ 
 
       // exit if we have more then 3 "DB server has gone away"-errors
       if ($RECONNECT_COUNTER > 3) {
-        $this->_debug->mailToAdmin('DB-Fatal-Error', $errorMsg . ":\n<br />" . $sql, 5);
+        $this->_debug->mailToAdmin('DB-Fatal-Error', $errorMsg.":\n<br />".$sql, 5);
         throw new DBGoneAwayException($errorMsg);
       }
 
-      $this->_debug->mailToAdmin('DB-Error', $errorMsg . ":\n<br />" . $sql);
+      $this->_debug->mailToAdmin('DB-Error', $errorMsg.":\n<br />".$sql);
 
       // reconnect
       $RECONNECT_COUNTER++;
@@ -400,10 +400,10 @@ 
       return $this->execute();
     }
 
-    $this->_debug->mailToAdmin('SQL-Error', $errorMsg . ":\n<br />" . $sql);
+    $this->_debug->mailToAdmin('SQL-Error', $errorMsg.":\n<br />".$sql);
 
     // this query returned an error, we must display it (only for dev) !!!
-    $this->_debug->displayError($errorMsg . ' | ' . $sql);
+    $this->_debug->displayError($errorMsg.' | '.$sql);
 
     return false;
   }

src/voku/db/Debug.php

Spacing +11 added lines, -11 removed lines

@@ -139,9 +139,9 @@ 
     $this->logger(
         [
             'error',
-            '<strong>' . \date(
+            '<strong>'.\date(
                 'd. m. Y G:i:s'
-            ) . ' (' . $fileInfo['file'] . ' line: ' . $fileInfo['line'] . ') (sql-error):</strong> ' . $error . '<br>',
+            ).' ('.$fileInfo['file'].' line: '.$fileInfo['line'].') (sql-error):</strong> '.$error.'<br>',
         ]
     );
 
@@ -156,11 +156,11 @@ 
       $box_bg = $this->css_mysql_box_bg;
 
       echo '
-      <div class="OBJ-mysql-box" style="border:' . $box_border . '; background:' . $box_bg . '; padding:10px; margin:10px;">
+      <div class="OBJ-mysql-box" style="border:' . $box_border.'; background:'.$box_bg.'; padding:10px; margin:10px;">
         <b style="font-size:14px;">MYSQL Error:</b>
         <code style="display:block;">
-          file / line: ' . $fileInfo['file'] . ' / ' . $fileInfo['line'] . '
-          ' . $error . '
+          file / line: ' . $fileInfo['file'].' / '.$fileInfo['line'].'
+          ' . $error.'
         </code>
       </div>
       ';
@@ -301,7 +301,7 @@ 
       /** @noinspection PhpUsageOfSilenceOperatorInspection */
       $infoExtra = @\mysqli_info($tmpLink);
       if ($infoExtra) {
-        $infoExtra = ' | info => ' . $infoExtra;
+        $infoExtra = ' | info => '.$infoExtra;
       }
     }
 
@@ -309,14 +309,14 @@ 
     // logging
     //
 
-    $info = 'time => ' . \round($duration, 5) . ' | results => ' . (int)$results . $infoExtra . ' | SQL => ' . UTF8::htmlentities($sql);
+    $info = 'time => '.\round($duration, 5).' | results => '.(int)$results.$infoExtra.' | SQL => '.UTF8::htmlentities($sql);
 
     $fileInfo = $this->getFileAndLineFromSql();
 
     return $this->logger(
         [
             $logLevel,
-            '<strong>' . \date('d. m. Y G:i:s') . ' (' . $fileInfo['file'] . ' line: ' . $fileInfo['line'] . '):</strong> ' . $info . '<br>',
+            '<strong>'.\date('d. m. Y G:i:s').' ('.$fileInfo['file'].' line: '.$fileInfo['line'].'):</strong> '.$info.'<br>',
             'sql',
         ]
     );
@@ -382,21 +382,21 @@ 
         $this->logger(
             [
                 'debug',
-                $subject . ' | ' . $htmlBody,
+                $subject.' | '.$htmlBody,
             ]
         );
       } elseif ($priority > 3) {
         $this->logger(
             [
                 'error',
-                $subject . ' | ' . $htmlBody,
+                $subject.' | '.$htmlBody,
             ]
         );
       } elseif ($priority < 3) {
         $this->logger(
             [
                 'info',
-                $subject . ' | ' . $htmlBody,
+                $subject.' | '.$htmlBody,
             ]
         );
       }

src/voku/db/ActiveRecord.php

Spacing +9 added lines, -9 removed lines

@@ -415,7 +415,7 @@ 
         null === $active_record->{$sql_string_part}
     ) {
 
-      $sql_string_part = \strtoupper($sql_string_part) . ' ' . $active_record->table . '.*';
+      $sql_string_part = \strtoupper($sql_string_part).' '.$active_record->table.'.*';
 
     } elseif (
         (
@@ -427,15 +427,15 @@ 
         null === $active_record->{$sql_string_part}
     ) {
 
-      $sql_string_part = \strtoupper($sql_string_part) . ' ' . $active_record->table;
+      $sql_string_part = \strtoupper($sql_string_part).' '.$active_record->table;
 
     } elseif ('delete' === $sql_string_part) {
 
-      $sql_string_part = \strtoupper($sql_string_part) . ' ';
+      $sql_string_part = \strtoupper($sql_string_part).' ';
 
     } else {
 
-      $sql_string_part = (null !== $active_record->{$sql_string_part}) ? $active_record->{$sql_string_part} . ' ' : '';
+      $sql_string_part = (null !== $active_record->{$sql_string_part}) ? $active_record->{$sql_string_part}.' ' : '';
 
     }
   }
@@ -451,10 +451,10 @@ 
   {
     if (\is_array($value)) {
       foreach ($value as $key => $val) {
-        $this->params[$value[$key] = self::PREFIX . ++self::$count] = $val;
+        $this->params[$value[$key] = self::PREFIX.++self::$count] = $val;
       }
     } elseif (\is_string($value)) {
-      $this->params[$ph = self::PREFIX . ++self::$count] = $value;
+      $this->params[$ph = self::PREFIX.++self::$count] = $value;
       $value = $ph;
     }
 
@@ -475,7 +475,7 @@ 
     $value = $this->_filterParam($value);
     $expression = new ActiveRecordExpressions(
         [
-            'source'   => ('where' === strtolower($name) ? $this->table . '.' : '') . $field,
+            'source'   => ('where' === strtolower($name) ? $this->table.'.' : '').$field,
             'operator' => $operator,
             'target'   => \is_array($value)
                 ? new ActiveRecordExpressionsWrap(
@@ -939,7 +939,7 @@ 
     $value = $this->_filterParam($this->dirty);
     $this->insert = new ActiveRecordExpressions(
         [
-            'operator' => 'INSERT INTO ' . $this->table,
+            'operator' => 'INSERT INTO '.$this->table,
             'target'   => new ActiveRecordExpressionsWrap(['target' => \array_keys($this->dirty)]),
         ]
     );
@@ -985,7 +985,7 @@ 
     $this->join = new ActiveRecordExpressions(
         [
             'source'   => $this->join ?: '',
-            'operator' => $type . ' JOIN',
+            'operator' => $type.' JOIN',
             'target'   => new ActiveRecordExpressions(
                 [
                     'source'   => $table,