@@ -1,6 +1,6 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db\exceptions; |
| 6 | 6 | |
@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db; |
| 6 | 6 | |
@@ -23,6 +23,6 @@ discard block |
||
| 23 | 23 | */ |
| 24 | 24 | public function __toString() |
| 25 | 25 | { |
| 26 | - return $this->source . ' ' . $this->operator . ' ' . $this->target; |
|
| 26 | + return $this->source.' '.$this->operator.' '.$this->target; |
|
| 27 | 27 | } |
| 28 | 28 | } |
@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db; |
| 6 | 6 | |
@@ -21,9 +21,9 @@ discard block |
||
| 21 | 21 | $delimiter = (string)($this->delimiter ?: ','); |
| 22 | 22 | |
| 23 | 23 | if ($this->start) { |
| 24 | - return $this->start . implode($delimiter, $this->target->getArray()) . ($this->end ?: ')'); |
|
| 24 | + return $this->start.implode($delimiter, $this->target->getArray()).($this->end ?: ')'); |
|
| 25 | 25 | } |
| 26 | 26 | |
| 27 | - return '(' . implode($delimiter, $this->target->getArray()) . ($this->end ?: ')'); |
|
| 27 | + return '('.implode($delimiter, $this->target->getArray()).($this->end ?: ')'); |
|
| 28 | 28 | } |
| 29 | 29 | } |
@@ -1,6 +1,6 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db\exceptions; |
| 6 | 6 | |
@@ -1,6 +1,6 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db\exceptions; |
| 6 | 6 | |
@@ -1,6 +1,6 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db\exceptions; |
| 6 | 6 | |
@@ -1,6 +1,6 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db\exceptions; |
| 6 | 6 | |
@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db; |
| 6 | 6 | |
@@ -679,7 +679,7 @@ discard block |
||
| 679 | 679 | { |
| 680 | 680 | if ($as_array) { |
| 681 | 681 | return \array_map( |
| 682 | - function ($object) { |
|
| 682 | + function($object) { |
|
| 683 | 683 | return (array)$object; |
| 684 | 684 | }, |
| 685 | 685 | \mysqli_fetch_fields($this->_result) |
@@ -791,7 +791,7 @@ discard block |
||
| 791 | 791 | } |
| 792 | 792 | |
| 793 | 793 | return \array_map( |
| 794 | - function ($values) use ($keys) { |
|
| 794 | + function($values) use ($keys) { |
|
| 795 | 795 | return \array_combine($keys, $values); |
| 796 | 796 | }, $rows |
| 797 | 797 | ); |
@@ -1,6 +1,6 @@ discard block |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -declare(strict_types=1); |
|
| 3 | +declare(strict_types = 1); |
|
| 4 | 4 | |
| 5 | 5 | namespace voku\db; |
| 6 | 6 | |
@@ -436,9 +436,9 @@ discard block |
||
| 436 | 436 | } |
| 437 | 437 | |
| 438 | 438 | if ($_connector === 'NOT IN' || $_connector === 'IN') { |
| 439 | - $_value = '(' . \implode(',', $_value) . ')'; |
|
| 439 | + $_value = '('.\implode(',', $_value).')'; |
|
| 440 | 440 | } elseif ($_connector === 'NOT BETWEEN' || $_connector === 'BETWEEN') { |
| 441 | - $_value = '(' . \implode(' AND ', $_value) . ')'; |
|
| 441 | + $_value = '('.\implode(' AND ', $_value).')'; |
|
| 442 | 442 | } |
| 443 | 443 | |
| 444 | 444 | } else { |
@@ -487,7 +487,7 @@ discard block |
||
| 487 | 487 | $valueInner = "''"; |
| 488 | 488 | } |
| 489 | 489 | |
| 490 | - $sql .= ' ' . $_glueHelperInner . ' ' . $quoteString . ' ' . $_connector . ' ' . $valueInner . " \n"; |
|
| 490 | + $sql .= ' '.$_glueHelperInner.' '.$quoteString.' '.$_connector.' '.$valueInner." \n"; |
|
| 491 | 491 | $tmpCounter++; |
| 492 | 492 | } |
| 493 | 493 | |
@@ -690,7 +690,7 @@ discard block |
||
| 690 | 690 | ); |
| 691 | 691 | |
| 692 | 692 | } catch (\Exception $e) { |
| 693 | - $error = 'Error connecting to mysql server: ' . $e->getMessage(); |
|
| 693 | + $error = 'Error connecting to mysql server: '.$e->getMessage(); |
|
| 694 | 694 | $this->_debug->displayError($error, true); |
| 695 | 695 | throw new DBConnectException($error, 100, $e); |
| 696 | 696 | } |
@@ -698,7 +698,7 @@ discard block |
||
| 698 | 698 | |
| 699 | 699 | $errno = mysqli_connect_errno(); |
| 700 | 700 | if (!$this->connected || $errno) { |
| 701 | - $error = 'Error connecting to mysql server: ' . \mysqli_connect_error() . ' (' . $errno . ')'; |
|
| 701 | + $error = 'Error connecting to mysql server: '.\mysqli_connect_error().' ('.$errno.')'; |
|
| 702 | 702 | $this->_debug->displayError($error, true); |
| 703 | 703 | throw new DBConnectException($error, 101); |
| 704 | 704 | } |
@@ -739,10 +739,10 @@ discard block |
||
| 739 | 739 | } |
| 740 | 740 | |
| 741 | 741 | if ($databaseName) { |
| 742 | - $databaseName = $this->quote_string(\trim($databaseName)) . '.'; |
|
| 742 | + $databaseName = $this->quote_string(\trim($databaseName)).'.'; |
|
| 743 | 743 | } |
| 744 | 744 | |
| 745 | - $sql = 'DELETE FROM ' . $databaseName . $this->quote_string($table) . " WHERE ($WHERE);"; |
|
| 745 | + $sql = 'DELETE FROM '.$databaseName.$this->quote_string($table)." WHERE ($WHERE);"; |
|
| 746 | 746 | |
| 747 | 747 | return $this->query($sql); |
| 748 | 748 | } |
@@ -812,8 +812,8 @@ discard block |
||
| 812 | 812 | $nameTmp = \substr($name, 1); |
| 813 | 813 | } |
| 814 | 814 | |
| 815 | - $parseKeyInner = $nameTmp . '-' . $parseKey; |
|
| 816 | - $sql = \str_replace(':' . $nameTmp, $parseKeyInner, $sql); |
|
| 815 | + $parseKeyInner = $nameTmp.'-'.$parseKey; |
|
| 816 | + $sql = \str_replace(':'.$nameTmp, $parseKeyInner, $sql); |
|
| 817 | 817 | } |
| 818 | 818 | |
| 819 | 819 | foreach ($params as $name => $value) { |
@@ -822,7 +822,7 @@ discard block |
||
| 822 | 822 | $nameTmp = \substr($name, 1); |
| 823 | 823 | } |
| 824 | 824 | |
| 825 | - $parseKeyInner = $nameTmp . '-' . $parseKey; |
|
| 825 | + $parseKeyInner = $nameTmp.'-'.$parseKey; |
|
| 826 | 826 | $sqlBefore = $sql; |
| 827 | 827 | $secureParamValue = $this->secure($params[$name]); |
| 828 | 828 | |
@@ -998,7 +998,7 @@ discard block |
||
| 998 | 998 | |
| 999 | 999 | if ($useCache === true) { |
| 1000 | 1000 | $cache = new Cache(null, null, false, $useCache); |
| 1001 | - $cacheKey = 'sql-' . \md5($query); |
|
| 1001 | + $cacheKey = 'sql-'.\md5($query); |
|
| 1002 | 1002 | |
| 1003 | 1003 | if ( |
| 1004 | 1004 | $cache->getCacheIsReady() === true |
@@ -1108,7 +1108,7 @@ discard block |
||
| 1108 | 1108 | static $firstInstance = null; |
| 1109 | 1109 | |
| 1110 | 1110 | if ( |
| 1111 | - $hostname . $username . $password . $database . $port . $charset == '3306utf8' |
|
| 1111 | + $hostname.$username.$password.$database.$port.$charset == '3306utf8' |
|
| 1112 | 1112 | && |
| 1113 | 1113 | null !== $firstInstance |
| 1114 | 1114 | ) { |
@@ -1118,7 +1118,7 @@ discard block |
||
| 1118 | 1118 | $extra_config_string = ''; |
| 1119 | 1119 | if (\is_array($extra_config) === true) { |
| 1120 | 1120 | foreach ($extra_config as $extra_config_key => $extra_config_value) { |
| 1121 | - $extra_config_string .= $extra_config_key . (string)$extra_config_value; |
|
| 1121 | + $extra_config_string .= $extra_config_key.(string)$extra_config_value; |
|
| 1122 | 1122 | } |
| 1123 | 1123 | } else { |
| 1124 | 1124 | // only for backward compatibility |
@@ -1126,7 +1126,7 @@ discard block |
||
| 1126 | 1126 | } |
| 1127 | 1127 | |
| 1128 | 1128 | $connection = \md5( |
| 1129 | - $hostname . $username . $password . $database . $port . $charset . (int)$exit_on_error . (int)$echo_on_error . $logger_class_name . $logger_level . $extra_config_string |
|
| 1129 | + $hostname.$username.$password.$database.$port.$charset.(int)$exit_on_error.(int)$echo_on_error.$logger_class_name.$logger_level.$extra_config_string |
|
| 1130 | 1130 | ); |
| 1131 | 1131 | |
| 1132 | 1132 | if (!isset($instance[$connection])) { |
@@ -1213,10 +1213,10 @@ discard block |
||
| 1213 | 1213 | $SET = $this->_parseArrayPair($data); |
| 1214 | 1214 | |
| 1215 | 1215 | if ($databaseName) { |
| 1216 | - $databaseName = $this->quote_string(\trim($databaseName)) . '.'; |
|
| 1216 | + $databaseName = $this->quote_string(\trim($databaseName)).'.'; |
|
| 1217 | 1217 | } |
| 1218 | 1218 | |
| 1219 | - $sql = 'INSERT INTO ' . $databaseName . $this->quote_string($table) . " SET $SET;"; |
|
| 1219 | + $sql = 'INSERT INTO '.$databaseName.$this->quote_string($table)." SET $SET;"; |
|
| 1220 | 1220 | |
| 1221 | 1221 | return $this->query($sql); |
| 1222 | 1222 | } |
@@ -1527,11 +1527,11 @@ discard block |
||
| 1527 | 1527 | |
| 1528 | 1528 | // exit if we have more then 3 "DB server has gone away"-errors |
| 1529 | 1529 | if ($RECONNECT_COUNTER > 3) { |
| 1530 | - $this->_debug->mailToAdmin('DB-Fatal-Error', $errorMessage . '(' . $errorNumber . ') ' . ":\n<br />" . $sql, 5); |
|
| 1530 | + $this->_debug->mailToAdmin('DB-Fatal-Error', $errorMessage.'('.$errorNumber.') '.":\n<br />".$sql, 5); |
|
| 1531 | 1531 | throw new DBGoneAwayException($errorMessage); |
| 1532 | 1532 | } |
| 1533 | 1533 | |
| 1534 | - $this->_debug->mailToAdmin('DB-Error', $errorMessage . '(' . $errorNumber . ') ' . ":\n<br />" . $sql); |
|
| 1534 | + $this->_debug->mailToAdmin('DB-Error', $errorMessage.'('.$errorNumber.') '.":\n<br />".$sql); |
|
| 1535 | 1535 | |
| 1536 | 1536 | // reconnect |
| 1537 | 1537 | $RECONNECT_COUNTER++; |
@@ -1545,7 +1545,7 @@ discard block |
||
| 1545 | 1545 | return false; |
| 1546 | 1546 | } |
| 1547 | 1547 | |
| 1548 | - $this->_debug->mailToAdmin('SQL-Error', $errorMessage . '(' . $errorNumber . ') ' . ":\n<br />" . $sql); |
|
| 1548 | + $this->_debug->mailToAdmin('SQL-Error', $errorMessage.'('.$errorNumber.') '.":\n<br />".$sql); |
|
| 1549 | 1549 | |
| 1550 | 1550 | $force_exception_after_error = null; // auto |
| 1551 | 1551 | if ($this->_in_transaction === true) { |
@@ -1553,7 +1553,7 @@ discard block |
||
| 1553 | 1553 | } |
| 1554 | 1554 | // this query returned an error, we must display it (only for dev) !!! |
| 1555 | 1555 | |
| 1556 | - $this->_debug->displayError($errorMessage . '(' . $errorNumber . ') ' . ' | ' . $sql, $force_exception_after_error); |
|
| 1556 | + $this->_debug->displayError($errorMessage.'('.$errorNumber.') '.' | '.$sql, $force_exception_after_error); |
|
| 1557 | 1557 | |
| 1558 | 1558 | return false; |
| 1559 | 1559 | } |
@@ -1576,7 +1576,7 @@ discard block |
||
| 1576 | 1576 | ) |
| 1577 | 1577 | ); |
| 1578 | 1578 | |
| 1579 | - return '`' . $str . '`'; |
|
| 1579 | + return '`'.$str.'`'; |
|
| 1580 | 1580 | } |
| 1581 | 1581 | |
| 1582 | 1582 | /** |
@@ -1647,10 +1647,10 @@ discard block |
||
| 1647 | 1647 | $values = \implode(',', $data); |
| 1648 | 1648 | |
| 1649 | 1649 | if ($databaseName) { |
| 1650 | - $databaseName = $this->quote_string(\trim($databaseName)) . '.'; |
|
| 1650 | + $databaseName = $this->quote_string(\trim($databaseName)).'.'; |
|
| 1651 | 1651 | } |
| 1652 | 1652 | |
| 1653 | - $sql = 'REPLACE INTO ' . $databaseName . $this->quote_string($table) . " ($columns) VALUES ($values);"; |
|
| 1653 | + $sql = 'REPLACE INTO '.$databaseName.$this->quote_string($table)." ($columns) VALUES ($values);"; |
|
| 1654 | 1654 | |
| 1655 | 1655 | return $this->query($sql); |
| 1656 | 1656 | } |
@@ -1748,7 +1748,7 @@ discard block |
||
| 1748 | 1748 | $var = $this->escape($var, false, false, null); |
| 1749 | 1749 | |
| 1750 | 1750 | if (\is_string($var)) { |
| 1751 | - $var = "'" . \trim($var, "'") . "'"; |
|
| 1751 | + $var = "'".\trim($var, "'")."'"; |
|
| 1752 | 1752 | } |
| 1753 | 1753 | |
| 1754 | 1754 | return $var; |
@@ -1785,10 +1785,10 @@ discard block |
||
| 1785 | 1785 | } |
| 1786 | 1786 | |
| 1787 | 1787 | if ($databaseName) { |
| 1788 | - $databaseName = $this->quote_string(\trim($databaseName)) . '.'; |
|
| 1788 | + $databaseName = $this->quote_string(\trim($databaseName)).'.'; |
|
| 1789 | 1789 | } |
| 1790 | 1790 | |
| 1791 | - $sql = 'SELECT * FROM ' . $databaseName . $this->quote_string($table) . " WHERE ($WHERE);"; |
|
| 1791 | + $sql = 'SELECT * FROM '.$databaseName.$this->quote_string($table)." WHERE ($WHERE);"; |
|
| 1792 | 1792 | |
| 1793 | 1793 | return $this->query($sql); |
| 1794 | 1794 | } |
@@ -1830,9 +1830,9 @@ discard block |
||
| 1830 | 1830 | |
| 1831 | 1831 | $return = mysqli_set_charset($this->link, $charset); |
| 1832 | 1832 | /** @noinspection PhpUsageOfSilenceOperatorInspection */ |
| 1833 | - @\mysqli_query($this->link, 'SET CHARACTER SET ' . $charset); |
|
| 1833 | + @\mysqli_query($this->link, 'SET CHARACTER SET '.$charset); |
|
| 1834 | 1834 | /** @noinspection PhpUsageOfSilenceOperatorInspection */ |
| 1835 | - @\mysqli_query($this->link, "SET NAMES '" . $charset . "'"); |
|
| 1835 | + @\mysqli_query($this->link, "SET NAMES '".$charset."'"); |
|
| 1836 | 1836 | |
| 1837 | 1837 | return $return; |
| 1838 | 1838 | } |
@@ -1966,7 +1966,7 @@ discard block |
||
| 1966 | 1966 | $result = $callback($this); |
| 1967 | 1967 | if ($result === false) { |
| 1968 | 1968 | /** @noinspection ThrowRawExceptionInspection */ |
| 1969 | - throw new \Exception('call_user_func [' . $callback . '] === false'); |
|
| 1969 | + throw new \Exception('call_user_func ['.$callback.'] === false'); |
|
| 1970 | 1970 | } |
| 1971 | 1971 | |
| 1972 | 1972 | return $this->commit(); |
@@ -2019,10 +2019,10 @@ discard block |
||
| 2019 | 2019 | } |
| 2020 | 2020 | |
| 2021 | 2021 | if ($databaseName) { |
| 2022 | - $databaseName = $this->quote_string(\trim($databaseName)) . '.'; |
|
| 2022 | + $databaseName = $this->quote_string(\trim($databaseName)).'.'; |
|
| 2023 | 2023 | } |
| 2024 | 2024 | |
| 2025 | - $sql = 'UPDATE ' . $databaseName . $this->quote_string($table) . " SET $SET WHERE ($WHERE);"; |
|
| 2025 | + $sql = 'UPDATE '.$databaseName.$this->quote_string($table)." SET $SET WHERE ($WHERE);"; |
|
| 2026 | 2026 | |
| 2027 | 2027 | return $this->query($sql); |
| 2028 | 2028 | } |
@@ -2036,7 +2036,7 @@ discard block |
||
| 2036 | 2036 | */ |
| 2037 | 2037 | public function table_exists(string $table): bool |
| 2038 | 2038 | { |
| 2039 | - $check = $this->query('SELECT 1 FROM ' . $this->quote_string($table)); |
|
| 2039 | + $check = $this->query('SELECT 1 FROM '.$this->quote_string($table)); |
|
| 2040 | 2040 | |
| 2041 | 2041 | return $check !== false |
| 2042 | 2042 | && |