mirror of
https://github.com/duanhf2012/origin.git
synced 2026-02-03 22:45:13 +08:00
Merge branch 'master' of https://github.com/comin2013/origin
struct 2 redis struc
This commit is contained in:
@@ -221,6 +221,39 @@ func (m *RedisModule) setStringByExpire(key, value, expire interface{}) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *RedisModule) HSetStruct(key string, val interface{}) error {
|
||||
conn, err := m.getConn()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
defer conn.Close()
|
||||
|
||||
|
||||
_, err = conn.Do("HSET", redis.Args{}.Add(key).AddFlat(val)...)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *RedisModule) HGetStruct(key string, out_val interface{}) error {
|
||||
conn, err := m.getConn()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
defer conn.Close()
|
||||
|
||||
v, err := redis.Values(conn.Do("HGETALL", key))
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
err = redis.ScanStruct(v, out_val)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
func (m *RedisModule) SetStringMap(mapInfo map[interface{}]interface{}) (err error) {
|
||||
err = m.setMuchStringByExpire(mapInfo, "-1")
|
||||
return
|
||||
|
||||
Reference in New Issue
Block a user