Majkl578 / doctrine-dbal

lib/Doctrine/DBAL/Sharding/SQLAzure/SQLAzureFederationsSynchronizer.php

Indentation +4 added lines, -4 removed lines

@@ -77,7 +77,7 @@ 
         $globalSql = $this->synchronizer->getCreateSchema($global);
         if ($globalSql) {
             $sql[] = "-- Create Root Federation\n" .
-                     "USE FEDERATION ROOT WITH RESET;";
+                        "USE FEDERATION ROOT WITH RESET;";
             $sql = array_merge($sql, $globalSql);
         }
 
@@ -158,7 +158,7 @@ 
             $federationSql = $this->synchronizer->getDropAllSchema();
             if ($federationSql) {
                 $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" .
-                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";
+                            "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";
                 $sql = array_merge($sql, $federationSql);
             }
         }
@@ -253,7 +253,7 @@ 
             $federationSql = $operation($this->synchronizer, $federation);
             if ($federationSql) {
                 $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" .
-                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";
+                            "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";
                 $sql   = array_merge($sql, $federationSql);
             }
         }
@@ -294,6 +294,6 @@ 
         $federationTypeSql = $federationType->getSQLDeclaration([], $this->conn->getDatabasePlatform());
 
         return "--Create Federation\n" .
-               "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql ."  RANGE)";
+                "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql ."  RANGE)";
     }
 }

Spacing +5 added lines, -5 removed lines

@@ -99,7 +99,7 @@ 
      */
     public function getUpdateSchema(Schema $toSchema, $noDrops = false)
     {
-        return $this->work($toSchema, function ($synchronizer, $schema) use ($noDrops) {
+        return $this->work($toSchema, function($synchronizer, $schema) use ($noDrops) {
             return $synchronizer->getUpdateSchema($schema, $noDrops);
         });
     }
@@ -109,7 +109,7 @@ 
      */
     public function getDropSchema(Schema $dropSchema)
     {
-        return $this->work($dropSchema, function ($synchronizer, $schema) {
+        return $this->work($dropSchema, function($synchronizer, $schema) {
             return $synchronizer->getDropSchema($schema);
         });
     }
@@ -158,7 +158,7 @@ 
             $federationSql = $this->synchronizer->getDropAllSchema();
             if ($federationSql) {
                 $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" .
-                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";
+                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'] . ") WITH RESET, FILTERING = OFF;";
                 $sql = array_merge($sql, $federationSql);
             }
         }
@@ -253,7 +253,7 @@ 
             $federationSql = $operation($this->synchronizer, $federation);
             if ($federationSql) {
                 $sql[] = "-- Work on Federation ID " . $shard['id'] . "\n" .
-                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'].") WITH RESET, FILTERING = OFF;";
+                         "USE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " = " . $shard['rangeLow'] . ") WITH RESET, FILTERING = OFF;";
                 $sql   = array_merge($sql, $federationSql);
             }
         }
@@ -294,6 +294,6 @@ 
         $federationTypeSql = $federationType->getSQLDeclaration([], $this->conn->getDatabasePlatform());
 
         return "--Create Federation\n" .
-               "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql ."  RANGE)";
+               "CREATE FEDERATION " . $this->shardManager->getFederationName() . " (" . $this->shardManager->getDistributionKey() . " " . $federationTypeSql . "  RANGE)";
     }
 }

lib/Doctrine/DBAL/Sharding/SQLAzure/SQLAzureShardManager.php

Indentation +5 added lines, -5 removed lines

@@ -198,9 +198,9 @@ 
         return $this->conn->fetchAll($sql);
     }
 
-     /**
-      * {@inheritDoc}
-      */
+        /**
+         * {@inheritDoc}
+         */
     public function queryAll($sql, array $params = [], array $types = [])
     {
         $shards = $this->getShards();
@@ -239,8 +239,8 @@ 
         $type = Type::getType($this->distributionType);
 
         $sql = "ALTER FEDERATION " . $this->getFederationName() . " " .
-               "SPLIT AT (" . $this->getDistributionKey() . " = " .
-               $this->conn->quote($splitDistributionValue, $type->getBindingType()) . ")";
+                "SPLIT AT (" . $this->getDistributionKey() . " = " .
+                $this->conn->quote($splitDistributionValue, $type->getBindingType()) . ")";
         $this->conn->exec($sql);
     }
 }

Spacing +2 added lines, -2 removed lines

@@ -157,7 +157,7 @@ 
             throw ShardingException::activeTransaction();
         }
 
-        if ($distributionValue === null || is_bool($distributionValue) || !is_scalar($distributionValue)) {
+        if ($distributionValue === null || is_bool($distributionValue) || ! is_scalar($distributionValue)) {
             throw ShardingException::noShardDistributionValue();
         }
 
@@ -204,7 +204,7 @@ 
     public function queryAll($sql, array $params = [], array $types = [])
     {
         $shards = $this->getShards();
-        if (!$shards) {
+        if ( ! $shards) {
             throw new \RuntimeException("No shards found for " . $this->federationName);
         }
 

lib/Doctrine/DBAL/Sharding/SQLAzure/Schema/MultiTenantVisitor.php

Spacing +1 added lines, -1 removed lines

@@ -96,7 +96,7 @@
         }
 
         $table->addColumn($this->tenantColumnName, $this->tenantColumnType, [
-            'default' => "federation_filtering_value('". $this->distributionName ."')",
+            'default' => "federation_filtering_value('" . $this->distributionName . "')",
         ]);
 
         $clusteredIndex = $this->getClusteredIndex($table);

lib/Doctrine/DBAL/Sharding/PoolingShardConnection.php

Spacing +3 added lines, -3 removed lines

@@ -92,11 +92,11 @@ 
      */
     public function __construct(array $params, Driver $driver, Configuration $config = null, EventManager $eventManager = null)
     {
-        if ( !isset($params['global']) || !isset($params['shards'])) {
+        if ( ! isset($params['global']) || ! isset($params['shards'])) {
             throw new \InvalidArgumentException("Connection Parameters require 'global' and 'shards' configurations.");
         }
 
-        if ( !isset($params['shardChoser'])) {
+        if ( ! isset($params['shardChoser'])) {
             throw new \InvalidArgumentException("Missing Shard Choser configuration 'shardChoser'");
         }
 
@@ -115,7 +115,7 @@ 
                 throw new \InvalidArgumentException("Missing 'id' for one configured shard. Please specify a unique shard-id.");
             }
 
-            if ( !is_numeric($shard['id']) || $shard['id'] < 1) {
+            if ( ! is_numeric($shard['id']) || $shard['id'] < 1) {
                 throw new \InvalidArgumentException("Shard Id has to be a non-negative number.");
             }
 

lib/Doctrine/DBAL/Connection.php

Spacing +3 added lines, -3 removed lines

@@ -758,7 +758,7 @@ 
             $types = $this->extractTypeValues($columns, $types);
         }
 
-        $sql  = 'UPDATE ' . $tableExpression . ' SET ' . implode(', ', $set)
+        $sql = 'UPDATE ' . $tableExpression . ' SET ' . implode(', ', $set)
                 . ' WHERE ' . implode(' AND ', $conditions);
 
         return $this->executeUpdate($sql, $values, $types);
@@ -978,7 +978,7 @@ 
             }
         }
 
-        if (!isset($stmt)) {
+        if ( ! isset($stmt)) {
             $stmt = new ResultCacheStatement($this->executeQuery($query, $params, $types), $resultCache, $cacheKey, $realKey, $qcp->getLifetime());
         }
 
@@ -1250,7 +1250,7 @@ 
      */
     protected function _getNestedTransactionSavePointName()
     {
-        return 'DOCTRINE2_SAVEPOINT_'.$this->_transactionNestingLevel;
+        return 'DOCTRINE2_SAVEPOINT_' . $this->_transactionNestingLevel;
     }
 
     /**

lib/Doctrine/DBAL/Event/SchemaDropTableEventArgs.php

Spacing +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
      */
     public function __construct($table, AbstractPlatform $platform)
     {
-        if ( ! $table instanceof Table && !is_string($table)) {
+        if ( ! $table instanceof Table && ! is_string($table)) {
             throw new \InvalidArgumentException('SchemaDropTableEventArgs expects $table parameter to be string or \Doctrine\DBAL\Schema\Table.');
         }
 

lib/Doctrine/DBAL/Event/Listeners/MysqlSessionInit.php

Spacing +2 added lines, -2 removed lines

@@ -66,8 +66,8 @@
      */
     public function postConnect(ConnectionEventArgs $args)
     {
-        $collation = ($this->_collation) ? " COLLATE ".$this->_collation : "";
-        $args->getConnection()->executeUpdate("SET NAMES ".$this->_charset . $collation);
+        $collation = ($this->_collation) ? " COLLATE " . $this->_collation : "";
+        $args->getConnection()->executeUpdate("SET NAMES " . $this->_charset . $collation);
     }
 
     /**

lib/Doctrine/DBAL/Event/Listeners/OracleSessionInit.php

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
                     $vars[] = $option . " = '" . $value . "'";
                 }
             }
-            $sql = "ALTER SESSION SET ".implode(" ", $vars);
+            $sql = "ALTER SESSION SET " . implode(" ", $vars);
             $args->getConnection()->executeUpdate($sql);
         }
     }

lib/Doctrine/DBAL/Id/TableGenerator.php

Indentation +2 added lines, -2 removed lines

@@ -143,8 +143,8 @@
                 }
 
                 $sql = "UPDATE " . $this->generatorTableName . " ".
-                       "SET sequence_value = sequence_value + sequence_increment_by " .
-                       "WHERE sequence_name = ? AND sequence_value = ?";
+                        "SET sequence_value = sequence_value + sequence_increment_by " .
+                        "WHERE sequence_name = ? AND sequence_value = ?";
                 $rows = $this->conn->executeUpdate($sql, [$sequenceName, $row['sequence_value']]);
 
                 if ($rows != 1) {

Spacing +1 added lines, -1 removed lines

@@ -142,7 +142,7 @@
                     ];
                 }
 
-                $sql = "UPDATE " . $this->generatorTableName . " ".
+                $sql = "UPDATE " . $this->generatorTableName . " " .
                        "SET sequence_value = sequence_value + sequence_increment_by " .
                        "WHERE sequence_name = ? AND sequence_value = ?";
                 $rows = $this->conn->executeUpdate($sql, [$sequenceName, $row['sequence_value']]);