Method parseSelect

rel/parse_filterql.go:271–340

First keyword was SELECT, so use the SELECT parser rule-set

()

// First keyword was SELECT, so use the SELECT parser rule-set
func (m *FilterQLParser) parseSelect() (*FilterSelect, error) {

	req := &FilterSelect{FilterStatement: &FilterStatement{}}
	m.fs = req.FilterStatement
	req.Raw = m.l.RawInput()
	req.Description = m.comment
	m.Next() // Consume Select

	err := parseColumns(m, m.funcs, req)
	if err != nil {
		return nil, err
	}

	// optional FROM
	if m.Cur().T == lex.TokenFrom {
		m.Next()
		if m.Cur().T == lex.TokenIdentity || m.Cur().T == lex.TokenTable {
			req.From = m.Next().V
		} else {
			return nil, fmt.Errorf("Expected FROM <identity> got %v", m.Cur())
		}
	}

	// We accept either WHERE or FILTER
	switch t := m.Next().T; t {
	case lex.TokenWhere:
		// one top level filter which may be nested
		if err = m.parseWhereExpr(req); err != nil {
			return nil, err
		}
	case lex.TokenFilter:
		// one top level filter which may be nested
		filter, err := m.parseFirstFilters()
		if err != nil {
			u.Warnf("Could not parse filters %q err=%v", req.Raw, err)
			return nil, err
		}
		req.Filter = filter
	default:
		return nil, fmt.Errorf("expected SELECT * FROM <table> { <WHERE> | <FILTER> } but got %v instead of WHERE/FILTER", t)
	}

	// LIMIT  - Optional
	m.discardCommentsNewLines()
	req.Limit, err = m.parseLimit()
	if err != nil {
		return nil, err
	}

	// WITH  - Optional
	m.discardCommentsNewLines()
	req.With, err = ParseWith(m)
	if err != nil {
		return nil, err
	}

	// ALIAS  - Optional
	m.discardCommentsNewLines()