go/go-mixed
1
0
Fork 0
mirror of https://github.com/charlienet/go-mixed.git synced 2025-07-18 08:32:40 +08:00
Code Issues Projects Releases Wiki Activity

redis rename key

Browse Source
This commit is contained in:
charlie
2023-11-01 16:32:58 +08:00
parent f3918dd02b
commit 5f065de145
3 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
redis/redis_test.go
View File

@ -143,6 +143,7 @@ func TestRedisPool(t *testing.T) {
t.Log(client.ConfigGet(context.Background(), "slowlog-log-slower-than").Result()) t.Log(client.ConfigGet(context.Background(), "slowlog-log-slower-than").Result())
// client.FunctionLoadReplace(context.Background(), "")
}, redis.RedisOption{ }, redis.RedisOption{
Addr: "192.168.123.100:6379", Addr: "192.168.123.100:6379",
PoolSize: 100, PoolSize: 100,

6
redis/rename_hook.go
View File

@ -49,7 +49,7 @@ func (r renameKey) renameKey(cmd redis.Cmder) {
} }
switch strings.ToUpper(cmd.Name()) { switch strings.ToUpper(cmd.Name()) {
case "SELECT": case "SELECT", "FUNCTION":
// 无KEY指令 // 无KEY指令
case case
"RENAME", "RENAMENX", "RENAME", "RENAMENX",
@ -69,8 +69,8 @@ func (r renameKey) renameKey(cmd redis.Cmder) {
case "MSET", "MSETNX": case "MSET", "MSETNX":
// 间隔KEY，KEY位置规则1,3,5,7 // 间隔KEY，KEY位置规则1,3,5,7
r.rename(args, createSepuence(1, len(args), 2)...) r.rename(args, createSepuence(1, len(args), 2)...)
case "EVAL": case "EVAL", "EVALSHA", "EVALSHA_RO", "FCALL", "FCALL_RO":
// 命令中包含键数量 EVAL script numkeys [key [key ...]] [arg [arg ...]] // 命令中包含键数量
if n, ok := args[2].(int); ok && n > 0 { if n, ok := args[2].(int); ok && n > 0 {
r.rename(args, createSepuence(3, 3+n, 1)...) r.rename(args, createSepuence(3, 3+n, 1)...)
} }

3
redis/rename_hook_test.go
View File

@ -21,4 +21,7 @@ func TestEvalName(t *testing.T) {
_, err := rdb.Eval(context.Background(), "return 1", []string{"a1", "a2", "a3"}, "b1", "b2", "b3").Result() _, err := rdb.Eval(context.Background(), "return 1", []string{"a1", "a2", "a3"}, "b1", "b2", "b3").Result()
assert.Nil(t, err, err) assert.Nil(t, err, err)
v, err := rdb.FunctionLoadReplace(context.Background(), "#!lua name=mylib\nredis.register_function('myfunc1', function() return 'hello world' end)").Result()
t.Log(v, err)
} }