Method parseInsertStatement

pkg/sql/parser/dml_insert.go:30–230

parseInsertStatement parses an INSERT statement

()

// parseInsertStatement parses an INSERT statement
func (p *Parser) parseInsertStatement() (ast.Statement, error) {
	// We've already consumed the INSERT token in matchType

	// Parse INTO
	if !p.isType(models.TokenTypeInto) {
		return nil, p.expectedError("INTO")
	}
	p.advance() // Consume INTO

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

	// Parse column list if present
	columns := make([]ast.Expression, 0)
	if p.isType(models.TokenTypeLParen) {
		p.advance() // Consume (

		for {
			// Parse column name (supports double-quoted identifiers)
			if !p.isIdentifier() {
				return nil, p.expectedError("column name")
			}
			columns = append(columns, &ast.Identifier{Name: p.currentToken.Token.Value})
			p.advance()

			// Check if there are more columns
			if !p.isType(models.TokenTypeComma) {
				break
			}
			p.advance() // Consume comma
		}

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

	// Parse SQL Server OUTPUT clause (between column list and VALUES)
	var outputCols []ast.Expression
	if p.dialect == string(keywords.DialectSQLServer) && strings.ToUpper(p.currentToken.Token.Value) == "OUTPUT" {
		p.advance() // Consume OUTPUT
		var err error
		outputCols, err = p.parseOutputColumns()
		if err != nil {
			return nil, err
		}
	}

	// Parse VALUES or SELECT
	var values [][]ast.Expression
	var query ast.QueryExpression

	// ClickHouse-only: INSERT INTO t [(cols)] FORMAT <name> with the data
	// payload being external (network / file). Short-circuit here — there is