From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from localhost (localhost [127.0.0.1]) by turing.freelists.org (Avenir Technologies Mail Multiplex) with ESMTP id 80CCD25C70 for ; Wed, 20 Jun 2018 06:46:24 -0400 (EDT) Received: from turing.freelists.org ([127.0.0.1]) by localhost (turing.freelists.org [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id u_Zb1zcjpau3 for ; Wed, 20 Jun 2018 06:46:24 -0400 (EDT) Received: from smtpng1.m.smailru.net (smtpng1.m.smailru.net [94.100.181.251]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by turing.freelists.org (Avenir Technologies Mail Multiplex) with ESMTPS id 7668425EEE for ; Wed, 20 Jun 2018 06:46:23 -0400 (EDT) From: Kirill Shcherbatov Subject: [tarantool-patches] [PATCH v4 4/6] sql: new _trigger space format with space_id Date: Wed, 20 Jun 2018 13:46:14 +0300 Message-Id: <26c9ea1a5e41c80d5376b185c5b23cfd9a944406.1529490955.git.kshcherbatov@tarantool.org> In-Reply-To: References: In-Reply-To: References: Sender: tarantool-patches-bounce@freelists.org Errors-to: tarantool-patches-bounce@freelists.org Reply-To: tarantool-patches@freelists.org List-help: List-unsubscribe: List-software: Ecartis version 1.0.0 List-Id: tarantool-patches List-subscribe: List-owner: List-post: List-archive: To: tarantool-patches@freelists.org Cc: korablev@tarantool.org, Kirill Shcherbatov As we would like to lookup triggers by space_id in future on space deletion to delete associated _trigger tuples we need to introduce new field space_id as secondary key. Part of #3273. --- src/box/bootstrap.snap | Bin 1698 -> 1704 bytes src/box/lua/upgrade.lua | 4 ++ src/box/schema_def.h | 7 ++++ src/box/sql.c | 21 +++++++---- src/box/sql/sqliteInt.h | 2 + src/box/sql/trigger.c | 8 ++-- test/app-tap/tarantoolctl.test.lua | 2 +- test/box-py/bootstrap.result | 5 ++- test/box/access_misc.result | 4 +- test/box/access_sysview.result | 4 +- test/box/alter.result | 1 + test/sql/gh2141-delete-trigger-drop-table.result | 4 +- test/sql/gh2141-delete-trigger-drop-table.test.lua | 4 +- test/sql/persistency.result | 8 ++-- test/sql/persistency.test.lua | 8 ++-- test/sql/upgrade.result | 41 ++++++++++++++++++--- test/sql/upgrade.test.lua | 10 ++++- 17 files changed, 97 insertions(+), 36 deletions(-) diff --git a/src/box/lua/upgrade.lua b/src/box/lua/upgrade.lua index 7258f47..f112a93 100644 --- a/src/box/lua/upgrade.lua +++ b/src/box/lua/upgrade.lua @@ -471,12 +471,16 @@ local function upgrade_to_2_1_0() log.info("create space _trigger") local format = {{name='name', type='string'}, + {name='space_id', type='unsigned'}, {name='opts', type='map'}} _space:insert{_trigger.id, ADMIN, '_trigger', 'memtx', 0, MAP, format} log.info("create index primary on _trigger") _index:insert{_trigger.id, 0, 'primary', 'tree', { unique = true }, {{0, 'string'}}} + log.info("create index secondary on _trigger") + _index:insert{_trigger.id, 1, 'space_id', 'tree', { unique = false }, + {{1, 'unsigned'}}} local stat1_ft = {{name='tbl', type='string'}, {name='idx', type='string'}, diff --git a/src/box/schema_def.h b/src/box/schema_def.h index eb07332..b9a5fa5 100644 --- a/src/box/schema_def.h +++ b/src/box/schema_def.h @@ -217,6 +217,13 @@ enum { BOX_SPACE_SEQUENCE_FIELD_IS_GENERATED = 2, }; +/** _trigger fields. */ +enum { + BOX_TRIGGER_FIELD_NAME = 0, + BOX_TRIGGER_FIELD_SPACE_ID = 1, + BOX_TRIGGER_FIELD_OPTS = 2, +}; + /* * Different objects which can be subject to access * control. diff --git a/src/box/sql.c b/src/box/sql.c index 0ae33b6..1b5e4a2 100644 --- a/src/box/sql.c +++ b/src/box/sql.c @@ -669,8 +669,11 @@ int tarantoolSqlite3RenameTrigger(const char *trig_name, if (box_index_get(BOX_TRIGGER_ID, 0, key_begin, key, &tuple) != 0) return SQL_TARANTOOL_ERROR; assert(tuple != NULL); - assert(tuple_field_count(tuple) == 2); - const char *field = box_tuple_field(tuple, 1); + assert(tuple_field_count(tuple) == 3); + const char *field = box_tuple_field(tuple, BOX_TRIGGER_FIELD_SPACE_ID); + assert(mp_typeof(*field) == MP_UINT); + uint32_t space_id = mp_decode_uint(&field); + field = box_tuple_field(tuple, BOX_TRIGGER_FIELD_OPTS); assert(mp_typeof(*field) == MP_MAP); mp_decode_map(&field); const char *sql_str = mp_decode_str(&field, &key_len); @@ -693,16 +696,18 @@ int tarantoolSqlite3RenameTrigger(const char *trig_name, uint32_t trigger_stmt_new_len = trigger_stmt_len + new_table_name_len - old_table_name_len + 2 * (!is_quoted); assert(trigger_stmt_new_len > 0); - key_len = mp_sizeof_array(2) + mp_sizeof_str(trig_name_len) + + key_len = mp_sizeof_array(3) + mp_sizeof_str(trig_name_len) + mp_sizeof_map(1) + mp_sizeof_str(3) + - mp_sizeof_str(trigger_stmt_new_len); + mp_sizeof_str(trigger_stmt_new_len) + + mp_sizeof_uint(space_id); char *new_tuple = (char*)region_alloc(&fiber()->gc, key_len); if (new_tuple == NULL) { diag_set(OutOfMemory, key_len, "region_alloc", "new_tuple"); return SQL_TARANTOOL_ERROR; } - char *new_tuple_end = mp_encode_array(new_tuple, 2); + char *new_tuple_end = mp_encode_array(new_tuple, 3); new_tuple_end = mp_encode_str(new_tuple_end, trig_name, trig_name_len); + new_tuple_end = mp_encode_uint(new_tuple_end, space_id); new_tuple_end = mp_encode_map(new_tuple_end, 1); new_tuple_end = mp_encode_str(new_tuple_end, "sql", 3); new_tuple_end = mp_encode_str(new_tuple_end, trigger_stmt, @@ -1253,7 +1258,7 @@ void tarantoolSqlite3LoadSchema(InitData *init) init, TARANTOOL_SYS_TRIGGER_NAME, BOX_TRIGGER_ID, 0, "CREATE TABLE \""TARANTOOL_SYS_TRIGGER_NAME"\" (" - "\"name\" TEXT PRIMARY KEY, \"opts\")" + "\"name\" TEXT PRIMARY KEY, \"space_id\" INT, \"opts\")" ); sql_schema_put( @@ -1308,14 +1313,14 @@ void tarantoolSqlite3LoadSchema(InitData *init) const char *field, *ptr; char *name, *sql; unsigned len; - assert(tuple_field_count(tuple) == 2); + assert(tuple_field_count(tuple) == 3); field = tuple_field(tuple, 0); assert (field != NULL); ptr = mp_decode_str(&field, &len); name = strndup(ptr, len); - field = tuple_field(tuple, 1); + field = tuple_field(tuple, BOX_TRIGGER_FIELD_OPTS); assert (field != NULL); mp_decode_array(&field); ptr = mp_decode_str(&field, &len); diff --git a/src/box/sql/sqliteInt.h b/src/box/sql/sqliteInt.h index a9388f1..91e32ab 100644 --- a/src/box/sql/sqliteInt.h +++ b/src/box/sql/sqliteInt.h @@ -3038,6 +3038,8 @@ struct Parse { */ struct Trigger { char *zName; /* The name of the trigger */ + /** The ID of space the trigger refers to. */ + uint32_t space_id; char *table; /* The table or view to which the trigger applies */ u8 op; /* One of TK_DELETE, TK_UPDATE, TK_INSERT */ u8 tr_tm; /* One of TRIGGER_BEFORE, TRIGGER_AFTER */ diff --git a/src/box/sql/trigger.c b/src/box/sql/trigger.c index fd1cb50..122c283 100644 --- a/src/box/sql/trigger.c +++ b/src/box/sql/trigger.c @@ -169,6 +169,7 @@ sqlite3BeginTrigger(Parse * pParse, /* The parse context of the CREATE TRIGGER s if (pTrigger == 0) goto trigger_cleanup; pTrigger->zName = zName; + pTrigger->space_id = pTab->def->id; zName = 0; pTrigger->table = sqlite3DbStrDup(db, pTableName->a[0].zName); pTrigger->pSchema = db->pSchema; @@ -255,7 +256,7 @@ sqlite3FinishTrigger(Parse * pParse, /* Parser context */ /* makerecord(cursor(iRecord), [reg(iFirstCol), reg(iFirstCol+1)]) */ iFirstCol = pParse->nMem + 1; - pParse->nMem += 2; + pParse->nMem += 3; iRecord = ++pParse->nMem; zOpts = sqlite3DbMallocRaw(pParse->db, @@ -275,9 +276,10 @@ sqlite3FinishTrigger(Parse * pParse, /* Parser context */ sqlite3VdbeAddOp4(v, OP_String8, 0, iFirstCol, 0, zName, P4_DYNAMIC); - sqlite3VdbeAddOp4(v, OP_Blob, zOptsSz, iFirstCol + 1, + sqlite3VdbeAddOp2(v, OP_Integer, pTrig->space_id, iFirstCol + 1); + sqlite3VdbeAddOp4(v, OP_Blob, zOptsSz, iFirstCol + 2, MSGPACK_SUBTYPE, zOpts, P4_DYNAMIC); - sqlite3VdbeAddOp3(v, OP_MakeRecord, iFirstCol, 2, iRecord); + sqlite3VdbeAddOp3(v, OP_MakeRecord, iFirstCol, 3, iRecord); sqlite3VdbeAddOp2(v, OP_IdxInsert, iCursor, iRecord); /* Do not account nested operations: the count of such * operations depends on Tarantool data dictionary internals, diff --git a/test/app-tap/tarantoolctl.test.lua b/test/app-tap/tarantoolctl.test.lua index cee9164..02ef5ea 100755 --- a/test/app-tap/tarantoolctl.test.lua +++ b/test/app-tap/tarantoolctl.test.lua @@ -339,7 +339,7 @@ do check_ctlcat_xlog(test_i, dir, "--from=3 --to=6 --format=json --show-system --replica 1 --replica 2", "\n", 3) check_ctlcat_xlog(test_i, dir, "--from=3 --to=6 --format=json --show-system --replica 2", "\n", 0) check_ctlcat_snap(test_i, dir, "--space=280", "---\n", 21) - check_ctlcat_snap(test_i, dir, "--space=288", "---\n", 46) + check_ctlcat_snap(test_i, dir, "--space=288", "---\n", 47) end) end) diff --git a/test/box-py/bootstrap.result b/test/box-py/bootstrap.result index ad9501b..b5c16c0 100644 --- a/test/box-py/bootstrap.result +++ b/test/box-py/bootstrap.result @@ -65,8 +65,8 @@ box.space._space:select{} {'name': 'object_id', 'type': 'unsigned'}, {'name': 'privilege', 'type': 'unsigned'}]] - [320, 1, '_cluster', 'memtx', 0, {}, [{'name': 'id', 'type': 'unsigned'}, {'name': 'uuid', 'type': 'string'}]] - - [328, 1, '_trigger', 'memtx', 0, {}, [{'name': 'name', 'type': 'string'}, {'name': 'opts', - 'type': 'map'}]] + - [328, 1, '_trigger', 'memtx', 0, {}, [{'name': 'name', 'type': 'string'}, {'name': 'space_id', + 'type': 'unsigned'}, {'name': 'opts', 'type': 'map'}]] - [330, 1, '_truncate', 'memtx', 0, {}, [{'name': 'id', 'type': 'unsigned'}, {'name': 'count', 'type': 'unsigned'}]] - [340, 1, '_space_sequence', 'memtx', 0, {}, [{'name': 'id', 'type': 'unsigned'}, @@ -122,6 +122,7 @@ box.space._index:select{} - [320, 0, 'primary', 'tree', {'unique': true}, [[0, 'unsigned']]] - [320, 1, 'uuid', 'tree', {'unique': true}, [[1, 'string']]] - [328, 0, 'primary', 'tree', {'unique': true}, [[0, 'string']]] + - [328, 1, 'space_id', 'tree', {'unique': false}, [[1, 'unsigned']]] - [330, 0, 'primary', 'tree', {'unique': true}, [[0, 'unsigned']]] - [340, 0, 'primary', 'tree', {'unique': true}, [[0, 'unsigned']]] - [340, 1, 'sequence', 'tree', {'unique': false}, [[1, 'unsigned']]] diff --git a/test/box/access_misc.result b/test/box/access_misc.result index 19e82bb..5a2563d 100644 --- a/test/box/access_misc.result +++ b/test/box/access_misc.result @@ -798,8 +798,8 @@ box.space._space:select() {'name': 'object_id', 'type': 'unsigned'}, {'name': 'privilege', 'type': 'unsigned'}]] - [320, 1, '_cluster', 'memtx', 0, {}, [{'name': 'id', 'type': 'unsigned'}, {'name': 'uuid', 'type': 'string'}]] - - [328, 1, '_trigger', 'memtx', 0, {}, [{'name': 'name', 'type': 'string'}, {'name': 'opts', - 'type': 'map'}]] + - [328, 1, '_trigger', 'memtx', 0, {}, [{'name': 'name', 'type': 'string'}, {'name': 'space_id', + 'type': 'unsigned'}, {'name': 'opts', 'type': 'map'}]] - [330, 1, '_truncate', 'memtx', 0, {}, [{'name': 'id', 'type': 'unsigned'}, {'name': 'count', 'type': 'unsigned'}]] - [340, 1, '_space_sequence', 'memtx', 0, {}, [{'name': 'id', 'type': 'unsigned'}, diff --git a/test/box/access_sysview.result b/test/box/access_sysview.result index 3f93b5e..ae04266 100644 --- a/test/box/access_sysview.result +++ b/test/box/access_sysview.result @@ -234,7 +234,7 @@ box.session.su('guest') ... #box.space._vindex:select{} --- -- 47 +- 48 ... #box.space._vuser:select{} --- @@ -262,7 +262,7 @@ box.session.su('guest') ... #box.space._vindex:select{} --- -- 47 +- 48 ... #box.space._vuser:select{} --- diff --git a/test/box/alter.result b/test/box/alter.result index 217c41d..c41b52f 100644 --- a/test/box/alter.result +++ b/test/box/alter.result @@ -224,6 +224,7 @@ _index:select{} - [320, 0, 'primary', 'tree', {'unique': true}, [[0, 'unsigned']]] - [320, 1, 'uuid', 'tree', {'unique': true}, [[1, 'string']]] - [328, 0, 'primary', 'tree', {'unique': true}, [[0, 'string']]] + - [328, 1, 'space_id', 'tree', {'unique': false}, [[1, 'unsigned']]] - [330, 0, 'primary', 'tree', {'unique': true}, [[0, 'unsigned']]] - [340, 0, 'primary', 'tree', {'unique': true}, [[0, 'unsigned']]] - [340, 1, 'sequence', 'tree', {'unique': false}, [[1, 'unsigned']]] diff --git a/test/sql/gh2141-delete-trigger-drop-table.result b/test/sql/gh2141-delete-trigger-drop-table.result index ba7016c..ec5a380 100644 --- a/test/sql/gh2141-delete-trigger-drop-table.result +++ b/test/sql/gh2141-delete-trigger-drop-table.result @@ -24,7 +24,7 @@ box.sql.execute("CREATE TRIGGER tt_ad AFTER DELETE ON t BEGIN SELECT 1; END") --- ... -- check that these triggers exist -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") --- - - ['TT_AD', !!binary gaNzcWzZOkNSRUFURSBUUklHR0VSIHR0X2FkIEFGVEVSIERFTEVURSBPTiB0IEJFR0lOIFNFTEVDVCAxOyBFTkQ=] - ['TT_AI', !!binary gaNzcWzZOkNSRUFURSBUUklHR0VSIHR0X2FpIEFGVEVSIElOU0VSVCBPTiB0IEJFR0lOIFNFTEVDVCAxOyBFTkQ=] @@ -38,7 +38,7 @@ box.sql.execute("DROP TABLE t") --- ... -- check that triggers were dropped with deleted table -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") --- - [] ... diff --git a/test/sql/gh2141-delete-trigger-drop-table.test.lua b/test/sql/gh2141-delete-trigger-drop-table.test.lua index e6a030c..87110a4 100644 --- a/test/sql/gh2141-delete-trigger-drop-table.test.lua +++ b/test/sql/gh2141-delete-trigger-drop-table.test.lua @@ -11,10 +11,10 @@ box.sql.execute("CREATE TRIGGER tt_bd BEFORE DELETE ON t BEGIN SELECT 1; END") box.sql.execute("CREATE TRIGGER tt_ad AFTER DELETE ON t BEGIN SELECT 1; END") -- check that these triggers exist -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") -- drop table box.sql.execute("DROP TABLE t") -- check that triggers were dropped with deleted table -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") diff --git a/test/sql/persistency.result b/test/sql/persistency.result index 7a7f6b8..d85d7cc 100644 --- a/test/sql/persistency.result +++ b/test/sql/persistency.result @@ -140,7 +140,7 @@ box.sql.execute("INSERT INTO barfoo VALUES ('foobar', 1000)") box.sql.execute("CREATE TRIGGER tfoobar AFTER INSERT ON foobar BEGIN INSERT INTO barfoo VALUES ('trigger test', 9999); END") --- ... -box.sql.execute("SELECT * FROM \"_trigger\""); +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\""); --- - - ['TFOOBAR', !!binary gaNzcWzZaUNSRUFURSBUUklHR0VSIHRmb29iYXIgQUZURVIgSU5TRVJUIE9OIGZvb2JhciBCRUdJTiBJTlNFUlQgSU5UTyBiYXJmb28gVkFMVUVTICgndHJpZ2dlciB0ZXN0JywgOTk5OSk7IEVORA==] ... @@ -166,7 +166,7 @@ box.sql.execute("SELECT a FROM t1 ORDER BY b, a LIMIT 10 OFFSET 20;"); ... test_run:cmd('restart server default'); -- prove that trigger survived -box.sql.execute("SELECT * FROM \"_trigger\""); +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\""); --- - - ['TFOOBAR', !!binary gaNzcWzZaUNSRUFURSBUUklHR0VSIHRmb29iYXIgQUZURVIgSU5TRVJUIE9OIGZvb2JhciBCRUdJTiBJTlNFUlQgSU5UTyBiYXJmb28gVkFMVUVTICgndHJpZ2dlciB0ZXN0JywgOTk5OSk7IEVORA==] ... @@ -179,7 +179,7 @@ box.sql.execute("SELECT * FROM barfoo WHERE foo = 9999"); - - ['trigger test', 9999] ... -- and still persistent -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") --- - - ['TFOOBAR', !!binary gaNzcWzZaUNSRUFURSBUUklHR0VSIHRmb29iYXIgQUZURVIgSU5TRVJUIE9OIGZvb2JhciBCRUdJTiBJTlNFUlQgSU5UTyBiYXJmb28gVkFMVUVTICgndHJpZ2dlciB0ZXN0JywgOTk5OSk7IEVORA==] ... @@ -193,7 +193,7 @@ box.sql.execute("DROP TRIGGER tfoobar") - error: 'no such trigger: TFOOBAR' ... -- Should be empty -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") --- - [] ... diff --git a/test/sql/persistency.test.lua b/test/sql/persistency.test.lua index bd05545..e994a62 100644 --- a/test/sql/persistency.test.lua +++ b/test/sql/persistency.test.lua @@ -49,7 +49,7 @@ box.sql.execute("INSERT INTO barfoo VALUES ('foobar', 1000)") -- create a trigger box.sql.execute("CREATE TRIGGER tfoobar AFTER INSERT ON foobar BEGIN INSERT INTO barfoo VALUES ('trigger test', 9999); END") -box.sql.execute("SELECT * FROM \"_trigger\""); +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\""); -- Many entries box.sql.execute("CREATE TABLE t1(a,b,c,PRIMARY KEY(b,c));") @@ -59,21 +59,21 @@ box.sql.execute("SELECT a FROM t1 ORDER BY b, a LIMIT 10 OFFSET 20;"); test_run:cmd('restart server default'); -- prove that trigger survived -box.sql.execute("SELECT * FROM \"_trigger\""); +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\""); -- ... functional box.sql.execute("INSERT INTO foobar VALUES ('foobar trigger test', 8888)") box.sql.execute("SELECT * FROM barfoo WHERE foo = 9999"); -- and still persistent -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") -- and can be dropped just once box.sql.execute("DROP TRIGGER tfoobar") -- Should error box.sql.execute("DROP TRIGGER tfoobar") -- Should be empty -box.sql.execute("SELECT * FROM \"_trigger\"") +box.sql.execute("SELECT \"name\", \"opts\" FROM \"_trigger\"") -- prove barfoo2 still exists box.sql.execute("INSERT INTO barfoo VALUES ('xfoo', 1)") diff --git a/test/sql/upgrade.result b/test/sql/upgrade.result index 9668a1d..6f7b115 100644 --- a/test/sql/upgrade.result +++ b/test/sql/upgrade.result @@ -19,8 +19,8 @@ test_run:switch('upgrade') -- test system tables box.space._space.index['name']:get('_trigger') --- -- [328, 1, '_trigger', 'memtx', 0, {}, [{'name': 'name', 'type': 'string'}, {'name': 'opts', - 'type': 'map'}]] +- [328, 1, '_trigger', 'memtx', 0, {}, [{'name': 'name', 'type': 'string'}, {'name': 'space_id', + 'type': 'unsigned'}, {'name': 'opts', 'type': 'map'}]] ... box.space._space.index['name']:get('_sql_stat1') --- @@ -69,6 +69,9 @@ box.sql.execute("CREATE TABLE t_out(x INTEGER PRIMARY KEY);") box.sql.execute("CREATE TRIGGER t1t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(1); END;") --- ... +box.sql.execute("CREATE TRIGGER t2t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(2); END;") +--- +... box.space._space.index['name']:get('T') --- - [513, 1, 'T', 'memtx', 1, {'sql': 'CREATE TABLE t(x INTEGER PRIMARY KEY)'}, [{'affinity': 68, @@ -79,10 +82,37 @@ box.space._space.index['name']:get('T_OUT') - [514, 1, 'T_OUT', 'memtx', 1, {'sql': 'CREATE TABLE t_out(x INTEGER PRIMARY KEY)'}, [{'affinity': 68, 'type': 'integer', 'nullable_action': 'abort', 'name': 'X', 'is_nullable': false}]] ... -box.space._trigger:get('T1T') +t1t = box.space._trigger:get('T1T') +--- +... +t2t = box.space._trigger:get('T2T') +--- +... +t1t.name +--- +- T1T +... +t1t.opts +--- +- {'sql': 'CREATE TRIGGER t1t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(1); + END;'} +... +t2t.name +--- +- T2T +... +t2t.opts +--- +- {'sql': 'CREATE TRIGGER t2t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(2); + END;'} +... +assert(t1t.space_id == t2t.space_id) --- -- ['T1T', {'sql': 'CREATE TRIGGER t1t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(1); - END;'}] +- true +... +assert(t1t.space_id == box.space.T.id) +--- +- true ... box.sql.execute("INSERT INTO T VALUES(1);") --- @@ -94,6 +124,7 @@ box.space.T:select() box.space.T_OUT:select() --- - - [1] + - [2] ... box.sql.execute("SELECT * FROM T") --- diff --git a/test/sql/upgrade.test.lua b/test/sql/upgrade.test.lua index d0add86..1619795 100644 --- a/test/sql/upgrade.test.lua +++ b/test/sql/upgrade.test.lua @@ -25,9 +25,17 @@ box.space._index:get({box.space._space.index['name']:get('T1').id, 0}) box.sql.execute("CREATE TABLE t(x INTEGER PRIMARY KEY);") box.sql.execute("CREATE TABLE t_out(x INTEGER PRIMARY KEY);") box.sql.execute("CREATE TRIGGER t1t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(1); END;") +box.sql.execute("CREATE TRIGGER t2t AFTER INSERT ON t BEGIN INSERT INTO t_out VALUES(2); END;") box.space._space.index['name']:get('T') box.space._space.index['name']:get('T_OUT') -box.space._trigger:get('T1T') +t1t = box.space._trigger:get('T1T') +t2t = box.space._trigger:get('T2T') +t1t.name +t1t.opts +t2t.name +t2t.opts +assert(t1t.space_id == t2t.space_id) +assert(t1t.space_id == box.space.T.id) box.sql.execute("INSERT INTO T VALUES(1);") box.space.T:select() -- 2.7.4