Method parseOnDuplicateKeyUpdateClause

pkg/sql/parser/dml_insert.go:386–416

parseOnDuplicateKeyUpdateClause parses the assignments in ON DUPLICATE KEY UPDATE

()

// parseOnDuplicateKeyUpdateClause parses the assignments in ON DUPLICATE KEY UPDATE
func (p *Parser) parseOnDuplicateKeyUpdateClause() (*ast.UpsertClause, error) {
	upsert := &ast.UpsertClause{}
	for {
		if !p.isIdentifier() {
			return nil, p.expectedError("column name in ON DUPLICATE KEY UPDATE")
		}
		columnName := p.currentToken.Token.Value
		p.advance()

		if !p.isType(models.TokenTypeEq) {
			return nil, p.expectedError("=")
		}
		p.advance()

		value, err := p.parseExpression()
		if err != nil {
			return nil, fmt.Errorf("failed to parse ON DUPLICATE KEY UPDATE value: %w", err)
		}

		upsert.Updates = append(upsert.Updates, ast.UpdateExpression{
			Column: &ast.Identifier{Name: columnName},
			Value:  value,
		})

		if !p.isType(models.TokenTypeComma) {
			break
		}
		p.advance() // Consume comma
	}
	return upsert, nil
}