byjg / anydataset

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
      * @throws \Exception
      * @throws \MongoDB\Driver\Exception\Exception
@@ -114,7 +114,7 @@ 
 
     /**
      * @param \ByJG\AnyDataset\Dataset\IteratorFilter $filter
-     * @param null $collection
+     * @param null|string $collection
      * @return \ByJG\AnyDataset\NoSqlDocument[]|null
      * @throws \Exception
      * @throws \MongoDB\Driver\Exception\Exception

Spacing +20 added lines, -20 removed lines

@@ -126,7 +126,7 @@ 
         }
 
         $dataCursor = $this->mongoManager->executeQuery(
-            $this->database . '.' . $collection,
+            $this->database.'.'.$collection,
             $this->getMongoFilterArray($filter)
         );
 
@@ -166,29 +166,29 @@ 
             }
 
             $data = [
-                Relation::EQUAL => function ($value) {
+                Relation::EQUAL => function($value) {
                     return $value;
                 },
-                Relation::GREATER_THAN => function ($value) {
-                    return [ '$gt' => $value ];
+                Relation::GREATER_THAN => function($value) {
+                    return ['$gt' => $value];
                 },
-                Relation::LESS_THAN => function ($value) {
-                    return [ '$lt' => $value ];
+                Relation::LESS_THAN => function($value) {
+                    return ['$lt' => $value];
                 },
-                Relation::GREATER_OR_EQUAL_THAN => function ($value) {
-                    return [ '$gte' => $value ];
+                Relation::GREATER_OR_EQUAL_THAN => function($value) {
+                    return ['$gte' => $value];
                 },
-                Relation::LESS_OR_EQUAL_THAN => function ($value) {
-                    return [ '$lte' => $value ];
+                Relation::LESS_OR_EQUAL_THAN => function($value) {
+                    return ['$lte' => $value];
                 },
-                Relation::NOT_EQUAL => function ($value) {
-                    return [ '$ne' => $value ];
+                Relation::NOT_EQUAL => function($value) {
+                    return ['$ne' => $value];
                 },
-                Relation::STARTS_WITH => function ($value) {
-                    return [ '$regex' => "^$value" ];
+                Relation::STARTS_WITH => function($value) {
+                    return ['$regex' => "^$value"];
                 },
-                Relation::CONTAINS => function ($value) {
-                    return [ '$regex' => "$value" ];
+                Relation::CONTAINS => function($value) {
+                    return ['$regex' => "$value"];
                 },
             ];
             
@@ -217,7 +217,7 @@ 
 
         $bulkWrite->delete($this->getMongoFilterArray($filter));
         $this->mongoManager->executeBulkWrite(
-            $this->database . '.' . $collection,
+            $this->database.'.'.$collection,
             $bulkWrite,
             $writeConcern
         );
@@ -244,10 +244,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;
@@ -255,7 +255,7 @@ 
         }
 
         $this->mongoManager->executeBulkWrite(
-            $this->database . "." . $document->getCollection(),
+            $this->database.".".$document->getCollection(),
             $bulkWrite,
             $writeConcern
         );

src/Dataset/IteratorFilterSqlFormatter.php

Spacing +11 added lines, -11 removed lines

@@ -35,43 +35,43 @@
         $paramName = $name;
         $counter = 0;
         while (array_key_exists($paramName, $param)) {
-            $paramName = $name . ($counter++);
+            $paramName = $name.($counter++);
         }
 
         $param[$paramName] = $value;
 
         $data = [
-            Relation::EQUAL => function ($name, $paramName) {
+            Relation::EQUAL => function($name, $paramName) {
                 return " $name = [[$paramName]] ";
             },
 
-            Relation::GREATER_THAN => function ($name, $paramName) {
+            Relation::GREATER_THAN => function($name, $paramName) {
                 return " $name > [[$paramName]] ";
             },
 
-            Relation::LESS_THAN => function ($name, $paramName) {
+            Relation::LESS_THAN => function($name, $paramName) {
                 return " $name < [[$paramName]] ";
             },
 
-            Relation::GREATER_OR_EQUAL_THAN => function ($name, $paramName) {
+            Relation::GREATER_OR_EQUAL_THAN => function($name, $paramName) {
                 return " $name >= [[$paramName]] ";
             },
 
-            Relation::LESS_OR_EQUAL_THAN => function ($name, $paramName) {
+            Relation::LESS_OR_EQUAL_THAN => function($name, $paramName) {
                 return " $name <= [[$paramName]] ";
             },
 
-            Relation::NOT_EQUAL => function ($name, $paramName) {
+            Relation::NOT_EQUAL => function($name, $paramName) {
                 return " $name != [[$paramName]] ";
             },
 
-            Relation::STARTS_WITH => function ($name, $paramName) use (&$param, $value) {
-                $param[$paramName] = $value . "%";
+            Relation::STARTS_WITH => function($name, $paramName) use (&$param, $value) {
+                $param[$paramName] = $value."%";
                 return " $name  like  [[$paramName]] ";
             },
 
-            Relation::CONTAINS => function ($name, $paramName) use (&$param, $value) {
-                $param[$paramName] = "%" . $value . "%";
+            Relation::CONTAINS => function($name, $paramName) use (&$param, $value) {
+                $param[$paramName] = "%".$value."%";
                 return " $name  like  [[$paramName]] ";
             }
         ];

src/Dataset/IteratorFilter.php

Spacing +8 added lines, -8 removed lines

@@ -72,35 +72,35 @@
             }
 
             $data = [
-                Relation::EQUAL => function ($valueparam, $value) {
+                Relation::EQUAL => function($valueparam, $value) {
                     return ($valueparam == $value);
                 },
 
-                Relation::GREATER_THAN => function ($valueparam, $value) {
+                Relation::GREATER_THAN => function($valueparam, $value) {
                     return ($valueparam > $value);
                 },
 
-                Relation::LESS_THAN => function ($valueparam, $value) {
+                Relation::LESS_THAN => function($valueparam, $value) {
                     return ($valueparam < $value);
                 },
 
-                Relation::GREATER_OR_EQUAL_THAN => function ($valueparam, $value) {
+                Relation::GREATER_OR_EQUAL_THAN => function($valueparam, $value) {
                     return ($valueparam >= $value);
                 },
 
-                Relation::LESS_OR_EQUAL_THAN => function ($valueparam, $value) {
+                Relation::LESS_OR_EQUAL_THAN => function($valueparam, $value) {
                     return ($valueparam <= $value);
                 },
 
-                Relation::NOT_EQUAL => function ($valueparam, $value) {
+                Relation::NOT_EQUAL => function($valueparam, $value) {
                     return ($valueparam != $value);
                 },
 
-                Relation::STARTS_WITH => function ($valueparam, $value) {
+                Relation::STARTS_WITH => function($valueparam, $value) {
                     return (strpos($valueparam, $value) === 0);
                 },
 
-                Relation::CONTAINS => function ($valueparam, $value) {
+                Relation::CONTAINS => function($valueparam, $value) {
                     return (strpos($valueparam, $value) !== false);
                 },
             ];

src/Dataset/SocketIterator.php

Spacing +3 added lines, -3 removed lines

@@ -41,10 +41,10 @@ 
         }
 
         $this->rows = array();
-        $rowsaux = preg_split("/" . $this->rowsep . "/", $linha);
+        $rowsaux = preg_split("/".$this->rowsep."/", $linha);
         sort($rowsaux);
         foreach ($rowsaux as $value) {
-            $colsaux = preg_split("/" . $this->colsep . "/", $value);
+            $colsaux = preg_split("/".$this->colsep."/", $value);
             if (count($colsaux) == count($fieldnames)) {
                 $this->rows[] = $value;
             }
@@ -77,7 +77,7 @@ 
      */
     public function moveNext()
     {
-        $cols = preg_split("/" . $this->colsep . "/", $this->rows[$this->current]);
+        $cols = preg_split("/".$this->colsep."/", $this->rows[$this->current]);
         $this->current++;
 
         $row = new Row();

src/Dataset/Row.php

Spacing +1 added lines, -1 removed lines

@@ -222,7 +222,7 @@
             return json_decode(json_encode($this->row));
         } else {
             throw new UnexpectedValueException(
-                'I expected that getRawFormat is array() but ' . gettype($this->row) . ' was given'
+                'I expected that getRawFormat is array() but '.gettype($this->row).' was given'
             );
         }
     }

src/Dataset/IteratorFilterXPathFormatter.php

Indentation +8 added lines, -8 removed lines

@@ -26,35 +26,35 @@
 
         $data = [
             Relation::EQUAL => function ($field, $value) {
-                 return $field . "=" . $value;
+                    return $field . "=" . $value;
             },
 
             Relation::GREATER_THAN => function ($field, $value) {
-                 return $field . ">" . $value;
+                    return $field . ">" . $value;
             },
 
             Relation::LESS_THAN => function ($field, $value) {
-                 return $field . "<" . $value;
+                    return $field . "<" . $value;
             },
 
             Relation::GREATER_OR_EQUAL_THAN => function ($field, $value) {
-                 return $field . ">=" . $value;
+                    return $field . ">=" . $value;
             },
 
             Relation::LESS_OR_EQUAL_THAN => function ($field, $value) {
-                 return $field . "<=" . $value;
+                    return $field . "<=" . $value;
             },
 
             Relation::NOT_EQUAL => function ($field, $value) {
-                 return $field . "!=" . $value;
+                    return $field . "!=" . $value;
             },
 
             Relation::STARTS_WITH => function ($field, $value) {
-                 return " starts-with($field, $value) ";
+                    return " starts-with($field, $value) ";
             },
 
             Relation::CONTAINS => function ($field, $value) {
-                 return " contains($field, $value) ";
+                    return " contains($field, $value) ";
             },
         ];
 

Spacing +16 added lines, -16 removed lines

@@ -15,45 +15,45 @@
             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 ";
 
         $data = [
-            Relation::EQUAL => function ($field, $value) {
-                 return $field . "=" . $value;
+            Relation::EQUAL => function($field, $value) {
+                 return $field."=".$value;
             },
 
-            Relation::GREATER_THAN => function ($field, $value) {
-                 return $field . ">" . $value;
+            Relation::GREATER_THAN => function($field, $value) {
+                 return $field.">".$value;
             },
 
-            Relation::LESS_THAN => function ($field, $value) {
-                 return $field . "<" . $value;
+            Relation::LESS_THAN => function($field, $value) {
+                 return $field."<".$value;
             },
 
-            Relation::GREATER_OR_EQUAL_THAN => function ($field, $value) {
-                 return $field . ">=" . $value;
+            Relation::GREATER_OR_EQUAL_THAN => function($field, $value) {
+                 return $field.">=".$value;
             },
 
-            Relation::LESS_OR_EQUAL_THAN => function ($field, $value) {
-                 return $field . "<=" . $value;
+            Relation::LESS_OR_EQUAL_THAN => function($field, $value) {
+                 return $field."<=".$value;
             },
 
-            Relation::NOT_EQUAL => function ($field, $value) {
-                 return $field . "!=" . $value;
+            Relation::NOT_EQUAL => function($field, $value) {
+                 return $field."!=".$value;
             },
 
-            Relation::STARTS_WITH => function ($field, $value) {
+            Relation::STARTS_WITH => function($field, $value) {
                  return " starts-with($field, $value) ";
             },
 
-            Relation::CONTAINS => function ($field, $value) {
+            Relation::CONTAINS => function($field, $value) {
                  return " contains($field, $value) ";
             },
         ];

src/Factory.php

Spacing +9 added lines, -9 removed lines

@@ -25,13 +25,13 @@ 
             $connectionString,
             array_merge(
                 [
-                    "oci8" => $prefix . "DbOci8Driver",
-                    "dblib" => $prefix . "PdoDblib",
-                    "mysql" => $prefix . "PdoMysql",
-                    "pgsql" => $prefix . "PdoPgsql",
-                    "oci" => $prefix . "PdoOci",
-                    "odbc" => $prefix . "PdoOdbc",
-                    "sqlite" => $prefix . "PdoSqlite",
+                    "oci8" => $prefix."DbOci8Driver",
+                    "dblib" => $prefix."PdoDblib",
+                    "mysql" => $prefix."PdoMysql",
+                    "pgsql" => $prefix."PdoPgsql",
+                    "oci" => $prefix."PdoOci",
+                    "odbc" => $prefix."PdoOdbc",
+                    "sqlite" => $prefix."PdoSqlite",
                 ],
                 (array)$schemesAlternative
             ),
@@ -54,7 +54,7 @@ 
             $connectionString,
             array_merge(
                 [
-                    "mongodb" => $prefix . "MongoDbDriver",
+                    "mongodb" => $prefix."MongoDbDriver",
                 ],
                 (array)$schemesAlternative
             ),
@@ -77,7 +77,7 @@ 
             $connectionString,
             array_merge(
                 [
-                    "s3" => $prefix . "AwsS3Driver",
+                    "s3" => $prefix."AwsS3Driver",
                 ],
                 (array)$schemesAlternative
             ),

src/Store/Route.php

Spacing +6 added lines, -6 removed lines

@@ -63,7 +63,7 @@ 
         if (empty($table)) {
             $table = '\w+';
         }
-        return $this->addCustomRoute($routeName, '^select.*from\s+([`]?' . $table . '[`]?)\s');
+        return $this->addCustomRoute($routeName, '^select.*from\s+([`]?'.$table.'[`]?)\s');
     }
 
     /**
@@ -77,7 +77,7 @@ 
         if (empty($table)) {
             $table = '\w+';
         }
-        return $this->addCustomRoute($routeName, '^insert\s+into\s+([`]?' . $table . '[`]?)\s+\(');
+        return $this->addCustomRoute($routeName, '^insert\s+into\s+([`]?'.$table.'[`]?)\s+\(');
     }
 
     /**
@@ -91,7 +91,7 @@ 
         if (empty($table)) {
             $table = '\w+';
         }
-        return $this->addCustomRoute($routeName, '^update\s+([`]?' . $table . '[`]?)\s+set');
+        return $this->addCustomRoute($routeName, '^update\s+([`]?'.$table.'[`]?)\s+set');
     }
 
     /**
@@ -105,7 +105,7 @@ 
         if (empty($table)) {
             $table = '\w+';
         }
-        return $this->addCustomRoute($routeName, '^delete\s+(from\s+)?([`]?' . $table . '[`]?)\s');
+        return $this->addCustomRoute($routeName, '^delete\s+(from\s+)?([`]?'.$table.'[`]?)\s');
     }
 
     /**
@@ -190,13 +190,13 @@ 
      */
     public function matchRoute($sql)
     {
-        $sql = trim(strtolower(str_replace("\n", " ", $sql))) . ' ';
+        $sql = trim(strtolower(str_replace("\n", " ", $sql))).' ';
         foreach ($this->routes as $pattern => $routeName) {
             if (!preg_match("/$pattern/", $sql)) {
                 continue;
             }
 
-            $dbDriver = $this->dbDriverInterface[$routeName][rand(0, count($this->dbDriverInterface[$routeName])-1)];
+            $dbDriver = $this->dbDriverInterface[$routeName][rand(0, count($this->dbDriverInterface[$routeName]) - 1)];
             if (is_string($dbDriver)) {
                 return Factory::getDbRelationalInstance($dbDriver);
             }