日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

MongoDB 基础教程CURD帮助类

發布時間:2024/10/12 编程问答 44 豆豆
生活随笔 收集整理的這篇文章主要介紹了 MongoDB 基础教程CURD帮助类 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

? ? ? 最近兩天在學習MongoDB,強大的文檔數據庫。給我最大的感覺就是相比于SQL或者MSQ等傳統的關系型數據庫,在使用和配置上真的是簡化了很多。無論是在集群的配置還是故障轉移方面,都省去了許多繁瑣的步驟,但最重要是的什么呢?是效率,它的出現解決了傳統關系型數據庫的IO瓶頸,極大的提高了工作效率,適合海量數據的查詢。

? ? ? 當然,這些老生常談的話可能你已經聽了很多,耳朵都磨出了繭子,廢話少說,整點干貨。

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

?

1.兩種常用的操作介質

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

(1)BsonDocument

? ? ? MongoDB是文檔型數據庫,在MongoDB的Collection中,每個文檔可以看做是一個Bson(Binary Json)對象,所以在驅動中有一個BsonDocument類型,它的本質name/value的鍵值對集合,可以通過下面方式生成一個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)自定義實體類型

關于自定義實體類型可能我們每天都在使用,沒有什么需要將的,只有一點,如果你想通過自定義的實體類型操作MongoDB中的數據集合,那么你的實體中的字段名要與MongoDB中的字段名保持一致(如_id與ID這樣就不一致,則會報錯),而且還需要有_id字段。

?

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

?

2.連接數據庫

供.NET使用的的MongoDB驅動不止一個,官方也有推薦的驅動,這里博主選用的是官方推薦的驅動mongocsharpdriver,可以通過NuGet下載安裝。

數據庫的連接代碼如下:

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); }

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

?

3.查詢

(1)查詢集合中所有的數據,并返回List集合:

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

?

(2)根據Id查詢集合中對應的數據,返回數據實體:(你的VS中需要有對應的實體model)

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

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

using MongoDB.Driver.Builders;

通過下面的語句,可以查詢年齡大于20的學生:

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

(3)根據字段查詢對應的數據實體

很多時候我們會根據Id查詢數據,但是有些情況下我們可能會用到其它的數據來查詢,這里封裝了一個方法:

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之后,官方驅動就可以支持LINQ操作了。我們只需要通過下面的using語句,就可以支持LINQ的方式進行查詢了。

using MongoDB.Driver.Linq;

所以,可以查詢年齡大于20的學生,也可以通過下面方式實現:

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個重載,可以根據實際情況選取使用,這里使用它的泛型方法Insert<T>(T document):

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

?

(2)新增實體集合

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,這里沒有進行方法封裝,給出示例。

(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到這里就完成了,希望前面講的東西能夠幫助到你,說實話,MongoDB真的很強大,但是呢,剛開始學習肯定會有一個懵逼的過程,博主現在還處于懵逼的過程,一邊分享一邊幫自己梳理。下一篇MongoDB會寫一下復制集以及分片,但不會寫怎么操作,畢竟園子里一搜一大把(主要是博主自己學的也不咋樣),會寫一下在使用的過程中的出錯點以及其中的原理,比如Master宕掉以后是如何從Slave中選舉出一個新的Master以及Slave的種類和作用。

?

?

轉載于:https://www.cnblogs.com/weiBlog/p/6307021.html

總結

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

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。