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