MongoDB 操作类的简单封装

meimei10251314

　　前阵子一直在寻找MongoDB类似于SqlHelper的类库，但是没有能找到。于是自己就写了一个简单的封装，希望与喜欢的朋友一起分享！
　　提示：使用官方的C#驱动，基本的操作已经封装进去了，如果觉得封装的方法还不够用的话，那么自己再添加吧！


  1 public sealed class MongoDbM where T : class
  2     {
  3         private MongoCollection _mongoCollection;
  4         private MongoServer _mongoServer;
  5         private MongoDatabase _mongoDb;
  6
  7         private string _collectionName;
  8         public MongoDbM(string connString, string dbName, string collectionName)
  9         {
10             _mongoServer = MongoServer.Create(connString);
11             _mongoDb = _mongoServer.GetDatabase(dbName);
12             _mongoCollection = _mongoDb.GetCollection(collectionName);
13             _collectionName = collectionName;
14         }
15
16         public int Execute(Action action)
17         {
18             int statusCode = 0;
19             try
20             {
21                 //_mongoServer.Reconnect();
22                 action(_mongoCollection);
23                 statusCode = 1;
24             }
25             finally
26             {
27                 _mongoServer.Disconnect();
28             }
29             return statusCode;
30         }
31
32         public List GetListNoPaging(BsonDocument fileds, BsonDocument greps, BsonDocument sorts)
33         {
34             List dataList = new List();
35             Execute(delegate(MongoCollection mongoCollection)
36             {
37                 MongoCursor dataCursor = mongoCollection.Find(new QueryDocument(greps))
38                     .SetFields(new FieldsDocument(fileds))
39                     .SetSortOrder(new SortByDocument(sorts));
40                 dataList.AddRange(dataCursor.ToList());
41             });
42             return dataList;
43         }
44         public List GetListPaging(BsonDocument fileds, BsonDocument greps, BsonDocument sorts, int limit, int skip, out long pageCount, out long rowCount)
45         {
46             long _rowcount = 0;
47             long _pagecount = 0;
48             List dataList = new List();
49             Execute(delegate(MongoCollection mongoCollection)
50             {
51
52                 _rowcount = mongoCollection.Find(new QueryDocument(greps)).Count();
53                 MongoCursor dataCursor = mongoCollection.Find(new QueryDocument(greps))
54                     .SetFields(new FieldsDocument(fileds))
55                     .SetSortOrder(new SortByDocument(sorts))
56                     .SetLimit(limit).SetSkip(skip);
57                 _pagecount = _rowcount % limit == 0 ? _rowcount / limit : _rowcount / limit + 1;
58                 dataList.AddRange(dataCursor.ToList());
59             });
60             rowCount = _rowcount;
61             pageCount = _pagecount;
62             return dataList;
63         }
64
65         public int Insert(T instance)
66         {
67             int resultCode = 0;
68             string _id_instance = GetObjectId(instance);
69             Execute(delegate(MongoCollection mongoCollection)
70             {
71                 Func _getId = new Func(GetObjectId);
72                 QueryDocument query = new QueryDocument(new BsonElement("_id", BsonValue.Create(_getId(instance))));
73                 //o => _getId(o) == _id_instance
74                 T temp = mongoCollection.FindOne(query);
75                 if (temp == null)
76                 {
77                     mongoCollection.Insert(instance);
78                     resultCode = 1;
79                 }
80             });
81             return resultCode;
82         }
83
84         public T One(BsonDocument fileds, BsonDocument greps)
85         {
86             T resultInstance = null;
87             Execute(delegate(MongoCollection mongoCollection)
88             {
89                 resultInstance = mongoCollection.Find(new QueryDocument(greps))
90                       .SetFields(new FieldsDocument(fileds)).FirstOrDefault();
91             });
92             return resultInstance;
93         }
94
95         public int Update(T instance)
96         {
97             int resultCode = 0;
98             Execute(delegate(MongoCollection mongoCollection)
99             {
100                 Func _getId = new Func(GetObjectId);
101                 QueryDocument query = new QueryDocument(new BsonElement("_id", BsonValue.Create(_getId(instance))));
102                 SafeModeResult result = mongoCollection.Update(query,
103                     new UpdateDocument(BsonExtensionMethods.ToBsonDocument(instance)));
104                 resultCode = 1;
105             });
106             return resultCode;
107         }
108
109         private string GetObjectId(T obj)
110         {
111             Type t = typeof(T);
112             PropertyInfo propertyInfo = t.GetProperty("_id");
113             return propertyInfo.GetValue(obj, null).ToString();
114         }　　115     }