Feature/redis v8 upgrade

example/model/gen.object.user.go

@@ -1773,7 +1773,7 @@ func (m *_UserRedisMgr) Fetch(pk PrimaryKey) (*User, error) {
 func (m *_UserRedisMgr) FetchByKey(key string) (*User, error) {
 	obj := UserMgr.NewUser()
 
-	ctx := context.Background()
+	ctx := context.TODO()
 	pipe := m.BeginPipeline()
 	pipe.Exists(ctx, key)
 	pipe.HMGet(ctx, key,
@@ -1914,10 +1914,14 @@ func (m *_UserRedisMgr) FetchByKey(key string) (*User, error) {
 }
 
 func (m *_UserRedisMgr) FetchByPrimaryKeys(pks []PrimaryKey) ([]*User, error) {
+	if len(pks) == 0 {
+		return nil, orm.ErrPrimaryKeysIsEmpty
+	}
+
 	objs := make([]*User, 0, len(pks))
 	pipe := m.BeginPipeline()
 	obj := UserMgr.NewUser()
-	ctx := context.Background()
+	ctx := context.TODO()
 	for _, pk := range pks {
 		key := pk.Key()
 		pipe.Exists(ctx, keyOfObject(obj, key))
@@ -2217,7 +2221,7 @@ func (m *_UserRedisMgr) Delete(obj *User) error {
 		return err
 	}
 
-	ctx := context.Background()
+	ctx := context.TODO()
 	if err := pipe.Del(ctx, keyOfObject(obj, pk.Key())).Err(); err != nil {
 		return err
 	}
@@ -2262,7 +2266,7 @@ func (m *_UserRedisMgr) SaveWithExpire(obj *User, expire time.Duration) error {
 			pipe.Close()
 			return err
 		}
-		if _, err = pipe.Exec(context.Background()); err != nil {
+		if _, err = pipe.Exec(context.TODO()); err != nil {
 			pipe.Close()
 			return err
 		}
@@ -2271,7 +2275,7 @@ func (m *_UserRedisMgr) SaveWithExpire(obj *User, expire time.Duration) error {
 }
 
 func (m *_UserRedisMgr) addToPipeline(pipe *_UserRedisPipeline, obj *User, expire time.Duration) error {
-	ctx := context.Background()
+	ctx := context.TODO()
 	pk := obj.GetPrimaryKey()
 	key := pk.Key()
 	//! fields

orm/errors.go

@@ -2,6 +2,7 @@ package orm
 
 import (
 	"database/sql"
+	"errors"
 	"strings"
 )
 
@@ -10,3 +11,7 @@ import (
 func IsErrNotFound(err error) bool {
 	return strings.Contains(err.Error(), "not found") || err == sql.ErrNoRows
 }
+
+var (
+    ErrPrimaryKeysIsEmpty = errors.New("redis-orm: provided primary keys are empty")
+)

tpl/object.redis.read.gogo

@@ -154,7 +154,7 @@ func (m *_{{$obj.Name}}RedisMgr) Fetch(pk PrimaryKey) (*{{$obj.Name}}, error) {
 func (m *_{{$obj.Name}}RedisMgr) FetchByKey(key string) (*{{$obj.Name}}, error) {
 	obj := {{$obj.Name}}Mgr.New{{$obj.Name}}()
 
-	ctx := context.Background()
+	ctx := context.TODO()
 	pipe := m.BeginPipeline()
 	pipe.Exists(ctx, key)
 	pipe.HMGet(ctx, key,
@@ -214,10 +214,14 @@ func (m *_{{$obj.Name}}RedisMgr) FetchByKey(key string) (*{{$obj.Name}}, error)
 }
 
 func (m *_{{$obj.Name}}RedisMgr) FetchByPrimaryKeys(pks []PrimaryKey) ([]*{{$obj.Name}}, error) {
+	if len(pks) == 0 {
+		return nil, orm.ErrPrimaryKeysIsEmpty
+	}
+
 	objs := make([]*{{$obj.Name}}, 0, len(pks))
 	pipe := m.BeginPipeline()
 	obj := {{$obj.Name}}Mgr.New{{$obj.Name}}()
-	ctx := context.Background()
+	ctx := context.TODO()
 	for _, pk := range pks {
 		key := pk.Key()
 		pipe.Exists(ctx, keyOfObject(obj, key))

tpl/object.redis.write.gogo

@@ -92,7 +92,7 @@ func (m *_{{$obj.Name}}RedisMgr) Delete(obj *{{$obj.Name}}) error {
 	}
 	{{- end}}
 
-	ctx := context.Background()
+	ctx := context.TODO()
 	if err := pipe.Del(ctx, keyOfObject(obj, pk.Key())).Err(); err != nil {
 		return err
 	}
@@ -139,7 +139,7 @@ func (m *_{{$obj.Name}}RedisMgr) SaveWithExpire(obj *{{$obj.Name}}, expire time.
 			pipe.Close()
 			return err
 		}
-		if _, err = pipe.Exec(context.Background()); err != nil {
+		if _, err = pipe.Exec(context.TODO()); err != nil {
 			pipe.Close()
 			return err
 		}
@@ -148,7 +148,7 @@ func (m *_{{$obj.Name}}RedisMgr) SaveWithExpire(obj *{{$obj.Name}}, expire time.
 }
 
 func (m *_{{$obj.Name}}RedisMgr) addToPipeline(pipe * _{{$obj.Name}}RedisPipeline, obj *{{$obj.Name}}, expire time.Duration) error {
-	ctx := context.Background()
+	ctx := context.TODO()
 	pk := obj.GetPrimaryKey()
 	key := pk.Key()
 	//! fields

tpl/relation.pair.sync.gogo

@@ -19,10 +19,8 @@ func (m *_{{$relation.Name}}RedisMgr) AddBySQL(db DBFetcher, sql string, args ..
 	if err != nil {
 		return err
 	}
-
-	ctx := context.TODO()
 	for _, obj := range objs {
-		if err := m.PairAdd(ctx, obj.(*{{$relation.Name}})); err != nil {
+		if err := m.PairAdd(obj.(*{{$relation.Name}})); err != nil {
 			return err
 		}
 	}
@@ -34,10 +32,8 @@ func (m *_{{$relation.Name}}RedisMgr) DelBySQL(db DBFetcher, sql string, args ..
 	if err != nil {
 		return err
 	}
-
-	ctx := context.TODO()
 	for _, obj := range objs {
-		if err := m.PairRem(ctx, fmt.Sprint(obj.(*{{$relation.Name}}).{{$primaryField.Name}})); err != nil {
+		if err := m.PairRem(fmt.Sprint(obj.(*{{$relation.Name}}).{{$primaryField.Name}})); err != nil {
 			return err
 		}
 	}