在C#中访问MongoDB,查询与修改

hyytaojunming

　　在 C# 中使用 mongodb 来查询以及修改数据。



  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Web;
  5 using System.Globalization;
  6 using MongoDB.Driver;
  7 using MongoDB.Driver.Linq;
  8 using MongoDB.Bson;
  9 using MongoDB.Driver.Builders;
10 using Com.iFlytek.MarkerPlatform.DomainObjects;
11
12 namespace Com.iFlytek.MarkerPlatform.Helper
13 {
14     public class MongdbHelper : IDisposable
15     {
16         public const string UrlSeparator = "@@";
17         public const string UrlTrimItemSeparator = "$$";
18         private static string _mongoConnectionString = "mongodb://192.168.86.131/?socketTimeoutMS=2400000";
19
20         public MongoServer Server { get; private set; }
21
22         public MongoDB.Driver.MongoDatabase Database { get; private set; }
23
24         public MongoCollection DataSet { get; set; }
25
26         public MongdbHelper(string dbName, string tableName)
27         {
28             Server = MongoServer.Create(_mongoConnectionString);
29             Database = Server.GetDatabase(dbName);
30             DataSet = Database.GetCollection(tableName);
31         }
32
33         public MongdbHelper(string connectionString, string dbName, string tableName)
34         {
35             Server = MongoServer.Create(connectionString);
36             Database = Server.GetDatabase(dbName);
37             DataSet = Database.GetCollection(tableName);
38         }
39
40         public void Dispose()
41         {
42             Server.Disconnect();
43         }
44
45         ///
46         ///
47         ///
48         ///
49         ///
50         ///
51         public static List GetTopQuestions(string startTime, string lastTime)
52         {
53
54             List noAnserQuestions = null;
55
56             DateTime coStartTime = new DateTime();
57             DateTime coLastTime = new DateTime();
58
59             if (startTime != "NULL")
60             {
61                 coStartTime = DateTime.ParseExact(startTime, "yyyy-MM-dd", CultureInfo.InvariantCulture).AddHours(-8);
62                 coLastTime = DateTime.ParseExact(lastTime, "yyyy-MM-dd", CultureInfo.InvariantCulture).AddHours(-8);
63             }
64
65             try
66             {
67                 using (MongdbHelper db = new MongdbHelper("CQAOnlineLog", "NoAnswerQuestion"))
68                 {
69
70                     if (startTime != "NULL")
71                     {                                                   //Convert.ToDateTime(q.LastEditTime).CompareTo(coStartTime) >= 0
72                         noAnserQuestions = db.DataSet.AsQueryable().Where(q => q.LastEditTime >= coStartTime.AddHours(-8)
73                                                                                     && q.LastEditTime < coLastTime.AddDays(1)
74                                                                                     && q.IsExport != 1).ToList();
75                     }
76                     else
77                     {
78                         noAnserQuestions = db.DataSet.AsQueryable().Where(q => q.IsExport != 1).ToList();
79                     }
80                 }
81  
82                 var queryIds = noAnserQuestions.Select(q => q.Id).ToList();
83
84                 using (MongdbHelper helper = new MongdbHelper("CQAOnlineLog", "NoAnswerQuestion"))
85                 {
86                     queryIds.ForEach(q =>
87                     {
88                         helper.DataSet.FindAndModify(new QueryDocument("_id",q),
89                         SortBy.Null,
90                         new UpdateBuilder().Set("IsExport", 1),
91                         false, true);
92                     });
93                 }
94
95                 return noAnserQuestions;
96             }
97             catch
98             {
99                 return null;
100             }
101         }
102
103         public static List GetOnColumn(string dbName, string tableName, string column, Func convert)
104         {
105             try
106             {
107                 using (MongdbHelper db = new MongdbHelper(dbName, tableName))
108                 {
109                     List results = new List();
110                     var r = db.DataSet.FindAll();
111                     r.SetFields(column);
112                     foreach (var c in r)
113                     {
114                         results.Add(convert(c[column]));
115                     }
116
117                     return results;
118                 }
119             }
120             catch
121             {
122                 return null;
123             }
124         }
125
126         public static bool IsExist(string dbName, string tableName, string column, object value)
127         {
128             try
129             {
130                 using (MongdbHelper db = new MongdbHelper(dbName, tableName))
131                 {
132                     IMongoQuery query = new QueryDocument() { { column, value.ToString() } };
133                     var results = db.DataSet.FindOne(query);
134                     return results != null;
135                 }
136             }
137             catch
138             {
139                 return false;
140             }
141         }
142     }
143 }