Method parseCreateTable

pkg/sql/parser/ddl.go:156–429

parseCreateTable parses CREATE TABLE statement with partitioning support

(temporary bool)

// parseCreateTable parses CREATE TABLE statement with partitioning support
func (p *Parser) parseCreateTable(temporary bool) (*ast.CreateTableStatement, error) {
	stmt := &ast.CreateTableStatement{
		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 table name (supports schema.table qualification and double-quoted identifiers)
	createTableName, err := p.parseQualifiedName()
	if err != nil {
		return nil, p.expectedError("table name")
	}
	stmt.Name = createTableName

	// Snowflake: COPY GRANTS modifier before the column list or AS SELECT.
	// Consumed but not modeled on the AST.
	if strings.EqualFold(p.currentToken.Token.Value, "COPY") &&
		strings.EqualFold(p.peekToken().Token.Value, "GRANTS") {
		p.advance() // COPY
		p.advance() // GRANTS
	}

	// CREATE TABLE ... AS SELECT — no column list, just a query.
	if p.isType(models.TokenTypeAs) {
		p.advance() // AS
		if p.isType(models.TokenTypeSelect) || p.isType(models.TokenTypeWith) {
			p.advance() // SELECT / WITH
			query, err := p.parseSelectWithSetOperations()
			if err != nil {
				return nil, err
			}
			_ = query // CTAS query not modeled on CreateTableStatement yet
			return stmt, nil
		}
		return nil, p.expectedError("SELECT after AS")
	}

	// Expect opening parenthesis for column definitions
	if !p.isType(models.TokenTypeLParen) {
		return nil, p.expectedError("(")
	}
	p.advance() // Consume (

	// Parse column definitions and constraints
	for {
		// MariaDB: PERIOD FOR name (start_col, end_col) — application-time or system-time period