? ? ? 最近兩天在學(xué)習(xí)MongoDB，強(qiáng)大的文檔數(shù)據(jù)庫。給我最大的感覺就是相比于SQL或者M(jìn)SQ等傳統(tǒng)的關(guān)系型數(shù)據(jù)庫，在使用和配置上真的是簡化了很多。無論是在集群的配置還是故障轉(zhuǎn)移方面，都省去了許多繁瑣的步驟，但最重要是的什么呢？是效率，它的出現(xiàn)解決了傳統(tǒng)關(guān)系型數(shù)據(jù)庫的IO瓶頸，極大的提高了工作效率，適合海量數(shù)據(jù)的查詢。

? ? ? 當(dāng)然，這些老生常談的話可能你已經(jīng)聽了很多，耳朵都磨出了繭子，廢話少說，整點(diǎn)干貨。

? ? ? 博客園里關(guān)于MongoDB的文章搜一下會(huì)出來很多，但是大多都是關(guān)于如果安裝或者復(fù)制集、故障轉(zhuǎn)移等，對于已經(jīng)學(xué)會(huì)安裝但是希望使用的同學(xué)會(huì)覺得無從下手，博主感同身受，所以在這里分享一下在.NET中如何使用MongoDB來進(jìn)行基本的CURD，同時(shí)自己寫了一個(gè)基本的通用幫助類，如果覺得有需要的同學(xué)可以拿去使用，覺得有用的可以給個(gè)贊，真的，給贊比給錢讓我更加歡樂！！！

?

1.兩種常用的操作介質(zhì)

? ? ? 在.NET中對MongoDB常用的操作介質(zhì)有兩種，分別是BsonDocument對象模型以及自定義的實(shí)體類型。

（1）BsonDocument

? ? ? MongoDB是文檔型數(shù)據(jù)庫，在MongoDB的Collection中，每個(gè)文檔可以看做是一個(gè)Bson（Binary Json）對象，所以在驅(qū)動(dòng)中有一個(gè)BsonDocument類型，它的本質(zhì)name/value的鍵值對集合，可以通過下面方式生成一個(gè)BsonDocument的文檔，并通過Add方法添加鍵值對，通過這種方式生成的BsonDocumen對象可以直接插入Collection。

BsonDocument student1 = new BsonDocument(); student1.Add("sid", 10); student1.Add("name", "Will10"); student1.Add("gender", "Male"); student1.Add("age", 26);

（2）自定義實(shí)體類型

關(guān)于自定義實(shí)體類型可能我們每天都在使用，沒有什么需要將的，只有一點(diǎn)，如果你想通過自定義的實(shí)體類型操作MongoDB中的數(shù)據(jù)集合，那么你的實(shí)體中的字段名要與MongoDB中的字段名保持一致（如_id與ID這樣就不一致，則會(huì)報(bào)錯(cuò)），而且還需要有_id字段。

?

上面兩種方式都可以使用，而且各有好處，通過自定義類型的方式，可以使得collection中的文檔有比較統(tǒng)一的模式；使用BsonDocument方式則可以支持更多的文檔模式，也就是說如果一個(gè)collection中的文檔擁有各種各樣的模式，那么BsonDocument方式就會(huì)更靈活。

?

2.連接數(shù)據(jù)庫

供.NET使用的的MongoDB驅(qū)動(dòng)不止一個(gè)，官方也有推薦的驅(qū)動(dòng)，這里博主選用的是官方推薦的驅(qū)動(dòng)mongocsharpdriver，可以通過NuGet下載安裝。

數(shù)據(jù)庫的連接代碼如下：

public static void GetColloection(string IP, string Port, string Database, string CollectionName) {string connection = string.Format("mongodb://{0}:{1}", Database, Port);MongoClient client = new MongoClient(connection)var server = client.GetServer();collection = server.GetDatabase(Database).GetCollection(CollectionName); }

這里博主自己封裝了一個(gè)連接方法，這個(gè)連接方法并不好，不夠靈活，切換數(shù)據(jù)集合的時(shí)候還要重新輸入一遍IP和Port，大家可以自己封裝適合自己使用的。

?

3.查詢

（1）查詢集合中所有的數(shù)據(jù)，并返回List集合：

public static List<T> GetList<T>() {return collection.FindAllAs<T>().ToList(); }

?

（2）根據(jù)Id查詢集合中對應(yīng)的數(shù)據(jù)，返回?cái)?shù)據(jù)實(shí)體：（你的VS中需要有對應(yīng)的實(shí)體model）

public static T GetById<T>(int Id) {var query = Query.EQ("_id", Id);return collection.FindOneAs<T>(query); }

這里使用了Query Builder的查詢方式，相比QueryDocument（這里沒有使用）這是一種更簡潔的查詢方式，EQ的意思表示“==”，其它還有GT（>）等。當(dāng)通過這種方式查詢的時(shí)候，我們需要使用driver中的builder來生成query。所以，要引用下面using語句：

using MongoDB.Driver.Builders;

通過下面的語句，可以查詢年齡大于20的學(xué)生：

var query = Query.GT("age", 20);foreach (var student in collection.Find(query)){Console.WriteLine(student);}

（3）根據(jù)字段查詢對應(yīng)的數(shù)據(jù)實(shí)體

很多時(shí)候我們會(huì)根據(jù)Id查詢數(shù)據(jù)，但是有些情況下我們可能會(huì)用到其它的數(shù)據(jù)來查詢，這里封裝了一個(gè)方法：

public static List<T> GetValueByKey<T>(string key, string value) {var query = Query.EQ(key, value);return collection.FindAs<T>(query).ToList(); }

（4）Linq查詢

在driver的1.8 release之后，官方驅(qū)動(dòng)就可以支持LINQ操作了。我們只需要通過下面的using語句，就可以支持LINQ的方式進(jìn)行查詢了。

using MongoDB.Driver.Linq;

所以，可以查詢年齡大于20的學(xué)生，也可以通過下面方式實(shí)現(xiàn)：

var linquery = from e in collection.AsQueryable<Student>()where e.age > 20select e;var linquery1 = collection.AsQueryable<Student>().Where(e => e.age > 20);

?

4.新增

(1)常用的有Insert方法，它有5個(gè)重載，可以根據(jù)實(shí)際情況選取使用，這里使用它的泛型方法Insert<T>(T document)：

public static void Insert<T>(T model) {try{collection.Insert(model);}catch (Exception ex){throw new Exception(ex.Message);} }

?

(2)新增實(shí)體集合

public static void Insert<T>(List<T> list) {try{foreach (var model in list){collection.Insert(model);}}catch (Exception ex){throw new Exception(ex.Message);} }

?

5.修改

修改的方式有兩種，分別是Save和Update，這里沒有進(jìn)行方法封裝，給出示例。

（1）Save

static void Save(MongoCollection collection) {var query = Query.EQ("_id", 9);var model = collection.FindOneAs<goods>(query);if (model != null){model.title = "修改測試";collection.Save(model);} }

?

（2）Update

static void Update(MongoCollection collection) {var query = Query.EQ("_id", 8);var update = Update<goods>.Set(x=>x.title, "Update修改測試");collection.Update(query, update); }

?

6.刪除

刪除就比較簡單了，給出示例和封裝的方法：

(1)示例

static void Remove(MongoCollection collection) {var query = Query.EQ("_id", 11);collection.Remove(query); }

（2）封裝的方法

public static void Remove(IMongoQuery query) {try{collection.Remove(query);}catch (Exception ex){throw new Exception(ex.Message);} }

?

? ? ? 好了，基本CURD到這里就完成了，希望前面講的東西能夠幫助到你，說實(shí)話，MongoDB真的很強(qiáng)大，但是呢，剛開始學(xué)習(xí)肯定會(huì)有一個(gè)懵逼的過程，博主現(xiàn)在還處于懵逼的過程，一邊分享一邊幫自己梳理。下一篇MongoDB會(huì)寫一下復(fù)制集以及分片，但不會(huì)寫怎么操作，畢竟園子里一搜一大把（主要是博主自己學(xué)的也不咋樣），會(huì)寫一下在使用的過程中的出錯(cuò)點(diǎn)以及其中的原理，比如Master宕掉以后是如何從Slave中選舉出一個(gè)新的Master以及Slave的種類和作用。

?

?

轉(zhuǎn)載于:https://www.cnblogs.com/weiBlog/p/6307021.html

總結(jié)

以上是生活随笔為你收集整理的MongoDB 基础教程CURD帮助类的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。