get operation

Author: ligurio

crud/common/sharding.lua

@@ -81,4 +81,19 @@ function sharding.get_ddl_sharding_key(space_name)
     end
 end
 
+function sharding.is_sharding_key_part_of_primary_index(sharding_index, sharding_key_fieldno)
+    for _, fieldno in ipairs(sharding_key_fieldno) do
+        local is_key_found = false
+        for _, part in ipairs(sharding_index.parts) do
+            if fieldno == part.fieldno then
+                is_key_found = true
+                break
+            end
+            if is_key_found == false then
+                return false
+            end
+        end
+    end
+end
+
 return sharding

crud/common/utils.lua

@@ -405,6 +405,15 @@ function utils.get_fieldno_by_name(space_format, field_name)
     return field_idx
 end
 
+function utils.get_sharding_key_fieldno(space_format, sharding_key)
+    key = {}
+    for i, field_name in ipairs(sharding_key) do
+        table.insert(key, utils.get_fieldno_by_name(space_format, field_name))
+    end
+
+    return key
+end
+
 local uuid_t = ffi.typeof('struct tt_uuid')
 function utils.is_uuid(value)
     return ffi.istype(uuid_t, value)

crud/get.lua

@@ -53,11 +53,22 @@ local function call_get_on_router(space_name, key, opts)
     if space == nil then
         return nil, GetError:new("Space %q doesn't exist", space_name), true
     end
+    local primary_index = space.index[0]
+    local space_format = space:format()
 
     if box.tuple.is(key) then
         key = key:totable()
     end
 
+    local ddl_sharding_key = sharding.get_ddl_sharding_key(space_name)
+    if ddl_sharding_key ~= nil then
+        local key = utils.get_sharding_key_fieldno(space_format, ddl_sharding_key)
+        local res = sharding.is_sharding_key_part_of_primary_index(primary_index, key)
+        if res == false and opts.bucket_id == nil then
+            return nil, GetError:new("Specify bucket_id"), true
+        end
+    end
+
     local bucket_id = sharding.key_get_bucket_id(key, opts.bucket_id)
     local call_opts = {
         mode = opts.mode or 'read',