MongoDB

falldog

　　最近在博客园经常看到关于mongodb的文章，闲暇时间自己也适用了一下，发现在某些方面用起来相当的简单，只要写一个类，再定义模型对象，其他的只要调用就OK了。
　　比如添加数据：


1 public staticvoid Add(TModel model)
2         {
3             var doc = BsonExtensionMethods.ToBsonDocument(model);
4             MongoServer server = MongoServer.Create(MongoConfig.ConnectionString);
5             MongoDatabase database = server.GetDatabase(MongoConfig.DataBase);
6 using (server.RequestStart(database))
7             {
8                 var collection = database.GetCollection(typeof(TModel).Name);
9                 collection.Insert(doc);
10             }
11         }　　调用示例：


1                 User user =new User();
2                 user.Password ="1234566";
3                 user.UserName ="hao";
4                 user.RegisterTime = DateTime.Now;
5                 MongoInstance.Add(user);　　更新数据：


1 public staticvoid Update(TModel model, object id)
2         {
3             BsonDocument doc = BsonExtensionMethods.ToBsonDocument(model);
4             IList elements =new List();
5 foreach (var item in doc.Elements)
6             {
7 if (item.Value.IsBsonNull)
8                 {
9                     elements.Add(item);
10                 }
11             }
12 foreach (var el in elements)
13             {
14                 doc.RemoveElement(el);
15             }
16             MongoServer server = MongoServer.Create(MongoConfig.ConnectionString);
17             MongoDatabase database = server.GetDatabase(MongoConfig.DataBase);
18 using (server.RequestStart(database))
19             {
20                 var collection = database.GetCollection(typeof(TModel).Name);
21                 var query =new QueryDocument { { "_id", new BsonObjectId(id.ToString()) } };
22                 var update =new UpdateDocument(doc);
23                 collection.Update(query, update);
24             }
25         }　　调用示例(不能设置Id)：


1  MongoInstance.Update(user, "4ddb06b73a0c080f4ccb6df5");　　删除数据：


1 public staticvoid Delete(object id)
2         {
3             MongoServer server = MongoServer.Create(MongoConfig.ConnectionString);
4             MongoDatabase database = server.GetDatabase(MongoConfig.DataBase);
5 using (server.RequestStart(database))
6             {
7                 var collection = database.GetCollection(typeof(TModel).Name);
8                 var query =new QueryDocument("_id", new BsonObjectId(id.ToString()));
9                 collection.Remove(query);
10             }
11         }　　调用示例：


MongoInstance.Delete("4ddb06b73a0c080f4ccb6df5");　　根据Id获得对象数据：


1 public static TModel GetById(object id)
2         {
3             MongoServer server = MongoServer.Create(MongoConfig.ConnectionString);
4             MongoDatabase database = server.GetDatabase(MongoConfig.DataBase);
5 using (server.RequestStart(database))
6             {
7                 var query =new QueryDocument("_id", new BsonObjectId(id.ToString()));
8                 var collection = database.GetCollection(typeof(TModel).Name);
9                 var m = collection.FindOne(query);
10 if (m !=null)
11 return m;
12             }
13 returndefault(TModel);
14         }　　调用示例：


1 MongoInstance.GetById("4ddb06ac3a0c080f4ccb6df4");　　获得全部数据：


1 public static IList GetAll()
2         {
3             MongoServer server = MongoServer.Create(MongoConfig.ConnectionString);
4             MongoDatabase database = server.GetDatabase(MongoConfig.DataBase);
5 using (server.RequestStart(database))
6             {
7                 var employees = database.GetCollection(typeof(TModel).Name);
8 return employees.FindAll().ToList();
9             }
10         }　　调用示例：


MongoInstance.GetAll();　　分页：


1 public static IList GetDataPaging(int pageIndex, outint totalPage, int pageSize =20)
2         {
3             totalPage =0;
4             MongoServer server = MongoServer.Create(MongoConfig.ConnectionString);
5             MongoDatabase database = server.GetDatabase(MongoConfig.DataBase);
6 using (server.RequestStart(database))
7             {
8                 var collection = database.GetCollection(typeof(TModel).Name);
9                 var result = collection.FindAll();
10                 result.Skip = (pageIndex -1) * pageSize;
11                 result.Limit = pageSize;
12 return result.ToList();
13             }
14         }　　调用示例：


1 MongoInstance.GetDataPaging(2, out tPage, 2);