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
|
# name: test/sql/parallelism/interquery/tpch_concurrent_operations.test_slow
# description: Run TPC-H queries while doing concurrent operations
# group: [interquery]
require tpch
statement ok
CALL dbgen(sf=1);
concurrentloop threadid 0 5
loop i 0 20
onlyif threadid=0
query I
INSERT INTO lineitem SELECT * REPLACE ('this is an extra row' AS l_comment) FROM lineitem USING SAMPLE (1000);
----
1000
onlyif threadid=0
query I
UPDATE lineitem SET l_orderkey = l_orderkey + 100 WHERE l_comment = 'this is an extra row'
----
1000
onlyif threadid=0
query I
DELETE FROM lineitem WHERE l_comment = 'this is an extra row'
----
1000
endloop
loop i 0 30
skipif threadid=0
statement ok
PRAGMA tpch((${threadid} + ${i}) % 22 + 1)
endloop
endloop
# verify that all TPC-H results are correct after this
loop i 1 9
query I
PRAGMA tpch(${i})
----
<FILE>:extension/tpch/dbgen/answers/sf1/q0${i}.csv
endloop
loop i 10 23
query I
PRAGMA tpch(${i})
----
<FILE>:extension/tpch/dbgen/answers/sf1/q${i}.csv
endloop
|
