@@ -46,7 +46,7 @@ |
||
| 46 | 46 | foreach ($this->parameters as $key => $val) { |
| 47 | 47 | $arg = $this->getArgName($key); |
| 48 | 48 | $columnsNames[] = $this->escape($key); |
| 49 | - $columnsValues[] = ':' . $arg; |
|
| 49 | + $columnsValues[] = ':'.$arg; |
|
| 50 | 50 | } |
| 51 | 51 | return trim(sprintf( |
| 52 | 52 | 'INSERT INTO %s (%s) VALUES (%s)', |
@@ -58,7 +58,7 @@ |
||
| 58 | 58 | */ |
| 59 | 59 | public function errorCode() |
| 60 | 60 | { |
| 61 | - return !empty($this->error) ? $this->error['code']: null; |
|
| 61 | + return !empty($this->error) ? $this->error['code'] : null; |
|
| 62 | 62 | } |
| 63 | 63 | |
| 64 | 64 | /** |
@@ -41,7 +41,7 @@ |
||
| 41 | 41 | */ |
| 42 | 42 | public static function getInstance(array $settings, $isServerConnection = false) |
| 43 | 43 | { |
| 44 | - if (! isset($settings['driver'])) { |
|
| 44 | + if (!isset($settings['driver'])) { |
|
| 45 | 45 | throw new Exception\MissingArgException('You must define a driver'); |
| 46 | 46 | } |
| 47 | 47 | |
@@ -261,7 +261,7 @@ |
||
| 261 | 261 | */ |
| 262 | 262 | public function beginTransaction(): void |
| 263 | 263 | { |
| 264 | - if (! $this->inTransaction()) { |
|
| 264 | + if (!$this->inTransaction()) { |
|
| 265 | 265 | $this->getConnection()->beginTransaction(); |
| 266 | 266 | } |
| 267 | 267 | } |
@@ -162,15 +162,15 @@ discard block |
||
| 162 | 162 | { |
| 163 | 163 | // check for required attributes |
| 164 | 164 | foreach ($this->dsnAttributes as $attribute) { |
| 165 | - if (! array_key_exists($attribute, $settings)) { |
|
| 165 | + if (!array_key_exists($attribute, $settings)) { |
|
| 166 | 166 | throw new Exception\MissingArgException('This configuration parameter is missing: "'.$attribute.'"'); |
| 167 | 167 | } |
| 168 | 168 | } |
| 169 | 169 | |
| 170 | 170 | // defaut output format |
| 171 | - if (array_key_exists('default_output_format', $settings)){ |
|
| 171 | + if (array_key_exists('default_output_format', $settings)) { |
|
| 172 | 172 | $format = $settings['default_output_format']; |
| 173 | - if (!in_array($format, $this->outputFormats)){ |
|
| 173 | + if (!in_array($format, $this->outputFormats)) { |
|
| 174 | 174 | throw new Exception\InvalidArgException('The default output format specified is invalid.'); |
| 175 | 175 | } |
| 176 | 176 | $this->defaultOutputFormat = $format; |
@@ -178,7 +178,7 @@ discard block |
||
| 178 | 178 | |
| 179 | 179 | $this->createConnection($settings); |
| 180 | 180 | $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); |
| 181 | - $this->hostname = array_key_exists('hostname',$settings) && $settings['hostname'] ? $settings['hostname'] : ''; |
|
| 181 | + $this->hostname = array_key_exists('hostname', $settings) && $settings['hostname'] ? $settings['hostname'] : ''; |
|
| 182 | 182 | $this->driverName = $settings['driver']; |
| 183 | 183 | } |
| 184 | 184 | |
@@ -212,7 +212,7 @@ discard block |
||
| 212 | 212 | */ |
| 213 | 213 | public function errorCode(): int |
| 214 | 214 | { |
| 215 | - return !empty($this->error) ? $this->error['code']: ''; |
|
| 215 | + return !empty($this->error) ? $this->error['code'] : ''; |
|
| 216 | 216 | } |
| 217 | 217 | |
| 218 | 218 | /** |
@@ -256,7 +256,7 @@ discard block |
||
| 256 | 256 | return $pdoStatement->execute($parameters); |
| 257 | 257 | } catch (\PDOException $e) { |
| 258 | 258 | // register error |
| 259 | - $this->error['code'] = (int)$e->getCode(); |
|
| 259 | + $this->error['code'] = (int) $e->getCode(); |
|
| 260 | 260 | $this->error['message'] = $e->getMessage(); |
| 261 | 261 | return false; |
| 262 | 262 | } |
@@ -98,9 +98,9 @@ discard block |
||
| 98 | 98 | */ |
| 99 | 99 | public function createConnection(array $settings): void |
| 100 | 100 | { |
| 101 | - $port = !empty($settings['port']) ? ';port='.$settings['port'] : ''; |
|
| 102 | - $dbname = !empty($settings['database']) ? ';dbname='.$settings['database'] : ''; |
|
| 103 | - $dsn = 'pgsql:host='.$settings['hostname'] .$port .$dbname ; |
|
| 101 | + $port = !empty($settings['port']) ? ';port='.$settings['port'] : ''; |
|
| 102 | + $dbname = !empty($settings['database']) ? ';dbname='.$settings['database'] : ''; |
|
| 103 | + $dsn = 'pgsql:host='.$settings['hostname'].$port.$dbname; |
|
| 104 | 104 | |
| 105 | 105 | $this->pdo = new \PDO( |
| 106 | 106 | $dsn, |
@@ -222,7 +222,7 @@ discard block |
||
| 222 | 222 | { |
| 223 | 223 | $sql = 'SELECT COUNT(*) FROM pg_database WHERE datname = :dbName'; |
| 224 | 224 | $query = $this->pdo->prepare($sql); |
| 225 | - $query->bindValue(':dbName', $databaseName, \PDO::PARAM_STR); |
|
| 225 | + $query->bindValue(':dbName', $databaseName, \PDO::PARAM_STR); |
|
| 226 | 226 | $query->execute(); |
| 227 | 227 | return (bool) $query->fetchColumn(); |
| 228 | 228 | } |
@@ -237,11 +237,11 @@ discard block |
||
| 237 | 237 | * |
| 238 | 238 | * @return bool True if the database has been created, otherwise false. |
| 239 | 239 | */ |
| 240 | - public function createDatabase(string $databaseName, ?string $owner= null, ?string $template = 'template0'): bool |
|
| 240 | + public function createDatabase(string $databaseName, ?string $owner = null, ?string $template = 'template0'): bool |
|
| 241 | 241 | { |
| 242 | 242 | $sql = trim(sprintf('CREATE DATABASE %s %s TEMPLATE %s', |
| 243 | 243 | $this->escape($databaseName), |
| 244 | - isset($owner) ? 'OWNER '. $this->escape($owner) : '', |
|
| 244 | + isset($owner) ? 'OWNER '.$this->escape($owner) : '', |
|
| 245 | 245 | $template |
| 246 | 246 | )); |
| 247 | 247 | return $this->prepareAndExecuteSql($sql); |
@@ -260,7 +260,7 @@ discard block |
||
| 260 | 260 | { |
| 261 | 261 | $sql = trim(sprintf('CREATE USER %s PASSWORD %s', |
| 262 | 262 | $this->escape($userName), |
| 263 | - "'" . $userPassword ."'" |
|
| 263 | + "'".$userPassword."'" |
|
| 264 | 264 | )); |
| 265 | 265 | return $this->prepareAndExecuteSql($sql); |
| 266 | 266 | } |
@@ -277,7 +277,7 @@ discard block |
||
| 277 | 277 | public function dropUser(string $userName, bool $ifExists = false): bool |
| 278 | 278 | { |
| 279 | 279 | $sql = trim(sprintf('DROP USER %s %s', |
| 280 | - $ifExists === true ? 'IF EXISTS': '', |
|
| 280 | + $ifExists === true ? 'IF EXISTS' : '', |
|
| 281 | 281 | $this->escape($userName) |
| 282 | 282 | )); |
| 283 | 283 | return $this->prepareAndExecuteSql($sql); |
@@ -37,7 +37,7 @@ discard block |
||
| 37 | 37 | public function __construct(array $settings, bool $isServerConnection = false) |
| 38 | 38 | { |
| 39 | 39 | // remove database attribute for server connection |
| 40 | - if ($isServerConnection){ |
|
| 40 | + if ($isServerConnection) { |
|
| 41 | 41 | $dbKey = array_search('database', $this->dsnAttributes); |
| 42 | 42 | if ($dbKey !== false) { |
| 43 | 43 | unset($this->dsnAttributes[$dbKey]); |
@@ -66,7 +66,7 @@ discard block |
||
| 66 | 66 | * |
| 67 | 67 | * @return bool True if the database has been created, otherwise false. |
| 68 | 68 | */ |
| 69 | - abstract public function createDatabase(string $databaseName, ?string $owner= null, ?string $template = null): bool; |
|
| 69 | + abstract public function createDatabase(string $databaseName, ?string $owner = null, ?string $template = null): bool; |
|
| 70 | 70 | |
| 71 | 71 | /** |
| 72 | 72 | * Create a user |
@@ -56,7 +56,7 @@ discard block |
||
| 56 | 56 | */ |
| 57 | 57 | public function escapeIdentifier(string $identifier): string |
| 58 | 58 | { |
| 59 | - return '`' . $identifier .'`'; |
|
| 59 | + return '`'.$identifier.'`'; |
|
| 60 | 60 | } |
| 61 | 61 | |
| 62 | 62 | /** |
@@ -82,15 +82,15 @@ discard block |
||
| 82 | 82 | */ |
| 83 | 83 | public function createConnection(array $settings): void |
| 84 | 84 | { |
| 85 | - $charset = !empty($settings['charset']) ? ';charset='.$settings['charset'] : ';charset=utf8'; |
|
| 86 | - $port = !empty($settings['port']) ? ';port='.$settings['port'] : ''; |
|
| 87 | - $dbname = !empty($settings['database']) ? ';dbname='.$settings['database'] : ''; |
|
| 85 | + $charset = !empty($settings['charset']) ? ';charset='.$settings['charset'] : ';charset=utf8'; |
|
| 86 | + $port = !empty($settings['port']) ? ';port='.$settings['port'] : ''; |
|
| 87 | + $dbname = !empty($settings['database']) ? ';dbname='.$settings['database'] : ''; |
|
| 88 | 88 | $options = [ |
| 89 | 89 | // \PDO::ATTR_EMULATE_PREPARES => false, |
| 90 | 90 | ]; |
| 91 | 91 | |
| 92 | 92 | $this->pdo = new \PDO( |
| 93 | - 'mysql:host='.$settings['hostname'] .$port .$dbname .$charset, |
|
| 93 | + 'mysql:host='.$settings['hostname'].$port.$dbname.$charset, |
|
| 94 | 94 | $settings['username'], |
| 95 | 95 | $settings['password'], |
| 96 | 96 | $options |
@@ -201,7 +201,7 @@ discard block |
||
| 201 | 201 | { |
| 202 | 202 | $sql = 'SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = :dbName'; |
| 203 | 203 | $query = $this->pdo->prepare($sql); |
| 204 | - $query->bindValue(':dbName', $databaseName, \PDO::PARAM_STR); |
|
| 204 | + $query->bindValue(':dbName', $databaseName, \PDO::PARAM_STR); |
|
| 205 | 205 | $query->execute(); |
| 206 | 206 | return (bool) $query->fetchColumn(); |
| 207 | 207 | } |
@@ -218,7 +218,7 @@ discard block |
||
| 218 | 218 | */ |
| 219 | 219 | public function createDatabase(string $databaseName, ?string $owner = null, ?string $template = null): bool |
| 220 | 220 | { |
| 221 | - $sql = trim(sprintf('CREATE DATABASE %s', $this->escape($databaseName))); |
|
| 221 | + $sql = trim(sprintf('CREATE DATABASE %s', $this->escape($databaseName))); |
|
| 222 | 222 | return $this->prepareAndExecuteSql($sql); |
| 223 | 223 | } |
| 224 | 224 | |
@@ -236,7 +236,7 @@ discard block |
||
| 236 | 236 | $sql = trim(sprintf('CREATE USER %s@%s IDENTIFIED BY %s', |
| 237 | 237 | $this->escape($userName), |
| 238 | 238 | $this->escape($this->getHostName()), |
| 239 | - "'" . $userPassword ."'" |
|
| 239 | + "'".$userPassword."'" |
|
| 240 | 240 | )); |
| 241 | 241 | return $this->prepareAndExecuteSql($sql); |
| 242 | 242 | } |
@@ -253,7 +253,7 @@ discard block |
||
| 253 | 253 | public function dropUser(string $userName, bool $ifExists = false): bool |
| 254 | 254 | { |
| 255 | 255 | $sql = trim(sprintf('DROP USER %s %s@%s', |
| 256 | - $ifExists === true ? 'IF EXISTS': '', |
|
| 256 | + $ifExists === true ? 'IF EXISTS' : '', |
|
| 257 | 257 | $this->escape($userName), |
| 258 | 258 | $this->escape($this->getHostName()) |
| 259 | 259 | )); |
@@ -320,7 +320,7 @@ discard block |
||
| 320 | 320 | */ |
| 321 | 321 | public function sqlCreateTableOptions(): string |
| 322 | 322 | { |
| 323 | - $engine = !empty($settings['engine']) ? $settings['engine'] : 'InnoDB'; |
|
| 323 | + $engine = !empty($settings['engine']) ? $settings['engine'] : 'InnoDB'; |
|
| 324 | 324 | $charset = !empty($settings['charset']) ? $settings['charset'] : 'utf8'; |
| 325 | 325 | $collate = !empty($settings['collate']) ? $settings['collate'] : 'utf8_unicode_ci'; |
| 326 | 326 | return sprintf('ENGINE=%s DEFAULT CHARSET=%s COLLATE=%s;', $engine, $charset, $collate); |
@@ -349,7 +349,7 @@ discard block |
||
| 349 | 349 | */ |
| 350 | 350 | public function sqlColumnAutoIncrement(string $type): string |
| 351 | 351 | { |
| 352 | - return $type .' AUTO_INCREMENT'; |
|
| 352 | + return $type.' AUTO_INCREMENT'; |
|
| 353 | 353 | } |
| 354 | 354 | |
| 355 | 355 | } |
@@ -61,7 +61,7 @@ discard block |
||
| 61 | 61 | */ |
| 62 | 62 | protected function getArgName(string $column): string |
| 63 | 63 | { |
| 64 | - return '_' . str_replace('.', '_', $column); |
|
| 64 | + return '_'.str_replace('.', '_', $column); |
|
| 65 | 65 | } |
| 66 | 66 | |
| 67 | 67 | /** |
@@ -76,7 +76,7 @@ discard block |
||
| 76 | 76 | { |
| 77 | 77 | // Define column parameters |
| 78 | 78 | $columns = func_get_args(); |
| 79 | - if (!empty($columns)){ |
|
| 79 | + if (!empty($columns)) { |
|
| 80 | 80 | |
| 81 | 81 | // clear current parameters |
| 82 | 82 | unset($this->parameters); |