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
|
# we are going to have everything owned by a particular connection
connect (barrier_owner,localhost,bob,,);
connection barrier_owner;
set @my_barrier= "barrier";
SELECT CREATE_BARRIER(@my_barrier);
SELECT USER_BARRIER_NAME FROM DATA_DICTIONARY.USER_DEFINED_BARRIERS WHERE USER_BARRIER_NAME=@my_barrier;
connection default;
set @my_barrier= "barrier";
SELECT USER_BARRIER_NAME FROM DATA_DICTIONARY.USER_DEFINED_BARRIERS WHERE USER_BARRIER_NAME=@my_barrier;
SET @execute= "SELECT WAIT('barrier')";
#SELECT SIGNAL(@my_barrier);
#
#EXECUTE @execute CONCURRENT;
#EXECUTE @execute CONCURRENT;
#EXECUTE @execute CONCURRENT;
#SELECT WAIT_UNTIL(@my_barrier, 3);
#
#### Now lets see what the processlist shows.
#SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST WHERE ID != CONNECTION_ID() AND USERNAME="bob" ORDER BY ID;
#SELECT SIGNAL(@my_barrier);
## Wait till we know the above is done (this will be replaced with broadcast() in the future)
#EXECUTE @sleep;
#
## Check that a concurrent session cannot create one of itself, but can call
## execute.
#SET @var="EXECUTE \"SELECT SLEEP(3)\"";
#EXECUTE @var CONCURRENT;
#SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST;
#
## Wait till everything closes out
#EXECUTE @sleep;
#SET @var="EXECUTE \"SELECT SLEEP(3)\" CONCURRENT";
#EXECUTE @var CONCURRENT;
#SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST;
#
#
## Test multiple statements
#
#SET @var="CREATE SCHEMA d; CREATE SCHEMA e;";
#EXECUTE @var CONCURRENT;
#
## Wait for a second...
#EXECUTE @sleep;
#show schemas LIKE "d";
#show schemas LIKE "e";
#DROP SCHEMA d;
#DROP SCHEMA e;
#
#
## We are now going to make sure that data is actually committed.
#CREATE TABLE foo (a serial);
#
#SET @var="INSERT INTO foo VALUES(); INSERT INTO foo VALUES ()";
#EXECUTE @var CONCURRENT;
#EXECUTE @sleep;
#SELECT * FROM foo;
#
#SET @var="SAVEPOINT mine; INSERT INTO foo VALUES(); INSERT INTO foo VALUES ()";
#EXECUTE @var CONCURRENT;
#EXECUTE @sleep;
#SELECT * FROM foo;
#
#SET @var="SAVEPOINT mine; INSERT INTO foo VALUES(); INSERT INTO foo VALUES (); RELEASE SAVEPOINT mine";
#EXECUTE @var CONCURRENT;
#EXECUTE @sleep;
#SELECT * FROM foo;
#
#SET @var="SAVEPOINT mine; INSERT INTO foo VALUES (); INSERT INTO foo VALUES (); ROLLBACK TO SAVEPOINT mine";
#EXECUTE @var CONCURRENT;
#EXECUTE @sleep;
#SELECT * FROM foo;
#
#DROP TABLE foo;
#
|