1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
# name: test/sql/topn/concurrent_topn_insert.test_slow
# description: Concurrent TopN queries with row group reordering and inserts/deletes/checkpoints
# group: [topn]
statement ok
PRAGMA enable_verification
statement ok
ATTACH '__TEST_DIR__/concurrent_topn_insert.duckdb'
statement ok
SET wal_autocheckpoint = '500 KiB';
statement ok
CREATE OR REPLACE TABLE integers AS SELECT i FROM range(0, 245000) t(i)
concurrentloop threadid 0 30
loop k 0 20
# Test TopN with concurrent inserts
onlyif threadid=0
statement ok
INSERT INTO integers SELECT * FROM range(245000 + ${k} * 100000, 345000 + ${k} * 100000);
onlyif threadid>=1&&threadid<=10
statement ok
SELECT * FROM integers ORDER BY i ASC LIMIT 100;
onlyif threadid>=11&&threadid<=20
statement ok
SELECT * FROM integers ORDER BY i DESC LIMIT 100;
onlyif threadid>=21&&threadid<=25
statement ok
SELECT * FROM integers ORDER BY i ASC LIMIT 100 OFFSET (${threadid} - 20) * 246000;
onlyif threadid>=26&&threadid<=30
statement ok
SELECT * FROM integers ORDER BY i DESC LIMIT 100 OFFSET (${threadid} - 25) * 246000;
endloop
endloop
concurrentloop threadid 0 30
loop k 0 20
# Test TopN with concurrent deletes
onlyif threadid=0
statement ok
DELETE FROM integers WHERE i BETWEEN (245000 + ${k} * 100000) AND (345000 + ${k} * 100000);
onlyif threadid>=1&&threadid<=10
statement ok
SELECT * FROM integers ORDER BY i ASC LIMIT 100 OFFSET 246000;
onlyif threadid>=11&&threadid<=20
statement ok
SELECT * FROM integers ORDER BY i DESC LIMIT 100;
onlyif threadid>=21&&threadid<=25
statement ok
SELECT * FROM integers ORDER BY i ASC LIMIT 100 OFFSET (${threadid} - 20) * 246000;
onlyif threadid>=26&&threadid<=30
statement ok
SELECT * FROM integers ORDER BY i DESC LIMIT 100 OFFSET (${threadid} - 25) * 246000;
endloop
endloop
|
