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`, `upsert_many`) which suppress returning
successfully processed tuple(s).

Closes #267

CHANGELOG.md

@@ -5,6 +5,11 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## Unreleased
+
+### Added
+* Add `noreturn` opt for some DML operations (PR #356).
+
 ## [1.1.1] - 24-03-23
 
 ### Changed

README.md

@@ -234,6 +234,7 @@ where:
     since each replicaset has its own sequence. If sequence field is a part
     of the sharding key (which is true by default), choosing the bucket id is
     the sole responsibility of the developer
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuple
 
 Returns metadata and array contains one inserted row, error.
 
@@ -299,6 +300,7 @@ where:
     since each replicaset has its own sequence. If sequence field is a part
     of the sharding key (which is true by default), choosing the bucket id is
     the sole responsibility of the developer
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuples
 
 Returns metadata and array with inserted rows, array of errors.
 Each error object can contain field `operation_data`.
@@ -474,6 +476,7 @@ where:
   * `vshard_router` (`?string|table`) - Cartridge vshard group name or
     vshard router instance. Set this parameter if your space is not
     a part of the default vshard cluster
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuple
 
 Returns metadata and array contains one updated row, error.
 
@@ -510,6 +513,7 @@ where:
   * `vshard_router` (`?string|table`) - Cartridge vshard group name or
     vshard router instance. Set this parameter if your space is not
     a part of the default vshard cluster
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuple
 
 Returns metadata and array contains one deleted row (empty for vinyl), error.
 
@@ -557,6 +561,7 @@ where:
     since each replicaset has its own sequence. If sequence field is a part
     of the sharding key (which is true by default), choosing the bucket id is
     the sole responsibility of the developer
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuple
 
 Returns inserted or replaced rows and metadata or nil with error.
 
@@ -622,6 +627,7 @@ where:
     since each replicaset has its own sequence. If sequence field is a part
     of the sharding key (which is true by default), choosing the bucket id is
     the sole responsibility of the developer
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuples
 
 Returns metadata and array with inserted/replaced rows, array of errors.
 Each error object can contain field `operation_data`.
@@ -819,6 +825,7 @@ where:
   * `vshard_router` (`?string|table`) - Cartridge vshard group name or
     vshard router instance. Set this parameter if your space is not
     a part of the default vshard cluster
+  * `noreturn` (`?boolean`) - suppress returning successfully processed tuples
 
 Returns metadata and array of errors.
 Each error object can contain field `operation_data`.

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

@@ -21,6 +21,7 @@ local function delete_on_storage(space_name, key, field_names, opts)
         sharding_key_hash = '?number',
         sharding_func_hash = '?number',
         skip_sharding_hash_check = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -44,6 +45,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
 
@@ -60,6 +62,7 @@ local function call_delete_on_router(vshard_router, space_name, key, opts)
         bucket_id = '?number|cdata',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     local space, err = utils.get_space(space_name, vshard_router, opts.timeout)
@@ -108,6 +111,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 = {
@@ -162,6 +166,9 @@ end
 --  Set this parameter if your space is not a part of the
 --  default vshard cluster.
 --
+-- @tparam ?boolean opts.noreturn
+--  Suppress returning successfully processed tuple.
+--
 -- @return[1] object
 -- @treturn[2] nil
 -- @treturn[2] table Error description
@@ -172,6 +179,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

@@ -21,6 +21,7 @@ local function insert_on_storage(space_name, tuple, opts)
         sharding_key_hash = '?number',
         sharding_func_hash = '?number',
         skip_sharding_hash_check = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -45,6 +46,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
 
@@ -62,6 +64,7 @@ local function call_insert_on_router(vshard_router, space_name, original_tuple,
         add_space_schema_hash = '?boolean',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     local space, err = utils.get_space(space_name, vshard_router, opts.timeout)
@@ -85,6 +88,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 = {
@@ -145,6 +149,9 @@ end
 --  Set this parameter if your space is not a part of the
 --  default vshard cluster.
 --
+-- @tparam ?boolean opts.noreturn
+--  Suppress returning successfully processed tuple.
+--
 -- @return[1] tuple
 -- @treturn[2] nil
 -- @treturn[2] table Error description
@@ -156,6 +163,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 +202,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

@@ -27,6 +27,7 @@ local function insert_many_on_storage(space_name, tuples, opts)
         sharding_key_hash = '?number',
         sharding_func_hash = '?number',
         skip_sharding_hash_check = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -56,6 +57,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
@@ -129,6 +131,7 @@ local function call_insert_many_on_router(vshard_router, space_name, original_tu
         stop_on_error = '?boolean',
         rollback_on_error = '?boolean',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     local space, err = utils.get_space(space_name, vshard_router, opts.timeout)
@@ -148,6 +151,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({
@@ -219,6 +223,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 +262,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 {}

crud/replace.lua

@@ -21,6 +21,7 @@ local function replace_on_storage(space_name, tuple, opts)
         sharding_key_hash = '?number',
         sharding_func_hash = '?number',
         skip_sharding_hash_check = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -45,6 +46,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
 
@@ -62,6 +64,7 @@ local function call_replace_on_router(vshard_router, space_name, original_tuple,
         add_space_schema_hash = '?boolean',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     local space, err = utils.get_space(space_name, vshard_router, opts.timeout)
@@ -85,6 +88,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 = {
@@ -144,6 +148,9 @@ end
 --  Set this parameter if your space is not a part of the
 --  default vshard cluster.
 --
+-- @tparam ?boolean opts.noreturn
+--  Suppress returning successfully processed tuple.
+--
 -- @return[1] object
 -- @treturn[2] nil
 -- @treturn[2] table Error description
@@ -155,6 +162,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 +201,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

@@ -27,6 +27,7 @@ local function replace_many_on_storage(space_name, tuples, opts)
         sharding_key_hash = '?number',
         sharding_func_hash = '?number',
         skip_sharding_hash_check = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -56,6 +57,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)
@@ -131,6 +133,7 @@ local function call_replace_many_on_router(vshard_router, space_name, original_t
         stop_on_error = '?boolean',
         rollback_on_error = '?boolean',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     local space, err = utils.get_space(space_name, vshard_router, opts.timeout)
@@ -150,6 +153,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({
@@ -221,6 +225,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 +264,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 {}

crud/update.lua

@@ -21,6 +21,7 @@ local function update_on_storage(space_name, key, operations, field_names, opts)
         sharding_key_hash = '?number',
         sharding_func_hash = '?number',
         skip_sharding_hash_check = '?boolean',
+        noreturn = '?boolean',
     })
 
     opts = opts or {}
@@ -44,6 +45,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
@@ -82,6 +84,7 @@ local function call_update_on_router(vshard_router, space_name, key, user_operat
         bucket_id = '?number|cdata',
         fields = '?table',
         vshard_router = '?string|table',
+        noreturn = '?boolean',
     })
 
     local space, err = utils.get_space(space_name, vshard_router, opts.timeout)
@@ -140,6 +143,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 = {
@@ -198,6 +202,9 @@ end
 --  Set this parameter if your space is not a part of the
 --  default vshard cluster.
 --
+-- @tparam ?boolean opts.noreturn
+--  Suppress returning successfully processed tuple.
+--
 -- @return[1] object
 -- @treturn[2] nil
 -- @treturn[2] table Error description
@@ -208,6 +215,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 {}