chickliu/Sillyv2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

x

Browse Source
This commit is contained in:
1-6
2023-07-30 21:40:51 +08:00
parent 75a10da58b
commit 1690a2139c
2 changed files with 6 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/storage/boltdb/init.go
+3 -5
View File
@@ -180,11 +180,9 @@ func (bucket *Bucket) Set(key interface{}, value interface{}) (string, bool, err
return msg, changed, fin.Error return msg, changed, fin.Error
} }
if fin.Now != "" { if fin.Now != "" {
if new == storage.EMPTY {
new = ""
} else {
new = fin.Now new = fin.Now
}
} }
if fin.EndFunc != nil { if fin.EndFunc != nil {
endFuncs = append(endFuncs, fin.EndFunc) endFuncs = append(endFuncs, fin.EndFunc)
@@ -197,7 +195,7 @@ func (bucket *Bucket) Set(key interface{}, value interface{}) (string, bool, err
if err != nil { if err != nil {
return err return err
} }
if new == "" { if new == "" || new == storage.EMPTY {
if err := b.Delete([]byte(k)); err != nil { if err := b.Delete([]byte(k)); err != nil {
return err return err
} }
core/storage/redis/init.go
+1 -5
View File
@@ -239,12 +239,8 @@ func (bucket *Bucket) Set(key interface{}, value interface{}) (string, bool, err
return msg, changed, fin.Error return msg, changed, fin.Error
} }
if fin.Now != "" { if fin.Now != "" {
if new == storage.EMPTY {
new = ""
} else {
new = fin.Now new = fin.Now
} }
}
if fin.EndFunc != nil { if fin.EndFunc != nil {
endFuncs = append(endFuncs, fin.EndFunc) endFuncs = append(endFuncs, fin.EndFunc)
} }
@@ -252,7 +248,7 @@ func (bucket *Bucket) Set(key interface{}, value interface{}) (string, bool, err
} }
} }
var err error var err error
if new == "" { if new == "" || new == storage.EMPTY {
err = db.HDel(ctx, bucket.name, k).Err() err = db.HDel(ctx, bucket.name, k).Err()
} else { } else {
err = db.HSet(ctx, bucket.name, k, new).Err() err = db.HSet(ctx, bucket.name, k, new).Err()