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 1090F2EF94 for ; Fri, 2 Nov 2018 07:30:48 -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 E4RlAQjFBbEd for ; Fri, 2 Nov 2018 07:30:47 -0400 (EDT) Received: from smtp54.i.mail.ru (smtp54.i.mail.ru [217.69.128.34]) (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 787462EF5C for ; Fri, 2 Nov 2018 07:30:47 -0400 (EDT) From: Georgy Kirichenko Subject: [tarantool-patches] [PATCH] Return valid lua error for func creation error Date: Fri, 2 Nov 2018 14:30:54 +0300 Message-Id: MIME-Version: 1.0 Content-Transfer-Encoding: 8bit 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: Georgy Kirichenko Return valid lua error if something fail while sql function creation. --- https://github.com/tarantool/tarantool/issues/3724 https://github.com/tarantool/tarantool/tree/g.kirichenko/gh-3724-return-error-from-func-creation src/box/lua/lua_sql.c | 3 +++ test/sql/func-recreate.result | 36 +++++++++++++++++++++++++++++++++ test/sql/func-recreate.test.lua | 17 ++++++++++++++++ 3 files changed, 56 insertions(+) create mode 100644 test/sql/func-recreate.result create mode 100644 test/sql/func-recreate.test.lua diff --git a/src/box/lua/lua_sql.c b/src/box/lua/lua_sql.c index 9d78679fb..100f53b01 100644 --- a/src/box/lua/lua_sql.c +++ b/src/box/lua/lua_sql.c @@ -193,6 +193,9 @@ int lbox_sql_create_function(struct lua_State *L) NULL, NULL, lua_sql_destroy); free(normalized_name); + if (rc != 0) { + return luaL_error(L, sqlite3ErrStr(rc)); + } return rc; } diff --git a/test/sql/func-recreate.result b/test/sql/func-recreate.result new file mode 100644 index 000000000..f12cc8d90 --- /dev/null +++ b/test/sql/func-recreate.result @@ -0,0 +1,36 @@ +test_run = require('test_run').new() +--- +... +engine = test_run:get_cfg('engine') +--- +... +box.sql.execute('pragma sql_default_engine=\''..engine..'\'') +--- +... +-- Check errors during function create process +fiber = require('fiber') +--- +... +box.internal.sql_create_function('WAITFOR', function (n) fiber.sleep(n) return n end) +--- +... +ch = fiber.channel(1) +--- +... +_ = fiber.create(function () ch:put(box.sql.execute('select WAITFOR(0.2)')) end) +--- +... +fiber.sleep(0.1) +--- +... +box.internal.sql_create_function('WAITFOR', function (n) require('fiber').sleep(n) return n end) +--- +- error: database is locked +... +ch:get() +--- +- - [0.2] +... +box.internal.sql_create_function('WAITFOR', function (n) require('fiber').sleep(n) return n end) +--- +... diff --git a/test/sql/func-recreate.test.lua b/test/sql/func-recreate.test.lua new file mode 100644 index 000000000..b105da8cb --- /dev/null +++ b/test/sql/func-recreate.test.lua @@ -0,0 +1,17 @@ +test_run = require('test_run').new() +engine = test_run:get_cfg('engine') +box.sql.execute('pragma sql_default_engine=\''..engine..'\'') + +-- Check errors during function create process +fiber = require('fiber') +box.internal.sql_create_function('WAITFOR', function (n) fiber.sleep(n) return n end) + +ch = fiber.channel(1) + +_ = fiber.create(function () ch:put(box.sql.execute('select WAITFOR(0.2)')) end) +fiber.sleep(0.1) + +box.internal.sql_create_function('WAITFOR', function (n) require('fiber').sleep(n) return n end) +ch:get() +box.internal.sql_create_function('WAITFOR', function (n) require('fiber').sleep(n) return n end) + -- 2.19.1