黑马程序员技术交流社区

标题: MongoDB入门教程之C#驱动操作实例 [打印本页]
作者: 陈君    时间: 2014-9-10 19:31
标题: MongoDB入门教程之C#驱动操作实例
这篇文章主要介绍了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。

  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：初始化一些变量

  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功能，我们还需要映射一下。

  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代码很类似，写起来好舒服。

  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:

  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”

  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这条记录

  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的人数列表

  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. }
复制代码

总的运行代码

  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;

  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. }
复制代码







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2