Add new API function sqlite3_create_window_function(), for creating new
[sqlite.git] / test / window1.test
blob8daa97c1bdb7efb7a151a8f51bf8b896f5b24c8f
1 # 2018 May 8
3 # The author disclaims copyright to this source code.  In place of
4 # a legal notice, here is a blessing:
6 #    May you do good and not evil.
7 #    May you find forgiveness for yourself and forgive others.
8 #    May you share freely, never taking more than you give.
10 #***********************************************************************
11 # This file implements regression tests for SQLite library.
14 set testdir [file dirname $argv0]
15 source $testdir/tester.tcl
16 set testprefix window1
19 do_execsql_test 1.0 {
20   CREATE TABLE t1(a, b, c, d);
21   INSERT INTO t1 VALUES(1, 2, 3, 4);
22   INSERT INTO t1 VALUES(5, 6, 7, 8);
23   INSERT INTO t1 VALUES(9, 10, 11, 12);
26 do_execsql_test 1.1 {
27   SELECT sum(b) OVER () FROM t1
28 } {18 18 18}
30 do_execsql_test 1.2 {
31   SELECT a, sum(b) OVER () FROM t1
32 } {1 18 5 18 9 18}
34 do_execsql_test 1.3 {
35   SELECT a, 4 + sum(b) OVER () FROM t1
36 } {1 22 5 22 9 22}
38 do_execsql_test 1.4 {
39   SELECT a + 4 + sum(b) OVER () FROM t1
40 } {23 27 31}
42 do_execsql_test 1.5 {
43   SELECT a, sum(b) OVER (PARTITION BY c) FROM t1
44 } {1 2 5 6 9 10}
46 foreach {tn sql} {
47   1 "SELECT sum(b) OVER () FROM t1"
48   2 "SELECT sum(b) OVER (PARTITION BY c) FROM t1"
49   3 "SELECT sum(b) OVER (ORDER BY c) FROM t1"
50   4 "SELECT sum(b) OVER (PARTITION BY d ORDER BY c) FROM t1"
51   5 "SELECT sum(b) FILTER (WHERE a>0) OVER (PARTITION BY d ORDER BY c) FROM t1"
52   6 "SELECT sum(b) OVER (ORDER BY c RANGE UNBOUNDED PRECEDING) FROM t1"
53   7 "SELECT sum(b) OVER (ORDER BY c ROWS 45 PRECEDING) FROM t1"
54   8 "SELECT sum(b) OVER (ORDER BY c RANGE CURRENT ROW) FROM t1"
55   9 "SELECT sum(b) OVER (ORDER BY c RANGE BETWEEN UNBOUNDED PRECEDING 
56      AND CURRENT ROW) FROM t1"
57  10 "SELECT sum(b) OVER (ORDER BY c ROWS BETWEEN UNBOUNDED PRECEDING 
58      AND UNBOUNDED FOLLOWING) FROM t1"
59 } {
60   do_test 2.$tn { lindex [catchsql $sql] 0 } 0
63 foreach {tn sql} {
64   1 "SELECT * FROM t1 WHERE sum(b) OVER ()"
65   2 "SELECT * FROM t1 GROUP BY sum(b) OVER ()"
66   3 "SELECT * FROM t1 GROUP BY a HAVING sum(b) OVER ()"
67 } {
68   do_catchsql_test 3.$tn $sql {1 {misuse of window function sum()}}
71 do_execsql_test 4.0 {
72   CREATE TABLE t2(a, b, c);
73   INSERT INTO t2 VALUES(0, 0, 0);
74   INSERT INTO t2 VALUES(1, 1, 1);
75   INSERT INTO t2 VALUES(2, 0, 2);
76   INSERT INTO t2 VALUES(3, 1, 0);
77   INSERT INTO t2 VALUES(4, 0, 1);
78   INSERT INTO t2 VALUES(5, 1, 2);
79   INSERT INTO t2 VALUES(6, 0, 0);
82 do_execsql_test 4.1 {
83   SELECT a, sum(a) OVER (PARTITION BY b) FROM t2;
84 } {
85   0 12  2 12  4 12  6 12   1  9  3  9  5  9 
88 do_execsql_test 4.2 {
89   SELECT a, sum(a) OVER (PARTITION BY b) FROM t2 ORDER BY a;
90 } {
91   0 12  1  9  2 12  3  9  4 12  5  9 6 12   
94 do_execsql_test 4.3 {
95   SELECT a, sum(a) OVER () FROM t2 ORDER BY a;
96 } {
97   0 21  1  21  2 21  3  21  4 21  5  21 6 21   
100 do_execsql_test 4.4 {
101   SELECT a, sum(a) OVER (ORDER BY a) FROM t2;
102 } {
103   0 0  1 1  2 3  3 6  4 10  5 15  6 21
106 do_execsql_test 4.5 {
107   SELECT a, sum(a) OVER (PARTITION BY b ORDER BY a) FROM t2 ORDER BY a
108 } {
109   0 0  1 1  2 2  3 4  4 6  5 9  6 12
112 do_execsql_test 4.6 {
113   SELECT a, sum(a) OVER (PARTITION BY c ORDER BY a) FROM t2 ORDER BY a
114 } {
115   0 0  1 1  2 2  3 3  4 5  5 7  6 9
118 do_execsql_test 4.7 {
119   SELECT a, sum(a) OVER (PARTITION BY b ORDER BY a DESC) FROM t2 ORDER BY a
120 } {
121   0 12  1 9  2 12  3 8  4 10  5 5  6 6
124 do_execsql_test 4.8 {
125   SELECT a, 
126     sum(a) OVER (PARTITION BY b ORDER BY a DESC),
127     sum(a) OVER (PARTITION BY c ORDER BY a) 
128   FROM t2 ORDER BY a
129 } {
130   0  12  0
131   1   9  1 
132   2  12  2 
133   3   8  3 
134   4  10  5 
135   5   5  7 
136   6   6  9
139 do_execsql_test 4.9 {
140   SELECT a, 
141     sum(a) OVER (ORDER BY a), 
142     avg(a) OVER (ORDER BY a) 
143   FROM t2 ORDER BY a
144 } {
145   0  0       0.0
146   1  1       0.5
147   2  3       1.0
148   3  6       1.5
149   4  10      2.0
150   5  15      2.5
151   6  21      3.0
154 do_execsql_test 4.10.1 {
155   SELECT a, 
156     count() OVER (ORDER BY a DESC),
157     group_concat(a, '.') OVER (ORDER BY a DESC) 
158   FROM t2 ORDER BY a DESC
159 } {
160   6 1 6
161   5 2 6.5
162   4 3 6.5.4
163   3 4 6.5.4.3
164   2 5 6.5.4.3.2
165   1 6 6.5.4.3.2.1
166   0 7 6.5.4.3.2.1.0
169 do_execsql_test 4.10.2 {
170   SELECT a, 
171     count(*) OVER (ORDER BY a DESC),
172     group_concat(a, '.') OVER (ORDER BY a DESC) 
173   FROM t2 ORDER BY a DESC
174 } {
175   6 1 6
176   5 2 6.5
177   4 3 6.5.4
178   3 4 6.5.4.3
179   2 5 6.5.4.3.2
180   1 6 6.5.4.3.2.1
181   0 7 6.5.4.3.2.1.0
184 do_catchsql_test 5.1 {
185   SELECT ntile(0) OVER (ORDER BY a) FROM t2;
186 } {1 {argument of ntile must be a positive integer}}
187 do_catchsql_test 5.2 {
188   SELECT ntile(-1) OVER (ORDER BY a) FROM t2;
189 } {1 {argument of ntile must be a positive integer}}
190 do_catchsql_test 5.3 {
191   SELECT ntile('zbc') OVER (ORDER BY a) FROM t2;
192 } {1 {argument of ntile must be a positive integer}}
193 do_execsql_test 5.4 {
194   CREATE TABLE t4(a, b);
195   SELECT ntile(1) OVER (ORDER BY a) FROM t4;
196 } {}
198 #-------------------------------------------------------------------------
199 reset_db
200 do_execsql_test 6.1 {
201   CREATE TABLE t1(x);
202   INSERT INTO t1 VALUES(7), (6), (5), (4), (3), (2), (1);
204   CREATE TABLE t2(x);
205   INSERT INTO t2 VALUES('b'), ('a');
207   SELECT x, count(*) OVER (ORDER BY x) FROM t1;
208 } {1 1 2 2 3 3 4 4 5 5 6 6 7 7}
210 do_execsql_test 6.2 {
211   SELECT * FROM t2, (SELECT x, count(*) OVER (ORDER BY x) FROM t1);
212 } {
213   b 1 1 b 2 2 b 3 3 b 4 4 b 5 5 b 6 6 b 7 7
214   a 1 1 a 2 2 a 3 3 a 4 4 a 5 5 a 6 6 a 7 7
217 do_catchsql_test 6.3 {
218   SELECT x, lag(x) FILTER (WHERE (x%2)=0) OVER w FROM t1 
219   WINDOW w AS (ORDER BY x)
220 } {1 {FILTER clause may only be used with aggregate window functions}}
222 #-------------------------------------------------------------------------
223 # Attempt to use a window function as an aggregate. And other errors.
225 reset_db
226 do_execsql_test 7.0 {
227   CREATE TABLE t1(x, y);
228   INSERT INTO t1 VALUES(1, 2);
229   INSERT INTO t1 VALUES(3, 4);
230   INSERT INTO t1 VALUES(5, 6);
231   INSERT INTO t1 VALUES(7, 8);
232   INSERT INTO t1 VALUES(9, 10);
235 do_catchsql_test 7.1.1 {
236   SELECT nth_value(x, 1) FROM t1;
237 } {1 {misuse of window function nth_value()}}
238 do_catchsql_test 7.1.2 {
239   SELECT * FROM t1 WHERE nth_value(x, 1) OVER (ORDER BY y);
240 } {1 {misuse of window function nth_value()}}
241 do_catchsql_test 7.1.3 {
242   SELECT count(*) FROM t1 GROUP BY y HAVING nth_value(x, 1) OVER (ORDER BY y);
243 } {1 {misuse of window function nth_value()}}
244 do_catchsql_test 7.1.4 {
245   SELECT count(*) FROM t1 GROUP BY nth_value(x, 1) OVER (ORDER BY y);
246 } {1 {misuse of window function nth_value()}}
247 do_catchsql_test 7.1.5 {
248   SELECT count(*) FROM t1 LIMIT nth_value(x, 1) OVER (ORDER BY y);
249 } {1 {no such column: x}}
250 do_catchsql_test 7.1.6 {
251   SELECT trim(x) OVER (ORDER BY y) FROM t1;
252 } {1 {trim() may not be used as a window function}}
253 do_catchsql_test 7.1.7 {
254   SELECT max(x) OVER abc FROM t1 WINDOW def AS (ORDER BY y);
255 } {1 {no such window: abc}}
257 do_execsql_test 7.2 {
258   SELECT 
259     lead(y) OVER win, 
260     lead(y, 2) OVER win, 
261     lead(y, 3, 'default') OVER win
262   FROM t1
263   WINDOW win AS (ORDER BY x)
264 } {
265   4 6 8   6 8 10   8 10 default   10 {} default   {} {} default
268 do_execsql_test 7.3 {
269   SELECT row_number() OVER (ORDER BY x) FROM t1
270 } {1 2 3 4 5}
272 do_execsql_test 7.4 {
273   SELECT 
274     row_number() OVER win,
275     lead(x) OVER win
276   FROM t1
277   WINDOW win AS (ORDER BY x ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)
278 } {1 3  2 5  3 7  4 9   5 {}}
280 finish_test