|
|
package dorm
|
|
|
|
|
|
import (
|
|
|
"context"
|
|
|
"github.com/redis/go-redis/v9"
|
|
|
)
|
|
|
|
|
|
// ListOperation 列表(list)类型数据操作
|
|
|
type ListOperation struct {
|
|
|
db *redis.Client
|
|
|
ctx context.Context
|
|
|
}
|
|
|
|
|
|
// NewListOperation 列表(list)类型数据操作 https://www.tizi365.com/archives/299.html
|
|
|
func (r *RedisClient) NewListOperation() *ListOperation {
|
|
|
return &ListOperation{db: r.db, ctx: context.Background()}
|
|
|
}
|
|
|
|
|
|
// LPush 从列表左边插入数据
|
|
|
func (cl *ListOperation) LPush(key string, value interface{}) *redis.IntCmd {
|
|
|
return cl.db.LPush(cl.ctx, key, value)
|
|
|
}
|
|
|
|
|
|
// LPushX 跟LPush的区别是，仅当列表存在的时候才插入数据
|
|
|
func (cl *ListOperation) LPushX(key string, value interface{}) *redis.IntCmd {
|
|
|
return cl.db.LPushX(cl.ctx, key, value)
|
|
|
}
|
|
|
|
|
|
// RPop 从列表的右边删除第一个数据，并返回删除的数据
|
|
|
func (cl *ListOperation) RPop(key string) *redis.StringCmd {
|
|
|
return cl.db.RPop(cl.ctx, key)
|
|
|
}
|
|
|
|
|
|
// RPush 从列表右边插入数据
|
|
|
func (cl *ListOperation) RPush(key string, value interface{}) *redis.IntCmd {
|
|
|
return cl.db.RPush(cl.ctx, key, value)
|
|
|
}
|
|
|
|
|
|
// RPushX 跟RPush的区别是，仅当列表存在的时候才插入数据
|
|
|
func (cl *ListOperation) RPushX(key string, value interface{}) *redis.IntCmd {
|
|
|
return cl.db.RPushX(cl.ctx, key, value)
|
|
|
}
|
|
|
|
|
|
// LPop 从列表左边删除第一个数据，并返回删除的数据
|
|
|
func (cl *ListOperation) LPop(key string) *redis.StringCmd {
|
|
|
return cl.db.LPop(cl.ctx, key)
|
|
|
}
|
|
|
|
|
|
// Len 返回列表的大小
|
|
|
func (cl *ListOperation) Len(key string) *redis.IntCmd {
|
|
|
return cl.db.LLen(cl.ctx, key)
|
|
|
}
|
|
|
|
|
|
// Range 返回列表的一个范围内的数据，也可以返回全部数据
|
|
|
func (cl *ListOperation) Range(key string, start, stop int64) *redis.StringSliceCmd {
|
|
|
return cl.db.LRange(cl.ctx, key, start, stop)
|
|
|
}
|
|
|
|
|
|
// RangeAli 返回key全部数据
|
|
|
func (cl *ListOperation) RangeAli(key string) *redis.StringSliceCmd {
|
|
|
return cl.db.LRange(cl.ctx, key, 0, -1)
|
|
|
}
|
|
|
|
|
|
// Rem 删除key中的数据
|
|
|
func (cl *ListOperation) Rem(key string, count int64, value interface{}) *redis.IntCmd {
|
|
|
return cl.db.LRem(cl.ctx, key, count, value)
|
|
|
}
|
|
|
|
|
|
// Index 根据索引坐标，查询key中的数据
|
|
|
func (cl *ListOperation) Index(key string, index int64) *redis.StringCmd {
|
|
|
return cl.db.LIndex(cl.ctx, key, index)
|
|
|
}
|
|
|
|
|
|
// Insert 在指定位置插入数据
|
|
|
func (cl *ListOperation) Insert(key, op string, pivot, value interface{}) *redis.IntCmd {
|
|
|
return cl.db.LInsert(cl.ctx, key, op, pivot, value)
|
|
|
}
|
