C# + MongoDB 簡易型函式庫

    MongoDB的操作語法有別於實體資料庫，雖然支援LINQ，但新增/刪除/修改等方式仍然要以MongoDB Driver 的語法為主，所以不熟悉MongoDB的朋友們超級的痛苦，所以自製簡易版的函式庫，供大家參考囉~ 也歡迎大家多多交流。

public class MongoDBComponent { string _connString; MongoClient _client; IMongoDatabase _server; public MongoDBComponent() {   try   {     _connString = "mongodb://localhost:27017"; //未來要改為設定檔的方式，目前暫時以本機端的mongoDB為測試     _client = new MongoClient(_connString);     _server = _client.GetDatabase("mydb");   }   catch (Exception ex)   {     throw new Exception(ex.Message);   }  } }

PS:注意事項

作者以本機端的MongoDB為測試機，記得要改_connString的設定值喔，另外要改為讀取設定值比較好維護 … 當然前提要安裝mongoDB Driver for c#

一、新增

public bool Add<T>(string tableName, T value ) {   try   {     string jsonString = Newtonsoft.Json.JsonConvert.SerializeObject(value);     BsonDocument document= BsonSerializer.Deserialize<BsonDocument>(jsonString);     var collection = _server.GetCollection<BsonDocument>(tableName);     collection.InsertOne(document);     return true;   }   catch (Exception ex)   {      throw new Exception(ex.Message);    } }

MongoDB是支援JSON格式，所有的物件經過JSON格式化後成為字串格式，才經由BsonDocument 轉成物件後，就可以傳入資料給MongoDB

二、修改

public bool Update<T>(string tableName,string searchKey, object searchValue, T value ) { try   {    var collection = _server.GetCollection<BsonDocument>(tableName);    var filter = Builders<BsonDocument>.Filter.Eq(searchKey, searchValue);    var atts = value.GetType().GetProperties();    //取得所有元素    string attributeName = "";    Type typeObj;    PropertyInfo properInfo;    object attributeValue;    for (int i = 0; i < atts.Length - 1; i++)    {     attributeName = atts[i].Name.ToString();     typeObj = value.GetType();     properInfo = typeObj.GetProperty(attributeName);     attributeValue = properInfo.GetValue(value);     if (attributeValue == null || attributeName== searchKey)     {         continue;     }     var update = Builders<BsonDocument>.Update.Set(attributeName, attributeValue);     var result = collection.UpdateOne(filter, update);     }     return true;   }   catch (Exception ex)   {     throw new Exception(ex.Message);   } }

MongoDB更新的方式要呼.update.set(''欄位名稱'',更新值), 但如果有多筆欄位值更新時，就.update.set(''欄位名稱1'',更新值).set(''欄位名稱2'',更新值) 一直串的set 串接在一起，但是想改為共用的原件，就只好用笨方法，找到物件的所有屬性後，逐一跑迴圈執行Update.Set 每個欄位就執行一次Update , 如果各位有更好的方法歡迎提供…

三、刪除

public bool Delete<T>(string tableName, string searchKey, object searchValue) {   try   {       var collection = _server.GetCollection<T>(tableName);       var filter = Builders<T>.Filter.Eq(searchKey, searchValue);       var result = collection.DeleteOne(filter);       return true;   }   catch (Exception ex)   {       throw new Exception(ex.Message);   } }

刪除資料時，要先查詢出要刪除的那筆資料，所以呼叫Filter.Eq 找到那筆資料後，再呼叫DeleteOne ，如果說要刪除多筆時，MongoDB 有另外的函式呼叫多筆刪除喔，可別傻傻的一直呼叫DeleteOne, 這邊就不再做介紹，請有興趣的客倌去goole吧!

四、查詢資料

public IEnumerable<T> FindMany<T>(string tableName,Expression<Func<T,bool>>whereConditions) {   try   {     var collection = _server.GetCollection<T>(tableName).AsQueryable<T>();     var result= collection.Where(whereConditions).AsQueryable();     return result;   }   catch (Exception ex)   {     throw new Exception(ex.Message);   } }

查詢資料時為了可以自訂查詢條件，所以用 Expression<Func<T,bool>>whereConditions，允許傳入linq的lamda 查詢條件，更具彈性，並將MongoDB的查詢資料列直接轉成Ienumerable<T>

五、練習 MongoDBComponent

public class Member :IEntityDB<Member> { [BsonId] public ObjectId _id { get; set; } public string Account { get; set; } public string IdentityNumber { get; set; } public string Password { get; set; } public string Name { get; set; } public string Mobile { get; set; } public string Tel { get; set; } public string Address { get; set; } public string Email { get; set; } public DateTime CreateDate { get; set; } private MongoDBComponent _MongoDBEntity = new MongoDBComponent(); public bool Add(Member entityMember) {     return _MongoDBEntity.Add<Member>("Member", entityMember); } public bool Delete(Member entityMember) {     return _MongoDBEntity.Delete<Member>("Member", "_id", entityMember._id); } public bool Update(Member entityMember) {     return _MongoDBEntity.Update<Member>("Member", "_id", entityMember._id, entityMember); } public Member FindOne(Member entityMember) {     return _MongoDBEntity.FindMany<Member>("Member", q => q._id == entityMember._id).FirstOrDefault(); } public IEnumerable<Member> FindMany(Expression<Func<Member, bool>> whereConditions) {     return _MongoDBEntity.FindMany<Member>("Member", whereConditions);  } }

這樣c#就能保持使用entity Framework的習慣和彈性，具有基本新增/刪除/修改/查詢，如果有需要擴充其他方式，還請各位自已修改囉!