@@ -23,7 +23,7 @@ discard block |
||
| 23 | 23 | try { |
| 24 | 24 | $stm->execute(); |
| 25 | 25 | } catch (PDOException $exception) { |
| 26 | - throw new DatabaseException($exception->getMessage() . ' [' . $query . ']'); |
|
| 26 | + throw new DatabaseException($exception->getMessage().' ['.$query.']'); |
|
| 27 | 27 | } |
| 28 | 28 | |
| 29 | 29 | return new ResultSet($stm); |
@@ -38,17 +38,17 @@ discard block |
||
| 38 | 38 | |
| 39 | 39 | $dsn = 'mysql:'; |
| 40 | 40 | if (isset($params['host']) && $params['host'] != '') { |
| 41 | - $dsn .= 'host=' . $params['host'] . ';'; |
|
| 41 | + $dsn .= 'host='.$params['host'].';'; |
|
| 42 | 42 | } |
| 43 | 43 | if (isset($params['port'])) { |
| 44 | - $dsn .= 'port=' . $params['port'] . ';'; |
|
| 44 | + $dsn .= 'port='.$params['port'].';'; |
|
| 45 | 45 | } |
| 46 | 46 | if (isset($params['charset'])) { |
| 47 | - $dsn .= 'charset=' . $params['charset'] . ';'; |
|
| 47 | + $dsn .= 'charset='.$params['charset'].';'; |
|
| 48 | 48 | } |
| 49 | 49 | |
| 50 | 50 | if (isset($params['socket']) && $params['socket'] != '') { |
| 51 | - $dsn .= 'unix_socket=' . $params['socket'] . ';'; |
|
| 51 | + $dsn .= 'unix_socket='.$params['socket'].';'; |
|
| 52 | 52 | } |
| 53 | 53 | |
| 54 | 54 | try { |
@@ -92,7 +92,7 @@ discard block |
||
| 92 | 92 | try { |
| 93 | 93 | $statement = $this->connection->query(implode(';', $queue)); |
| 94 | 94 | } catch (PDOException $exception) { |
| 95 | - throw new DatabaseException($exception->getMessage() .' [ '.implode(';', $queue).']'); |
|
| 95 | + throw new DatabaseException($exception->getMessage().' [ '.implode(';', $queue).']'); |
|
| 96 | 96 | } |
| 97 | 97 | |
| 98 | 98 | return new MultiResultSet($statement); |