feature: add noreturn opt for some DML operations

This patch introduces `noreturn` opt for some DML operarions (`insert`,
`replace`, `update`, `delete`, `insert_many`, `replace_many`) which
suppress returning successfully processed tuple(s).

Closes #267

Author: GRISHNOV

crud/common/schema.lua

@@ -216,7 +216,9 @@ function schema.wrap_func_result(space, func, args, opts)
             result.space_schema_hash = get_space_schema_hash(space)
         end
     else
-        result.res = filter_tuple_fields(func_res, opts.field_names)
+        if opts.noreturn ~= true then
+            result.res = filter_tuple_fields(func_res, opts.field_names)
+        end
     end
 
     return result

crud/delete.lua

@@ -44,6 +44,7 @@ local function delete_on_storage(space_name, key, field_names, opts)
     return schema.wrap_box_space_func_result(space, 'delete', {key}, {
         add_space_schema_hash = false,
         field_names = field_names,
+        noreturn = opts.noreturn,
     })
 end
 
@@ -108,6 +109,7 @@ local function call_delete_on_router(vshard_router, space_name, key, opts)
         sharding_func_hash = bucket_id_data.sharding_func_hash,
         sharding_key_hash = sharding_key_hash,
         skip_sharding_hash_check = skip_sharding_hash_check,
+        noreturn = opts.noreturn,
     }
 
     local call_opts = {
@@ -172,6 +174,7 @@ function delete.call(space_name, key, opts)
         bucket_id = '?number|cdata',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}

crud/insert.lua

@@ -45,6 +45,7 @@ local function insert_on_storage(space_name, tuple, opts)
     return schema.wrap_box_space_func_result(space, 'insert', {tuple}, {
         add_space_schema_hash = opts.add_space_schema_hash,
         field_names = opts.fields,
+        noreturn = opts.noreturn,
     })
 end
 
@@ -85,6 +86,7 @@ local function call_insert_on_router(vshard_router, space_name, original_tuple,
         sharding_func_hash = sharding_data.sharding_func_hash,
         sharding_key_hash = sharding_data.sharding_key_hash,
         skip_sharding_hash_check = sharding_data.skip_sharding_hash_check,
+        noreturn = opts.noreturn,
     }
 
     local call_opts = {
@@ -156,6 +158,7 @@ function insert.tuple(space_name, tuple, opts)
         add_space_schema_hash = '?boolean',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -194,6 +197,7 @@ function insert.object(space_name, obj, opts)
         fields = '?table',
         vshard_router = '?string|table',
         skip_nullability_check_on_flatten = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}

crud/insert_many.lua

@@ -56,6 +56,7 @@ local function insert_many_on_storage(space_name, tuples, opts)
         local insert_result = schema.wrap_box_space_func_result(space, 'insert', {tuple}, {
             add_space_schema_hash = opts.add_space_schema_hash,
             field_names = opts.fields,
+            noreturn = opts.noreturn,
         })
 
         if insert_result.err ~= nil then
@@ -148,6 +149,7 @@ local function call_insert_many_on_router(vshard_router, space_name, original_tu
         fields = opts.fields,
         stop_on_error = opts.stop_on_error,
         rollback_on_error = opts.rollback_on_error,
+        noreturn = opts.noreturn,
     }
 
     local iter, err = BatchInsertIterator:new({
@@ -181,6 +183,9 @@ local function call_insert_many_on_router(vshard_router, space_name, original_tu
     end
 
     if next(rows) == nil then
+        if errs == nil then
+            return true
+        end
         return nil, errs
     end
 
@@ -219,6 +224,7 @@ function insert_many.tuples(space_name, tuples, opts)
         stop_on_error = '?boolean',
         rollback_on_error = '?boolean',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -257,6 +263,7 @@ function insert_many.objects(space_name, objs, opts)
         rollback_on_error = '?boolean',
         vshard_router = '?string|table',
         skip_nullability_check_on_flatten = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -291,6 +298,9 @@ function insert_many.objects(space_name, objs, opts)
     end
 
     if next(tuples) == nil then
+        if next(format_errs) == nil then
+            return true, {}
+        end
         return nil, format_errs
     end
 

crud/replace.lua

@@ -45,6 +45,7 @@ local function replace_on_storage(space_name, tuple, opts)
     return schema.wrap_box_space_func_result(space, 'replace', {tuple}, {
         add_space_schema_hash = opts.add_space_schema_hash,
         field_names = opts.fields,
+        noreturn = opts.noreturn,
     })
 end
 
@@ -85,6 +86,7 @@ local function call_replace_on_router(vshard_router, space_name, original_tuple,
         sharding_func_hash = sharding_data.sharding_func_hash,
         sharding_key_hash = sharding_data.sharding_key_hash,
         skip_sharding_hash_check = sharding_data.skip_sharding_hash_check,
+        noreturn = opts.noreturn,
     }
 
     local call_opts = {
@@ -155,6 +157,7 @@ function replace.tuple(space_name, tuple, opts)
         add_space_schema_hash = '?boolean',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -193,6 +196,7 @@ function replace.object(space_name, obj, opts)
         fields = '?table',
         vshard_router = '?string|table',
         skip_nullability_check_on_flatten = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}

crud/replace_many.lua

@@ -56,6 +56,7 @@ local function replace_many_on_storage(space_name, tuples, opts)
         local insert_result = schema.wrap_box_space_func_result(space, 'replace', {tuple}, {
             add_space_schema_hash = opts.add_space_schema_hash,
             field_names = opts.fields,
+            noreturn = opts.noreturn,
         })
 
         table.insert(errs, err)
@@ -150,6 +151,7 @@ local function call_replace_many_on_router(vshard_router, space_name, original_t
         fields = opts.fields,
         stop_on_error = opts.stop_on_error,
         rollback_on_error = opts.rollback_on_error,
+        noreturn = opts.noreturn,
     }
 
     local iter, err = BatchInsertIterator:new({
@@ -183,6 +185,9 @@ local function call_replace_many_on_router(vshard_router, space_name, original_t
     end
 
     if next(rows) == nil then
+        if errs == nil then
+            return true
+        end
         return nil, errs
     end
 
@@ -221,6 +226,7 @@ function replace_many.tuples(space_name, tuples, opts)
         stop_on_error = '?boolean',
         rollback_on_error = '?boolean',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -259,6 +265,7 @@ function replace_many.objects(space_name, objs, opts)
         rollback_on_error = '?boolean',
         vshard_router = '?string|table',
         skip_nullability_check_on_flatten = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -293,6 +300,9 @@ function replace_many.objects(space_name, objs, opts)
     end
 
     if next(tuples) == nil then
+        if next(format_errs) == nil then
+            return true, {}
+        end
         return nil, format_errs
     end
 

crud/update.lua

@@ -44,6 +44,7 @@ local function update_on_storage(space_name, key, operations, field_names, opts)
     local res, err = schema.wrap_box_space_func_result(space, 'update', {key, operations}, {
         add_space_schema_hash = false,
         field_names = field_names,
+        noreturn = opts.noreturn,
     })
 
     if err ~= nil then
@@ -140,6 +141,7 @@ local function call_update_on_router(vshard_router, space_name, key, user_operat
         sharding_func_hash = bucket_id_data.sharding_func_hash,
         sharding_key_hash = sharding_key_hash,
         skip_sharding_hash_check = skip_sharding_hash_check,
+        noreturn = opts.noreturn,
     }
 
     local call_opts = {
@@ -208,6 +210,7 @@ function update.call(space_name, key, user_operations, opts)
         bucket_id = '?number|cdata',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}