byjg / anydataset

src/Store/Helpers/SqlHelper.php

Doc Comments +3 added lines

@@ -160,6 +160,9 @@
         $this->fieldDeliRight = $right;
     }
 
+    /**
+     * @param string $sql
+     */
     public static function createSafeSQL($sql, $list)
     {
         return str_replace(array_keys($list), array_values($list), $sql);

Spacing +3 added lines, -3 removed lines

@@ -79,7 +79,7 @@ 
                     $campos .= ", ";
                     $valores .= ", ";
                 }
-                $campos .= $this->fieldDeliLeft . $fieldname . $this->fieldDeliRight;
+                $campos .= $this->fieldDeliLeft.$fieldname.$this->fieldDeliRight;
                 $valores .= $this->getValue($fieldname, $fieldvalue, $param, $decimalpoint);
             }
             $sql = "insert into $table ($campos) values ($valores)";
@@ -103,7 +103,7 @@ 
      */
     protected function getValue($name, $valores, &$param, $decimalpoint)
     {
-        $paramName = "[[" . $name . "]]";
+        $paramName = "[[".$name."]]";
         if (!is_array($valores)) {
             $valores = array(SQLFieldType::TEXT, $valores);
         }
@@ -151,7 +151,7 @@ 
         if (strlen($sql) > 4) {
             $sql .= ' and ';
         }
-        $sql = " $fieldName " . $relation . " " . $this->getValue($fieldName, $value, $param, '.');
+        $sql = " $fieldName ".$relation." ".$this->getValue($fieldName, $value, $param, '.');
     }
 
     public function setFieldDelimeters($left, $right)

src/Store/MongoDbDriver.php

Doc Comments +2 added lines, -2 removed lines

@@ -94,7 +94,7 @@ 
 
     /**
      * @param $idDocument
-     * @param null $collection
+     * @param string $collection
      * @return \ByJG\AnyDataset\NoSqlDocument|null
      */
     public function getDocumentById($idDocument, $collection = null)
@@ -112,7 +112,7 @@ 
 
     /**
      * @param \ByJG\AnyDataset\Dataset\IteratorFilter $filter
-     * @param null $collection
+     * @param null|string $collection
      * @return \ByJG\AnyDataset\NoSqlDocument[]|null
      */
     public function getDocuments(IteratorFilter $filter, $collection = null)

Switch Indentation +24 added lines, -24 removed lines

@@ -162,37 +162,37 @@
             }
 
             switch ($relation) {
-                case Relation::EQUAL:
-                    $result[$name] = $value;
-                    break;
+            case Relation::EQUAL:
+                $result[$name] = $value;
+                break;
 
-                case Relation::GREATER_THAN:
-                    $result[$name] = [ '$gt' => $value ];
-                    break;
+            case Relation::GREATER_THAN:
+                $result[$name] = [ '$gt' => $value ];
+                break;
 
-                case Relation::LESS_THAN:
-                    $result[$name] = [ '$lt' => $value ];
-                    break;
+            case Relation::LESS_THAN:
+                $result[$name] = [ '$lt' => $value ];
+                break;
 
-                case Relation::GREATER_OR_EQUAL_THAN:
-                    $result[$name] = [ '$gte' => $value ];
-                    break;
+            case Relation::GREATER_OR_EQUAL_THAN:
+                $result[$name] = [ '$gte' => $value ];
+                break;
 
-                case Relation::LESS_OR_EQUAL_THAN:
-                    $result[$name] = [ '$lte' => $value ];
-                    break;
+            case Relation::LESS_OR_EQUAL_THAN:
+                $result[$name] = [ '$lte' => $value ];
+                break;
 
-                case Relation::NOT_EQUAL:
-                    $result[$name] = [ '$ne' => $value ];
-                    break;
+            case Relation::NOT_EQUAL:
+                $result[$name] = [ '$ne' => $value ];
+                break;
 
-                case Relation::STARTS_WITH:
-                    $result[$name] = [ '$regex' => "^$value" ];
-                    break;
+            case Relation::STARTS_WITH:
+                $result[$name] = [ '$regex' => "^$value" ];
+                break;
 
-                case Relation::CONTAINS:
-                    $result[$name] = [ '$regex' => "$value" ];
-                    break;
+            case Relation::CONTAINS:
+                $result[$name] = [ '$regex' => "$value" ];
+                break;
 
             }
         }

Spacing +12 added lines, -12 removed lines

@@ -122,7 +122,7 @@ 
         }
 
         $dataCursor = $this->mongoManager->executeQuery(
-            $this->database . '.' . $collection,
+            $this->database.'.'.$collection,
             $this->getMongoFilterArray($filter)
         );
 
@@ -167,31 +167,31 @@ 
                     break;
 
                 case Relation::GREATER_THAN:
-                    $result[$name] = [ '$gt' => $value ];
+                    $result[$name] = ['$gt' => $value];
                     break;
 
                 case Relation::LESS_THAN:
-                    $result[$name] = [ '$lt' => $value ];
+                    $result[$name] = ['$lt' => $value];
                     break;
 
                 case Relation::GREATER_OR_EQUAL_THAN:
-                    $result[$name] = [ '$gte' => $value ];
+                    $result[$name] = ['$gte' => $value];
                     break;
 
                 case Relation::LESS_OR_EQUAL_THAN:
-                    $result[$name] = [ '$lte' => $value ];
+                    $result[$name] = ['$lte' => $value];
                     break;
 
                 case Relation::NOT_EQUAL:
-                    $result[$name] = [ '$ne' => $value ];
+                    $result[$name] = ['$ne' => $value];
                     break;
 
                 case Relation::STARTS_WITH:
-                    $result[$name] = [ '$regex' => "^$value" ];
+                    $result[$name] = ['$regex' => "^$value"];
                     break;
 
                 case Relation::CONTAINS:
-                    $result[$name] = [ '$regex' => "$value" ];
+                    $result[$name] = ['$regex' => "$value"];
                     break;
 
             }
@@ -219,7 +219,7 @@ 
 
         $bulkWrite->delete($this->getMongoFilterArray($filter));
         $this->mongoManager->executeBulkWrite(
-            $this->database . '.' . $collection,
+            $this->database.'.'.$collection,
             $bulkWrite,
             $writeConcern
         );
@@ -241,10 +241,10 @@ 
             $idDocument = isset($data['_id']) ? $data['_id'] : null;
         }
 
-        $data['updated'] = new UTCDateTime((new \DateTime())->getTimestamp()*1000);
+        $data['updated'] = new UTCDateTime((new \DateTime())->getTimestamp() * 1000);
         if (empty($idDocument)) {
             $data['_id'] = $idDocument = new ObjectID();
-            $data['created'] = new UTCDateTime((new \DateTime())->getTimestamp()*1000);
+            $data['created'] = new UTCDateTime((new \DateTime())->getTimestamp() * 1000);
             $bulkWrite->insert($data);
         } else {
             $data['_id'] = $idDocument;
@@ -252,7 +252,7 @@ 
         }
 
         $this->mongoManager->executeBulkWrite(
-            $this->database . "." . $document->getCollection(),
+            $this->database.".".$document->getCollection(),
             $bulkWrite,
             $writeConcern
         );

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

Switch Indentation +33 added lines, -33 removed lines

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

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";