@@ -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)); |