这篇文章主要介绍了MongoDB入门教程之C#驱动操作实例,即C#中操作MongoDB数据的方法和代码示例,需要的朋友可以参考下
作为系列的最后一篇，得要说说C#驱动对mongodb的操作，目前驱动有两种：官方驱动和samus驱动，不过我个人还是喜欢后者，
因为提供了丰富的linq操作，相当方便。
官方驱动：https://github.com/mongodb/mongo-csharp-driver/downloads。下载后，还提供了一个酷似msdn的帮助文档。
samus驱动：https://github.com/samus/mongodb-csharp/downloads。
下面就具体看看samus驱动，https://github.com/samus/mongodb-csharp/blob/master/examples/Simple/Main.cs上面提供了
一个简单的demo，大体上看看我们就知道怎么玩了。
一： 实践
1：我们建立一个Person实体，MongoAlias特性表示取别名，这里的ID值将会覆盖掉数据库自动生成的_id。

1. 
   
2. #region 数据实体
   
3. /// <summary>
   
4. /// 数据实体
   
5. /// </summary>
   
6. public class Person
   
7. {
   
8. [MongoAlias("_id")]
   
9. public string ID { get; set; }
   
10. public string Name { get; set; }
    
11. public int Age { get; set; }
    
12. public DateTime CreateTime { get; set; }
    
13. }
    
14. #endregion

复制代码

2：初始化一些变量

1. 
   
2. string connectionString = string.Empty;
   
3. string databaseName = string.Empty;
   
4. string collectionName = string.Empty;
   
5. static MongodbHelper<T> mongodb;
   
6. #region 初始化操作
   
7. /// <summary>
   
8. /// 初始化操作
   
9. /// </summary>
   
10. public MongodbHelper()
    
11. {
    
12. connectionString = "Server=127.0.0.1:2222";
    
13. databaseName = "shopex";
    
14. collectionName = "person";
    
15. }
    
16. #endregion

复制代码

3：为了方便T的继承类使用linq功能，我们还需要映射一下。

1. 
   
2. #region 实现linq查询的映射配置
   
3. /// <summary>
   
4. /// 实现linq查询的映射配置
   
5. /// </summary>
   
6. public MongoConfiguration configuration
   
7. {
   
8. get
   
9. {
   
10. var config = new MongoConfigurationBuilder();
    
11. config.Mapping(mapping =>
    
12. {
    
13. mapping.DefaultProfile(profile =>
    
14. {
    
15. profile.SubClassesAre(t => t.IsSubclassOf(typeof(T)));
    
16. });
    
17. mapping.Map<T>();
    
18. mapping.Map<T>();
    
19. });
    
20. config.ConnectionString(connectionString);
    
21. return config.BuildConfiguration();
    
22. }
    
23. }
    
24. #endregion

复制代码

4：下面是一些基本的CURD的代码，跟写EF代码很类似，写起来好舒服。

1. 
   
2. #region 插入操作
   
3. /// <summary>
   
4. /// 插入操作
   
5. /// </summary>
   
6. /// <param name="person"></param>
   
7. /// <returns></returns>
   
8. public void Insert(T t)
   
9. {
   
10. using (Mongo mongo = new Mongo(configuration))
    
11. {
    
12. try
    
13. {
    
14. mongo.Connect();
    
15. var db = mongo.GetDatabase(databaseName);
    
16. var collection = db.GetCollection<T>(collectionName);
    
17. collection.Insert(t, true);
    
18. mongo.Disconnect();
    
19. }
    
20. catch (Exception)
    
21. {
    
22. mongo.Disconnect();
    
23. throw;
    
24. }
    
25. }
    
26. }
    
27. #endregion
    
28. #region 更新操作
    
29. /// <summary>
    
30. /// 更新操作
    
31. /// </summary>
    
32. /// <param name="person"></param>
    
33. /// <returns></returns>
    
34. public void Update(T t, Expression<Func<T, bool>> func)
    
35. {
    
36. using (Mongo mongo = new Mongo(configuration))
    
37. {
    
38. try
    
39. {
    
40. mongo.Connect();
    
41. var db = mongo.GetDatabase(databaseName);
    
42. var collection = db.GetCollection<T>(collectionName);
    
43. collection.Update<T>(t, func, true);
    
44. mongo.Disconnect();
    
45. }
    
46. catch (Exception)
    
47. {
    
48. mongo.Disconnect();
    
49. throw;
    
50. }
    
51. }
    
52. }
    
53. #endregion
    
54. #region 获取集合
    
55. /// <summary>
    
56. ///获取集合
    
57. /// </summary>
    
58. /// <param name="person"></param>
    
59. /// <returns></returns>
    
60. public List<T> List(int pageIndex, int pageSize, Expression<Func<T, bool>> func, out int pageCount)
    
61. {
    
62. pageCount = 0;
    
63. using (Mongo mongo = new Mongo(configuration))
    
64. {
    
65. try
    
66. {
    
67. mongo.Connect();
    
68. var db = mongo.GetDatabase(databaseName);
    
69. var collection = db.GetCollection<T>(collectionName);
    
70. pageCount = Convert.ToInt32(collection.Count());
    
71. var personList = collection.Linq().Where(func).Skip(pageSize * (pageIndex - 1))
    
72. .Take(pageSize).Select(i => i).ToList();
    
73. mongo.Disconnect();
    
74. return personList;
    
75. }
    
76. catch (Exception)
    
77. {
    
78. mongo.Disconnect();
    
79. throw;
    
80. }
    
81. }
    
82. }
    
83. #endregion
    
84. #region 读取单条记录
    
85. /// <summary>
    
86. ///读取单条记录
    
87. /// </summary>
    
88. /// <param name="person"></param>
    
89. /// <returns></returns>
    
90. public T Single(Expression<Func<T, bool>> func)
    
91. {
    
92. using (Mongo mongo = new Mongo(configuration))
    
93. {
    
94. try
    
95. {
    
96. mongo.Connect();
    
97. var db = mongo.GetDatabase(databaseName);
    
98. var collection = db.GetCollection<T>(collectionName);
    
99. var single = collection.Linq().FirstOrDefault(func);
    
100. mongo.Disconnect();
     
101. return single;
     
102. }
     
103. catch (Exception)
     
104. {
     
105. mongo.Disconnect();
     
106. throw;
     
107. }
     
108. }
     
109. }
     
110. #endregion
     
111. #region 删除操作
     
112. /// <summary>
     
113. /// 删除操作
     
114. /// </summary>
     
115. /// <param name="person"></param>
     
116. /// <returns></returns>
     
117. public void Delete(Expression<Func<T, bool>> func)
     
118. {
     
119. using (Mongo mongo = new Mongo(configuration))
     
120. {
     
121. try
     
122. {
     
123. mongo.Connect();
     
124. var db = mongo.GetDatabase(databaseName);
     
125. var collection = db.GetCollection<T>(collectionName);
     
126. //这个地方要注意，一定要加上T参数，否则会当作object类型处理
     
127. //导致删除失败
     
128. collection.Remove<T>(func);
     
129. mongo.Disconnect();
     
130. }
     
131. catch (Exception)
     
132. {
     
133. mongo.Disconnect();
     
134. throw;
     
135. }
     
136. }
     
137. }
     
138. #endregion

复制代码

5. 好，我们开一下2222端口，由于前前篇我已经把这个mongodb做成了服务，现在就直接连过去了，并做一下对Name的索引。
6. 一切准备妥当，我们做下基本的操作，比如这里我添加一千条数据，注意我开启的是安全模式，如果插入不成功，将会抛出异常。
<1> Add:

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. //插入1000条数据
   
6. for (int i = 0; i < 1000; i++)
   
7. {
   
8. helper.Insert(new Person()
   
9. {
   
10. ID = Guid.NewGuid().ToString(),
    
11. Name = "jack" + i,
    
12. Age = i,
    
13. CreateTime = DateTime.Now
    
14. });
    
15. }
    
16. Console.WriteLine("插入成功");
    
17. Console.Read();
    
18. }
    

复制代码

乍一看显示的数据以为有问题，为什么没有出现jack0或者jack999，不过find的一下后心情舒坦了。
<2> update: 这里就把jack941的名字改掉“mary”

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. //修改jack941改成mary
   
6. var single = helper.Single(i => i.Name == "jack941");
   
7. single.Name = "mary";
   
8. helper.Update(single, i => i.ID == single.ID);
   
9. Console.WriteLine("修改成功");
   
10. Console.Read();
    
11. }

复制代码

<3>Delete： 删除mary这条记录

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. //删除mary这个记录
   
6. helper.Delete(i => i.Name == "mary");
   
7. Console.WriteLine("删除成功");
   
8. Console.Read();
   
9. }

复制代码

<4> list操作： 这里我获取一下名字里面带9的人数列表

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. int pagecount;
   
6. //获取名字里面带9的人数
   
7. var list = helper.List(1, 20, i => i.Name.Contains("9"), out pagecount);
   
8. Console.Read();
   
9. }

复制代码

总的运行代码

1. 
   
2. using System;
   
3. using System.Collections.Generic;
   
4. using System.Linq;
   
5. using System.Text;
   
6. using System.Configuration;
   
7. using System.Linq.Expressions;
   
8. using MongoDB.Configuration;
   
9. using MongoDB.Linq;
   
10. using MongoDB.Attributes;
    
11. 
    
12. namespace MongoDB.Test
    
13. {
    
14. public class MongodbHelper<T> where T : class
    
15. {
    
16. string connectionString = string.Empty;
    
17. string databaseName = string.Empty;
    
18. string collectionName = string.Empty;
    
19. static MongodbHelper<T> mongodb;
    
20. #region 初始化操作
    
21. /// <summary>
    
22. /// 初始化操作
    
23. /// </summary>
    
24. public MongodbHelper()
    
25. {
    
26. connectionString = "Server=127.0.0.1:2222";
    
27. databaseName = "shopex";
    
28. collectionName = "person";
    
29. }
    
30. #endregion
    
31. #region 实现linq查询的映射配置
    
32. /// <summary>
    
33. /// 实现linq查询的映射配置
    
34. /// </summary>
    
35. public MongoConfiguration configuration
    
36. {
    
37. get
    
38. {
    
39. var config = new MongoConfigurationBuilder();
    
40. config.Mapping(mapping =>
    
41. {
    
42. mapping.DefaultProfile(profile =>
    
43. {
    
44. profile.SubClassesAre(t => t.IsSubclassOf(typeof(T)));
    
45. });
    
46. mapping.Map<T>();
    
47. mapping.Map<T>();
    
48. });
    
49. config.ConnectionString(connectionString);
    
50. return config.BuildConfiguration();
    
51. }
    
52. }
    
53. #endregion
    
54. #region 插入操作
    
55. /// <summary>
    
56. /// 插入操作
    
57. /// </summary>
    
58. /// <param name="person"></param>
    
59. /// <returns></returns>
    
60. public void Insert(T t)
    
61. {
    
62. using (Mongo mongo = new Mongo(configuration))
    
63. {
    
64. try
    
65. {
    
66. mongo.Connect();
    
67. var db = mongo.GetDatabase(databaseName);
    
68. var collection = db.GetCollection<T>(collectionName);
    
69. collection.Insert(t, true);
    
70. mongo.Disconnect();
    
71. }
    
72. catch (Exception)
    
73. {
    
74. mongo.Disconnect();
    
75. throw;
    
76. }
    
77. }
    
78. }
    
79. #endregion
    
80. #region 更新操作
    
81. /// <summary>
    
82. /// 更新操作
    
83. /// </summary>
    
84. /// <param name="person"></param>
    
85. /// <returns></returns>
    
86. public void Update(T t, Expression<Func<T, bool>> func)
    
87. {
    
88. using (Mongo mongo = new Mongo(configuration))
    
89. {
    
90. try
    
91. {
    
92. mongo.Connect();
    
93. var db = mongo.GetDatabase(databaseName);
    
94. var collection = db.GetCollection<T>(collectionName);
    
95. collection.Update<T>(t, func, true);
    
96. mongo.Disconnect();
    
97. }
    
98. catch (Exception)
    
99. {
    
100. mongo.Disconnect();
     
101. throw;
     
102. }
     
103. }
     
104. }
     
105. #endregion
     
106. #region 获取集合
     
107. /// <summary>
     
108. ///获取集合
     
109. /// </summary>
     
110. /// <param name="person"></param>
     
111. /// <returns></returns>
     
112. public List<T> List(int pageIndex, int pageSize, Expression<Func<T, bool>> func, out int pageCount)
     
113. {
     
114. pageCount = 0;
     
115. using (Mongo mongo = new Mongo(configuration))
     
116. {
     
117. try
     
118. {
     
119. mongo.Connect();
     
120. var db = mongo.GetDatabase(databaseName);
     
121. var collection = db.GetCollection<T>(collectionName);
     
122. pageCount = Convert.ToInt32(collection.Count());
     
123. var personList = collection.Linq().Where(func).Skip(pageSize * (pageIndex - 1))
     
124. .Take(pageSize).Select(i => i).ToList();
     
125. mongo.Disconnect();
     
126. return personList;
     
127. }
     
128. catch (Exception)
     
129. {
     
130. mongo.Disconnect();
     
131. throw;
     
132. }
     
133. }
     
134. }
     
135. #endregion
     
136. #region 读取单条记录
     
137. /// <summary>
     
138. ///读取单条记录
     
139. /// </summary>
     
140. /// <param name="person"></param>
     
141. /// <returns></returns>
     
142. public T Single(Expression<Func<T, bool>> func)
     
143. {
     
144. using (Mongo mongo = new Mongo(configuration))
     
145. {
     
146. try
     
147. {
     
148. mongo.Connect();
     
149. var db = mongo.GetDatabase(databaseName);
     
150. var collection = db.GetCollection<T>(collectionName);
     
151. var single = collection.Linq().FirstOrDefault(func);
     
152. mongo.Disconnect();
     
153. return single;
     
154. }
     
155. catch (Exception)
     
156. {
     
157. mongo.Disconnect();
     
158. throw;
     
159. }
     
160. }
     
161. }
     
162. #endregion
     
163. #region 删除操作
     
164. /// <summary>
     
165. /// 删除操作
     
166. /// </summary>
     
167. /// <param name="person"></param>
     
168. /// <returns></returns>
     
169. public void Delete(Expression<Func<T, bool>> func)
     
170. {
     
171. using (Mongo mongo = new Mongo(configuration))
     
172. {
     
173. try
     
174. {
     
175. mongo.Connect();
     
176. var db = mongo.GetDatabase(databaseName);
     
177. var collection = db.GetCollection<T>(collectionName);
     
178. //这个地方要注意，一定要加上T参数，否则会当作object类型处理
     
179. //导致删除失败
     
180. collection.Remove<T>(func);
     
181. mongo.Disconnect();
     
182. }
     
183. catch (Exception)
     
184. {
     
185. mongo.Disconnect();
     
186. throw;
     
187. }
     
188. }
     
189. }
     
190. #endregion
     
191. }
     
192. #region 数据实体
     
193. /// <summary>
     
194. /// 数据实体
     
195. /// </summary>
     
196. public class Person
     
197. {
     
198. [MongoAlias("_id")]
     
199. public string ID { get; set; }
     
200. public string Name { get; set; }
     
201. public int Age { get; set; }
     
202. public DateTime CreateTime { get; set; }
     
203. }
     
204. #endregion
     
205. }

复制代码

这篇文章主要介绍了MongoDB入门教程之C#驱动操作实例,即C#中操作MongoDB数据的方法和代码示例,需要的朋友可以参考下
作为系列的最后一篇，得要说说C#驱动对mongodb的操作，目前驱动有两种：官方驱动和samus驱动，不过我个人还是喜欢后者，
因为提供了丰富的linq操作，相当方便。
官方驱动：https://github.com/mongodb/mongo-csharp-driver/downloads。下载后，还提供了一个酷似msdn的帮助文档。
samus驱动：https://github.com/samus/mongodb-csharp/downloads。
下面就具体看看samus驱动，https://github.com/samus/mongodb-csharp/blob/master/examples/Simple/Main.cs上面提供了
一个简单的demo，大体上看看我们就知道怎么玩了。
一： 实践
1：我们建立一个Person实体，MongoAlias特性表示取别名，这里的ID值将会覆盖掉数据库自动生成的_id。

1. 
   
2. #region 数据实体
   
3. /// <summary>
   
4. /// 数据实体
   
5. /// </summary>
   
6. public class Person
   
7. {
   
8. [MongoAlias("_id")]
   
9. public string ID { get; set; }
   
10. public string Name { get; set; }
    
11. public int Age { get; set; }
    
12. public DateTime CreateTime { get; set; }
    
13. }
    
14. #endregion

复制代码

2：初始化一些变量

1. 
   
2. string connectionString = string.Empty;
   
3. string databaseName = string.Empty;
   
4. string collectionName = string.Empty;
   
5. static MongodbHelper<T> mongodb;
   
6. #region 初始化操作
   
7. /// <summary>
   
8. /// 初始化操作
   
9. /// </summary>
   
10. public MongodbHelper()
    
11. {
    
12. connectionString = "Server=127.0.0.1:2222";
    
13. databaseName = "shopex";
    
14. collectionName = "person";
    
15. }
    
16. #endregion

复制代码

3：为了方便T的继承类使用linq功能，我们还需要映射一下。

1. 
   
2. #region 实现linq查询的映射配置
   
3. /// <summary>
   
4. /// 实现linq查询的映射配置
   
5. /// </summary>
   
6. public MongoConfiguration configuration
   
7. {
   
8. get
   
9. {
   
10. var config = new MongoConfigurationBuilder();
    
11. config.Mapping(mapping =>
    
12. {
    
13. mapping.DefaultProfile(profile =>
    
14. {
    
15. profile.SubClassesAre(t => t.IsSubclassOf(typeof(T)));
    
16. });
    
17. mapping.Map<T>();
    
18. mapping.Map<T>();
    
19. });
    
20. config.ConnectionString(connectionString);
    
21. return config.BuildConfiguration();
    
22. }
    
23. }
    
24. #endregion

复制代码

4：下面是一些基本的CURD的代码，跟写EF代码很类似，写起来好舒服。

1. 
   
2. #region 插入操作
   
3. /// <summary>
   
4. /// 插入操作
   
5. /// </summary>
   
6. /// <param name="person"></param>
   
7. /// <returns></returns>
   
8. public void Insert(T t)
   
9. {
   
10. using (Mongo mongo = new Mongo(configuration))
    
11. {
    
12. try
    
13. {
    
14. mongo.Connect();
    
15. var db = mongo.GetDatabase(databaseName);
    
16. var collection = db.GetCollection<T>(collectionName);
    
17. collection.Insert(t, true);
    
18. mongo.Disconnect();
    
19. }
    
20. catch (Exception)
    
21. {
    
22. mongo.Disconnect();
    
23. throw;
    
24. }
    
25. }
    
26. }
    
27. #endregion
    
28. #region 更新操作
    
29. /// <summary>
    
30. /// 更新操作
    
31. /// </summary>
    
32. /// <param name="person"></param>
    
33. /// <returns></returns>
    
34. public void Update(T t, Expression<Func<T, bool>> func)
    
35. {
    
36. using (Mongo mongo = new Mongo(configuration))
    
37. {
    
38. try
    
39. {
    
40. mongo.Connect();
    
41. var db = mongo.GetDatabase(databaseName);
    
42. var collection = db.GetCollection<T>(collectionName);
    
43. collection.Update<T>(t, func, true);
    
44. mongo.Disconnect();
    
45. }
    
46. catch (Exception)
    
47. {
    
48. mongo.Disconnect();
    
49. throw;
    
50. }
    
51. }
    
52. }
    
53. #endregion
    
54. #region 获取集合
    
55. /// <summary>
    
56. ///获取集合
    
57. /// </summary>
    
58. /// <param name="person"></param>
    
59. /// <returns></returns>
    
60. public List<T> List(int pageIndex, int pageSize, Expression<Func<T, bool>> func, out int pageCount)
    
61. {
    
62. pageCount = 0;
    
63. using (Mongo mongo = new Mongo(configuration))
    
64. {
    
65. try
    
66. {
    
67. mongo.Connect();
    
68. var db = mongo.GetDatabase(databaseName);
    
69. var collection = db.GetCollection<T>(collectionName);
    
70. pageCount = Convert.ToInt32(collection.Count());
    
71. var personList = collection.Linq().Where(func).Skip(pageSize * (pageIndex - 1))
    
72. .Take(pageSize).Select(i => i).ToList();
    
73. mongo.Disconnect();
    
74. return personList;
    
75. }
    
76. catch (Exception)
    
77. {
    
78. mongo.Disconnect();
    
79. throw;
    
80. }
    
81. }
    
82. }
    
83. #endregion
    
84. #region 读取单条记录
    
85. /// <summary>
    
86. ///读取单条记录
    
87. /// </summary>
    
88. /// <param name="person"></param>
    
89. /// <returns></returns>
    
90. public T Single(Expression<Func<T, bool>> func)
    
91. {
    
92. using (Mongo mongo = new Mongo(configuration))
    
93. {
    
94. try
    
95. {
    
96. mongo.Connect();
    
97. var db = mongo.GetDatabase(databaseName);
    
98. var collection = db.GetCollection<T>(collectionName);
    
99. var single = collection.Linq().FirstOrDefault(func);
    
100. mongo.Disconnect();
     
101. return single;
     
102. }
     
103. catch (Exception)
     
104. {
     
105. mongo.Disconnect();
     
106. throw;
     
107. }
     
108. }
     
109. }
     
110. #endregion
     
111. #region 删除操作
     
112. /// <summary>
     
113. /// 删除操作
     
114. /// </summary>
     
115. /// <param name="person"></param>
     
116. /// <returns></returns>
     
117. public void Delete(Expression<Func<T, bool>> func)
     
118. {
     
119. using (Mongo mongo = new Mongo(configuration))
     
120. {
     
121. try
     
122. {
     
123. mongo.Connect();
     
124. var db = mongo.GetDatabase(databaseName);
     
125. var collection = db.GetCollection<T>(collectionName);
     
126. //这个地方要注意，一定要加上T参数，否则会当作object类型处理
     
127. //导致删除失败
     
128. collection.Remove<T>(func);
     
129. mongo.Disconnect();
     
130. }
     
131. catch (Exception)
     
132. {
     
133. mongo.Disconnect();
     
134. throw;
     
135. }
     
136. }
     
137. }
     
138. #endregion

复制代码

5. 好，我们开一下2222端口，由于前前篇我已经把这个mongodb做成了服务，现在就直接连过去了，并做一下对Name的索引。
6. 一切准备妥当，我们做下基本的操作，比如这里我添加一千条数据，注意我开启的是安全模式，如果插入不成功，将会抛出异常。
<1> Add:

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. //插入1000条数据
   
6. for (int i = 0; i < 1000; i++)
   
7. {
   
8. helper.Insert(new Person()
   
9. {
   
10. ID = Guid.NewGuid().ToString(),
    
11. Name = "jack" + i,
    
12. Age = i,
    
13. CreateTime = DateTime.Now
    
14. });
    
15. }
    
16. Console.WriteLine("插入成功");
    
17. Console.Read();
    
18. }
    

复制代码

乍一看显示的数据以为有问题，为什么没有出现jack0或者jack999，不过find的一下后心情舒坦了。
<2> update: 这里就把jack941的名字改掉“mary”

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. //修改jack941改成mary
   
6. var single = helper.Single(i => i.Name == "jack941");
   
7. single.Name = "mary";
   
8. helper.Update(single, i => i.ID == single.ID);
   
9. Console.WriteLine("修改成功");
   
10. Console.Read();
    
11. }

复制代码

<3>Delete： 删除mary这条记录

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. //删除mary这个记录
   
6. helper.Delete(i => i.Name == "mary");
   
7. Console.WriteLine("删除成功");
   
8. Console.Read();
   
9. }

复制代码

<4> list操作： 这里我获取一下名字里面带9的人数列表

1. 
   
2. static void Main(string[] args)
   
3. {
   
4. MongodbHelper<Person> helper = new MongodbHelper<Person>();
   
5. int pagecount;
   
6. //获取名字里面带9的人数
   
7. var list = helper.List(1, 20, i => i.Name.Contains("9"), out pagecount);
   
8. Console.Read();
   
9. }

复制代码

总的运行代码

1. 
   
2. using System;
   
3. using System.Collections.Generic;
   
4. using System.Linq;
   
5. using System.Text;
   
6. using System.Configuration;
   
7. using System.Linq.Expressions;
   
8. using MongoDB.Configuration;
   
9. using MongoDB.Linq;
   
10. using MongoDB.Attributes;
    
11. 
    
12. namespace MongoDB.Test
    
13. {
    
14. public class MongodbHelper<T> where T : class
    
15. {
    
16. string connectionString = string.Empty;
    
17. string databaseName = string.Empty;
    
18. string collectionName = string.Empty;
    
19. static MongodbHelper<T> mongodb;
    
20. #region 初始化操作
    
21. /// <summary>
    
22. /// 初始化操作
    
23. /// </summary>
    
24. public MongodbHelper()
    
25. {
    
26. connectionString = "Server=127.0.0.1:2222";
    
27. databaseName = "shopex";
    
28. collectionName = "person";
    
29. }
    
30. #endregion
    
31. #region 实现linq查询的映射配置
    
32. /// <summary>
    
33. /// 实现linq查询的映射配置
    
34. /// </summary>
    
35. public MongoConfiguration configuration
    
36. {
    
37. get
    
38. {
    
39. var config = new MongoConfigurationBuilder();
    
40. config.Mapping(mapping =>
    
41. {
    
42. mapping.DefaultProfile(profile =>
    
43. {
    
44. profile.SubClassesAre(t => t.IsSubclassOf(typeof(T)));
    
45. });
    
46. mapping.Map<T>();
    
47. mapping.Map<T>();
    
48. });
    
49. config.ConnectionString(connectionString);
    
50. return config.BuildConfiguration();
    
51. }
    
52. }
    
53. #endregion
    
54. #region 插入操作
    
55. /// <summary>
    
56. /// 插入操作
    
57. /// </summary>
    
58. /// <param name="person"></param>
    
59. /// <returns></returns>
    
60. public void Insert(T t)
    
61. {
    
62. using (Mongo mongo = new Mongo(configuration))
    
63. {
    
64. try
    
65. {
    
66. mongo.Connect();
    
67. var db = mongo.GetDatabase(databaseName);
    
68. var collection = db.GetCollection<T>(collectionName);
    
69. collection.Insert(t, true);
    
70. mongo.Disconnect();
    
71. }
    
72. catch (Exception)
    
73. {
    
74. mongo.Disconnect();
    
75. throw;
    
76. }
    
77. }
    
78. }
    
79. #endregion
    
80. #region 更新操作
    
81. /// <summary>
    
82. /// 更新操作
    
83. /// </summary>
    
84. /// <param name="person"></param>
    
85. /// <returns></returns>
    
86. public void Update(T t, Expression<Func<T, bool>> func)
    
87. {
    
88. using (Mongo mongo = new Mongo(configuration))
    
89. {
    
90. try
    
91. {
    
92. mongo.Connect();
    
93. var db = mongo.GetDatabase(databaseName);
    
94. var collection = db.GetCollection<T>(collectionName);
    
95. collection.Update<T>(t, func, true);
    
96. mongo.Disconnect();
    
97. }
    
98. catch (Exception)
    
99. {
    
100. mongo.Disconnect();
     
101. throw;
     
102. }
     
103. }
     
104. }
     
105. #endregion
     
106. #region 获取集合
     
107. /// <summary>
     
108. ///获取集合
     
109. /// </summary>
     
110. /// <param name="person"></param>
     
111. /// <returns></returns>
     
112. public List<T> List(int pageIndex, int pageSize, Expression<Func<T, bool>> func, out int pageCount)
     
113. {
     
114. pageCount = 0;
     
115. using (Mongo mongo = new Mongo(configuration))
     
116. {
     
117. try
     
118. {
     
119. mongo.Connect();
     
120. var db = mongo.GetDatabase(databaseName);
     
121. var collection = db.GetCollection<T>(collectionName);
     
122. pageCount = Convert.ToInt32(collection.Count());
     
123. var personList = collection.Linq().Where(func).Skip(pageSize * (pageIndex - 1))
     
124. .Take(pageSize).Select(i => i).ToList();
     
125. mongo.Disconnect();
     
126. return personList;
     
127. }
     
128. catch (Exception)
     
129. {
     
130. mongo.Disconnect();
     
131. throw;
     
132. }
     
133. }
     
134. }
     
135. #endregion
     
136. #region 读取单条记录
     
137. /// <summary>
     
138. ///读取单条记录
     
139. /// </summary>
     
140. /// <param name="person"></param>
     
141. /// <returns></returns>
     
142. public T Single(Expression<Func<T, bool>> func)
     
143. {
     
144. using (Mongo mongo = new Mongo(configuration))
     
145. {
     
146. try
     
147. {
     
148. mongo.Connect();
     
149. var db = mongo.GetDatabase(databaseName);
     
150. var collection = db.GetCollection<T>(collectionName);
     
151. var single = collection.Linq().FirstOrDefault(func);
     
152. mongo.Disconnect();
     
153. return single;
     
154. }
     
155. catch (Exception)
     
156. {
     
157. mongo.Disconnect();
     
158. throw;
     
159. }
     
160. }
     
161. }
     
162. #endregion
     
163. #region 删除操作
     
164. /// <summary>
     
165. /// 删除操作
     
166. /// </summary>
     
167. /// <param name="person"></param>
     
168. /// <returns></returns>
     
169. public void Delete(Expression<Func<T, bool>> func)
     
170. {
     
171. using (Mongo mongo = new Mongo(configuration))
     
172. {
     
173. try
     
174. {
     
175. mongo.Connect();
     
176. var db = mongo.GetDatabase(databaseName);
     
177. var collection = db.GetCollection<T>(collectionName);
     
178. //这个地方要注意，一定要加上T参数，否则会当作object类型处理
     
179. //导致删除失败
     
180. collection.Remove<T>(func);
     
181. mongo.Disconnect();
     
182. }
     
183. catch (Exception)
     
184. {
     
185. mongo.Disconnect();
     
186. throw;
     
187. }
     
188. }
     
189. }
     
190. #endregion
     
191. }
     
192. #region 数据实体
     
193. /// <summary>
     
194. /// 数据实体
     
195. /// </summary>
     
196. public class Person
     
197. {
     
198. [MongoAlias("_id")]
     
199. public string ID { get; set; }
     
200. public string Name { get; set; }
     
201. public int Age { get; set; }
     
202. public DateTime CreateTime { get; set; }
     
203. }
     
204. #endregion
     
205. }

复制代码