@@ -220,9 +220,9 @@ |
||
220 | 220 | private static function getUnquotedStatementFragments($statement) |
221 | 221 | { |
222 | 222 | $literal = self::ESCAPED_SINGLE_QUOTED_TEXT . '|' . |
223 | - self::ESCAPED_DOUBLE_QUOTED_TEXT . '|' . |
|
224 | - self::ESCAPED_BACKTICK_QUOTED_TEXT . '|' . |
|
225 | - self::ESCAPED_BRACKET_QUOTED_TEXT; |
|
223 | + self::ESCAPED_DOUBLE_QUOTED_TEXT . '|' . |
|
224 | + self::ESCAPED_BACKTICK_QUOTED_TEXT . '|' . |
|
225 | + self::ESCAPED_BRACKET_QUOTED_TEXT; |
|
226 | 226 | preg_match_all("/([^'\"`\[]+)(?:$literal)?/s", $statement, $fragments, PREG_OFFSET_CAPTURE); |
227 | 227 | |
228 | 228 | return $fragments[1]; |
@@ -59,7 +59,7 @@ |
||
59 | 59 | * - passing client_encoding via the 'options' param breaks pgbouncer support |
60 | 60 | */ |
61 | 61 | if (isset($params['charset'])) { |
62 | - $pdo->query('SET NAMES \''.$params['charset'].'\''); |
|
62 | + $pdo->query('SET NAMES \''.$params['charset'].'\''); |
|
63 | 63 | } |
64 | 64 | |
65 | 65 | return $pdo; |
@@ -41,11 +41,11 @@ |
||
41 | 41 | if ($params['host'] !== 'localhost' && $params['host'] != '127.0.0.1') { |
42 | 42 | // if the host isn't localhost, use extended connection params |
43 | 43 | $params['dbname'] = 'DRIVER={IBM DB2 ODBC DRIVER}' . |
44 | - ';DATABASE=' . $params['dbname'] . |
|
45 | - ';HOSTNAME=' . $params['host'] . |
|
46 | - ';PROTOCOL=' . $params['protocol'] . |
|
47 | - ';UID=' . $username . |
|
48 | - ';PWD=' . $password .';'; |
|
44 | + ';DATABASE=' . $params['dbname'] . |
|
45 | + ';HOSTNAME=' . $params['host'] . |
|
46 | + ';PROTOCOL=' . $params['protocol'] . |
|
47 | + ';UID=' . $username . |
|
48 | + ';PWD=' . $password .';'; |
|
49 | 49 | if (isset($params['port'])) { |
50 | 50 | $params['dbname'] .= 'PORT=' . $params['port']; |
51 | 51 | } |
@@ -145,8 +145,8 @@ |
||
145 | 145 | } |
146 | 146 | |
147 | 147 | return '(DESCRIPTION=' . |
148 | - '(ADDRESS=(PROTOCOL=TCP)(HOST=' . $params['host'] . ')(PORT=' . $params['port'] . '))' . |
|
149 | - '(CONNECT_DATA=(' . $service . ')' . $instance . $pooled . '))'; |
|
148 | + '(ADDRESS=(PROTOCOL=TCP)(HOST=' . $params['host'] . ')(PORT=' . $params['port'] . '))' . |
|
149 | + '(CONNECT_DATA=(' . $service . ')' . $instance . $pooled . '))'; |
|
150 | 150 | |
151 | 151 | } |
152 | 152 |
@@ -49,18 +49,18 @@ discard block |
||
49 | 49 | * |
50 | 50 | * @var array |
51 | 51 | */ |
52 | - private static $_driverMap = [ |
|
53 | - 'pdo_mysql' => 'Doctrine\DBAL\Driver\PDOMySql\Driver', |
|
54 | - 'pdo_sqlite' => 'Doctrine\DBAL\Driver\PDOSqlite\Driver', |
|
55 | - 'pdo_pgsql' => 'Doctrine\DBAL\Driver\PDOPgSql\Driver', |
|
56 | - 'pdo_oci' => 'Doctrine\DBAL\Driver\PDOOracle\Driver', |
|
57 | - 'oci8' => 'Doctrine\DBAL\Driver\OCI8\Driver', |
|
58 | - 'ibm_db2' => 'Doctrine\DBAL\Driver\IBMDB2\DB2Driver', |
|
59 | - 'pdo_sqlsrv' => 'Doctrine\DBAL\Driver\PDOSqlsrv\Driver', |
|
60 | - 'mysqli' => 'Doctrine\DBAL\Driver\Mysqli\Driver', |
|
61 | - 'drizzle_pdo_mysql' => 'Doctrine\DBAL\Driver\DrizzlePDOMySql\Driver', |
|
62 | - 'sqlanywhere' => 'Doctrine\DBAL\Driver\SQLAnywhere\Driver', |
|
63 | - 'sqlsrv' => 'Doctrine\DBAL\Driver\SQLSrv\Driver', |
|
52 | + private static $_driverMap = [ |
|
53 | + 'pdo_mysql' => 'Doctrine\DBAL\Driver\PDOMySql\Driver', |
|
54 | + 'pdo_sqlite' => 'Doctrine\DBAL\Driver\PDOSqlite\Driver', |
|
55 | + 'pdo_pgsql' => 'Doctrine\DBAL\Driver\PDOPgSql\Driver', |
|
56 | + 'pdo_oci' => 'Doctrine\DBAL\Driver\PDOOracle\Driver', |
|
57 | + 'oci8' => 'Doctrine\DBAL\Driver\OCI8\Driver', |
|
58 | + 'ibm_db2' => 'Doctrine\DBAL\Driver\IBMDB2\DB2Driver', |
|
59 | + 'pdo_sqlsrv' => 'Doctrine\DBAL\Driver\PDOSqlsrv\Driver', |
|
60 | + 'mysqli' => 'Doctrine\DBAL\Driver\Mysqli\Driver', |
|
61 | + 'drizzle_pdo_mysql' => 'Doctrine\DBAL\Driver\DrizzlePDOMySql\Driver', |
|
62 | + 'sqlanywhere' => 'Doctrine\DBAL\Driver\SQLAnywhere\Driver', |
|
63 | + 'sqlsrv' => 'Doctrine\DBAL\Driver\SQLSrv\Driver', |
|
64 | 64 | ]; |
65 | 65 | |
66 | 66 | /** |
@@ -172,7 +172,7 @@ discard block |
||
172 | 172 | $wrapperClass = 'Doctrine\DBAL\Connection'; |
173 | 173 | if (isset($params['wrapperClass'])) { |
174 | 174 | if (is_subclass_of($params['wrapperClass'], $wrapperClass)) { |
175 | - $wrapperClass = $params['wrapperClass']; |
|
175 | + $wrapperClass = $params['wrapperClass']; |
|
176 | 176 | } else { |
177 | 177 | throw DBALException::invalidWrapperClass($params['wrapperClass']); |
178 | 178 | } |
@@ -77,7 +77,7 @@ discard block |
||
77 | 77 | $globalSql = $this->synchronizer->getCreateSchema($global); |
78 | 78 | if ($globalSql) { |
79 | 79 | $sql[] = "-- Create Root Federation\n" . |
80 | - "USE FEDERATION ROOT WITH RESET;"; |
|
80 | + "USE FEDERATION ROOT WITH RESET;"; |
|
81 | 81 | $sql = array_merge($sql, $globalSql); |
82 | 82 | } |
83 | 83 | |
@@ -158,7 +158,7 @@ discard block |
||
158 | 158 | $federationSql = $this->synchronizer->getDropAllSchema(); |
159 | 159 | if ($federationSql) { |
160 | 160 | $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" . |
161 | - "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;"; |
|
161 | + "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;"; |
|
162 | 162 | $sql = array_merge($sql, $federationSql); |
163 | 163 | } |
164 | 164 | } |
@@ -253,7 +253,7 @@ discard block |
||
253 | 253 | $federationSql = $operation($this->synchronizer, $federation); |
254 | 254 | if ($federationSql) { |
255 | 255 | $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" . |
256 | - "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;"; |
|
256 | + "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;"; |
|
257 | 257 | $sql = array_merge($sql, $federationSql); |
258 | 258 | } |
259 | 259 | } |
@@ -294,6 +294,6 @@ discard block |
||
294 | 294 | $federationTypeSql = $federationType->getSQLDeclaration([], $this->conn->getDatabasePlatform()); |
295 | 295 | |
296 | 296 | return "--Create Federation\n" . |
297 | - "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql ." RANGE)"; |
|
297 | + "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql ." RANGE)"; |
|
298 | 298 | } |
299 | 299 | } |
@@ -198,9 +198,9 @@ discard block |
||
198 | 198 | return $this->conn->fetchAll($sql); |
199 | 199 | } |
200 | 200 | |
201 | - /** |
|
202 | - * {@inheritDoc} |
|
203 | - */ |
|
201 | + /** |
|
202 | + * {@inheritDoc} |
|
203 | + */ |
|
204 | 204 | public function queryAll($sql, array $params = [], array $types = []) |
205 | 205 | { |
206 | 206 | $shards = $this->getShards(); |
@@ -239,8 +239,8 @@ discard block |
||
239 | 239 | $type = Type::getType($this->distributionType); |
240 | 240 | |
241 | 241 | $sql = "ALTER FEDERATION " . $this->getFederationName() . " " . |
242 | - "SPLIT AT (" . $this->getDistributionKey() . " = " . |
|
243 | - $this->conn->quote($splitDistributionValue, $type->getBindingType()) . ")"; |
|
242 | + "SPLIT AT (" . $this->getDistributionKey() . " = " . |
|
243 | + $this->conn->quote($splitDistributionValue, $type->getBindingType()) . ")"; |
|
244 | 244 | $this->conn->exec($sql); |
245 | 245 | } |
246 | 246 | } |
@@ -143,8 +143,8 @@ |
||
143 | 143 | } |
144 | 144 | |
145 | 145 | $sql = "UPDATE " . $this->generatorTableName . " ". |
146 | - "SET sequence_value = sequence_value + sequence_increment_by " . |
|
147 | - "WHERE sequence_name = ? AND sequence_value = ?"; |
|
146 | + "SET sequence_value = sequence_value + sequence_increment_by " . |
|
147 | + "WHERE sequence_name = ? AND sequence_value = ?"; |
|
148 | 148 | $rows = $this->conn->executeUpdate($sql, [$sequenceName, $row['sequence_value']]); |
149 | 149 | |
150 | 150 | if ($rows != 1) { |
@@ -413,7 +413,7 @@ |
||
413 | 413 | } |
414 | 414 | |
415 | 415 | return 'ALTER TABLE ' . $table . |
416 | - ' ADD ' . $this->getTableConstraintDeclarationSQL($constraint, $constraint->getQuotedName($this)); |
|
416 | + ' ADD ' . $this->getTableConstraintDeclarationSQL($constraint, $constraint->getQuotedName($this)); |
|
417 | 417 | } |
418 | 418 | |
419 | 419 | /** |