在.Net中如何使用MongoDB的實(shí)例-創(chuàng)新互聯(lián)

這篇文章將為大家詳細(xì)講解有關(guān)在.Net中如何使用MongoDB的實(shí)例，小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司是一家服務(wù)多年做網(wǎng)站建設(shè)策劃設(shè)計(jì)制作的公司,為廣大用戶提供了成都網(wǎng)站制作、成都做網(wǎng)站，成都網(wǎng)站設(shè)計(jì)，一元廣告，成都做網(wǎng)站選創(chuàng)新互聯(lián)，貼合企業(yè)需求，高性價(jià)比，滿足客戶不同層次的需求一站式服務(wù)歡迎致電。

什么是MongoDB

MongoDB是基于文檔的存儲(chǔ)的（而非表），是一個(gè)介于關(guān)系數(shù)據(jù)庫(kù)和非關(guān)系數(shù)據(jù)庫(kù)之間的產(chǎn)品，是非關(guān)系數(shù)據(jù)庫(kù)當(dāng)中功能最豐富，最像關(guān)系數(shù)據(jù)庫(kù)的。他支持的數(shù)據(jù)結(jié)構(gòu)非常松散，是類似json的bson格式，因此可以存儲(chǔ)比較復(fù)雜的數(shù)據(jù)類型。Mongo大的特點(diǎn)是他支持的查詢語(yǔ)言非常強(qiáng)大，其語(yǔ)法有點(diǎn)類似于面向?qū)ο蟮牟樵冋Z(yǔ)言，幾乎可以實(shí)現(xiàn)類似關(guān)系數(shù)據(jù)庫(kù)單表查詢的絕大部分功能，而且還支持對(duì)數(shù)據(jù)建立索引。Mongo主要解決的是海量數(shù)據(jù)的訪問(wèn)效率問(wèn)題。因?yàn)镸ongo主要是支持海量數(shù)據(jù)存儲(chǔ)的，所以Mongo還自帶了一個(gè)出色的分布式文件系統(tǒng)GridFS，可以支持海量的數(shù)據(jù)存儲(chǔ)。由于Mongo可以支持復(fù)雜的數(shù)據(jù)結(jié)構(gòu)，而且?guī)в袕?qiáng)大的數(shù)據(jù)查詢功能，因此非常受到歡迎。

BSON是MongoDB的數(shù)據(jù)存儲(chǔ)格式。大家對(duì)于JSON比較熟悉，但是什么是BSON呢BSON基于JSON格式，選擇JSON進(jìn)行改造的原因主要是JSON的通用性及JSON的schemaless的特性。

BSON具有如下特點(diǎn)

1.更快的遍歷速度

　　對(duì)JSON格式來(lái)說(shuō)，太大的JSON結(jié)構(gòu)會(huì)導(dǎo)致數(shù)據(jù)遍歷非常慢。在JSON中，要跳過(guò)一個(gè)文檔進(jìn)行數(shù)據(jù)讀取，需要對(duì)此文檔進(jìn)行掃描才行，需要進(jìn)行麻煩數(shù)據(jù)結(jié)構(gòu)匹配，比如括號(hào)的匹配，而BSON對(duì)JSON的一大改進(jìn)就是，它會(huì)將JSON的每一個(gè)元素的長(zhǎng)度存在元素的頭部，這樣你只需要讀取到元素長(zhǎng)度就能直接seek到指定的點(diǎn)上進(jìn)行讀取了。

2.操作更簡(jiǎn)易

　　對(duì)JSON來(lái)說(shuō)，數(shù)據(jù)存儲(chǔ)是無(wú)類型的，比如你要修改基本一個(gè)值，從9到10，由于從一個(gè)字符變成了兩個(gè)，所以可能其后面的所有內(nèi)容都需要往后移一位才可以。而使用BSON，你可以指定這個(gè)列為數(shù)字列，那么無(wú)論數(shù)字從9長(zhǎng)到10還是100，我們都只是在存儲(chǔ)數(shù)字的那一位上進(jìn)行修改，不會(huì)導(dǎo)致數(shù)據(jù)總長(zhǎng)變大。當(dāng)然，在MongoDB中，如果數(shù)字從整形增大到長(zhǎng)整型，還是會(huì)導(dǎo)致數(shù)據(jù)總長(zhǎng)變大的。

3.增加了額外的數(shù)據(jù)類型

　　JSON是一個(gè)很方便的數(shù)據(jù)交換格式，但是其類型比較有限。BSON在其基礎(chǔ)上增加了“byte array”數(shù)據(jù)類型。這使得二進(jìn)制的存儲(chǔ)不再需要先base64轉(zhuǎn)換后再存成JSON。大大減少了計(jì)算開(kāi)銷和數(shù)據(jù)大小。當(dāng)然，在有的時(shí)候，BSON相對(duì)JSON來(lái)說(shuō)也并沒(méi)有空間上的優(yōu)勢(shì)，因?yàn)橛辛祟愋透拍睢?/p>

MongoDB windows下安裝

MongoDB的安裝很簡(jiǎn)單，設(shè)置好安裝路徑后，一直Next直到安裝結(jié)束，大的坑就是MongoDB服務(wù)的安裝，下面具體說(shuō)下MongoDB安裝之后的一些配置操作

1.在根目錄下創(chuàng)建數(shù)據(jù)庫(kù)路徑（data目錄）、日志路徑（logs目錄）、日志文件（mongo.log文件）、配置路徑（conf目錄）我的安裝路徑是：D:\Program Files\mongodb

2.在conf目錄下創(chuàng)建配置文件mongo.conf，文件內(nèi)容如下：

logpath=D:\Program Files\mongodb\logs\mongodb.log #日志輸出文件路徑

logappend=true #錯(cuò)誤日志采用追加模式，配置這個(gè)選項(xiàng)后mongodb的日志會(huì)追加到現(xiàn)有的日志文件，而不是從新創(chuàng)建一個(gè)新文件

journal=true #啟用日志文件，默認(rèn)啟用

quiet=true #這個(gè)選項(xiàng)可以過(guò)濾掉一些無(wú)用的日志信息，若需要調(diào)試使用請(qǐng)?jiān)O(shè)置為false

port=27017 #端口號(hào) 默認(rèn)為27017

auth=true #啟用驗(yàn)證 需要用戶名密碼

配置完成以上2個(gè)步驟就可以啟動(dòng)MongoDB了

運(yùn)行CMD 輸入命令 (注意 mongod的路徑)

mongod --config " D:\Program Files\mongodb\data \conf\mongo.conf"

3.創(chuàng)建并啟動(dòng)MongoDB服務(wù)

如果每次都按照步驟三那樣操作，豈不是相當(dāng)麻煩，按照如下命令來(lái)創(chuàng)建并啟動(dòng)MongoDB服務(wù)，就可以通過(guò)windows服務(wù)來(lái)管理MongoDB的啟動(dòng)和關(guān)閉了

mongod --config " D:\Program Files\mongodb\data \conf\mongo.conf" --install --serviceName "MongoDB"

net start MongoDB

測(cè)試是否成功可以在瀏覽器中輸入http://localhost:27017/如果出現(xiàn)下圖表示服務(wù)安裝成功

在.Net中如何使用MongoDB的實(shí)例

如果需要卸載MongoDB服務(wù) 在CMD 中運(yùn)行

mongod.exe --remove --serviceName "MongoDB"

前期準(zhǔn)備工作完成了，就可以開(kāi)始擼代碼了

如何在.net 中使用MongoDB

首先在項(xiàng)目中引入 MongoDB.Bson.dll，MongoDB.Driver.dll,MongoDB.Driver.Core.dll 我使用的是2.0版本的現(xiàn)在好多文章都是介紹使用1+版本的這也是我寫此文的目的引入驅(qū)動(dòng)DLL后，就可以開(kāi)始擼代碼了

部分代碼如下

private static MongoClient client;

private static IMongoDatabase database;

//本地配置

private const string MongoDBConnectionStr = "mongodb://localhost";

//數(shù)據(jù)庫(kù)名稱

private static string DefaultDataBaseName = "Test";

 

 

public MongoDBHelper()

{

 GetConnection(DefaultDataBaseName);

}

 

/// <summary>

/// 構(gòu)造函數(shù) 指定數(shù)據(jù)庫(kù)

/// </summary>

/// <param name="dataBaseName"></param>

public MongoDBHelper(string dataBaseName)

{

 GetConnection(dataBaseName);

}

 
private static void GetConnection(string dataBaseName)

{

 client = new MongoClient(MongoDBConnectionStr);

 database = client.GetDatabase(dataBaseName);

}

/// <summary>

/// 異步插入一條數(shù)據(jù)，手動(dòng)輸入collection name

/// </summary>

public Task InsertAsync<T>(string collectionName, T obj)

{
 if (database == null)

 {

  throw new Exception("沒(méi)有指定數(shù)據(jù)庫(kù)");

 }

 var collection = database.GetCollection<T>(collectionName);

 return collection.InsertOneAsync(obj);

}

 

/// <summary>

/// 異步插入一條數(shù)據(jù)，采用類型T的完全限定名作為collection name

/// </summary>

public Task InsertAsync<T>(T obj)

{

 return InsertAsync(typeof(T).FullName, obj);

}

 
/// <summary>

/// 異步插入多條數(shù)據(jù)，手動(dòng)輸入collection name

/// </summary>

public Task BatchInsertAsync<T>(string collectionName, IEnumerable<T> objs)

{

 if (database == null)

 {

  throw new Exception("沒(méi)有指定數(shù)據(jù)庫(kù)");

 }

 if (objs == null)

 {

  throw new ArgumentException();

 }

 var collection = database.GetCollection<T>(collectionName);

 return collection.InsertManyAsync(objs);

}

 

/// <summary>

/// 異步插入多條數(shù)據(jù)，采用類型T的完全限定名作為collection name

/// </summary>

public Task BatchInsertAsync<T>(IEnumerable<T> objs)

{

 return BatchInsertAsync(typeof(T).FullName, objs);

}

 

/// <summary>

/// 插入一條數(shù)據(jù)

/// </summary>

public void Insert<T>(T obj)

{

 InsertAsync(obj).Wait();

}

 

/// <summary>

/// 插入多條數(shù)據(jù)

/// </summary>

public void Insert<T>(IEnumerable<T> objs)

{

 BatchInsertAsync(objs).Wait();

}

/// <summary>

/// MongoDB C# Driver的Find方法，返回IFindFluent。手動(dòng)輸入collection name

/// </summary>

public IFindFluent<T, T> Find<T>(string collectionName, FilterDefinition<T> filter, FindOptions options = null)

{

 if (database == null)

 {
  throw new Exception("沒(méi)有指定數(shù)據(jù)庫(kù)");

 }
 var collection = database.GetCollection<T>(collectionName);

 return collection.Find(filter, options);

}

/// <summary>

/// MongoDB C# Driver的Find方法，返回IFindFluent。采用類型T的完全限定名作為collection name

/// </summary>

public IFindFluent<T, T> Find<T>(FilterDefinition<T> filter, FindOptions options = null)

{

 return Find(typeof(T).FullName, filter, options);

}
/// <summary>

/// 取符合條件的數(shù)據(jù) sort中多個(gè)排序條件逗號(hào)分隔，默認(rèn)asc

/// </summary>

public List<T> Get<T>(Expression<Func<T, bool>> condition, int skip, int limit, string sort)

{

 return Get(new List<Expression<Func<T, bool>>> { condition }, skip, limit, sort);

}

public List<T> Get<T>(Expression<Func<T, bool>> condition)

{
 return Get(condition, 0, 0, null);

}

/// <summary>

/// 取符合條件的數(shù)據(jù) sort中多個(gè)排序條件逗號(hào)分隔，默認(rèn)asc

/// </summary>

public List<T> Get<T>(List<Expression<Func<T, bool>>> conditions, int skip, int limit, string sort)

{

 if (conditions == null || conditions.Count == 0)

 {

  conditions = new List<Expression<Func<T, bool>>> { x => true };

 }

 var builder = Builders<T>.Filter;

 var filter = builder.And(conditions.Select(x => builder.Where(x)));

 var ret = new List<T>();

 try

 {

  List<SortDefinition<T>> sortDefList = new List<SortDefinition<T>>();

  if (sort != null)

  {

   var sortList = sort.Split(',');

   for (var i = 0; i < sortList.Length; i++)

   {
    var sl = Regex.Replace(sortList[i].Trim(), @"\s+", " ").Split(' ');

    if (sl.Length == 1 || (sl.Length >= 2 && sl[1].ToLower() == "asc"))

    {

     sortDefList.Add(Builders<T>.Sort.Ascending(sl[0]));

    }

    else if (sl.Length >= 2 && sl[1].ToLower() == "desc")

    {

     sortDefList.Add(Builders<T>.Sort.Descending(sl[0]));
    }

   }
  }

  var sortDef = Builders<T>.Sort.Combine(sortDefList);

  ret = Find(filter).Sort(sortDef).Skip(skip).Limit(limit).ToListAsync().Result;

 }

 catch (Exception e)

 {

  //異常處理

 }

 return ret;

}

public List<T> Get<T>(List<Expression<Func<T, bool>>> conditions)

{

 return Get(conditions, 0, 0, null);

}

示例代碼中只實(shí)現(xiàn)了插入和查詢功能，后續(xù)會(huì)將完整代碼上傳

關(guān)于在.Net中如何使用MongoDB的實(shí)例就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

文章題目：在.Net中如何使用MongoDB的實(shí)例-創(chuàng)新互聯(lián)
轉(zhuǎn)載來(lái)源：http://muchs.cn/article12/idhdc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供商城網(wǎng)站、做網(wǎng)站、網(wǎng)站導(dǎo)航、用戶體驗(yàn)、網(wǎng)站建設(shè)、建站公司

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容