~skinny.moey/drizzle/transaction_log_674588

« back to all changes in this revision

Viewing changes to tests/suite/execute/t/concurrent.disabled

  • Committer: Joseph Daly
  • Date: 2010-11-17 01:58:53 UTC
  • mfrom: (1926.1.8 build)
  • Revision ID: skinny.moey@gmail.com-20101117015853-ph45cjv2dxlhzow2
merge trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
SET @var="CREATE SCHEMA foomine";
 
2
EXECUTE @var CONCURRENT;
 
3
# YEs, this is a hack. Remember that foomine may or may not be around since
 
4
# it happens at the same time.
 
5
select sleep(2);
 
6
show schemas LIKE "foomine";
 
7
SET @var="DROP SCHEMA foomine";
 
8
EXECUTE @var CONCURRENT;
 
9
 
 
10
# Now lets see what the processlist shows.
 
11
SET @sleep="SELECT SLEEP(3)";
 
12
EXECUTE @sleep CONCURRENT;
 
13
SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST;
 
14
 
 
15
# Wait till we know the above is done (this will be replaced with broadcast() in the future)
 
16
EXECUTE @sleep;
 
17
 
 
18
# Check that a concurrent session cannot create one of itself, but can call
 
19
# execute.
 
20
SET @var="EXECUTE \"SELECT SLEEP(3)\"";
 
21
EXECUTE @var CONCURRENT;
 
22
SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST;
 
23
 
 
24
# Wait till everything closes out
 
25
EXECUTE @sleep;
 
26
SET @var="EXECUTE \"SELECT SLEEP(3)\" CONCURRENT";
 
27
EXECUTE @var CONCURRENT;
 
28
SELECT USER,INFO FROM DATA_DICTIONARY.PROCESSLIST;
 
29
 
 
30
 
 
31
# Test multiple statements
 
32
 
 
33
SET @var="CREATE SCHEMA d; CREATE SCHEMA e;";
 
34
EXECUTE @var CONCURRENT;
 
35
 
 
36
# Wait for a second...
 
37
EXECUTE @sleep;
 
38
show schemas LIKE "d";
 
39
show schemas LIKE "e";
 
40
DROP SCHEMA d;
 
41
DROP SCHEMA e;
 
42
 
 
43
 
 
44
# We are now going to make sure that data is actually committed.
 
45
CREATE TABLE foo (a serial);
 
46
 
 
47
SET @var="INSERT INTO foo VALUES(); INSERT INTO foo VALUES ()";
 
48
EXECUTE @var CONCURRENT;
 
49
EXECUTE @sleep;
 
50
SELECT * FROM foo;
 
51
 
 
52
SET @var="SAVEPOINT mine; INSERT INTO foo VALUES(); INSERT INTO foo VALUES ()";
 
53
EXECUTE @var CONCURRENT;
 
54
EXECUTE @sleep;
 
55
SELECT * FROM foo;
 
56
 
 
57
SET @var="SAVEPOINT mine; INSERT INTO foo VALUES(); INSERT INTO foo VALUES (); RELEASE SAVEPOINT mine";
 
58
EXECUTE @var CONCURRENT;
 
59
EXECUTE @sleep;
 
60
SELECT * FROM foo;
 
61
 
 
62
SET @var="SAVEPOINT mine; INSERT INTO foo VALUES (); INSERT INTO foo VALUES (); ROLLBACK TO SAVEPOINT mine";
 
63
EXECUTE @var CONCURRENT;
 
64
EXECUTE @sleep;
 
65
SELECT * FROM foo;
 
66
 
 
67
DROP TABLE foo;
 
68