首页 > 解决方案 > 如何在事务中选择性地执行多个更新(不是添加或更新)?

问题描述

我有这个方法:

    public async Task<bool> UpdateIfExist<T>(string cacheKey, IDictionary<string, T> dictionary)
    {
        ITransaction tran = m_connection.GetDatabase().CreateTransaction();

        List<HashEntry> hashEntries = new List<HashEntry>();
        foreach (KeyValuePair<string, T> keyValuePair in dictionary)
        {
            tran.AddCondition(Condition.HashExists(cacheKey, keyValuePair.Key)); // <-- this guy is the problem

            HashEntry hashEntry = GetHashEntry(keyValuePair);
            hashEntries.Add(hashEntry);
        }

        bool committed = await tran.ExecuteAsync();
        if (committed)
        {
            await tran.HashSetAsync(cacheKey, hashEntries.ToArray()));
        }

        return committed;
    }

我的意图是执行纯更新,即更新那些dictionary也存在于缓存哈希中的键。我不希望将新的键值对dictionary插入到缓存的哈希中。但是上面执行的是“全有或全无”更新,也就是说,如果缓存的哈希中缺少字典中的任何一个键,则不会更新任何内容。


例如,假设我的 Redis 缓存中有这个哈希:

myKey foo bar
      goo baz

说,这是我的输入字典:

foo newBar
qoo qux

在我调用我的方法之后..

预期在缓存中:

myKey foo newBar // updated since the field exists in hash
      goo baz

实际的:

myKey foo bar   // no change to cache
      goo baz

注意:如果 Lua 脚本是我会尝试的唯一方法,但主要是寻找原生 SE.Redis API 方法。

标签: redisstackexchange.redis

解决方案


没有本地 redis 方法可以直接执行此操作,因此没有本地 SE-Redis 方法可以直接执行此操作。我们在这里真正想要的是一个XX修饰符(请参阅SET我的意思),但这在任何哈希命令上都不存在 - only NX,这与您想要的相反(NX是“当不存在时”)。

可以通过以下方式在没有 Lua 的情况下做到这一点:

  • 检查每个第一个是否存在
  • 修剪你的更新集
  • 创建仅包含修剪更新的事务,并带有断言检查的条件
  • ETC

但这是很多往返和操作,并且由于数据更改冲突而失败的可能性很高。因此,我想说最好的方法是使用 Lua(对于您希望成为原子的多个相关操作通常是这种情况)。我会在 中发送一个值KEYS,每个条目中的一对值ARGV,并在 Lua 中循环,本质上(完全未经测试 - 甚至可能不是有效的语法)

for i=1, #ARGV, 2 do
    if redis.call('hexists', KEYS[1], ARGV[i]) == 1then
        redis.call('hset', KEYS[1], ARGV[i], ARGV[i+1])
    end
end

推荐阅读