test_run = require('test_run').new()
---
...
s = box.schema.space.create('test')
---
...
_ = s:create_index('primary')
---
...
_ = s:create_index('secondary', {unique = false, parts = {2, 'unsigned'}})
---
...
function fail(old, new) error('fail') end
---
...
function save(old, new) old_tuple = old new_tuple = new end
---
...
function ret_new(old, new) return new end
---
...
function ret_old(old, new) return old end
---
...
function ret_nil(old, new) return nil end
---
...
function ret_null(old, new) return nil end
---
...
function ret_none(old, new) return end
---
...
function ret_invalid(old, new) return 'test' end
---
...
function ret_update(old, new) return box.tuple.update(new, {{'+', 3, 1}}) end
---
...
function ret_update_pk(old, new) return box.tuple.update(new, {{'+', 1, 1}}) end
---
...
-- Exception in trigger.
s:before_replace(fail) == fail
---
- true
...
s:insert{1, 1}
---
- error: '[string "function fail(old, new) error(''fail'') end "]:1: fail'
...
s:select()
---
- []
...
s:before_replace(nil, fail)
---
...
-- Check 'old' and 'new' trigger arguments.
old_tuple = nil
---
...
new_tuple = nil
---
...
s:before_replace(save) == save
---
- true
...
s:insert{1, 1}
---
- [1, 1]
...
old_tuple, new_tuple
---
- null
- [1, 1]
...
s:replace{1, 2}
---
- [1, 2]
...
old_tuple, new_tuple
---
- [1, 1]
- [1, 2]
...
s:update(1, {{'+', 2, 1}})
---
- [1, 3]
...
old_tuple, new_tuple
---
- [1, 2]
- [1, 3]
...
s:upsert({1, 1}, {{'=', 2, 1}})
---
...
old_tuple, new_tuple
---
- [1, 3]
- [1, 1]
...
s:upsert({2, 2}, {{'=', 2, 2}})
---
...
old_tuple, new_tuple
---
- null
- [2, 2]
...
s:select()
---
- - [1, 1]
  - [2, 2]
...
s:delete(1)
---
- [1, 1]
...
old_tuple, new_tuple
---
- [1, 1]
- null
...
s:delete(2)
---
- [2, 2]
...
old_tuple, new_tuple
---
- [2, 2]
- null
...
s:select()
---
- []
...
s:before_replace(nil, save)
---
...
-- Returning 'new' from trigger doesn't affect statement.
s:before_replace(ret_new) == ret_new
---
- true
...
s:insert{1, 1}
---
- [1, 1]
...
s:update(1, {{'+', 2, 1}})
---
- [1, 2]
...
s:select()
---
- - [1, 2]
...
s:delete(1)
---
- [1, 2]
...
s:select()
---
- []
...
s:before_replace(nil, ret_new)
---
...
-- Returning 'old' from trigger skips statement.
s:insert{1, 1}
---
- [1, 1]
...
s:before_replace(ret_old) == ret_old
---
- true
...
s:insert{2, 2}
---
...
s:update(1, {{'+', 2, 1}})
---
...
s:delete(1)
---
...
s:select()
---
- - [1, 1]
...
s:before_replace(nil, ret_old)
---
...
s:delete(1)
---
- [1, 1]
...
-- Returning nil from trigger turns statement into DELETE.
s:insert{1, 1}
---
- [1, 1]
...
s:before_replace(ret_nil) == ret_nil
---
- true
...
s:replace{1, 2}
---
- [1, 1]
...
s:select()
---
- []
...
s:before_replace(nil, ret_nil)
---
...
-- Returning box.NULL from trigger turns statement into DELETE.
s:insert{1, 1}
---
- [1, 1]
...
s:before_replace(ret_null) == ret_null
---
- true
...
s:replace{1, 2}
---
- [1, 1]
...
s:select()
---
- []
...
s:before_replace(nil, ret_null)
---
...
-- Returning nothing doesn't affect the operation.
s:insert{1, 1}
---
- [1, 1]
...
s:insert{2, 2}
---
- [2, 2]
...
s:before_replace(ret_none) == ret_none
---
- true
...
s:replace{1, 2}
---
- [1, 2]
...
s:update(1, {{'+', 2, 1}})
---
- [1, 3]
...
s:delete(2)
---
- [2, 2]
...
s:select()
---
- - [1, 3]
...
s:before_replace(nil, ret_none)
---
...
s:delete(1)
---
- [1, 3]
...
-- Update statement from trigger.
s:before_replace(ret_update) == ret_update
---
- true
...
s:insert{1, 1, 1}
---
- [1, 1, 2]
...
s:update(1, {{'+', 2, 1}})
---
- [1, 2, 3]
...
s:select()
---
- - [1, 2, 3]
...
s:before_replace(nil, ret_update)
---
...
s:delete(1)
---
- [1, 2, 3]
...
-- Invalid return value.
s:before_replace(ret_invalid) == ret_invalid
---
- true
...
s:insert{1, 1}
---
- error: 'Invalid return value of space:before_replace trigger: expected tuple or
    nil, got string'
...
s:select()
---
- []
...
s:before_replace(nil, ret_invalid)
---
...
-- Update of the primary key from trigger is forbidden.
s:insert{1, 1}
---
- [1, 1]
...
s:before_replace(ret_update_pk) == ret_update_pk
---
- true
...
s:replace{1, 2}
---
- error: Attempt to modify a tuple field which is part of index 'primary' in space
    'test'
...
s:before_replace(nil, ret_update_pk)
---
...
s:delete(1)
---
- [1, 1]
...
-- Update over secondary index + space:before_replace.
s2 = box.schema.space.create('test2')
---
...
_ = s2:create_index('pk')
---
...
_ = s2:create_index('sk', {unique = true, parts = {2, 'unsigned'}})
---
...
s2:insert{1, 1, 1, 1}
---
- [1, 1, 1, 1]
...
s2:before_replace(ret_update) == ret_update
---
- true
...
s2.index.sk:update(1, {{'+', 4, 1}})
---
- [1, 1, 2, 2]
...
s2:select()
---
- - [1, 1, 2, 2]
...
s2:drop()
---
...
-- Stacking triggers.
old_tuple = nil
---
...
new_tuple = nil
---
...
s:before_replace(save) == save
---
- true
...
s:before_replace(ret_update) == ret_update
---
- true
...
s:insert{1, 1, 1}
---
- [1, 1, 2]
...
old_tuple, new_tuple
---
- null
- [1, 1, 2]
...
s:before_replace(nil, save)
---
...
s:before_replace(nil, ret_update)
---
...
s:delete(1)
---
- [1, 1, 2]
...
-- Issue DML from trigger.
s2 = box.schema.space.create('test2')
---
...
_ = s2:create_index('pk')
---
...
cb = function(old, new) s2:insert{i, old, new} end
---
...
s:before_replace(cb) == cb
---
- true
...
i = 1
---
...
s:insert{1, 1}
---
- [1, 1]
...
i = 2
---
...
s:replace{1, 2}
---
- [1, 2]
...
s:replace{1, 3} -- error: conflict in s2
---
- error: Duplicate key exists in unique index 'pk' in space 'test2'
...
s:select()
---
- - [1, 2]
...
s2:select()
---
- - [1, null, [1, 1]]
  - [2, [1, 1], [1, 2]]
...
-- DML done from space:before_replace is undone
-- if space:on_replace fails.
s:truncate()
---
...
s2:truncate()
---
...
s:on_replace(fail) == fail
---
- true
...
s:replace{1, 3}
---
- error: '[string "function fail(old, new) error(''fail'') end "]:1: fail'
...
s:select()
---
- []
...
s2:select()
---
- []
...
s:on_replace(nil, fail)
---
...
s:before_replace(nil, cb)
---
...
s2:drop()
---
...
-- If space:before_replace turns the request into NOP,
-- space:on_replace isn't called.
old_tuple = nil
---
...
new_tuple = nil
---
...
s:insert{1, 1}
---
- [1, 1]
...
s:before_replace(ret_old) == ret_old
---
- true
...
s:on_replace(save) == save
---
- true
...
s:replace{1, 2}
---
...
old_tuple, new_tuple
---
- null
- null
...
s:delete(1)
---
...
old_tuple, new_tuple
---
- null
- null
...
s:insert{2, 2}
---
...
old_tuple, new_tuple
---
- null
- null
...
s:select()
---
- - [1, 1]
...
s:before_replace(nil, ret_old)
---
...
s:on_replace(nil, save)
---
...
s:delete(1)
---
- [1, 1]
...
-- Changed done in space:before_replace are visible
-- in space:on_replace
old_tuple = nil
---
...
new_tuple = nil
---
...
s:before_replace(ret_update) == ret_update
---
- true
...
s:on_replace(save) == save
---
- true
...
s:insert{1, 1, 1}
---
- [1, 1, 2]
...
old_tuple, new_tuple
---
- null
- [1, 1, 2]
...
s:replace{1, 2, 2}
---
- [1, 2, 3]
...
old_tuple, new_tuple
---
- [1, 1, 2]
- [1, 2, 3]
...
s:select()
---
- - [1, 2, 3]
...
s:before_replace(nil, ret_update)
---
...
s:on_replace(nil, save)
---
...
s:delete(1)
---
- [1, 2, 3]
...
-- Nesting limit: space.before_replace
cb = function(old, new) s:insert{1, 1} end
---
...
s:before_replace(cb) == cb
---
- true
...
s:insert{1, 1} -- error
---
- error: 'Can not execute a nested statement: nesting limit reached'
...
s:select()
---
- []
...
s:before_replace(nil, cb)
---
...
-- Nesting limit: space.before_replace + space.on_replace
cb = function(old, new) s:delete(1) end
---
...
s:before_replace(cb) == cb
---
- true
...
s:on_replace(cb) == cb
---
- true
...
s:insert{1, 1} -- error
---
- error: 'Can not execute a nested statement: nesting limit reached'
...
s:select()
---
- []
...
s:before_replace(nil, cb)
---
...
s:on_replace(nil, cb)
---
...
-- gh-3678: Check that IPROTO_NOP in a multi-statement transaction
-- is recovered correctly.
f = function(old, new) return old end
---
...
type(s:before_replace(f))
---
- function
...
box.begin() s:replace{10, 10} s:before_replace(nil, f) s:replace{10, 100} box.commit()
---
...
test_run:cmd('restart server default')
s = box.space.test
---
...
s:select() -- [10, 100]
---
- - [10, 100]
...
-- Check that IPROTO_NOP is actually written to xlog.
fio = require('fio')
---
...
xlog = require('xlog')
---
...
function ret_old(old,new) return old end
---
...
s:before_replace(ret_old) == ret_old
---
- true
...
s:insert{1, 1}
---
...
path = fio.pathjoin(box.cfg.wal_dir, string.format('%020d.xlog', box.info.lsn - 1))
---
...
fun, param, state = xlog.pairs(path)
---
...
state, row = fun(param, state)
---
...
row.HEADER.type
---
- NOP
...
row.BODY == nil
---
- true
...
s:before_replace(nil, ret_old)
---
...
-- gh-3128 before_replace with run_triggers
s2 = box.schema.space.create("test2")
---
...
_ = s2:create_index("prim")
---
...
before_replace1 = function() s2:insert{1} s:run_triggers(false) end
---
...
before_replace2 = function() s2:insert{2} end
---
...
on_replace = function() s2:insert{3} end
---
...
type(s:on_replace(on_replace))
---
- function
...
type(s:before_replace(before_replace1))
---
- function
...
type(s:before_replace(before_replace2))
---
- function
...
s:insert{1, 1}
---
- [1, 1]
...
s2:select{}
---
- - [1]
  - [2]
...
s:truncate()
---
...
s2:truncate()
---
...
s:on_replace(nil, on_replace)
---
...
s:before_replace(nil, before_replace1)
---
...
s:before_replace(nil, before_replace2)
---
...
--
-- gh-3128
-- If at least one before trigger returns old
-- insertion will be aborted, but other before triggers
-- will be executed
before_replace1 = function(old, new) s2:insert{1} return old end
---
...
before_replace2 = function(old, new) s2:insert{2} end
---
...
type(s:on_replace(on_replace))
---
- function
...
type(s:before_replace(before_replace1))
---
- function
...
type(s:before_replace(before_replace2))
---
- function
...
s:insert{1, 1}
---
...
s:select{}
---
- []
...
s2:select{}
---
- - [1]
  - [2]
...
s:truncate()
---
...
s2:drop()
---
...
s:on_replace(nil, on_replace)
---
...
s:before_replace(nil, before_replace1)
---
...
s:before_replace(nil, before_replace2)
---
...
--
-- gh-4099 provide type of operation inside before_replace triggers
--
save_type = ''
---
...
function find_type(old, new, name, type) save_type = type return new end
---
...
s:before_replace(find_type) == find_type
---
- true
...
_ = s:insert{1, 2}
---
...
save_type
---
- INSERT
...
_ = s:update({1}, {{'+', 2, 1}})
---
...
save_type
---
- UPDATE
...
_ = s:delete{1}
---
...
save_type
---
- DELETE
...
_ = s:replace{2, 3}
---
...
save_type
---
- REPLACE
...
_ = s:upsert({3,4,5}, {{'+', 2, 1}})
---
...
save_type
---
- UPSERT
...
s:drop()
---
...
--
-- gh-4266 triggers on temporary space fail
--
s = box.schema.space.create('test', {temporary = true})
---
...
_ = s:create_index('pk')
---
...
save_type = ''
---
...
_ = s:before_replace(function(old,new, name, type) save_type = type return new end)
---
...
_ = s:insert{1}
---
...
save_type
---
- INSERT
...
s:drop()
---
...
--
-- gh-4275 segfault if before_replace
-- trigger set in on_schema_init triggers runs on recovery.
--
test_run:cmd('create server test with script="box/on_schema_init.lua"')
---
- true
...
test_run:cmd('start server test')
---
- true
...
test_run:cmd('switch test')
---
- true
...
s = box.schema.space.create('test_on_schema_init')
---
...
_ = s:create_index('pk')
---
...
test_run:cmd('setopt delimiter ";"')
---
- true
...
function gen_inserts()
    box.begin()
    for i = 1,1000 do
        s:upsert({1, 1}, {{'+', 2, 1}})
    end
    box.commit()
end;
---
...
test_run:cmd('setopt delimiter ""');
---
- true
...
for i = 1,17 do gen_inserts() end
---
...
test_run:cmd('restart server test')
s = box.space.test_on_schema_init
---
...
s:count()
---
- 1
...
-- For this test the number of invocations of the before_replace
-- trigger during recovery multiplied by the amount of return values
-- in before_replace trigger must be greater than 66000.
-- A total of 1 + 16999 + 17000 + 1= 34001
-- insertion: 16999 updates from gen_inserts(), starting value is 1,
-- plus additional 17000 runs of before_replace trigger, each updating
-- the value by adding 1.
-- recovery: 17000 invocations of before replace trigger.
-- Each invocation updates the recovered tuple, but only in-memory, the
-- WAL remains intact. Thus, we only see the last update. During recovery
-- the value is only increased by 1, and this change is visible only in memory.
s:get{1}[2] == 1 + 16999 + 17000 + 1 or s:get{1}[2]
---
- true
...
test_run:cmd('switch default')
---
- true
...
test_run:cmd('stop server test')
---
- true
...
test_run:cmd('cleanup server test')
---
- true
...
test_run:cmd('delete server test')
---
- true
...