C# 操作mongodb 分組

c#操作mongodb的分組的簡單例子：

1、首先要下載c#對應的mongodb驅動，官方下載地址：https://github.com/mongodb/mongo-csharp-driver/releases，目前版本是2.3.0

　　然后引用相應的命名空間，

　　using MongoDB.Bson;
　　using MongoDB.Driver;
　　using MongoDB.Driver.Core;

2、實例代碼：

    

　　/// <summary>
　　/// 數據集合，類似關系型數據庫中的表
　　/// </summary>
　　static IMongoCollection<BsonDocument> _collect;

　　　　

　　/// <summary>
　　/// 數據庫初始化
　　/// </summary>
　　/// <param name="collectionName">數據集合名（就是數據庫表名））</param>
　　public static void Init(string collectionName)
　　{
　　　　string mongoDB_Host = ConfigurationManager.AppSettings["MongoDB_Host"].ToString();
　　　　string mongoDB_DbName = ConfigurationManager.AppSettings["MongoDB_DbName"].ToString();
　　　　MongoDB.Driver.MongoClient mc = new MongoClient(mongoDB_Host);
　　　　IMongoDatabase _db = mc.GetDatabase(mongoDB_DbName);
　　　　_collect = _db.GetCollection<BsonDocument>(collectionName);
　　}

　　假設有這樣一個數據集合：

　　{ "_id" : 1, "name" : "mike", "sex" : "男", "age" : 20 }
　　{ "_id" : 2, "name" : "Marry", "sex" : "女", "age" : 25 }
　　{ "_id" : 3, "name" : "Tom", "sex" : "女", "age" : 35 }
　　{ "_id" : 4, "name" : "Joe", "sex" : "女", "age" : 35 }
　　{ "_id" : 5, "name" : "Joe", "sex" : "女", "age" : 45 }
　　{ "_id" : 6, "name" : "John", "sex" : "男", "age" : 45 }

　　a、統計男女的數量

　　Sql： select $sex,count(1) from student group by $sex

　　BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "count", new BsonDocument("$sum", 1) } };
　　var aggregate = _collect.Aggregate().Group(db);
　　List<BsonDocument> list = aggregate.ToList<BsonDocument>();

　　b、統計男女的總年齡

　　SQL: select sex,SUM(aget) totalAge  from student group by sex

　　BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "totalAge", new BsonDocument("$sum", "$age") } };
　　var aggregate = _collect.Aggregate().Group(db);
　　List<BsonDocument> list = aggregate.ToList<BsonDocument>();

　　c、統計男女的平均年齡，最大和最小年齡學生的信息

　　SQL：select sex,avg(age) avgAge  from student group by sex

　　SQL：select sex,max(age) maxAge  from student group by sex

　　SQL：select sex,min(age) minAge  from student group by sex

 　　

　　//BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "avgAge", new BsonDocument("$avg", "$age") } };
　　//BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "maxAge", new BsonDocument("$max", "$age") } };
　　BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "minAge", new BsonDocument("$min", "$age") } };
　　var aggregate = _collect.Aggregate().Group(db);
　　List<BsonDocument> list = aggregate.ToList<BsonDocument>();

　　d、統計年齡大於25男女的平均年齡的信息

　　SQL：select sex,avg(age) avgAge  from student where age >25 group by sex

 

　　BsonDocument dbMatch = new BsonDocument {  { "age",  new BsonDocument("$gt", 25)} };

　　BsonDocument dbGroup = new BsonDocument { { "_id", "$sex" }, { "avgAge", new BsonDocument("$avg", "$age") } };

　　var aggregate = _collect.Aggregate().Match(dbMatch).Group(dbGroup);
　　List<BsonDocument> list = aggregate.ToList<BsonDocument>();

　　

　　e、$push，$addToSet

　　//把男女學生的年齡放在一個集合里面，並允許年齡一樣的同時存在

　　//BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "AllAge", new BsonDocument("$push", "$age") } };
　　//var aggregate = _collect.Aggregate().Group(db);
　　//List<BsonDocument> list = aggregate.ToList<BsonDocument>();

 

　　//把男女學生的年齡放在一個集合里面，並不允許年齡一樣的數據

　　//BsonDocument db = new BsonDocument { { "_id", "$sex" }, { "AllAge", new BsonDocument("$addToSet, "$age") } };
　　//var aggregate = _collect.Aggregate().Group(db);
　　//List<BsonDocument> list = aggregate.ToList<BsonDocument>();