Mongodb在CSharp里實(shí)現(xiàn)Aggregate實(shí)例

2020-01-24 00:39:39

字體：大中小

供稿：網(wǎng)友

今天主要用了一個(gè)mongodb.driver里的分組，事實(shí)上在網(wǎng)上介紹這方面的文章非常少，以至于我在出現(xiàn)問題后，無法找到一個(gè)正確的解決方案，最后還是通過異常信息找到的解決方法，所以感覺自己更應(yīng)該去寫一篇關(guān)于如何在Ｃ＃驅(qū)動(dòng)里進(jìn)行聚合Aggregate的文章！

/// <summary>    /// 返回UI消息樹    /// </summary>    /// <returns></returns>    public static string GetMongoLog(DateTime? fromDate, DateTime? toDate, int page = 1)    {      string from = DateTime.Now.Date.ToString("yyyy-MM-dd");      string to = DateTime.Now.Date.AddDays(1).ToString("yyyy-MM-dd");      if (fromDate.HasValue)      {        from = fromDate.Value.ToString("yyyy-MM-dd");      }      if (toDate.HasValue)      {        to = toDate.Value.ToString("yyyy-MM-dd");      }      var stages = new List<IPipelineStageDefinition>();      stages.Add(new JsonPipelineStageDefinition<BsonDocument, BsonDocument>("{$match:{AddTime:{$gt:ISODate('" + from + "'),$lt:ISODate('" + to + "')}}}"));      stages.Add(new JsonPipelineStageDefinition<BsonDocument, BsonDocument>("{$group:{_id: /"$RootId/", count: {$sum: 1}}}"));      stages.Add(new JsonPipelineStageDefinition<BsonDocument, BsonDocument>("{$skip:" + page * 5 + "}"));      stages.Add(new JsonPipelineStageDefinition<BsonDocument, BsonDocument>("{$limit:5}"));      var pipeline = new PipelineStagePipelineDefinition<BsonDocument, BsonDocument>(stages);      var result = NoSql.MongodbManager<LoggerContext>.Collection.Aggregate(pipeline);      StringBuilder str = new StringBuilder();      str.Append("<ol class='treeMsg'>");      foreach (var item in result.ToList())      {        var timer = new List<DateTime>();        var old = NoSql.MongodbManager<LoggerContext>.Instance.Find(i => i.RootId == item.Values.ToArray()[0].ToString() && i.ParentId == null).FirstOrDefault();        timer.Add(old.AddTime);        str.Append("<li style='margin:5px;border:1px dashed #aaa'>");        str.AppendFormat("<span style='color:red;'>{0}</span><span style='color:green'>{1}</span><span>{2}</span>"          , old.Url          , old.MessageBody          , old.AddTime);        MsgTree(str, old.ChildId, timer);        str.AppendFormat("<p><b><em>本次請(qǐng)求用時(shí){0}毫秒（{1}秒）<em></b></p>"          , (timer.Max() - timer.Min()).TotalMilliseconds          , (timer.Max() - timer.Min()).TotalSeconds);        str.Append("</li>");      }      str.Append("</ol>");      return str.ToString();    }

注意，目前mongodb for C#這個(gè)驅(qū)動(dòng)，在進(jìn)行Aggregate時(shí)，只支持BsonDocument類型，也就是說，你的集合collection也必須返回的是BsonDocument，而實(shí)體類型是不可以被認(rèn)出的，這點(diǎn)要注意．