github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-09 14:52:07 +02:00
parent 790a9491b2
commit 9e4abde51d
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 104 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

104
lib/logstorage/parser_test.go
View file

@ -3,6 +3,7 @@ package logstorage
import (
"math"
"reflect"
"strings"
"testing"
"time"
)
@ -1253,3 +1254,106 @@ func TestParseQueryFailure(t *testing.T) {
f(`foo | sort by(baz,`)
f(`foo | sort by(bar) foo`)
}
func TestQueryGetNeededColumns(t *testing.T) {
f := func(s, neededColumnsExpected string) {
t.Helper()
q, err := ParseQuery(s)
if err != nil {
t.Fatalf("cannot parse query %s: %s", s, err)
}
columns := q.getNeededColumns()
neededColumns := strings.Join(columns, ",")
if neededColumns != neededColumnsExpected {
t.Fatalf("unexpected neededColumns; got %q; want %q", neededColumns, neededColumnsExpected)
}
}
f(`*`, `*`)
f(`foo bar`, `*`)
f(`foo:bar _time:5m baz`, `*`)
f(`* | fields *`, `*`)
f(`* | fields * | offset 10`, `*`)
f(`* | fields * | offset 10 | limit 20`, `*`)
f(`* | fields foo`, `foo`)
f(`* | fields foo, bar`, `bar,foo`)
f(`* | fields foo, bar | fields baz, bar`, `bar`)
f(`* | fields foo, bar | fields baz, a`, ``)
f(`* | fields f1, f2 | rm f3, f4`, `f1,f2`)
f(`* | fields f1, f2 | rm f2, f3`, `f1`)
f(`* | fields f1, f2 | rm f1, f2, f3`, ``)
f(`* | fields f1, f2 | cp f1 f2, f3 f4`, `f1`)
f(`* | fields f1, f2 | cp f1 f3, f4 f5`, `f1,f2`)
f(`* | fields f1, f2 | cp f2 f3, f4 f5`, `f1,f2`)
f(`* | fields f1, f2 | cp f2 f3, f4 f1`, `f2`)
f(`* | fields f1, f2 | mv f1 f2, f3 f4`, `f1`)
f(`* | fields f1, f2 | mv f1 f3, f4 f5`, `f1,f2`)
f(`* | fields f1, f2 | mv f2 f3, f4 f5`, `f1,f2`)
f(`* | fields f1, f2 | mv f2 f3, f4 f1`, `f2`)
f(`* | fields f1, f2 | stats count() r1`, ``)
f(`* | fields f1, f2 | stats count_uniq() r1`, `f1,f2`)
f(`* | fields f1, f2 | stats count(f1) r1`, `f1`)
f(`* | fields f1, f2 | stats count(f1,f2,f3) r1`, `f1,f2`)
f(`* | fields f1, f2 | stats by(b1) count() r1`, ``)
f(`* | fields f1, f2 | stats by(b1,f1) count() r1`, `f1`)
f(`* | fields f1, f2 | stats by(b1,f1) count(f1) r1`, `f1`)
f(`* | fields f1, f2 | stats by(b1,f1) count(f1,f2,f3) r1`, `f1,f2`)
f(`* | fields f1, f2 | sort by(f3)`, `f1,f2`)
f(`* | fields f1, f2 | sort by(f1,f3)`, `f1,f2`)
f(`* | fields f1, f2 | sort by(f3) | stats count() r1`, ``)
f(`* | fields f1, f2 | sort by(f1) | stats count() r1`, `f1`)
f(`* | fields f1, f2 | sort by(f1) | stats count(f2,f3) r1`, `f1,f2`)
f(`* | fields f1, f2 | sort by(f3) | fields f2`, `f2`)
f(`* | fields f1, f2 | sort by(f1,f3) | fields f2`, `f1,f2`)
f(`* | cp foo bar`, `*`)
f(`* | cp foo bar, baz a`, `*`)
f(`* | cp foo bar, baz a | fields foo,a,b`, `b,baz,foo`)
f(`* | cp foo bar, baz a | fields bar,a,b`, `b,baz,foo`)
f(`* | cp foo bar, baz a | fields baz,a,b`, `b,baz`)
f(`* | cp foo bar | fields bar,a`, `a,foo`)
f(`* | cp foo bar | fields baz,a`, `a,baz`)
f(`* | cp foo bar | fields foo,a`, `a,foo`)
f(`* | cp f1 f2 | rm f1`, `*`)
f(`* | cp f1 f2 | rm f2`, `*`)
f(`* | cp f1 f2 | rm f3`, `*`)
f(`* | mv foo bar`, `*`)
f(`* | mv foo bar, baz a`, `*`)
f(`* | mv foo bar, baz a | fields foo,a,b`, `b,baz`)
f(`* | mv foo bar, baz a | fields bar,a,b`, `b,baz,foo`)
f(`* | mv foo bar, baz a | fields baz,a,b`, `b,baz`)
f(`* | mv foo bar, baz a | fields baz,foo,b`, `b`)
f(`* | mv foo bar | fields bar,a`, `a,foo`)
f(`* | mv foo bar | fields baz,a`, `a,baz`)
f(`* | mv foo bar | fields foo,a`, `a`)
f(`* | mv f1 f2 | rm f1`, `*`)
f(`* | mv f1 f2 | rm f2`, `*`)
f(`* | mv f1 f2 | rm f3`, `*`)
f(`* | sort by (f1)`, `*`)
f(`* | sort by (f1) | fields f2`, `f1,f2`)
f(`* | sort by (f1) | fields *`, `*`)
f(`* | sort by (f1) | sort by (f2,f3 desc) desc`, `*`)
f(`* | sort by (f1) | sort by (f2,f3 desc) desc | fields f4`, `f1,f2,f3,f4`)
f(`* | sort by (f1) | sort by (f2,f3 desc) desc | fields f4 | rm f1,f2,f5`, `f1,f2,f3,f4`)
f(`* | stats by(f1) count(f2) r1, count(f3,f4) r2`, `f1,f2,f3,f4`)
f(`* | stats by(f1) count(f2) r1, count(f3,f4) r2 | fields f1`, ``)
f(`* | stats by(f1) count(f2) r1, count(f3,f4) r2 | fields r1`, `f1,f2`)
f(`* | stats by(f1) count(f2) r1, count(f3,f4) r2 | fields r2,r3`, `f1,f3,f4`)
f(`* | rm f1, f2`, `*`)
f(`* | rm f1, f2 | fields f3`, `f3`)
f(`* | rm f1, f2 | fields f1,f3`, `f3`)
f(`* | rm f1, f2 | stats count() f1`, ``)
f(`* | rm f1, f2 | stats count(f3) r1`, `f3`)
f(`* | rm f1, f2 | stats count(f1) r1`, ``)
f(`* | rm f1, f2 | stats count(f1,f3) r1`, `f3`)
f(`* | rm f1, f2 | stats by(f1) count(f2) r1`, ``)
f(`* | rm f1, f2 | stats by(f3) count(f2) r1`, `f3`)
f(`* | rm f1, f2 | stats by(f3) count(f4) r1`, `f3,f4`)
}