byjg / anydataset

src/Dataset/AnyDataset.php

Doc Comments +5 added lines, -1 removed lines

@@ -310,6 +310,10 @@ 
         return;
     }
 
+    /**
+     * @param SingleRow[] $seq
+     * @param string $field
+     */
     protected function quickSortExec($seq, $field)
     {
         if (!count($seq)) {
@@ -337,7 +341,7 @@ 
 
     /**
      * @param $document
-     * @return array|string
+     * @return string
      */
     public static function fixUTF8($document)
     {

Spacing +3 added lines, -3 removed lines

@@ -105,7 +105,7 @@ 
                 foreach ($fields as $field) {
                     $attr = $field->attributes->getNamedItem("name");
                     if (is_null($attr)) {
-                        throw new \InvalidArgumentException('Malformed anydataset file ' . basename($filepath));
+                        throw new \InvalidArgumentException('Malformed anydataset file '.basename($filepath));
                     }
 
                     $sr->addField($attr->nodeValue, $field->nodeValue);
@@ -322,7 +322,7 @@ 
         $left = $right = array();
 
         $cntSeq = count($seq);
-        for ($i = 1; $i < $cntSeq; $i ++) {
+        for ($i = 1; $i < $cntSeq; $i++) {
             if ($seq[$i]->getField($field) <= $key->getField($field)) {
                 $left[] = $seq[$i];
             } else {
@@ -332,7 +332,7 @@ 
 
         return array_merge(
             $this->quickSortExec($left, $field),
-            [ $key ],
+            [$key],
             $this->quickSortExec($right, $field)
         );
     }

src/Dataset/FixedTextFileIterator.php

Doc Comments +4 added lines

@@ -94,6 +94,10 @@
         return null;
     }
 
+    /**
+     * @param string $buffer
+     * @param FixedTextDefinition[] $fieldDefinition
+     */
     protected function processBuffer($buffer, $fieldDefinition)
     {
         $cntDef = count($fieldDefinition);

Spacing +1 added lines, -1 removed lines

@@ -103,7 +103,7 @@
             $fields[$fieldDef->fieldName] = substr($buffer, $fieldDef->startPos, $fieldDef->length);
             if (!empty($fieldDef->requiredValue)
                 && (
-                    !preg_match("/^[" . $fieldDef->requiredValue . "]$/", $fields[$fieldDef->fieldName])
+                    !preg_match("/^[".$fieldDef->requiredValue."]$/", $fields[$fieldDef->fieldName])
                 )
             ) {
                 throw new IteratorException(

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);
         }
     }