因為MongoDb 跨平台，可以免費使用，讀寫效率高，集群搭建簡單，可以水平擴展等各種因素。
我決定研究一下Mongodb,在查看了相關文檔後發現它對C#的支持不錯，而且還有現成的C#的驅動，
新版的驅動還支持Linq，因為復雜的查詢可以交給Linq去實現。正因為官方的驅動很強大。
剛開始接觸時發現在大量的東西要去了解，為了能快速處理簡單的項目，我對官方驅動做了進一步封裝。項目中需要引入官方提供的dll,下載地址
https://github-cloud.s3.amazonaws.com/releases/699689/ea9bea12-819f-11e6-965b-d3b6bb718019.zip?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAISTNZFOVBIJMK3TQ%2F20161218%2Fus-east-1%2Fs3%2Faws4_request&X-Amz-Date=20161218T122012Z&X-Amz-Expires=300&X-Amz-Signature=c52d17292deec2a49eb30f53f4847fc168b82df42dfe69252429faad760e8c05&X-Amz-SignedHeaders=host&actor_id=0&response-content-disposition=attachment%3B%20filename%3DCSharpDriver-2.3.0.zip&response-content-type=application%2Foctet-stream
下載好後解壓到相應目錄，將裡面的dll引入到項目下（如紅框所示）
以下為我封裝的一些簡單的增刪改查操作
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading.Tasks;
6 using MongoDB.Driver;
7 using MongoDB.Bson;
8 using MongoDB.Bson.Serialization.Attributes;
9 using System.Linq.Expressions;
10
11 namespace Langu.DbHelper
12 {
13 /// <summary>
14 /// MongoDb 數據庫操作類
15 /// </summary>
16 public class MongoHelper<T> where T : BaseEntity
17 {
18 /// <summary>
19 /// 數據庫對象
20 /// </summary>
21 private IMongoDatabase database;
22 /// <summary>
23 /// 構造函數
24 /// </summary>
25 /// <param name="conString">連接字符串</param>
26 public MongoHelper(String conString)
27 {
28 var url = new MongoUrl(conString);
29 MongoClientSettings mcs = MongoClientSettings.FromUrl(url);
30 mcs.MaxConnectionLifeTime = TimeSpan.FromMilliseconds(1000);
31 var client = new MongoClient(mcs);
32 this.database = client.GetDatabase(url.DatabaseName);
33 }
34 /// <summary>
35 /// 創建集合對象
36 /// </summary>
37 /// <param name="collName">集合名稱</param>
38 ///<returns>集合對象</returns>
39 private IMongoCollection<T> GetColletion(String collName)
40 {
41 return database.GetCollection<T>(collName);
42 }
43
44 #region 增加
45 /// <summary>
46 /// 插入對象
47 /// </summary>
48 /// <param name="collName">集合名稱</param>
49 /// <param name="t">插入的對象</param>
50 public void Insert(String collName, T t)
51 {
52 var coll = GetColletion(collName);
53 coll.InsertOne(t);
54 }
55 /// <summary>
56 /// 批量插入
57 /// </summary>
58 /// <param name="collName">集合名稱</param>
59 /// <param name="ts">要插入的對象集合</param>
60 public void InsertBath(String collName, IEnumerable<T> ts)
61 {
62 var coll = GetColletion(collName);
63 coll.InsertMany(ts);
64 }
65 #endregion
66
67 #region 刪除
68 /// <summary>
69 /// 按BsonDocument條件刪除
70 /// </summary>
71 /// <param name="collName">集合名稱</param>
72 /// <param name="document">文檔</param>
73 /// <returns></returns>
74 public Int64 Delete(String collName, BsonDocument document)
75 {
76 var coll = GetColletion(collName);
77 var result = coll.DeleteOne(document);
78 return result.DeletedCount;
79 }
80 /// <summary>
81 /// 按json字符串刪除
82 /// </summary>
83 /// <param name="collName">集合名稱</param>
84 /// <param name="json">json字符串</param>
85 /// <returns></returns>
86 public Int64 Delete(String collName, String json)
87 {
88 var coll = GetColletion(collName);
89 var result = coll.DeleteOne(json);
90 return result.DeletedCount;
91 }
92 /// <summary>
93 /// 按條件表達式刪除
94 /// </summary>
95 /// <param name="collName">集合名稱</param>
96 /// <param name="predicate">條件表達式</param>
97 /// <returns></returns>
98 public Int64 Delete(String collName, Expression<Func<T, Boolean>> predicate)
99 {
100 var coll = GetColletion(collName);
101 var result = coll.DeleteOne(predicate);
102 return result.DeletedCount;
103 }
104 /// <summary>
105 /// 按檢索條件刪除
106 /// 建議用Builders<T>構建復雜的查詢條件
107 /// </summary>
108 /// <param name="collName">集合名稱</param>
109 /// <param name="filter">條件</param>
110 /// <returns></returns>
111 public Int64 Delete(String collName, FilterDefinition<T> filter)
112 {
113 var coll = GetColletion(collName);
114 var result = coll.DeleteOne(filter);
115 return result.DeletedCount;
116 }
117 #endregion
118
119 #region 修改
120 /// <summary>
121 /// 修改文檔
122 /// </summary>
123 /// <param name="collName">集合名稱</param>
124 /// <param name="filter">修改條件</param>
125 /// <param name="update">修改結果</param>
126 /// <param name="upsert">是否插入新文檔（filter條件滿足就更新，否則插入新文檔）</param>
127 /// <returns></returns>
128 public Int64 Update(String collName, Expression<Func<T, Boolean>> filter, UpdateDefinition<T> update, Boolean upsert = false)
129 {
130 var coll = GetColletion(collName);
131 var result = coll.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert });
132 return result.ModifiedCount;
133 }
134 /// <summary>
135 /// 用新對象替換新文檔
136 /// </summary>
137 /// <param name="collName">集合名稱</param>
138 /// <param name="filter">修改條件</param>
139 /// <param name="t">新對象</param>
140 /// <param name="upsert">是否插入新文檔（filter條件滿足就更新，否則插入新文檔）</param>
141 /// <returns>修改影響文檔數</returns>
142 public Int64 Update(String collName, Expression<Func<T, Boolean>> filter, T t, Boolean upsert = false)
143 {
144 var coll = GetColletion(collName);
145 BsonDocument document = t.ToBsonDocument<T>();
146 document.Remove("_id");
147 UpdateDocument update = new UpdateDocument("$set", document);
148 var result = coll.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert });
149 return result.ModifiedCount;
150 }
151 #endregion
152
153 /// <summary>
154 /// 查詢，復雜查詢直接用Linq處理
155 /// </summary>
156 /// <param name="collName">集合名稱</param>
157 /// <returns>要查詢的對象</returns>
158 public IQueryable<T> GetQueryable(String collName)
159 {
160 var coll = GetColletion(collName);
161 return coll.AsQueryable<T>();
162 }
163 #region 查詢
164 #endregion
165 }
166
167 /// <summary>
168 /// 實體基類，方便生成_id
169 /// </summary>
170 public class BaseEntity
171 {
172 [BsonRepresentation(BsonType.ObjectId)]
173 public String Id { get; set; }
174 /// <summary>
175 /// 給對象初值
176 /// </summary>
177 public BaseEntity()
178 {
179 this.Id = ObjectId.GenerateNewId().ToString();
180 }
181 }
182 }
做了一個簡單的控制台調用（前提是mongodb服務已經打開,安裝Mongodb以及打開部分有時間會一並發上來）
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading.Tasks;
6 using Langu.DbHelper;
7 using System.Threading;
8 using System.Linq.Expressions;
9 using MongoDB.Driver;
10
11 namespace Client
12 {
13 class Program
14 {
15 static void Main(string[] args)
16 {
17 //連接字符串 127.0.0.1 服務器IP 27100 mongodb服務端口號 mydb 數據庫名稱
18 String conString = "mongodb://127.0.0.1:27100/mydb";
19 //實例化MongoHelper對象（泛型版本），構造函數要求傳入連接字符串
20 MongoHelper<User> mongoHelper = new MongoHelper<User>(conString);
21 //查詢集合 user中有多少數據量
22 var cnt = mongoHelper.GetQueryable("user").Count();
23 Console.WriteLine(cnt);
24 Console.ReadKey();
25 }
26 }
27
28 internal class User : BaseEntity
29 {
30 public int Age { get; set; }
31 public String Name { get; set; }
32 }
33 }
