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
74
75
76
77
78
79
80
81
82
83
84
85
86
|
#!/usr/bin/env tarantool
test = require("sqltester")
test:plan(3)
local fiber = require("fiber")
local N = 20
-- this test uses ddl which is not working concurrently
-- see issue #2741
ch = fiber.channel(N)
for id = 1, N do
fiber.create(
function ()
local table_name = "table2723"..id
box.execute("create table "..table_name.."(id INT primary key, a integer unique, b INT)")
box.execute("insert into "..table_name.." values(1, 2, 3)")
box.execute("insert into "..table_name.." values(3, 4, 3)")
pcall( function() box.execute("insert into "..table_name.." values(3, 4, 3)") end)
box.execute("drop table "..table_name)
ch:put(1)
end
)
end
for id = 1, N do
ch:get()
end
test:do_test(
"concurrency:1",
function()
return test:execsql([[select count(*) from "_space" where "name" like 'table-2723-%']])[1]
end,
0)
ch = fiber.channel(N)
box.execute("create table t1(id INT primary key, a integer unique, b INT);")
box.execute("create index i1 on t1(b);")
for id = 1, N do
fiber.create(
function ()
box.execute(string.format("insert into t1 values(%s, %s, 3)", id, id))
box.execute(string.format("insert into t1 values(%s, %s, 3)", id+N, id+N))
box.execute(string.format("delete from t1 where id = %s", id+N))
box.execute(string.format("insert into t1 values(%s, %s, 3)", id+2*N, id+2*N))
box.execute(string.format("delete from t1 where id = %s", id+2*N))
ch:put(1)
end
)
end
for id = 1, N do
ch:get()
end
test:do_test(
"concurrency:2",
function()
return test:execsql("select count(*) from (select distinct * from t1);")[1]
end,
N)
box.execute("drop table t1;")
ch = fiber.channel(N)
box.execute("create table t1(id INT primary key, a integer unique, b INT);")
box.execute("create index i1 on t1(b);")
for id = 1, N*N do
box.execute(string.format("insert into t1 values(%s, %s, 3)", id, id))
end
for id = 1, N do
fiber.create(
function ()
box.execute("delete from t1")
ch:put(1)
end
)
end
for id = 1, N do
ch:get()
end
test:do_test(
"concurrency:3",
function()
return test:execsql("select count(*) from t1;")[1]
end,
0)
box.execute("drop table t1;")
test:finish_test()
|
