transaction.result

test_run = require('test_run')
---
...
inspector = test_run.new()
---
...
engine = inspector:get_cfg('engine')
---
...
-- basic transaction tests
space = box.schema.space.create('test', { engine = engine })
---
...
index = space:create_index('primary', { type = 'tree', parts = {1, 'unsigned'} })
---
...
-- begin/rollback
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
for key = 1, 10 do space:insert({key}) end
box.rollback();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
t = {}
---
...
for key = 1, 10 do assert(#space:select({key}) == 0) end
---
...
t
---
- []
...
-- begin/commit insert
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
for key = 1, 10 do space:insert({key}) end
box.commit();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
t = {}
---
...
for key = 1, 10 do table.insert(t, space:select({key})[1]) end
---
...
t
---
- - [1]
  - [2]
  - [3]
  - [4]
  - [5]
  - [6]
  - [7]
  - [8]
  - [9]
  - [10]
...
-- begin/commit delete
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
for key = 1, 10 do space:delete({key}) end
box.commit();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
t = {}
---
...
for key = 1, 10 do assert(#space:select({key}) == 0) end
---
...
t
---
- []
...
space:drop()
---
...
-- multi-space transactions
a = box.schema.space.create('test', { engine = engine })
---
...
index = a:create_index('primary', { type = 'tree', parts = {1, 'unsigned'} })
---
...
b = box.schema.space.create('test_tmp', { engine = engine })
---
...
index = b:create_index('primary', { type = 'tree', parts = {1, 'unsigned'} })
---
...
-- begin/rollback
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
for key = 1, 10 do a:insert({key}) end
for key = 1, 10 do b:insert({key}) end
box.rollback();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
t = {}
---
...
for key = 1, 10 do assert(#a:select({key}) == 0) end
---
...
t
---
- []
...
for key = 1, 10 do assert(#b:select({key}) == 0) end
---
...
t
---
- []
...
-- begin/commit insert
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
for key = 1, 10 do a:insert({key}) end
for key = 1, 10 do b:insert({key}) end
box.commit();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
t = {}
---
...
for key = 1, 10 do table.insert(t, a:select({key})[1]) end
---
...
t
---
- - [1]
  - [2]
  - [3]
  - [4]
  - [5]
  - [6]
  - [7]
  - [8]
  - [9]
  - [10]
...
t = {}
---
...
for key = 1, 10 do table.insert(t, b:select({key})[1]) end
---
...
t
---
- - [1]
  - [2]
  - [3]
  - [4]
  - [5]
  - [6]
  - [7]
  - [8]
  - [9]
  - [10]
...
-- begin/commit delete
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
for key = 1, 10 do a:delete({key}) end
for key = 1, 10 do b:delete({key}) end
box.commit();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
t = {}
---
...
for key = 1, 10 do assert(#a:select({key}) == 0) end
---
...
t
---
- []
...
for key = 1, 10 do assert(#b:select({key}) == 0) end
---
...
t
---
- []
...
a:drop()
---
...
b:drop()
---
...
-- ensure findByKey works in empty transaction context
space = box.schema.space.create('test', { engine = engine })
---
...
index = space:create_index('primary', { type = 'tree', parts = {1, 'unsigned'} })
---
...
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
space:get({0})
box.rollback();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
space:drop()
---
...
--
-- gh-857: on_commit/rollback triggers in Lua.
--
s = box.schema.create_space('test')
---
...
_ = s:create_index('pk')
---
...
call_list = {}
---
...
on_commit = {}
---
...
inspector:cmd("setopt delimiter ';'")
---
- true
...
for i = 1, 3 do
    table.insert(on_commit, function()
        table.insert(call_list, 'on_commit_'..tostring(i))
    end)
end;
---
...
function on_rollback()
    table.insert(call_list, 'on_rollback')
end;
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
-- A basic test: when a transaction is committed, the appropriate
-- trigger is called, in opposite to its on_rollback vis-a-vis.
box.begin() s:replace{1} box.on_commit(on_commit[1]) box.on_rollback(on_rollback) box.commit()
---
...
call_list
---
- - on_commit_1
...
call_list = {}
---
...
-- The same vice versa.
box.begin() s:replace{2} box.on_commit(on_commit[1]) box.on_rollback(on_rollback) box.rollback()
---
...
call_list
---
- - on_rollback
...
call_list = {}
---
...
-- Incorrect usage outside of a transaction.
box.on_commit()
---
- error: 'Usage inside a transaction: box.on_commit([function | nil, [function | nil]])'
...
-- Incorrect usage inside a transaction.
box.begin() s:replace{3} box.on_rollback(on_rollback) box.on_commit(100)
---
- error: '[string "box.begin() s:replace{3} box.on_rollback(on_r..."]:1: trigger reset:
    incorrect arguments'
...
box.rollback()
---
...
call_list
---
- - on_rollback
...
call_list = {}
---
...
-- Multiple triggers.
funcs = {}
---
...
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
table.insert(funcs, box.on_commit())
box.on_commit(on_commit[1])
table.insert(funcs, box.on_commit())
box.on_commit(on_commit[2])
table.insert(funcs, box.on_commit())
box.on_commit(on_commit[3])
box.on_commit(on_commit[3])
table.insert(funcs, box.on_commit())
box.on_commit(on_commit[3], on_commit[2])
table.insert(funcs, box.on_commit())
box.commit();
---
...
for _, list in pairs(funcs) do
    for i, f1 in pairs(list) do
        for j, f2 in pairs(on_commit) do
            if f1 == f2 then
                list[i] = 'on_commit_'..tostring(j)
                break
            end
        end
    end
end;
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
-- Yes, the order is reversed. Like all other Lua triggers.
call_list
---
- - on_commit_1
  - on_commit_3
  - on_commit_3
  - on_commit_3
...
funcs
---
- - []
  - - on_commit_1
  - - on_commit_1
    - on_commit_2
  - - on_commit_1
    - on_commit_2
    - on_commit_3
    - on_commit_3
  - - on_commit_1
    - on_commit_3
    - on_commit_3
    - on_commit_3
...
--
-- Test on_commit/rollback txn iterators.
--
iter = nil
---
...
function steal_iterator(iter_) iter = iter_ end
---
...
box.begin() s:replace{1, 1} box.on_commit(steal_iterator) box.commit()
---
...
-- Fail. No transaction.
iter()
---
- error: The transaction the cursor belongs to has ended
...
-- Fail. Not the same transaction.
box.begin() iter()
---
- error: The transaction the cursor belongs to has ended
...
box.rollback()
---
...
-- Test the same for the iterator generator.
a = nil
---
...
b = nil
---
...
c = nil
---
...
function steal_iterator(iter) a, b, c = iter() end
---
...
box.begin() s:replace{1, 1} box.on_commit(steal_iterator) box.commit()
---
...
a(b, c)
---
- error: The transaction the cursor belongs to has ended
...
box.begin() a(b, c)
---
- error: The transaction the cursor belongs to has ended
...
box.rollback()
---
...
-- Test appropriate usage.
for i = 1, 5 do s:replace{i} end
---
...
stmts = nil
---
...
inspector:cmd("setopt delimiter ';'")
---
- true
...
function on_commit(iter)
    stmts = {}
    for i, old, new, space in iter() do
        stmts[i] = {old, new, space == s.id or space}
    end
end;
---
...
-- Test read and rolled back statements.
-- Test save point rollbacks.
box.begin()
s:replace{1, 1}
s:replace{2, 2}
s:delete{3}
s:replace{6, 6}
s:replace{0, 0}
s:get{3}
s:get{1}
pcall(s.insert, s, {1})
box.on_commit(on_commit)
s:replace{7, 7}
sv = box.savepoint()
s:replace{8, 8}
box.rollback_to_savepoint(sv)
s:replace{9, 9}
box.commit();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
stmts
---
- - - [1]
    - [1, 1]
    - true
  - - [2]
    - [2, 2]
    - true
  - - [3]
    - null
    - true
  - - null
    - [6, 6]
    - true
  - - null
    - [0, 0]
    - true
  - - null
    - [7, 7]
    - true
  - - null
    - [9, 9]
    - true
...
-- Check empty transaction iteration.
box.begin() box.on_commit(on_commit) box.commit()
---
...
stmts
---
- []
...
s:drop()
---
...
--
-- Check that on rollback to a savepoint we remove all commit
-- triggers and run all rollback triggers installed after the
-- savepoint.
--
s = box.schema.space.create('test', {engine = engine})
---
...
_ = s:create_index('pk')
---
...
commit = {}
---
...
rollback = {}
---
...
on_commit1 = function() table.insert(commit, 'on_commit_1') end
---
...
on_commit2 = function() table.insert(commit, 'on_commit_2') end
---
...
on_commit3 = function() table.insert(commit, 'on_commit_3') end
---
...
on_rollback1 = function() table.insert(rollback, 'on_rollback_1') end
---
...
on_rollback2 = function() table.insert(rollback, 'on_rollback_2') end
---
...
on_rollback3 = function() table.insert(rollback, 'on_rollback_3') end
---
...
inspector:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
box.on_commit(on_commit1)
box.on_rollback(on_rollback1)
sv = box.savepoint()
s:insert{1}
box.on_commit(on_commit2)
box.on_rollback(on_rollback2)
s:insert{2}
box.on_commit(on_commit3)
box.on_rollback(on_rollback3)
box.rollback_to_savepoint(sv)
s:insert{3}
box.commit();
---
...
inspector:cmd("setopt delimiter ''");
---
- true
...
commit -- on_commit_1
---
- - on_commit_1
...
rollback -- on_rollback_3, on_rollback_2
---
- - on_rollback_3
  - on_rollback_2
...
s:select() -- 3
---
- - [3]
...
s:drop()
---
...