voku / simple-mysqli

src/voku/db/DB.php

Doc Comments +1 added lines, -1 removed lines

@@ -1079,7 +1079,7 @@
      * @param string  $query    <p>sql-query</p>
      * @param bool    $useCache optional <p>use cache?</p>
      * @param int     $cacheTTL optional <p>cache-ttl in seconds</p>
-     * @param DB|null $db       optional <p>the database connection</p>
+     * @param null|\self $db       optional <p>the database connection</p>
      *
      * @throws QueryException
      *

Spacing +56 added lines, -56 removed lines

@@ -319,10 +319,10 @@ 
         }
 
         if ($port) {
-            $this->port = (int) $port;
+            $this->port = (int)$port;
         } else {
             /** @noinspection PhpUsageOfSilenceOperatorInspection */
-            $this->port = (int) @\ini_get('mysqli.default_port');
+            $this->port = (int)@\ini_get('mysqli.default_port');
         }
 
         // fallback
@@ -375,7 +375,7 @@ 
         foreach ($arrayPair as $_key => $_value) {
             $_connector = '=';
             $_glueHelper = '';
-            $_key_upper = \strtoupper((string) $_key);
+            $_key_upper = \strtoupper((string)$_key);
 
             if (\strpos($_key_upper, ' NOT') !== false) {
                 $_connector = 'NOT';
@@ -457,18 +457,18 @@ 
                 }
 
                 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).')';
                 } elseif ($firstKey && $firstValue) {
-                    if (\strpos((string) $firstKey, ' +') !== false) {
-                        $firstKey = \str_replace(' +', '', (string) $firstKey);
-                        $_value = $firstKey . ' + ' . $firstValue;
+                    if (\strpos((string)$firstKey, ' +') !== false) {
+                        $firstKey = \str_replace(' +', '', (string)$firstKey);
+                        $_value = $firstKey.' + '.$firstValue;
                     }
 
-                    if (\strpos((string) $firstKey, ' -') !== false) {
-                        $firstKey = \str_replace(' -', '', (string) $firstKey);
-                        $_value = $firstKey . ' - ' . $firstValue;
+                    if (\strpos((string)$firstKey, ' -') !== false) {
+                        $firstKey = \str_replace(' -', '', (string)$firstKey);
+                        $_value = $firstKey.' - '.$firstValue;
                     }
                 }
             } else {
@@ -477,18 +477,18 @@ 
 
             $quoteString = $this->quote_string(
                 \trim(
-                    (string) \str_ireplace(
+                    (string)\str_ireplace(
                         [
                             $_connector,
                             $_glueHelper,
                         ],
                         '',
-                        (string) $_key
+                        (string)$_key
                     )
                 )
             );
 
-            $_value = (array) $_value;
+            $_value = (array)$_value;
 
             if (!$_glueHelper) {
                 $_glueHelper = $glue;
@@ -512,7 +512,7 @@ 
                     $valueInner = "''";
                 }
 
-                $sql .= ' ' . $_glueHelperInner . ' ' . $quoteString . ' ' . $_connector . ' ' . $valueInner . " \n";
+                $sql .= ' '.$_glueHelperInner.' '.$quoteString.' '.$_connector.' '.$valueInner." \n";
                 $tmpCounter++;
             }
 
@@ -564,7 +564,7 @@ 
             unset($params[$key]);
 
             $sql = \substr_replace($sql, $replacement, $offset, 1);
-            $offset = \strpos($sql, '?', $offset + \strlen((string) $replacement));
+            $offset = \strpos($sql, '?', $offset + \strlen((string)$replacement));
         }
 
         return ['sql' => $sql, 'params' => $params];
@@ -601,7 +601,7 @@ 
 
             // add ":" if needed
             if (\strpos($name, ':') !== 0) {
-                $nameTmp = ':' . $name;
+                $nameTmp = ':'.$name;
             } else {
                 $nameTmp = $name;
             }
@@ -609,7 +609,7 @@ 
             if ($offset === null) {
                 $offset = \strpos($sql, $nameTmp);
             } else {
-                $offset = \strpos($sql, $nameTmp, $offset + \strlen((string) $replacement));
+                $offset = \strpos($sql, $nameTmp, $offset + \strlen((string)$replacement));
             }
 
             if ($offset === false) {
@@ -641,7 +641,7 @@ 
             return \mysqli_affected_rows($this->mysqli_link);
         }
 
-        return (int) $this->affected_rows;
+        return (int)$this->affected_rows;
     }
 
     /**
@@ -853,10 +853,10 @@ 
                 $this->database,
                 $this->port,
                 $this->socket,
-                (int) $flags
+                (int)$flags
             );
         } 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);
@@ -865,7 +865,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);
@@ -884,7 +884,7 @@ 
         $this->connected = $this->doctrine_connection->isConnected();
 
         if (!$this->connected) {
-            $error = 'Error connecting to mysql server: ' . \print_r($this->doctrine_connection->errorInfo(), false);
+            $error = 'Error connecting to mysql server: '.\print_r($this->doctrine_connection->errorInfo(), false);
             $this->debug->displayError($error, false);
 
             throw new DBConnectException($error, 101);
@@ -927,10 +927,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);
 
@@ -1027,14 +1027,14 @@ 
                 $var = $var->format('Y-m-d H:i:s');
                 $type = 'string';
             } elseif (\method_exists($var, '__toString')) {
-                $var = (string) $var;
+                $var = (string)$var;
                 $type = 'string';
             }
         }
 
         switch ($type) {
             case 'boolean':
-                $var = (int) $var;
+                $var = (int)$var;
 
                 break;
 
@@ -1077,7 +1077,7 @@ 
                     }
                 } else {
                     $varCleaned = [];
-                    foreach ((array) $var as $key => $value) {
+                    foreach ((array)$var as $key => $value) {
                         $key = $this->escape($key, $stripe_non_utf8, $html_entity_decode);
                         $value = $this->escape($value, $stripe_non_utf8, $html_entity_decode);
 
@@ -1143,7 +1143,7 @@ 
 
         if ($useCache) {
             $cache = new Cache(null, null, false, $useCache);
-            $cacheKey = 'sql-' . \md5($query);
+            $cacheKey = 'sql-'.\md5($query);
 
             if (
                 $cache->getCacheIsReady()
@@ -1317,7 +1317,7 @@ 
         }
 
         if (
-            '' . $hostname . $username . $password . $database . $port . $charset === '' . $port . $charset
+            ''.$hostname.$username.$password.$database.$port.$charset === ''.$port.$charset
             &&
             $firstInstance instanceof self
         ) {
@@ -1333,13 +1333,13 @@ 
             if (\is_object($extra_config_value)) {
                 $extra_config_value_tmp = \spl_object_hash($extra_config_value);
             } else {
-                $extra_config_value_tmp = (string) $extra_config_value;
+                $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;
         }
 
         $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])) {
@@ -1479,10 +1479,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);
         if ($return === false) {
@@ -2011,12 +2011,12 @@ 
 
             // 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++;
@@ -2030,7 +2030,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) {
@@ -2038,7 +2038,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;
     }
@@ -2056,12 +2056,12 @@ 
             '`',
             '``',
             \trim(
-                (string) $this->escape($str, false),
+                (string)$this->escape($str, false),
                 '`'
             )
         );
 
-        return '`' . $str . '`';
+        return '`'.$str.'`';
     }
 
     /**
@@ -2130,10 +2130,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);
         \assert(\is_int($return) || $return === false);
@@ -2232,7 +2232,7 @@ 
                 }
             } else {
                 $varCleaned = [];
-                foreach ((array) $var as $key => $value) {
+                foreach ((array)$var as $key => $value) {
                     $key = $this->escape($key, false, false, $convert_array);
                     $value = $this->secure($value);
 
@@ -2279,7 +2279,7 @@ 
         $var = $this->escape($var, false, false, null);
 
         if (\is_string($var)) {
-            $var = "'" . \trim($var, "'") . "'";
+            $var = "'".\trim($var, "'")."'";
         }
 
         return $var;
@@ -2317,10 +2317,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);
         \assert($return instanceof Result || $return === false);
@@ -2371,7 +2371,7 @@ 
     public function setConfigExtra(array $extra_config)
     {
         if (isset($extra_config['session_to_db'])) {
-            $this->session_to_db = (bool) $extra_config['session_to_db'];
+            $this->session_to_db = (bool)$extra_config['session_to_db'];
         }
 
         if (isset($extra_config['doctrine'])) {
@@ -2434,9 +2434,9 @@ 
             $return = \mysqli_set_charset($this->mysqli_link, $charset);
 
             /** @noinspection PhpUsageOfSilenceOperatorInspection */
-            @\mysqli_query($this->mysqli_link, 'SET CHARACTER SET ' . $charset);
+            @\mysqli_query($this->mysqli_link, 'SET CHARACTER SET '.$charset);
             /** @noinspection PhpUsageOfSilenceOperatorInspection */
-            @\mysqli_query($this->mysqli_link, "SET NAMES '" . $charset . "'");
+            @\mysqli_query($this->mysqli_link, "SET NAMES '".$charset."'");
         } elseif ($this->doctrine_connection && $this->isDoctrinePDOConnection()) {
             $doctrineWrappedConnection = $this->getDoctrinePDOConnection();
             if (!$doctrineWrappedConnection instanceof Connection) {
@@ -2444,9 +2444,9 @@ 
             }
 
             /** @noinspection PhpUsageOfSilenceOperatorInspection */
-            @$doctrineWrappedConnection->exec('SET CHARACTER SET ' . $charset);
+            @$doctrineWrappedConnection->exec('SET CHARACTER SET '.$charset);
             /** @noinspection PhpUsageOfSilenceOperatorInspection */
-            @$doctrineWrappedConnection->exec("SET NAMES '" . $charset . "'");
+            @$doctrineWrappedConnection->exec("SET NAMES '".$charset."'");
 
             $return = true;
         } else {
@@ -2587,7 +2587,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
                &&
@@ -2618,7 +2618,7 @@ 
             $result = $callback($this);
             if ($result === false) {
                 /** @noinspection ThrowRawExceptionInspection */
-                throw new \Exception('call_user_func [' . \print_r($callback, true) . '] === false');
+                throw new \Exception('call_user_func ['.\print_r($callback, true).'] === false');
             }
 
             return $this->commit();
@@ -2676,10 +2676,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);
         \assert(\is_int($return) || $return === false);

src/voku/db/Debug.php

Spacing +18 added lines, -18 removed lines

@@ -86,7 +86,7 @@ 
         } else {
 
             // for testing with dev-address
-            $noDev = isset($_GET['noDev']) ? (int) $_GET['noDev'] : 0;
+            $noDev = isset($_GET['noDev']) ? (int)$_GET['noDev'] : 0;
             $remoteIpAddress = $_SERVER['REMOTE_ADDR'] ?? false;
 
             if (
@@ -137,9 +137,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>',
             ]
         );
 
@@ -155,16 +155,16 @@ 
 
             if (\PHP_SAPI === 'cli') {
                 echo "\n";
-                echo 'file:line -> ' . $fileInfo['file'] . ':' . $fileInfo['line'] . "\n";
-                echo 'error: ' . \str_replace(["\r\n", "\n", "\r"], '', $error);
+                echo 'file:line -> '.$fileInfo['file'].':'.$fileInfo['line']."\n";
+                echo 'error: '.\str_replace(["\r\n", "\n", "\r"], '', $error);
                 echo "\n";
             } else {
                 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>
         ';
@@ -305,7 +305,7 @@ 
             /** @noinspection PhpUsageOfSilenceOperatorInspection */
             $infoExtra = @\mysqli_info($tmpLink);
             if ($infoExtra) {
-                $infoExtra = ' | info => ' . $infoExtra;
+                $infoExtra = ' | info => '.$infoExtra;
             }
         }
 
@@ -313,14 +313,14 @@ 
         // logging
         //
 
-        $info = 'time => ' . \round($duration, 5) . ' | results => ' . \print_r($results, true) . $infoExtra . ' | SQL => ' . UTF8::htmlentities($sql);
+        $info = 'time => '.\round($duration, 5).' | results => '.\print_r($results, true).$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',
             ]
         );
@@ -393,21 +393,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,
                     ]
                 );
             }
@@ -419,7 +419,7 @@ 
      */
     public function setEchoOnError($echo_on_error)
     {
-        $this->echo_on_error = (bool) $echo_on_error;
+        $this->echo_on_error = (bool)$echo_on_error;
     }
 
     /**
@@ -427,7 +427,7 @@ 
      */
     public function setExitOnError($exit_on_error)
     {
-        $this->exit_on_error = (bool) $exit_on_error;
+        $this->exit_on_error = (bool)$exit_on_error;
     }
 
     /**
@@ -435,7 +435,7 @@ 
      */
     public function setLoggerClassName($logger_class_name)
     {
-        $this->logger_class_name = (string) $logger_class_name;
+        $this->logger_class_name = (string)$logger_class_name;
     }
 
     /**
@@ -443,6 +443,6 @@ 
      */
     public function setLoggerLevel($logger_level)
     {
-        $this->logger_level = (string) $logger_level;
+        $this->logger_level = (string)$logger_level;
     }
 }

src/voku/db/Prepare.php

Spacing +13 added lines, -13 removed lines

@@ -101,11 +101,11 @@ 
         $value = $this->_db->escape($value);
 
         if ($type === 's') {
-            $valueForSqlWithBoundParameters = "'" . $value . "'";
+            $valueForSqlWithBoundParameters = "'".$value."'";
         } elseif ($type === 'i') {
-            $valueForSqlWithBoundParameters = (int) $value;
+            $valueForSqlWithBoundParameters = (int)$value;
         } elseif ($type === 'd') {
-            $valueForSqlWithBoundParameters = (float) $value;
+            $valueForSqlWithBoundParameters = (float)$value;
         } else {
             $valueForSqlWithBoundParameters = $value;
         }
@@ -204,7 +204,7 @@ 
 
             // "INSERT" || "REPLACE"
             if (\preg_match('/^\s*"?(INSERT|REPLACE)\s+/i', $this->_sql)) {
-                $insert_id = (int) $this->insert_id;
+                $insert_id = (int)$this->insert_id;
                 $this->_debug->logQuery($this->_sql_with_bound_parameters, $query_duration, $insert_id);
 
                 return $insert_id;
@@ -212,7 +212,7 @@ 
 
             // "UPDATE" || "DELETE"
             if (\preg_match('/^\s*"?(UPDATE|DELETE)\s+/i', $this->_sql)) {
-                $affected_rows = (int) $this->affected_rows;
+                $affected_rows = (int)$this->affected_rows;
                 $this->_debug->logQuery($this->_sql_with_bound_parameters, $query_duration, $affected_rows);
 
                 return $affected_rows;
@@ -229,7 +229,7 @@ 
                     return $this->queryErrorHandling($this->error, $this->_sql_with_bound_parameters);
                 }
 
-                $num_rows = (int) $select_result->num_rows;
+                $num_rows = (int)$select_result->num_rows;
                 $this->_debug->logQuery($this->_sql_with_bound_parameters, $query_duration, $num_rows);
 
                 return new Result($this->_sql_with_bound_parameters, $select_result);
@@ -288,7 +288,7 @@ 
     public function prepare($query): bool
     {
         if (!\is_string($query)) {
-            throw new \InvalidArgumentException('$query was no string: ' . \gettype($query));
+            throw new \InvalidArgumentException('$query was no string: '.\gettype($query));
         }
 
         $this->_sql = $query;
@@ -307,7 +307,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;
@@ -368,7 +368,7 @@ 
                 // we need to replace the question mark "?" here
                 $values[1] = \str_replace('?', '###simple_mysqli__prepare_question_mark###', $values[1]);
                 // build the query (only for debugging)
-                $testQuery = (string) \preg_replace("/\?/", $values[1], $testQuery, 1);
+                $testQuery = (string)\preg_replace("/\?/", $values[1], $testQuery, 1);
             }
             $testQuery = \str_replace('###simple_mysqli__prepare_question_mark###', '?', $testQuery);
         }
@@ -399,12 +399,12 @@ 
 
             // 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++;
@@ -414,10 +414,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;
     }