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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
test_run = require('test_run').new()
---
...
engine = test_run:get_cfg('engine')
---
...
_ = box.space._session_settings:update('sql_default_engine', {{'=', 2, engine}})
---
...
-- These tests check that SQL savepoints properly work outside
-- transactions as well as inside transactions started in Lua.
-- gh-3313
--
box.execute('SAVEPOINT t1;');
---
- null
- No active transaction
...
box.execute('RELEASE SAVEPOINT t1;');
---
- null
- No active transaction
...
box.execute('ROLLBACK TO SAVEPOINT t1;');
---
- null
- No active transaction
...
box.begin() box.execute('SAVEPOINT t1;') box.execute('RELEASE SAVEPOINT t1;') box.commit();
---
...
box.begin() box.execute('SAVEPOINT t1;') box.execute('ROLLBACK TO t1;') box.commit();
---
...
box.begin() box.execute('SAVEPOINT t1;') box.commit();
---
...
box.commit();
---
...
-- These tests check that release of SQL savepoints works as desired.
-- gh-3379
test_run:cmd("setopt delimiter ';'")
---
- true
...
release_sv = function()
box.begin()
box.execute('SAVEPOINT t1;')
box.execute('RELEASE SAVEPOINT t1;')
end;
---
...
release_sv();
---
...
box.commit();
---
...
release_sv_2 = function()
box.begin()
box.execute('SAVEPOINT t1;')
box.execute('SAVEPOINT t2;')
box.execute('SAVEPOINT t3;')
box.execute('RELEASE SAVEPOINT t2;')
local _, err = box.execute('ROLLBACK TO t1;')
assert(err == nil)
end;
---
...
release_sv_2();
---
...
box.commit();
---
...
release_sv_fail = function()
box.begin()
box.execute('SAVEPOINT t1;')
box.execute('SAVEPOINT t2;')
box.execute('RELEASE SAVEPOINT t2;')
box.execute('RELEASE SAVEPOINT t1;')
local _, err = box.execute('ROLLBACK TO t1;')
if err ~= nil then
return err
end
end;
---
...
release_sv_fail();
---
- 'Can not rollback to savepoint: the savepoint does not exist'
...
box.commit();
---
...
-- Make sure that if the current transaction has a savepoint
-- with the same name, the old savepoint is deleted and
-- a new one is set. Note that no error should be raised.
--
collision_sv_2 = function()
box.begin()
box.execute('SAVEPOINT t1;')
box.execute('SAVEPOINT t2;')
local _,err = box.execute('SAVEPOINT t1;')
assert(err == nil)
box.execute('RELEASE SAVEPOINT t1;')
local _,err = box.execute('RELEASE SAVEPOINT t1;')
assert(err ~= nil)
local _, err = box.execute('ROLLBACK TO t2;')
assert(err == nil)
end;
---
...
collision_sv_2();
---
...
box.commit();
---
...
|
