mirror of
https://gitee.com/johng/gf.git
synced 2024-11-29 18:57:44 +08:00
46 lines
1.4 KiB
Go
46 lines
1.4 KiB
Go
// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
|
|
//
|
|
// This Source Code Form is subject to the terms of the MIT License.
|
|
// If a copy of the MIT was not distributed with this file,
|
|
// You can obtain one at https://github.com/gogf/gf.
|
|
|
|
package redis
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/gogf/gf/v2/container/gvar"
|
|
"github.com/gogf/gf/v2/database/gredis"
|
|
"github.com/gogf/gf/v2/errors/gerror"
|
|
)
|
|
|
|
// Do send a command to the server and returns the received reply.
|
|
// It uses json.Marshal for struct/slice/map type values before committing them to redis.
|
|
func (r *Redis) Do(ctx context.Context, command string, args ...interface{}) (*gvar.Var, error) {
|
|
conn, err := r.Conn(ctx)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer func() {
|
|
_ = conn.Close(ctx)
|
|
}()
|
|
return conn.Do(ctx, command, args...)
|
|
}
|
|
|
|
// Close closes the redis connection pool, which will release all connections reserved by this pool.
|
|
// It is commonly not necessary to call Close manually.
|
|
func (r *Redis) Close(ctx context.Context) (err error) {
|
|
if err = r.client.Close(); err != nil {
|
|
err = gerror.Wrap(err, `Operation Client Close failed`)
|
|
}
|
|
return
|
|
}
|
|
|
|
// Conn retrieves and returns a connection object for continuous operations.
|
|
// Note that you should call Close function manually if you do not use this connection any further.
|
|
func (r *Redis) Conn(ctx context.Context) (gredis.Conn, error) {
|
|
return &Conn{
|
|
redis: r,
|
|
}, nil
|
|
}
|