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

扩展CountDocument条件参数

Browse Source
This commit is contained in:
orgin
2022-11-17 09:26:10 +08:00
parent d28094eefa
commit 5601ab5ae2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
sysmodule/mongodbmodule/mongodbmodule.go
View File

@@ -52,10 +52,10 @@ func (mm *MongoModule) TakeSession() Session {
return Session{Client: mm.client, maxOperatorTimeOut: mm.maxOperatorTimeOut} return Session{Client: mm.client, maxOperatorTimeOut: mm.maxOperatorTimeOut}
} }
func (s *Session) CountDocument(db string, collection string) (int64, error) { func (s *Session) CountDocument(db string, collection string, filter interface{}) (int64, error) {
ctxTimeout, cancel := s.GetDefaultContext() ctxTimeout, cancel := s.GetDefaultContext()
defer cancel() defer cancel()
return s.Database(db).Collection(collection).CountDocuments(ctxTimeout, bson.D{}) return s.Database(db).Collection(collection).CountDocuments(ctxTimeout, filter)
} }
func (s *Session) NextSeq(db string, collection string, id interface{}) (int, error) { func (s *Session) NextSeq(db string, collection string, id interface{}) (int, error) {