Remove unused code

muglug · muglug · commit 7aa564cba076 · 2021-03-29T20:07:37.000-04:00
diff --git a/src/FakePdoStatementTrait.php b/src/FakePdoStatementTrait.php
@@ -405,8 +405,6 @@ function ($row) {
                 },
                 $this->result ?: []
             );
-
-            return $this->result ?: [];
         }
 
         if ($fetch_style === \PDO::FETCH_NUM) {
diff --git a/src/Parser/CreateTableParser.php b/src/Parser/CreateTableParser.php
@@ -117,7 +117,7 @@ private function lexImpl(string $sql)
                 }
                 continue;
             }
-            $match = \preg_match('!(\d+\.?\d*|\.\d+)!A', $sql, $matches, 0, $pos);
+            \preg_match('!(\d+\.?\d*|\.\d+)!A', $sql, $matches, 0, $pos);
             if ($matches) {
                 $source_map[] = [$pos, \strlen($matches[0])];
                 $pos += \strlen($matches[0]);
@@ -159,7 +159,7 @@ private static function walk(array $tokens, string $sql, array $source_map)
         $temp = [];
         $start = 0;
 
-        foreach ($tokens as $i => $t) {
+        foreach ($tokens as $i => $_t) {
             $t = $tokens[$i];
             if ($t === ';') {
                 if (\count($temp)) {
@@ -293,12 +293,8 @@ private static function parseCreateDefinition(array &$tokens)
      */
     private static function parseFieldOrKey(array &$tokens, array &$fields, array &$indexes)
     {
-        $has_constraint = false;
-        $constraint = null;
 
         if ($tokens[0] === 'CONSTRAINT') {
-            $has_constraint = true;
-
             if ($tokens[1] === 'PRIMARY KEY'
                 || $tokens[1] === 'UNIQUE'
                 || $tokens[1] === 'UNIQUE KEY'
@@ -308,7 +304,7 @@ private static function parseFieldOrKey(array &$tokens, array &$fields, array &$
                 \array_shift($tokens);
             } else {
                 \array_shift($tokens);
-                $constraint = \array_shift($tokens);
+                \array_shift($tokens);
             }
         }
 
diff --git a/src/Parser/ExpressionParser.php b/src/Parser/ExpressionParser.php
@@ -291,7 +291,6 @@ function ($token) {
     public function build()
     {
         $token = $this->nextToken();
-        $break_while = false;
         while ($token !== null) {
             switch ($token->type) {
                 case TokenType::PAREN:
@@ -303,7 +302,6 @@ public function build()
                     }
 
                     $this->pointer = $close;
-                    $expr = new StubExpression();
 
                     if ($arg_tokens[0]->value === 'SELECT') {
                         $subquery_sql = \implode(
diff --git a/src/Parser/FromParser.php b/src/Parser/FromParser.php
@@ -185,7 +185,7 @@ private function getSubquery()
             throw new ParserException("Empty parentheses found");
         }
         $this->pointer = $close;
-        $expr = new StubExpression();
+
         $subquery_sql = \implode(
             ' ',
             \array_map(
diff --git a/src/Parser/InsertParser.php b/src/Parser/InsertParser.php
@@ -77,7 +77,6 @@ public function parse()
         $query = new InsertQuery($token->value, $this->sql, $ignore_dupes);
         $count = \count($this->tokens);
         $needs_comma = false;
-        $end_of_set = false;
 
         while ($this->pointer < $count) {
             $token = $this->tokens[$this->pointer];
@@ -221,7 +220,6 @@ protected function parseValues(array $tokens)
         $count = \count($tokens);
         $expressions = [];
         $needs_comma = false;
-        $end_of_set = false;
         while ($pointer < $count) {
             $token = $tokens[$pointer];
             switch ($token->type) {
@@ -238,7 +236,7 @@ protected function parseValues(array $tokens)
                         );
                     }
                     $expression_parser = new ExpressionParser($tokens, $pointer - 1);
-                    $start = $pointer;
+
                     list($pointer, $expression) = $expression_parser->buildWithPointer();
                     $expressions[] = $expression;
                     $needs_comma = true;
diff --git a/src/Parser/SQLParser.php b/src/Parser/SQLParser.php
@@ -400,7 +400,6 @@ public static function findMatchingParen(int $pointer, array $tokens)
     {
         $paren_count = 0;
         $remaining_tokens = \array_slice($tokens, $pointer);
-        $token_count = \count($remaining_tokens);
         foreach ($remaining_tokens as $i => $token) {
             if ($token->type === TokenType::PAREN) {
                 $paren_count++;
@@ -425,7 +424,6 @@ public static function findMatchingEnd(int $pointer, array $tokens)
     {
         $paren_count = 0;
         $remaining_tokens = \array_slice($tokens, $pointer);
-        $token_count = \count($remaining_tokens);
         foreach ($remaining_tokens as $i => $token) {
             if ($token->type === TokenType::OPERATOR
                 && $token->value === 'CASE'
diff --git a/src/Parser/SelectParser.php b/src/Parser/SelectParser.php
@@ -71,7 +71,6 @@ public function parse() : SelectQuery
 
         if (\array_key_exists($this->pointer, $this->tokens)) {
             $next = $this->tokens[$this->pointer] ?? null;
-            $val = $next ? $next->value : 'null';
             while ($next !== null
                 && ($next->value === 'UNION' || $next->value === 'INTERSECT' || $next->value === 'EXCEPT')
             ) {
@@ -180,7 +179,7 @@ private function parseMainSelect() : SelectQuery
                             $this->pointer++;
                             $next = $this->tokens[$this->pointer] ?? null;
                             $expressions = [];
-                            $sort_directions = [];
+
                             if ($next === null || $next->value !== 'BY') {
                                 throw new ParserException("Expected BY after GROUP");
                             }
@@ -224,7 +223,7 @@ private function parseMainSelect() : SelectQuery
                         case 'EXCEPT':
                         case 'INTERSECT':
                             return $query;
-                        break;
+
                         default:
                             throw new ParserException("Unexpected {$token->value}");
                     }
diff --git a/src/Parser/SetParser.php b/src/Parser/SetParser.php
@@ -58,7 +58,7 @@ public function parse(bool $skip_set = false)
                         throw new ParserException("Expected , between expressions in SET clause");
                     }
                     $expression_parser = new ExpressionParser($this->tokens, $this->pointer - 1);
-                    $start = $this->pointer;
+
                     list($this->pointer, $expression) = $expression_parser->buildWithPointer();
 
                     if (!$expression instanceof BinaryOperatorExpression || $expression->operator !== '=') {
diff --git a/src/Processor/Expression/BinaryOperatorEvaluator.php b/src/Processor/Expression/BinaryOperatorEvaluator.php
@@ -246,7 +246,6 @@ public static function evaluate(
                 throw new ProcessorException("Operator recognized but not implemented");
 
             case 'LIKE':
-                $l_value = Evaluator::evaluate($conn, $scope, $left, $row, $result);
                 $r_value = Evaluator::evaluate($conn, $scope, $right, $row, $result);
 
                 $left_string = (string) Evaluator::evaluate($conn, $scope, $left, $row, $result);
@@ -356,8 +355,6 @@ public static function getColumnSchema(
         if ($right instanceof IntervalOperatorExpression
             && ($expr->operator === '+' || $expr->operator === '-')
         ) {
-            $functionName = $expr->operator === '+' ? 'DATE_ADD' : 'DATE_SUB';
-
             return new Column\DateTime();
         }
 
@@ -486,7 +483,6 @@ private static function evaluateRowComparison(
             throw new ProcessorException("Mismatched column count in row comparison expression");
         }
         $last_index = \array_key_last($left_elems);
-        $match = true;
         foreach ($left_elems as $index => $le) {
             $re = $right_elems[$index];
             if ($le == $re && $index !== $last_index) {
diff --git a/src/Processor/Expression/Evaluator.php b/src/Processor/Expression/Evaluator.php
@@ -306,7 +306,6 @@ public static function combineColumnTypes(array $types) : Column
         $has_floating_point = false;
         $has_integer = false;
         $has_string = false;
-        $has_date = false;
 
         $non_null_types = [];
 
diff --git a/src/Processor/Expression/FunctionEvaluator.php b/src/Processor/Expression/FunctionEvaluator.php
@@ -833,7 +833,7 @@ private static function sqlConcat(
         }
 
         $final_concat = "";
-        foreach ($args as $k => $arg) {
+        foreach ($args as $arg) {
             $val = (string) Evaluator::evaluate($conn, $scope, $arg, $row, $result);
             $final_concat .= $val;
         }
diff --git a/src/Processor/FromProcessor.php b/src/Processor/FromProcessor.php
@@ -11,8 +11,6 @@ public static function process(
         Scope $scope,
         FromClause $stmt
     ) : QueryResult {
-        $is_first_table = true;
-        $left_column_list = [];
 
         $result = null;
 
diff --git a/src/Processor/InsertProcessor.php b/src/Processor/InsertProcessor.php
@@ -25,9 +25,7 @@ public static function process(
 
         $rows_affected = 0;
 
-        $row = [];
 
-        $last_insert_id = null;
 
         $conn->setLastInsertId("0");
 
@@ -98,7 +96,7 @@ public static function process(
         $conn->getServer()->saveTable($database, $table_name, $table);
 
         if ($stmt->setClause) {
-            list($set_rows_affected) = self::applySet(
+            list($rows_affected) = self::applySet(
                 $conn,
                 $scope,
                 $database,
diff --git a/src/Processor/JoinProcessor.php b/src/Processor/JoinProcessor.php
@@ -39,7 +39,6 @@ public static function process(
 
                 foreach ($left_result->rows as $row) {
                     foreach ($right_result->rows as $r) {
-                        $left_row = $row;
                         $candidate_row = \array_merge($row, $r);
                         if (!$filter
                             || ExpressionEvaluator::evaluate(
@@ -95,41 +94,7 @@ public static function process(
                 break;
 
             case JoinType::RIGHT:
-                $null_placeholder = [];
-
-                foreach ($right_result->columns as $name => $_) {
-                    $parts = explode('.%.', $name);
-                    $null_placeholder[$right_table_name . '.%.' . end($parts)] = null;
-                }
-
-                $joined_columns = array_merge($left_result->columns, $right_result->columns);
-
-                foreach ($right_result->rows as $raw) {
-                    $any_match = false;
-
-                    foreach ($left_result->rows as $row) {
-                        $left_row = $row;
-                        $candidate_row = \array_merge($left_row, $raw);
-
-                        if (!$filter
-                            || ExpressionEvaluator::evaluate(
-                                $conn,
-                                $scope,
-                                $filter,
-                                $candidate_row,
-                                new QueryResult([], $joined_columns)
-                            )
-                        ) {
-                            $rows[] = $candidate_row;
-                            $any_match = true;
-                        }
-                    }
-
-                    if (!$any_match) {
-                        $rows[] = $raw;
-                    }
-                }
-                break;
+                throw new \Exception('Right joins are currently unsupported');
 
             case JoinType::CROSS:
                 $joined_columns = array_merge($left_result->columns, $right_result->columns);
@@ -185,10 +150,10 @@ protected static function buildNaturalJoinFilter(array $left_dataset, array $rig
             throw new ParserException("Attempted NATURAL join with no data present");
         }
 
-        foreach ($left as $column => $val) {
+        foreach ($left as $column => $_val) {
             $name_parts = \explode('.%.', $column);
             $name = end($name_parts);
-            foreach ($right as $col => $v) {
+            foreach ($right as $col => $_v) {
                 $col_parts = \explode('.%.', $col);
                 $colname = end($col_parts);
                 if ($colname === $name) {
diff --git a/src/Processor/Processor.php b/src/Processor/Processor.php
@@ -93,7 +93,7 @@ function ($a, $b) use ($sort_fun) {
         );
 
         $rows = [];
-        foreach ($rows_temp as $index => $item) {
+        foreach ($rows_temp as $item) {
             $rows[$item[0]] = $item[1];
         }
 
@@ -231,7 +231,6 @@ protected static function applySet(
                 }
             }
         } else {
-            $changes_found = true;
             $row = [];
 
             foreach ($set_clauses as $clause) {
diff --git a/src/Processor/SelectProcessor.php b/src/Processor/SelectProcessor.php
@@ -204,7 +204,7 @@ protected static function applyHaving(
 
         $out_groups = [];
 
-        foreach ($result->grouped_rows as $group_id => $rows) {
+        foreach ($result->grouped_rows as $rows) {
             $group_result = new QueryResult($rows, $result->columns);
 
             $first_row = reset($rows);
@@ -279,7 +279,7 @@ function ($expr) {
 
         $have_reevaluated_columns = false;
 
-        foreach ($grouped_rows as $group_id => $rows) {
+        foreach ($grouped_rows as $rows) {
             $group_result = $result->grouped_rows !== null
                 ? new QueryResult($rows, $result->columns)
                 : $result;
@@ -392,20 +392,12 @@ function ($expr) {
                 }
 
                 $out[$i][$name] = $val;
-
-                if ($expr->hasAggregate()) {
-                    $found_aggregate = true;
-                }
             }
         }
 
         $i = 0;
 
-        foreach ($grouped_rows as $group_id => $rows) {
-            $group_result = $result->grouped_rows !== null
-                ? new QueryResult($rows, $result->columns)
-                : $result;
-
+        foreach ($grouped_rows as $rows) {
             foreach ($rows as $row) {
                 $found_aggregate = false;
 
@@ -485,7 +477,7 @@ private static function getSelectSchema(
                     $parts = \explode(".", $column_id);
 
                     if ($expr_table_name = $expr->tableName()) {
-                        list($column_table_name, $column_name) = $parts;
+                        list($column_table_name) = $parts;
 
                         if ($column_table_name === $expr_table_name) {
                             $columns[$column_id] = $from_column;
diff --git a/src/Processor/UpdateProcessor.php b/src/Processor/UpdateProcessor.php
@@ -10,8 +10,6 @@ public static function process(
     ) : int {
         list($table_name, $database) = self::processUpdateClause($conn, $stmt);
 
-        $table_definition = $conn->getServer()->getTableDefinition($database, $table_name);
-
         $existing_rows = $conn->getServer()->getTable($database, $table_name) ?: [];
 
         //Metrics::trackQuery(QueryType::UPDATE, $conn->getServer()->name, $table_name, $this->sql);
diff --git a/src/Schema/Column/CharacterColumn.php b/src/Schema/Column/CharacterColumn.php
@@ -63,7 +63,6 @@ public function getPhpCode() : string
             if ($this->getDefault() === null) {
                 $default = '->setDefault(null)';
             } else {
-                $use_quotes = $this->getPhpType() === 'string';
                 $default = '->setDefault(\'' . $this->getDefault() . '\')';
             }
         }
diff --git a/tests/CreateTableParseTest.php b/tests/CreateTableParseTest.php
@@ -27,6 +27,6 @@ public function testSimpleParse()
             $new_table = eval('return ' . $new_table_php_code . ';');
 
             $this->assertSame(\var_export($table, true), \var_export($new_table, true));
-        }        
+        }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -405,8 +405,6 @@ function ($row) {`
`405`	`405`	`},`
`406`	`406`	`$this->result ?: []`
`407`	`407`	`);`
`408`		`-`
`409`		`- return $this->result ?: [];`
`410`	`408`	`}`
`411`	`409`
`412`	`410`	`if ($fetch_style === \PDO::FETCH_NUM) {`
Original file line number	Diff line number	Diff line change
`@@ -291,7 +291,6 @@ function ($token) {`
`291`	`291`	`public function build()`
`292`	`292`	`{`
`293`	`293`	`$token = $this->nextToken();`
`294`		`- $break_while = false;`
`295`	`294`	`while ($token !== null) {`
`296`	`295`	`switch ($token->type) {`
`297`	`296`	`case TokenType::PAREN:`
`@@ -303,7 +302,6 @@ public function build()`
`303`	`302`	`}`
`304`	`303`
`305`	`304`	`$this->pointer = $close;`
`306`		`- $expr = new StubExpression();`
`307`	`305`
`308`	`306`	`if ($arg_tokens[0]->value === 'SELECT') {`
`309`	`307`	`$subquery_sql = \implode(`
Original file line number	Diff line number	Diff line change
`@@ -185,7 +185,7 @@ private function getSubquery()`
`185`	`185`	`throw new ParserException("Empty parentheses found");`
`186`	`186`	`}`
`187`	`187`	`$this->pointer = $close;`
`188`		`- $expr = new StubExpression();`
	`188`	`+`
`189`	`189`	`$subquery_sql = \implode(`
`190`	`190`	`' ',`
`191`	`191`	`\array_map(`
Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ public function parse(bool $skip_set = false)`
`58`	`58`	`throw new ParserException("Expected , between expressions in SET clause");`
`59`	`59`	`}`
`60`	`60`	`$expression_parser = new ExpressionParser($this->tokens, $this->pointer - 1);`
`61`		`- $start = $this->pointer;`
	`61`	`+`
`62`	`62`	`list($this->pointer, $expression) = $expression_parser->buildWithPointer();`
`63`	`63`
`64`	`64`	`if (!$expression instanceof BinaryOperatorExpression \|\| $expression->operator !== '=') {`