zishuo/chaisql
1
0
Fork 0
mirror of https://github.com/chaisql/chai.git synced 2025-11-02 11:44:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

Normalize stream environment

Browse Source
This commit is contained in:
Asdine El Hrychy
2021-11-19 16:25:33 +01:00
parent 321c8e9b97
commit 0327fe9407
31 changed files with 624 additions and 756 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/sql/parser/delete_test.go
View File

@@ -36,14 +36,14 @@ func TestParserDelete(t *testing.T) {
{"WithOrderByThenOffset", "DELETE FROM test WHERE age = 10 ORDER BY age OFFSET 20",
stream.New(stream.SeqScan("test")).
Pipe(stream.Filter(parser.MustParseExpr("age = 10"))).
Pipe(stream.Sort(parser.MustParseExpr("age"))).
Pipe(stream.TempTreeSort(parser.MustParseExpr("age"))).
Pipe(stream.Skip(20)).
Pipe(stream.TableDelete("test")),
},
{"WithOrderByThenLimitThenOffset", "DELETE FROM test WHERE age = 10 ORDER BY age LIMIT 10 OFFSET 20",
stream.New(stream.SeqScan("test")).
Pipe(stream.Filter(parser.MustParseExpr("age = 10"))).
Pipe(stream.Sort(parser.MustParseExpr("age"))).
Pipe(stream.TempTreeSort(parser.MustParseExpr("age"))).
Pipe(stream.Skip(20)).
Pipe(stream.Take(10)).
Pipe(stream.TableDelete("test")),