C# mongodb帮助类

这是在C#连接MongoDB的帮助类，所使用的驱动是在Vs2015的Nuget管理器中下载的mongodb驱动。

下载第一个，会自动下载下面的两个，不要删除。

 

在配置文件中配置连接字符串connStr和数据库名称dbName：

<appSettings>
    <add key="webpages:Version" value="3.0.0.0"/>
    <add key="webpages:Enabled" value="false"/>
    <add key="ClientValidationEnabled" value="true"/>
    <add key="UnobtrusiveJavaScriptEnabled" value="true"/>
    <add key="dbName" value="demodb"/>
</appSettings>
<connectionStrings>
    <add name="connStr" connectionString="mongodb://127.0.0.1:27017"/>
</connectionStrings>

 

MongoDbHelper类：

using Cong.Model;  2 using MongoDB.Bson;  3 using MongoDB.Driver;  4 using System;  5 using System.Collections.Generic;  6 using System.Configuration;  7 using System.Linq;  8 
namespace Cong.Utility  10 {  11     public class Db  12  {  13         private static readonly string connStr = ConfigurationManager.ConnectionStrings["connStr"].ToString();  14 
        private static readonly string dbName = ConfigurationManager.AppSettings["dbName"].ToString();  16 
        private static IMongoDatabase db = null;  18 
        private static readonly object lockHelper = new object();  20 
        private Db() { }  22 
        public static IMongoDatabase GetDb()  24  {  25             if (db == null)  26  {  27                 lock (lockHelper)  28  {  29                     if (db == null)  30  {  31                         var client = new MongoClient(connStr);  32                         db = client.GetDatabase(dbName);  33  }  34  }  35  }  36             return db;  37  }  38  }  39 
    public class MongoDbHelper<T> where T : BaseEntity  41  {  42         private IMongoDatabase db = null;  43 
        private IMongoCollection<T> collection = null;  45 
        public MgHelper()  47  {  48             this.db = Db.GetDb();  49             collection = db.GetCollection<T>(typeof(T).Name);  50  }  51 
        public T Insert(T entity)  53  {  54             var flag = ObjectId.GenerateNewId();  55             entity.GetType().GetProperty("Id").SetValue(entity, flag);  56             entity.State = "y";  57             entity.CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");  58             entity.UpdateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");  59 
 collection.InsertOneAsync(entity);  61             return entity;  62  }  63 
        public void Modify(string id, string field, string value)  65  {  66             var filter = Builders<T>.Filter.Eq("Id", ObjectId.Parse(id));  67             var updated = Builders<T>.Update.Set(field, value);  68             UpdateResult result = collection.UpdateOneAsync(filter, updated).Result;  69  }  70 
        public void Update(T entity)  72  {  73             var old = collection.Find(e => e.Id.Equals(entity.Id)).ToList().FirstOrDefault();  74 
            foreach (var prop in entity.GetType().GetProperties())  76  {  77                 var newValue = prop.GetValue(entity);  78                 var oldValue = old.GetType().GetProperty(prop.Name).GetValue(old);  79                 if (newValue != null)  80  {  81                     if (!newValue.ToString().Equals(oldValue.ToString()))  82  {  83  old.GetType().GetProperty(prop.Name).SetValue(old, newValue.ToString());  84  }  85  }  86  }  87             old.State = "y";  88             old.UpdateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");  89 
            var filter = Builders<T>.Filter.Eq("Id", entity.Id);  91             ReplaceOneResult result = collection.ReplaceOneAsync(filter, old).Result;  92  }  93 
        public void Delete(T entity)  95  {  96             var filter = Builders<T>.Filter.Eq("Id", entity.Id);  97  collection.DeleteOneAsync(filter);  98  }  99 
        public T QueryOne(string id) 101  { 102             return collection.Find(a => a.Id == ObjectId.Parse(id)).ToList().FirstOrDefault(); 103  } 104 
        public List<T> QueryAll() 106  { 107             return collection.Find(a => a.State.Equals("y")).ToList(); 108  } 109  } 110 }

另外，我的实体类全部都继承自下面这个基类，里面有几个数据中常用的字段

BaseEntity：

using MongoDB.Bson;  2 using System;  3 using System.Collections.Generic;  4 using System.Linq;  5 using System.Text;  6 using System.Threading.Tasks;  7 
namespace Cong.Model  9 { 10     public abstract class BaseEntity 11  { 12         public ObjectId Id { get; set; } 13 
        public string State { get; set; } 15 
        public string CreateTime { get; set; } 17 
        public string UpdateTime { get; set; } 19  } 20 }

 最后，这个是我在MVC的一个控制器的代码，使用了增改查的功能，以供参考，另外这个我是用模板生成的代码。

using Cong.Model;  2 using Cong.Utility;  3 using MongoDB.Bson;  4 using System.Web.Mvc;  5 using WebApp.Models;  6 
namespace WebApp.Controllers  8 {  9 
    public partial class AuthController : BaseController  11  {  12         MgHelper<Auth> mg = new MgHelper<Auth>();  13 
        public ActionResult Index()  15  {  16             return View();  17  }  18 
 [HttpGet]  20         public ActionResult Create()  21  {  22             return View();  23  }  24 
 [HttpPost]  26         public ActionResult Create(Auth auth)  27  {  28  mg.Insert(auth);  29             return Content("<script>alert('success!');window.location='/Auth/Create';</script>");  30  }  31 
 [HttpGet]  33         public ActionResult Modify()  34  {  35             AuthVM authvm = new AuthVM { Auths = mg.QueryAll() };  36             return View(authvm);  37  }  38 
 [HttpPost]  40         public ActionResult Modify(Auth auth, FormCollection form)  41  {  42             auth.Id = ObjectId.Parse(form["id"]);  43  mg.Update(auth);  44             return Content("<script>alert('success!');window.location='/Auth/Modify';</script>");  45  }  46 
 [HttpPost]  48         public string Delete(string id)  49  {  50             mg.Modify(id, "State", "n");  51             return "success!";  52  }  53  }  54 
    public partial class RoleController : BaseController  56  {  57         MgHelper<Role> mg = new MgHelper<Role>();  58 
        public ActionResult Index()  60  {  61             return View();  62  }  63 
 [HttpGet]  65         public ActionResult Create()  66  {  67             return View();  68  }  69 
 [HttpPost]  71         public ActionResult Create(Role role)  72  {  73  mg.Insert(role);  74             return Content("<script>alert('success!');window.location='/Role/Create';</script>");  75  }  76 
 [HttpGet]  78         public ActionResult Modify()  79  {  80             RoleVM rolevm = new RoleVM { Roles = mg.QueryAll() };  81             return View(rolevm);  82  }  83 
 [HttpPost]  85         public ActionResult Modify(Role role, FormCollection form)  86  {  87             role.Id = ObjectId.Parse(form["id"]);  88  mg.Update(role);  89             return Content("<script>alert('success!');window.location='/Role/Modify';</script>");  90  }  91 
 [HttpPost]  93         public string Delete(string id)  94  {  95             mg.Modify(id, "State", "n");  96             return "success!";  97  }  98  }  99 
    public partial class UserController : BaseController 101  { 102         MgHelper<User> mg = new MgHelper<User>(); 103 
        public ActionResult Index() 105  { 106             return View(); 107  } 108 
 [HttpGet] 110         public ActionResult Create() 111  { 112             return View(); 113  } 114 
 [HttpPost] 116         public ActionResult Create(User user) 117  { 118  mg.Insert(user); 119             return Content("<script>alert('success!');window.location='/User/Create';</script>"); 120  } 121 
 [HttpGet] 123         public ActionResult Modify() 124  { 125             UserVM uservm = new UserVM { Users = mg.QueryAll() }; 126             return View(uservm); 127  } 128 
 [HttpPost] 130         public ActionResult Modify(User user, FormCollection form) 131  { 132             user.Id = ObjectId.Parse(form["id"]); 133  mg.Update(user); 134             return Content("<script>alert('success!');window.location='/User/Modify';</script>"); 135  } 136 
 [HttpPost] 138         public string Delete(string id) 139  { 140             mg.Modify(id, "State", "n"); 141             return "success!"; 142  } 143  } 144 }

我的测试项目是用户管理系统，有三个类： User（用户），Role（角色），Auth（权限）。

 

源代码下载：http://download.csdn.net/detail/cycong108/9737751