Method parseInsertStmt

parser/parser_table.go:1839–1898

(pos Pos)

}

func (p *Parser) parseInsertStmt(pos Pos) (*InsertStmt, error) {
	if err := p.expectKeyword(KeywordInsert); err != nil {
		return nil, err
	}
	if err := p.expectKeyword(KeywordInto); err != nil {
		return nil, err
	}

	insertExpr := &InsertStmt{InsertPos: pos}
	insertExpr.HasTableKeyword = p.tryConsumeKeywords(KeywordTable)

	var table Expr
	var err error
	if p.tryConsumeKeywords(KeywordFunction) {
		table, err = p.parseFunctionExpr(p.Pos())
	} else {
		table, err = p.parseTableIdentifier(p.Pos())
	}
	if err != nil {
		return nil, err
	}
	insertExpr.Table = table

	if p.matchTokenKind(TokenKindLParen) {
		// parse column names
		insertExpr.ColumnNames, err = p.parseColumnNamesExpr(p.Pos())
		if err != nil {
			return nil, err
		}
	}

	switch {
	case p.matchKeyword(KeywordFormat):
		insertExpr.Format, err = p.parseFormat(p.Pos())
	case p.matchKeyword(KeywordValues):
		// consume VALUES keyword
		_ = p.lexer.consumeToken()
		values := make([]*AssignmentValues, 0)
		for !p.lexer.isEOF() {
			value, err := p.parseAssignmentValues(p.Pos())
			if err != nil {
				return nil, err
			}
			values = append(values, value)
			if p.tryConsumeTokenKind(TokenKindComma) == nil {
				break
			}
		}
		insertExpr.Values = values
	case p.matchKeyword(KeywordSelect):
		insertExpr.SelectExpr, err = p.parseSelectQuery(p.Pos())
	default:
		// do nothing
	}

	if err != nil {
		return nil, err
	}