Method parseCreateView

pkg/sql/parser/ddl_view.go:27–131

parseCreateView parses CREATE [OR REPLACE] [TEMPORARY] VIEW statement

(orReplace, temporary bool)

// parseCreateView parses CREATE [OR REPLACE] [TEMPORARY] VIEW statement
func (p *Parser) parseCreateView(orReplace, temporary bool) (*ast.CreateViewStatement, error) {
	stmt := &ast.CreateViewStatement{
		OrReplace: orReplace,
		Temporary: temporary,
	}

	// Check for IF NOT EXISTS
	if p.isType(models.TokenTypeIf) {
		p.advance() // Consume IF
		if !p.isType(models.TokenTypeNot) {
			return nil, p.expectedError("NOT after IF")
		}
		p.advance() // Consume NOT
		if !p.isType(models.TokenTypeExists) {
			return nil, p.expectedError("EXISTS after NOT")
		}
		p.advance() // Consume EXISTS
		stmt.IfNotExists = true
	}

	// Parse view name (supports schema.view qualification and double-quoted identifiers)
	viewName, err := p.parseQualifiedName()
	if err != nil {
		return nil, p.expectedError("view name")
	}
	stmt.Name = viewName

	// Parse optional column list
	if p.isType(models.TokenTypeLParen) {
		p.advance() // Consume (
		for {
			if !p.isIdentifier() {
				return nil, p.expectedError("column name")
			}
			stmt.Columns = append(stmt.Columns, p.currentToken.Token.Value)
			p.advance()

			if p.isType(models.TokenTypeComma) {
				p.advance() // Consume comma
				continue
			}
			break
		}
		if !p.isType(models.TokenTypeRParen) {
			return nil, p.expectedError(")")
		}
		p.advance() // Consume )
	}

	// Expect AS
	if !p.isType(models.TokenTypeAs) {
		return nil, p.expectedError("AS")
	}
	p.advance() // Consume AS

	// Parse the SELECT statement
	if !p.isType(models.TokenTypeSelect) {
		return nil, p.expectedError("SELECT")