在MVC模式下通过Jqgrid表格操作MongoDB数据

看到下图，是通过Jqgrid实现表格数据的基本增删查改的操作。表格数据增删改是一般企业应用系统开发的常见功能，不过不同的是这个表格数据来源是非关系型的数据库MongoDB。nosql虽然概念新颖，但是MongoDB基本应用实现起来还是比较轻松的，甚至代码比基本的ADO.net访问关系数据源还要简洁。由于其本身的“非关系”的数据存储方式，使得对象关系映射这个环节对于MongoDB来讲显得毫无意义，因此我们也不会对MongoDB引入所谓的“ORM”框架。

　　

　　下面我们将逐步讲解怎么在MVC模式下将MongoDB数据读取，并展示在前台Jqgrid表格上。这个“简易系统”的基本设计思想是这样的：我们在视图层展示表格，Jqgrid相关Js逻辑全部放在一个Js文件中，控制层实现了“增删查改”四个业务，MongoDB的基本数据访问放在了模型层实现。下面我们一步步实现。
 

一、实现视图层Jqgrid表格逻辑

　　首先，我们新建一个MVC空白项目，添加好jQuery、jQueryUI、Jqgrid的BETWAY登录框架代码：

　　然后在Views的Home文件夹下新建视图“Index.aspx”，在视图的body标签中添加如下HTML代码：

1. <div> 
2.     <table id="table1"> 
3.     </table> 
4.     <div id="div1"> 
5.     </div> 
6. </div> 

　　接着新建Scripts\Home文件夹，在该目录新建“Index.js”文件，并再视图中引用，代码如下：

二、实现控制层业务

　　在Controllers目录下新建控制器“HomeController.cs”，Index.js中产生了四个ajax请求，对应控制层也有四个业务方法。HomeController代码如下：
 

1. public class HomeController : Controller 
2. { 
3.     UserModel userModel = new UserModel(); 
4.     public ActionResult Index() 
5.     { 
6.         return View(); 
7.     } 
8.   
9.     /// <summary> 
10.     /// 获取全部用户列表，通过json将数据提供给jqGrid 
11.     /// </summary> 
12.     public JsonResult UserList(string sord, string sidx, string rows, string page) 
13.     { 
14.         var list = userModel.FindAll(); 
15.         int i = 0; 
16.         var query = from u in list 
17.                     select new 
18.                     { 
19.                         id = i++, 
20.                         cell = new string[]{ 
21.                             u["UserId"].ToString(), 
22.                             u["UserName"].ToString(), 
23.                             u["Age"].ToString(), 
24.                             u["Tel"].ToString(), 
25.                             u["Email"].ToString(), 
26.                             "-" 
27.                         } 
28.                     }; 
29.   
30.         var data = new 
31.         { 
32.             total = query.Count() / Convert.ToInt32(rows) + 1, 
33.             page = Convert.ToInt32(page), 
34.             records = query.Count(), 
35.             rows = query.Skip(Convert.ToInt32(rows) * (Convert.ToInt32(page) - 1)).Take(Convert.ToInt32(rows)) 
36.         }; 
37.   
38.         return Json(data, JsonRequestBehavior.AllowGet); 
39.     } 
40.   
41.     /// <summary> 
42.     /// 响应Js的“Add”ajax请求，执行添加用户操作 
43.     /// </summary> 
44.     public ContentResult Add(string UserId, string UserName, int Age, string Tel, string Email) 
45.     { 
46.         Document doc = new Document(); 
47.         doc["UserId"] = UserId; 
48.         doc["UserName"] = UserName; 
49.         doc["Age"] = Age; 
50.         doc["Tel"] = Tel; 
51.         doc["Email"] = Email; 
52.   
53.         try 
54.         { 
55.             userModel.Add(doc); 
56.             return Content("添加成功"); 
57.         } 
58.         catch 
59.         { 
60.             return Content("添加失败"); 
61.         } 
62.     } 
63.   
64.     /// <summary> 
65.     /// 响应Js的“Delete”ajax请求，执行删除用户操作 
66.     /// </summary> 
67.     public ContentResult Delete(string UserId) 
68.     { 
69.         try 
70.         { 
71.             userModel.Delete(UserId); 
72.             return Content("删除成功"); 
73.         } 
74.         catch 
75.         { 
76.             return Content("删除失败"); 
77.         } 
78.     } 
79.   
80.     /// <summary> 
81.     /// 响应Js的“Update”ajax请求，执行更新用户操作 
82.     /// </summary> 
83.     public ContentResult Update(string UserId, string UserName, int Age, string Tel, string Email) 
84.     { 
85.         Document doc = new Document(); 
86.         doc["UserId"] = UserId; 
87.         doc["UserName"] = UserName; 
88.         doc["Age"] = Age; 
89.         doc["Tel"] = Tel; 
90.         doc["Email"] = Email; 
91.         try 
92.         { 
93.             userModel.Update(doc); 
94.             return Content("修改成功"); 
95.         } 
96.         catch 
97.         { 
98.             return Content("修改失败"); 
99.         } 
100.     } 
101. } 

三、实现模型层数据访问

　　最后，我们在Models新建一个Home文件夹，添加模型“UserModel.cs”，实现MongoDB数据库访问代码如下：

1. public class UserModel 
2. { 
3.     //链接字符串(此处三个字段值根据需要可为读配置文件) 
4.     public string connectionString = "mongodb://localhost"; 
5.     //数据库名 
6.     public string databaseName = "myDatabase"; 
7.     //集合名 
8.     public string collectionName = "userCollection"; 
9.   
10.     private Mongo mongo; 
11.     private MongoDatabase mongoDatabase; 
12.     private MongoCollection<Document> mongoCollection; 
13.   
14.     public UserModel() 
15.     { 
16.         mongo = new Mongo(connectionString); 
17.         mongoDatabase = mongo.GetDatabase(databaseName) as MongoDatabase; 
18.         mongoCollection = mongoDatabase.GetCollection<Document>(collectionName) as MongoCollection<Document>; 
19.         mongo.Connect(); 
20.     } 
21.     ~UserModel() 
22.     { 
23.         mongo.Disconnect(); 
24.     } 
25.   
26.     /// <summary> 
27.     /// 增加一条用户记录 
28.     /// </summary> 
29.     /// <param name="doc"></param> 
30.     public void Add(Document doc) 
31.     { 
32.         mongoCollection.Insert(doc); 
33.     } 
34.   
35.     /// <summary> 
36.     /// 删除一条用户记录 
37.     /// </summary> 
38.     public void Delete(string UserId) 
39.     { 
40.         mongoCollection.Remove(new Document { { "UserId", UserId } }); 
41.     } 
42.   
43.     /// <summary> 
44.     /// 更新一条用户记录 
45.     /// </summary> 
46.     /// <param name="doc"></param> 
47.     public void Update(Document doc) 
48.     { 
49.         mongoCollection.FindAndModify(doc, new Document { { "UserId", doc["UserId"].ToString() } }); 
50.     } 
51.   
52.     /// <summary> 
53.     /// 查找所有用户记录 
54.     /// </summary> 
55.     /// <returns></returns> 
56.     public IEnumerable<Document> FindAll() 
57.     { 
58.         return mongoCollection.FindAll().Documents; 
59.     } 
60.   
61. } 

代码下载:mongodb_003.rar