mongo driver 的 countdocument方法

2025-11-25 16:37:29 +08:00
parent 8665705f26
commit 62f545affd
1 changed files with 7 additions and 0 deletions
--- a/mongo/mongo.go
+++ b/mongo/mongo.go
@@ -94,3 +94,10 @@ func Insert(ctx context.Context, documents []interface{}, collection string, opt
 	ids = r.InsertedIDs
 	return
 }
+
+// Count  查询总数 
+func Count(ctx context.Context, filter bson.M, collection string) (count int64, err error) {
+	// 调用驱动的 CountDocuments，在数据库端执行的
+	count, err = db.Collection(collection).CountDocuments(ctx, filter)
+	return
+}