Graze\Morphism\Parse\ColumnDefinition::parseColumnOptions()

Complexity

Conditions	35
Paths	23

Size

Total Lines	98
Code Lines	68

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	65
CRAP Score	35.0043

Importance

Changes

0

<?php
    private function parseColumnOptions(TokenStream $stream)
    {
        while (true) {
            $mark = $stream->getMark();
            $token1 = $stream->nextToken();
            if ($token1->type !== Token::IDENTIFIER) {
                $stream->rewind($mark);
                break;
            }

            if ($token1->eq(Token::IDENTIFIER, 'NOT') &&
                $stream->consume('NULL')
            ) {
                $this->nullable = false;
            } elseif ($token1->eq(Token::IDENTIFIER, 'NULL')
            ) {
                if (!$this->autoIncrement) {
                    $this->nullable = true;
                }
            } elseif ($token1->eq(Token::IDENTIFIER, 'DEFAULT')
            ) {
                $token2 = $stream->nextToken();

                if ($token2->eq(Token::IDENTIFIER, 'NOW') ||
                    $token2->eq(Token::IDENTIFIER, 'CURRENT_TIMESTAMP') ||
                    $token2->eq(Token::IDENTIFIER, 'LOCALTIME') ||
                    $token2->eq(Token::IDENTIFIER, 'LOCALTIMESTAMP')
                ) {
                    if (!$stream->consume([[Token::SYMBOL, '('], [Token::SYMBOL, ')']]) &&
                        $token2->eq(Token::IDENTIFIER, 'NOW')
                    ) {
                        throw new RuntimeException("Expected () after keyword NOW");
                    }
                    $token2 = new Token(Token::IDENTIFIER, 'CURRENT_TIMESTAMP');
                }

                try {
                    $this->default = $this->defaultValue($token2);
                } catch (Exception $e) {
                    throw new RuntimeException("Invalid DEFAULT for '" . $this->name . "'");
                }
            } elseif ($token1->eq(Token::IDENTIFIER, 'ON') &&
                $stream->consume('UPDATE')
            ) {
                $token2 = $stream->nextToken();
                if ($token2->eq(Token::IDENTIFIER, 'NOW') ||
                    $token2->eq(Token::IDENTIFIER, 'CURRENT_TIMESTAMP') ||
                    $token2->eq(Token::IDENTIFIER, 'LOCALTIME') ||
                    $token2->eq(Token::IDENTIFIER, 'LOCALTIMESTAMP')
                ) {
                    if (!$stream->consume([[Token::SYMBOL, '('], [Token::SYMBOL, ')']]) &&
                        $token2->eq(Token::IDENTIFIER, 'NOW')
                    ) {
                        throw new RuntimeException("Expected () after keyword NOW");
                    }
                    if (!in_array($this->type, ['timestamp', 'datetime'])) {
                        throw new RuntimeException("ON UPDATE CURRENT_TIMESTAMP only valid for TIMESTAMP and DATETIME columns");
                    }
                    $this->onUpdateCurrentTimestamp = true;
                } else {
                    throw new RuntimeException("Expected CURRENT_TIMESTAMP, NOW, LOCALTIME or LOCALTIMESTAMP");
                }
            } elseif ($token1->eq(Token::IDENTIFIER, 'AUTO_INCREMENT')
            ) {
                if (!$this->getTypeInfo()->allowAutoIncrement) {
                    throw new RuntimeException("AUTO_INCREMENT not allowed for this datatype");
                }
                $this->autoIncrement = true;
                $this->nullable = false;
            } elseif ($token1->eq(Token::IDENTIFIER, 'UNIQUE')
            ) {
                $stream->consume('KEY');
                $this->uniqueKey = true;
            } elseif ($token1->eq(Token::IDENTIFIER, 'PRIMARY') && $stream->consume('KEY') ||

Consider adding parentheses for clarity. Current Interpretation: ($token1->eq(Graze\Morphism\Parse\Token::IDENTIFIER, 'PRIMARY') && $stream->consume('KEY')) || $token1->eq(Graze\Morphism\Parse\Token::IDENTIFIER, 'KEY'), Probably Intended Meaning: $token1->eq(Graze\Morphism\Parse\Token::IDENTIFIER, 'PRIMARY') && ($stream->consume('KEY') || $token1->eq(Graze\Morphism\Parse\Token::IDENTIFIER, 'KEY'))

                $token1->eq(Token::IDENTIFIER, 'KEY')
            ) {
                $this->primaryKey = true;
                $this->nullable = false;
            } elseif ($token1->eq(Token::IDENTIFIER, 'COMMENT')
            ) {
                $this->comment = $stream->expectString();
            } elseif ($token1->eq(Token::IDENTIFIER, 'SERIAL') &&
                $stream->consume('DEFAULT VALUE')
            ) {
                if (!$this->getTypeInfo()->allowAutoIncrement) {
                    throw new RuntimeException("SERIAL DEFAULT VALUE is not allowed for this datatype");
                }
                $this->uniqueKey = true;
                $this->autoIncrement = true;
                $this->nullable = false;
                $this->default = null;
            } elseif ($token1->eq(Token::IDENTIFIER, 'DEFAULT_GENERATED')
            ) {
                // DEFAULT_GENERATED is new in MySQL 8 and not required.
                continue;
            } else {
                $stream->rewind($mark);
                break;
            }