Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化mongodbmodule的NextSeq接口

Browse Source
This commit is contained in:
orgin
2022-04-01 17:35:13 +08:00
parent 4d5d45d555
commit 63199bf862
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
sysmodule/mongodbmodule/mongodbmodule.go
View File

@@ -65,7 +65,10 @@ func (s *Session) NextSeq(db string, collection string, id interface{}) (int, er
ctxTimeout, cancel := s.GetDefaultContext()
defer cancel()
err := s.Client.Database(db).Collection(collection).FindOneAndUpdate(ctxTimeout, bson.M{"_id": id}, bson.M{"$inc": bson.M{"Seq": 1}}).Decode(&res)
after := options.After
updateOpts := options.FindOneAndUpdateOptions{ReturnDocument: &after}
err := s.Client.Database(db).Collection(collection).FindOneAndUpdate(ctxTimeout, bson.M{"_id": id}, bson.M{"$inc": bson.M{"Seq": 1}},&updateOpts).Decode(&res)
return res.Seq, err
}