graze / data-db

src/Dialect/RedshiftDialect.php

Doc Comments +2 added lines, -2 removed lines

@@ -656,7 +656,7 @@ 
     }
 
     /**
-     * @param object $entity
+     * @param FileNodeInterface $entity
      *
      * @return string
      */
@@ -682,7 +682,7 @@ 
     }
 
     /**
-     * @param object $entity
+     * @param FileNodeInterface $entity
      *
      * @return string|null
      */

Spacing +4 added lines, -5 removed lines

@@ -55,7 +55,7 @@ 
         return [
             $this->format(
                 'CREATE TABLE {new:schema|q}.{new:table|q} (LIKE {old:schema|q}.{old:table|q})',
-                ['old' => $old, 'new' => $new,]
+                ['old' => $old, 'new' => $new, ]
             ),
             [],
         ];
@@ -155,8 +155,7 @@ 
                         $this->format(
                             ' {table:softUpdated|q} = CONVERT_TIMEZONE(\'UTC\', \'{timezone}\', GETDATE()),',
                             ['table' => $table, 'timezone' => $this->timezone]
-                        ) :
-                        ''),
+                        ) : ''),
                     'where'       => ($where ? 'WHERE ' . $where : ''),
                     'timezone'    => $this->timezone,
                 ]
@@ -451,7 +450,7 @@ 
         $bucket = $this->getS3BucketFromFile($file);
 
         if ($table->getColumns()) {
-            $columns = implode(',', array_map(function ($column) {
+            $columns = implode(',', array_map(function($column) {
                 return $this->format('{column|q}', ['column' => $column]);
             }, $table->getColumns()));
         } else {
@@ -547,7 +546,7 @@ 
         $bucket = $this->getS3BucketFromFile($file);
 
         if ($table->getColumns()) {
-            $columns = implode(',', array_map(function ($column) {
+            $columns = implode(',', array_map(function($column) {
                 return $this->format('{column|q}', ['column' => $column]);
             }, $table->getColumns()));
         } else {

src/Helper/ChunkedIterator.php

Doc Comments +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
     }
 
     /**
-     * @return int|mixed
+     * @return integer
      */
     public function key()
     {

src/QueryNode.php

Doc Comments +2 added lines, -2 removed lines

@@ -21,7 +21,7 @@ 
      *
      * @param AdapterInterface $adapter
      * @param string           $sql
-     * @param array            $bind
+     * @param string[]            $bind
      */
     public function __construct(AdapterInterface $adapter, $sql, array $bind = [])
     {
@@ -52,7 +52,7 @@ 
     }
 
     /**
-     * @return mixed
+     * @return string
      */
     public function getSql()
     {

src/TableNode.php

Doc Comments +1 added lines, -1 removed lines

@@ -128,7 +128,7 @@
     }
 
     /**
-     * @return string[]
+     * @return string
      */
     public function getColumns()
     {

src/Dialect/MysqlDialect.php

Spacing +2 added lines, -3 removed lines

@@ -25,7 +25,7 @@ 
         return [
             $this->format(
                 'CREATE TABLE {new:schema|q}.{new:table|q} LIKE {old:schema|q}.{old:table|q}',
-                ['old' => $old, 'new' => $new,]
+                ['old' => $old, 'new' => $new, ]
             ),
             [],
         ];
@@ -119,8 +119,7 @@ 
                 [
                     'table'       => $table,
                     'softUpdated' => ($table->getSoftUpdated() ?
-                        $this->format(' {table:softUpdated|q} = CURRENT_TIMESTAMP,', ['table' => $table]) :
-                        ''),
+                        $this->format(' {table:softUpdated|q} = CURRENT_TIMESTAMP,', ['table' => $table]) : ''),
                     'where'       => ($where ? 'WHERE ' . $where : ''),
                 ]
             ),

src/Dialect/AbstractDialect.php

Spacing +5 added lines, -5 removed lines

@@ -59,7 +59,7 @@ 
         return [
             $this->format(
                 'ALTER TABLE {table:schema|q}.{table:table|q} DROP COLUMN {column|q}',
-                ['table' => $table, 'column' => $column,]
+                ['table' => $table, 'column' => $column, ]
             ),
             [],
         ];
@@ -117,7 +117,7 @@ 
     public function getCopyTable(TableNodeInterface $from, TableNodeInterface $to)
     {
         if ($from->getColumns()) {
-            $fromColumns = implode(',', array_map(function ($column) {
+            $fromColumns = implode(',', array_map(function($column) {
                 return $this->format('{column|q}', ['column' => $column]);
             }, $from->getColumns()));
         } else {
@@ -127,7 +127,7 @@ 
         if ($to->getColumns()) {
             $toColumns = sprintf(
                 ' (%s)',
-                implode(',', array_map(function ($column) {
+                implode(',', array_map(function($column) {
                     return $this->format('{column|q}', ['column' => $column]);
                 }, $to->getColumns()))
             );
@@ -158,7 +158,7 @@ 
     public function getSelectSyntax(TableNodeInterface $table)
     {
         if ($table->getColumns()) {
-            $fromColumns = implode(',', array_map(function ($column) {
+            $fromColumns = implode(',', array_map(function($column) {
                 return $this->format('{column|q}', ['column' => $column]);
             }, $table->getColumns()));
         } else {
@@ -194,7 +194,7 @@ 
         if ($table->getColumns()) {
             $toColumns = sprintf(
                 ' (%s)',
-                implode(',', array_map(function ($column) {
+                implode(',', array_map(function($column) {
                     return $this->format('{column|q}', ['column' => $column]);
                 }, $table->getColumns()))
             );

src/Formatter/SyntaxFormatter.php

Spacing +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
      */
     public function format($syntax, array $params = [])
     {
-        return preg_replace_callback('/(?<!\{)\{(\w+)(?:\:(\w+))?(\|q)?\}(?!\})/i', function ($match) use ($params) {
+        return preg_replace_callback('/(?<!\{)\{(\w+)(?:\:(\w+))?(\|q)?\}(?!\})/i', function($match) use ($params) {
             $key = $match[1];
             $result = $match[0];
             if (isset($params[$key])) {

src/Export/Query/RedshiftExportQuery.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         $baseBindings = $query->getBind();
         return preg_replace_callback(
             '/\?/',
-            function ($value) use (&$c, $query, $baseBindings) {
+            function($value) use (&$c, $query, $baseBindings) {
                 if (!isset($baseBindings[$c])) {
                     throw new RuntimeException("Different number of options in query to parameters supplied");
                 }

src/Helper/RedshiftHelper.php

Spacing +1 added lines, -1 removed lines

@@ -104,7 +104,7 @@
         $result = $db->fetchAll(trim($sql), $params);
 
         if ($result) {
-            $col = array_map(function ($row) {
+            $col = array_map(function($row) {
                 return $row['ddl'];
             }, $result);