using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using StackExchange.Redis;
namespace RedisStuy
{
///
/// 集合操作学习
///
public class RedisSetStudy
{
#region 初始化
private IDatabase redisDatabase;
public RedisSetStudy()
{
redisDatabase = RedisHelper.GetRedisDatabase();
}
#endregion
///
/// 添加单个值到集合中
///
public bool SetAdd(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetAdd(key, value, flags);
}
///
/// 添加一组值到集合中
///
public long SetAdd(RedisKey key, RedisValue[] values, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetAdd(key, values, flags);
}
///
/// 获取两个集合运算的结果
///
/// 集合运算:Union 并集 Intersect交集 Difference 差集
/// 第一个集合
/// 第二个集合
/// 命令参数
/// 两个集合运算(集合并,交,补)的结果
public RedisValue[] SetCombine(SetOperation operation, RedisKey first, RedisKey second, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetCombine(operation, first, second, flags);
}
///
/// 获取指定集合,进行集合运算后的结果集
///
/// 集合运算:Union 并集 Intersect交集 Difference 差集
/// 指定集合的一组key
/// 命令参数
/// 指定的一组集合运算(集合并,交,补)的结果
public RedisValue[] SetCombine(SetOperation operation, RedisKey[] keys, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetCombine(operation, keys, flags);
}
///
/// 此命令等于SetCombine,但不是返回结果集,而是将其存储在目的地中。
/// 如果目的地已经存在,则将其覆盖。
///
/// 集合运算:Union 并集 Intersect交集 Difference 差集
/// 目标集合
/// 第一个集合
/// 第二个集合
/// 命令参数
///
/// 结果集中的元素数目
///
public long SetCombineAndStore(SetOperation operation, RedisKey destination, RedisKey first, RedisKey second, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetCombineAndStore(operation, destination, first, second, flags);
}
///
/// 此命令等于SetCombine,但不是返回结果集,而是将其存储在目的地中。
/// 如果目的地已经存在,则将其覆盖。
///
/// 集合运算:Union 并集 Intersect交集 Difference 差集
/// 目标集合
/// 参与集合运算的一组key
/// 命令参数
/// 结果集中的元素数目
public long SetCombineAndStore(SetOperation operation, RedisKey destination, RedisKey[] keys, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetCombineAndStore(operation, destination, keys,flags);
}
///
/// 指定的值,在集合中是存在
///
public bool SetContains(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetContains(key, value, flags);
}
///
/// 获取集合中元素的数量
///
public long SetLength(RedisKey key, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetLength(key, flags);
}
///
/// 获取集合中所的元素
///
public RedisValue[] SetMembers(RedisKey key, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetMembers(key, flags);
}
///
/// 将 member 元素从 source 集合移动到 destination 集合
/// SMOVE 是原子性操作:如果 source 集合不存在或不包含指定的 member 元素,则 SMOVE 命令不执行任何操作,仅返回 0 。
/// 否则, member 元素从 source 集合中被移除,并添加到 destination 集合中去。
/// 当 destination 集合已经包含 member 元素时, SMOVE 命令只是简单地将 source 集合中的 member 元素删除。
/// 当 source 或 destination 不是集合类型时,返回一个错误。
///
/// 源集合
/// 目标集合
/// 元素的值
/// 命令参数
///
/// 1如果元素被移动
/// 0如果元素不是源成员,则不执行操作。
///
public bool SetMove(RedisKey source, RedisKey destination, RedisValue value, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetMove(source, destination, value, flags);
}
///
/// 移除并返回集合中的一个随机元素
///
public RedisValue SetPop(RedisKey key, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetPop(key, flags);
}
///
/// 获取集合中的一个随机元素
///
public RedisValue SetRandomMember(RedisKey key, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetRandomMember(key, flags);
}
///
/// 随机获取集合中指定数量的元素
///
public RedisValue[] SetRandomMembers(RedisKey key, long count, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetRandomMembers(key, count, flags);
}
///
/// 移除集合 key 中的一个 member 元素,不存在的 member 元素会被忽略
///
public bool SetRemove(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetRemove(key, value, flags);
}
///
/// 移除集合 key 中多个 member 元素,不存在的 member 元素会被忽略
///
public long SetRemove(RedisKey key, RedisValue[] values, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetRemove(key, values, flags);
}
///
/// 增量遍历集合
/// 注意:通过光标恢复迭代,将原始枚举或枚举器转换为ISCANIN光标。
///
/// 键
/// 模式值
/// 页大小
/// cursor
/// 页偏移量
/// 命令参数
///
/// 集合中所有元素
///
public IEnumerable SetScan(RedisKey key, RedisValue pattern = default(RedisValue), int pageSize = 10, long cursor = 0, int pageOffset = 0, CommandFlags flags = CommandFlags.None)
{
return redisDatabase.SetScan(key, pattern, pageSize, cursor, pageOffset, flags);
}
///
/// 增量遍历集合
/// 注意:通过光标恢复迭代,将原始枚举或枚举器转换为ISCANIN光标。
///
/// 键
/// 模式值
/// 页大小
/// 命令参数
///
/// 集合中所有元素
///
public IEnumerable SetScan(RedisKey key, RedisValue pattern, int pageSize, CommandFlags flags)
{
return redisDatabase.SetScan(key, pattern, pageSize, flags);
}
}
}