byjg / anydataset

testsdb/MongoDbDriverTest.php

Spacing +1 added lines, -1 removed lines

@@ -100,7 +100,7 @@
         $documentToUpdate = new NoSqlDocument(
             $document[0]->getIdDocument(),
             self::TEST_COLLECTION,
-            [ 'price' => 150000 ]
+            ['price' => 150000]
         );
         sleep(1); // Just to force a new Update DateTime
         $documentSaved = $this->dbDriver->save($documentToUpdate);

src/Factory.php

Spacing +10 added lines, -10 removed lines

@@ -27,14 +27,14 @@ 
             $connectionString,
             array_merge(
                 [
-                    "sqlrelay" => $prefix . "DbSqlRelayDriver",
-                    "oci8" => $prefix . "DbOci8Driver",
-                    "dblib" => $prefix . "PdoDblib",
-                    "mysql" => $prefix . "PdoMysql",
-                    "pgsql" => $prefix . "PdoPgsql",
-                    "oci" => $prefix . "PdoOci",
-                    "odbc" => $prefix . "PdoOdbc",
-                    "sqlite" => $prefix . "PdoSqlite",
+                    "sqlrelay" => $prefix."DbSqlRelayDriver",
+                    "oci8" => $prefix."DbOci8Driver",
+                    "dblib" => $prefix."PdoDblib",
+                    "mysql" => $prefix."PdoMysql",
+                    "pgsql" => $prefix."PdoPgsql",
+                    "oci" => $prefix."PdoOci",
+                    "odbc" => $prefix."PdoOdbc",
+                    "sqlite" => $prefix."PdoSqlite",
                 ],
                 (array)$schemesAlternative
             ),
@@ -57,7 +57,7 @@ 
             $connectionString,
             array_merge(
                 [
-                    "mongodb" => $prefix . "MongoDbDriver",
+                    "mongodb" => $prefix."MongoDbDriver",
                 ],
                 (array)$schemesAlternative
             ),
@@ -75,7 +75,7 @@ 
             $connectionString,
             array_merge(
                 [
-                    "s3" => $prefix . "AwsS3Driver",
+                    "s3" => $prefix."AwsS3Driver",
                 ],
                 (array)$schemesAlternative
             ),

src/Dataset/SocketDataset.php

Spacing +2 added lines, -2 removed lines

@@ -57,8 +57,8 @@
             throw new DatasetException("Socket error: $errstr ($errno)");
         }
 
-        $out = "GET " . $this->path . " HTTP/1.1\r\n";
-        $out .= "Host: " . $this->server . "\r\n";
+        $out = "GET ".$this->path." HTTP/1.1\r\n";
+        $out .= "Host: ".$this->server."\r\n";
         $out .= "Connection: Close\r\n\r\n";
 
         fwrite($handle, $out);

src/Dataset/FixedTextFileDataset.php

Spacing +3 added lines, -3 removed lines

@@ -37,7 +37,7 @@ 
 
         if (!preg_match("~^https?://~", $source)) {
             if (!file_exists($this->source)) {
-                throw new NotFoundException("The specified file " . $this->source . " does not exists");
+                throw new NotFoundException("The specified file ".$this->source." does not exists");
             }
 
             $this->sourceType = "FILE";
@@ -80,8 +80,8 @@ 
             throw new DatasetException("TextFileDataset Socket error: $errstr ($errno)");
         }
 
-        $out = "GET " . $urlParts[4] . " HTTP/1.1\r\n";
-        $out .= "Host: " . $urlParts[2] . "\r\n";
+        $out = "GET ".$urlParts[4]." HTTP/1.1\r\n";
+        $out .= "Host: ".$urlParts[2]."\r\n";
         $out .= "Connection: Close\r\n\r\n";
 
         fwrite($handle, $out);

src/Dataset/SparQLDataset.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
         }
 
         if (function_exists('dba_open')) {
-            $cache = sys_get_temp_dir() . "/caps.db";
+            $cache = sys_get_temp_dir()."/caps.db";
             $this->connection->capabilityCache($cache);
         }
     }

src/Dataset/IteratorFilterSqlFormatter.php

Spacing +12 added lines, -12 removed lines

@@ -35,47 +35,47 @@
         $paramName = $name;
         $counter = 0;
         while (array_key_exists($paramName, $param)) {
-            $paramName = $name . ($counter++);
+            $paramName = $name.($counter++);
         }
 
         $param[$paramName] = $value;
 
         $result = "";
         $field = " $name ";
-        $valueparam = " [[" . $paramName . "]] ";
+        $valueparam = " [[".$paramName."]] ";
         switch ($relation) {
             case Relation::EQUAL:
-                $result = $field . "=" . $valueparam;
+                $result = $field."=".$valueparam;
                 break;
 
             case Relation::GREATER_THAN:
-                $result = $field . ">" . $valueparam;
+                $result = $field.">".$valueparam;
                 break;
 
             case Relation::LESS_THAN:
-                $result = $field . "<" . $valueparam;
+                $result = $field."<".$valueparam;
                 break;
 
             case Relation::GREATER_OR_EQUAL_THAN:
-                $result = $field . ">=" . $valueparam;
+                $result = $field.">=".$valueparam;
                 break;
 
             case Relation::LESS_OR_EQUAL_THAN:
-                $result = $field . "<=" . $valueparam;
+                $result = $field."<=".$valueparam;
                 break;
 
             case Relation::NOT_EQUAL:
-                $result = $field . "!=" . $valueparam;
+                $result = $field."!=".$valueparam;
                 break;
 
             case Relation::STARTS_WITH:
-                $param[$paramName] = $value . "%";
-                $result = $field . " like " . $valueparam;
+                $param[$paramName] = $value."%";
+                $result = $field." like ".$valueparam;
                 break;
 
             case Relation::CONTAINS:
-                $param[$paramName] = "%" . $value . "%";
-                $result = $field . " like " . $valueparam;
+                $param[$paramName] = "%".$value."%";
+                $result = $field." like ".$valueparam;
                 break;
 
         }

src/Dataset/TextFileDataset.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
             $this->source = $source;
 
             if (!file_exists($this->source)) {
-                throw new NotFoundException("The specified file " . $this->source . " does not exists");
+                throw new NotFoundException("The specified file ".$this->source." does not exists");
             }
 
             $this->sourceType = "FILE";

src/Dataset/IteratorFilterXPathFormatter.php

Spacing +8 added lines, -8 removed lines

@@ -15,39 +15,39 @@
             return "/anydataset/row";
         }
 
-        return "/anydataset/row[" . $xpathFilter . "]";
+        return "/anydataset/row[".$xpathFilter."]";
     }
 
     public function getRelation($name, $relation, $value, &$param)
     {
         $str = is_numeric($value) ? "" : "'";
-        $field = "field[@name='" . $name . "'] ";
+        $field = "field[@name='".$name."'] ";
         $value = " $str$value$str ";
 
         $result = "";
         switch ($relation) {
             case Relation::EQUAL:
-                $result = $field . "=" . $value;
+                $result = $field."=".$value;
                 break;
 
             case Relation::GREATER_THAN:
-                $result = $field . ">" . $value;
+                $result = $field.">".$value;
                 break;
 
             case Relation::LESS_THAN:
-                $result = $field . "<" . $value;
+                $result = $field."<".$value;
                 break;
 
             case Relation::GREATER_OR_EQUAL_THAN:
-                $result = $field . ">=" . $value;
+                $result = $field.">=".$value;
                 break;
 
             case Relation::LESS_OR_EQUAL_THAN:
-                $result = $field . "<=" . $value;
+                $result = $field."<=".$value;
                 break;
 
             case Relation::NOT_EQUAL:
-                $result = $field . "!=" . $value;
+                $result = $field."!=".$value;
                 break;
 
             case Relation::STARTS_WITH:

src/Store/DbPdoDriver.php

Spacing +10 added lines, -10 removed lines

@@ -33,8 +33,8 @@ 
             throw new NotAvailableException("Extension 'PDO' is not loaded");
         }
 
-        if (!extension_loaded('pdo_' . strtolower($connUri->getScheme()))) {
-            throw new NotAvailableException("Extension 'pdo_" . strtolower($connUri->getScheme()) . "' is not loaded");
+        if (!extension_loaded('pdo_'.strtolower($connUri->getScheme()))) {
+            throw new NotAvailableException("Extension 'pdo_".strtolower($connUri->getScheme())."' is not loaded");
         }
 
         $strcnn = $this->createPboConnStr($connUri);
@@ -49,7 +49,7 @@ 
             $pdoConnectionString,
             $this->connectionUri->getUsername(),
             $this->connectionUri->getPassword(),
-            (array) $preOptions
+            (array)$preOptions
         );
 
         $this->connectionUri->withScheme($this->instance->getAttribute(PDO::ATTR_DRIVER_NAME));
@@ -58,7 +58,7 @@ 
         $this->instance->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
         $this->instance->setAttribute(PDO::ATTR_CASE, PDO::CASE_LOWER);
 
-        foreach ((array) $postOptions as $key => $value) {
+        foreach ((array)$postOptions as $key => $value) {
             $this->instance->setAttribute($key, $value);
         }
     }
@@ -67,7 +67,7 @@ 
     {
         $host = $connUri->getHost();
         if (empty($host)) {
-            return $connUri->getScheme() . ":" . $connUri->getPath();
+            return $connUri->getScheme().":".$connUri->getPath();
         }
 
         $database = preg_replace('~^/~', '', $connUri->getPath());
@@ -75,16 +75,16 @@ 
             $database = ";dbname=$database";
         }
 
-        $strcnn = $connUri->getScheme() . ":"
-            . "host=" . $connUri->getHost()
+        $strcnn = $connUri->getScheme().":"
+            . "host=".$connUri->getHost()
             . $database;
 
         if ($connUri->getPort() != "") {
-            $strcnn .= ";port=" . $connUri->getPort();
+            $strcnn .= ";port=".$connUri->getPort();
         }
 
         $query = $connUri->getQuery();
-        $strcnn .= ";" . implode(';', explode('&', $query));
+        $strcnn .= ";".implode(';', explode('&', $query));
 
         return $strcnn;
     }
@@ -108,7 +108,7 @@ 
 
         if (!empty($array)) {
             foreach ($array as $key => $value) {
-                $stmt->bindValue(":" . SqlBind::keyAdj($key), $value);
+                $stmt->bindValue(":".SqlBind::keyAdj($key), $value);
             }
         }