First keyword was FILTER, so use the FILTER parser rule-set
()
| 341 | |
| 342 | // First keyword was FILTER, so use the FILTER parser rule-set |
| 343 | func (m *FilterQLParser) parseFilter() (*FilterStatement, error) { |
| 344 | |
| 345 | req := NewFilterStatement() |
| 346 | m.fs = req |
| 347 | req.Description = m.comment |
| 348 | req.Raw = m.l.RawInput() |
| 349 | m.Next() // Consume (FILTER | WHERE ) |
| 350 | |
| 351 | // one top level filter which may be nested |
| 352 | filter, err := m.parseFirstFilters() |
| 353 | if err != nil { |
| 354 | return nil, err |
| 355 | } |
| 356 | req.Filter = filter |
| 357 | |
| 358 | m.discardCommentsNewLines() |
| 359 | // OPTIONAL From clause |
| 360 | if m.Cur().T == lex.TokenFrom { |
| 361 | m.Next() |
| 362 | if m.Cur().T != lex.TokenIdentity { |
| 363 | return nil, m.Cur().ErrMsg(m.l, "Expected identity after FROM") |
| 364 | } |
| 365 | if m.Cur().T == lex.TokenIdentity || m.Cur().T == lex.TokenTable { |
| 366 | req.From = m.Cur().V |
| 367 | m.Next() |
| 368 | } |
| 369 | } |
| 370 | |
| 371 | // LIMIT - Optional |
| 372 | m.discardCommentsNewLines() |
| 373 | req.Limit, err = m.parseLimit() |
| 374 | if err != nil { |
| 375 | return nil, err |
| 376 | } |
| 377 | |
| 378 | // WITH - Optional |
| 379 | m.discardCommentsNewLines() |
| 380 | req.With, err = ParseWith(m) |
| 381 | if err != nil { |
| 382 | return nil, err |
| 383 | } |
| 384 | |
| 385 | // ALIAS - Optional |
| 386 | m.discardCommentsNewLines() |
| 387 | req.Alias, err = m.parseAlias() |
| 388 | if err != nil { |
| 389 | return nil, err |
| 390 | } |
| 391 | |
| 392 | m.discardCommentsNewLines() |
| 393 | switch m.Cur().T { |
| 394 | case lex.TokenEOF, lex.TokenEOS: //, lex.TokenRightParenthesis |
| 395 | return req, nil |
| 396 | case lex.TokenError: |
| 397 | return nil, m.Cur().Err(m.l) |
| 398 | } |
| 399 | return nil, fmt.Errorf("Did not complete parsing input: %v", m.Cur()) |
| 400 | } |
no test coverage detected