因為MongoDb 跨平臺，可以免費使用，讀寫效率高，集群搭建簡單，可以水平擴展等各種因素。 我決定研究一下Mongodb,在查看了相關文檔後發現它對C#的支持不錯，而且還有現成的C#的驅動， 新版的驅動還支持Linq，因為複雜的查詢可以交給Linq去實現。正因為官方的驅動很強大。 剛開始接觸時發現 ...
因為MongoDb 跨平臺，可以免費使用，讀寫效率高，集群搭建簡單，可以水平擴展等各種因素。
我決定研究一下Mongodb,在查看了相關文檔後發現它對C#的支持不錯，而且還有現成的C#的驅動，
新版的驅動還支持Linq，因為複雜的查詢可以交給Linq去實現。正因為官方的驅動很強大。
剛開始接觸時發現在大量的東西要去瞭解，為了能快速處理簡單的項目，我對官方驅動做了進一步封裝。項目中需要引入官方提供的dll,下載地址
下載好後解壓到相應目錄，將裡面的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 }
