asp.netcore集成MongoDB有哪些步驟

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)asp.net core集成MongoDB有哪些步驟，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

專注于為中小企業(yè)提供成都網(wǎng)站建設(shè)、網(wǎng)站制作服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)屏邊免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了近千家企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

一、前言及MongoDB的介紹

最近在整合自己的框架，順便把MongoDBD的最簡單CRUD重構(gòu)一下作為組件化集成到asp.net core項(xiàng)目中，當(dāng)然此篇文章中沒有講解mongodb的集群部署，等有機(jī)會(huì)分享一下。

首先，我們在MongoDB的官方文檔中看到，MongoDb的2.4以上的For .Net的驅(qū)動(dòng)是支持.Net Core 2.0的。

針對MongoDB，我想大家應(yīng)該不陌生，沒有用過也有聽過。

1、mongodb是什么？

MongoDB是一個(gè)基于分布式文件存儲(chǔ)的數(shù)據(jù)庫，為web應(yīng)用提供可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)解決方案，介于關(guān)系型數(shù)據(jù)庫和非關(guān)系型數(shù)據(jù)庫的產(chǎn)品，是非關(guān)系型數(shù)據(jù)庫中功能最豐富的。針對于數(shù)據(jù)處理是一把利器。

2、什么是關(guān)系型數(shù)據(jù)庫和非關(guān)系型數(shù)據(jù)庫？

關(guān)系型數(shù)據(jù)庫：在我們所用過的sqlserver、MySQL等，這些都是關(guān)系型數(shù)據(jù)庫，并且關(guān)系型數(shù)據(jù)庫是遵循ACID原則的，嚴(yán)格的一致性。

非關(guān)系型數(shù)據(jù)庫：也叫作NOSQL，用與超大規(guī)模數(shù)據(jù)的存儲(chǔ)，這些類型的數(shù)據(jù)存儲(chǔ)不需要固定的模式，無需多余的操作就可以橫向擴(kuò)展。

3、RDBMS VS NoSQL

RDBMS:

高度組織結(jié)構(gòu)化數(shù)據(jù)

結(jié)構(gòu)化查詢語言

數(shù)據(jù)和關(guān)系都存儲(chǔ)在單獨(dú)的表中

嚴(yán)格一致性

基礎(chǔ)事務(wù)

NoSQL：

沒有聲明性查詢語言

鍵-值對存儲(chǔ)，列存儲(chǔ)、文檔存儲(chǔ)等

最終一致性

非結(jié)構(gòu)化和不可預(yù)知數(shù)據(jù)

CAP定理、高可用、高性能、高擴(kuò)展

我相信講到這里，眼尖的同學(xué)應(yīng)該有注意到 CAP定理和最終一致性，肯定會(huì)聯(lián)想到 分布式系統(tǒng)，在這里給你大大的一個(gè)贊。在分布式系統(tǒng)中可以完美的結(jié)合nosql，提高我們的性能。

4、介紹一下RDBMS與Mongodb的一些概念，有助于幫助大家理解

翻譯一下，即如下：

二、asp.net core集成mongoDB

1、為了演示方便我下載了 windows版本的mongodb server

大家可以自行去官網(wǎng)下載，然后針對于可視化界面，我采用了 Robo 3T 這個(gè)工具。很簡潔美觀的可視化工具。推薦大家使用。

安裝結(jié)束后會(huì)在windows服務(wù)中看到mongodb server

然后我們打開一下Robo 3T，連接我們的mongodb。

2、開始在項(xiàng)目中配置一下我們的mongodb吧

第一步：我新建一個(gè)Core2.0類庫

引入了 “MongoDB.Driver” 這個(gè)nuget包。

然后擴(kuò)展了 Startup.cs 中的Services的擴(kuò)展方法

//擴(kuò)展方法public static class ServiceCollectionExtensions
 {
 public static void AddMongoDB(this IServiceCollection services, IConfiguration configuration)
 {
  services.Configure<Settings>(options =>
  {
  options.ConnectionString = configuration.GetSection("MongoConnection:ConnectionString").Value;
  options.Database = configuration.GetSection("MongoConnection:Database").Value;
  });
 }
 }

第二步：重構(gòu)封裝了mongodb的CRUD類，此處大家可以自行封裝，只展示了查找和新增。

public class MongoDBBase
 {
 private readonly IMongoDatabase _database = null;
 public MongoDBBase(string connectionString, string databaseName)
 {
  var client = new MongoClient(connectionString);
  if (client != null)
  {
  _database = client.GetDatabase(databaseName);
  }
 }

 #region SELECT
 /// <summary>
 /// 根據(jù)查詢條件，獲取數(shù)據(jù)
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="id"></param>
 /// <returns></returns>
 public List<T> GetList<T>(Expression<Func<T, bool>> conditions = null)
 {
  var collection = _database.GetCollection<T>(typeof(T).Name);
  if (conditions != null)
  {
  return collection.Find(conditions).ToList();
  }
  return collection.Find(_ => true).ToList();
 }#endregion

 #region INSERT/// <summary>
 /// 插入多條數(shù)據(jù)，數(shù)據(jù)用list表示
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="list"></param>
 /// <returns></returns>
 public List<T> InsertMany<T>(List<T> list)
 {
  var collection = _database.GetCollection<T>(typeof(T).Name);
  collection.InsertMany(list);
  return list;
 }
 #endregion
 }

第三步：新建一個(gè)asp.net core webapi 項(xiàng)目，引用此類庫進(jìn)行演示

在項(xiàng)目中的 appsetting.json 添加 mongodb的連接字符串：我在這邊使用自定義的一個(gè)數(shù)據(jù)名稱 testdb，在插入mongodb的時(shí)候會(huì)會(huì)自動(dòng)在創(chuàng)建數(shù)據(jù)庫和集合以及文檔。接著往下看

 "MongoConnection": { //mongodb數(shù)據(jù)庫連接
 "ConnectionString": "mongodb://127.0.0.1:27017",
 "Database": "testdb",
 "IsSSL": true
 },

第四步：新建一個(gè)mongodb測試控制器，展示了插入單條和多條以及查詢的接口。

[Produces("application/json")]
 [Route("api/MongoDB/[action]")]
 public class MongoDBController : Controller
 {
  private readonly MongoDBBase _context = null;
  public MongoDBController(IOptions<Settings> settings)
  {
   _context = new MongoDBBase(settings.Value.ConnectionString, settings.Value.Database);
  }
  [HttpGet]
  public IActionResult AddList()
  {
   List<MongoDBPostTest> list = new List<MongoDBPostTest>()
   {
    new MongoDBPostTest()
    {
     Id = "2",
     Body = "Test note 3",
     UpdatedOn = DateTime.Now,
     UserId = 1,
     HeaderImage = new NoteImage
     {
      ImageSize = 10,
      Url = "http://localhost/image1.png",
      ThumbnailUrl = "http://localhost/image1_small.png"
     }
    },
    new MongoDBPostTest()
    {
     Id = "3",
     Body = "Test note 4",
     UpdatedOn = DateTime.Now,
     UserId = 1,
     HeaderImage = new NoteImage
     {
      ImageSize = 14,
      Url = "http://localhost/image3.png",
      ThumbnailUrl = "http://localhost/image3_small.png"
     }
    }
   };

   try
   {
    _context.InsertMany(list);
   }
   catch (Exception ex)
   {

    throw;
   }

   return Ok("成功");
  }

  [HttpGet]
  public Result<List<MongoDBPostTest>> SelectSingle()
  {
   //無條件
   var list = _context.GetList<MongoDBPostTest>();

   //有條件
   //var list = _context.GetList<MongoDBPostTest>(a => a.Id == "1");

   //得到單條數(shù)據(jù),無條件
   //var list = _context.GetSingle<MongoDBPostTest>();

   //得到單條數(shù)據(jù),有條件
   //var list = _context.GetSingle<MongoDBPostTest>(a => a.Id == "3");

   ObjectId internalId = _context.GetInternalId("5bbf41651d3b66668cbb5bfc");

   var a = _context.GetSingle<MongoDBPostTest>(note => note.Id == "5bbf41651d3b66668cbb5bfc" || note.InternalId == internalId);

   return ResHelper.Suc(1, list, "成功");
  }
}

測試類

public class MongoDBPostTest
 {
  [BsonId]
  // standard BSonId generated by MongoDb
  public ObjectId InternalId { get; set; }
  public string Id { get; set; }

  public string Body { get; set; } = string.Empty;

  [BsonDateTimeOptions]
  public DateTime UpdatedOn { get; set; } = DateTime.Now;

  public NoteImage HeaderImage { get; set; }

  public int UserId { get; set; } = 0;
 }

public class NoteImage
 {
  public string Url { get; set; } = string.Empty;
  public string ThumbnailUrl { get; set; } = string.Empty;
  public long ImageSize { get; set; } = 0L;
 }

第五步：運(yùn)行項(xiàng)目，執(zhí)行一下。

我們執(zhí)行一下插入多條的數(shù)據(jù)吧，執(zhí)行成功。

然后我們看一下數(shù)據(jù)庫，發(fā)現(xiàn)已經(jīng)生成了一個(gè) testdb 數(shù)據(jù)庫，里面包含了我們的數(shù)據(jù)內(nèi)容

然后我們執(zhí)行以下查的操作：把我們剛才插入的數(shù)據(jù)返回回來了。

注意：這邊有一個(gè)坑有待解決，就是mongodb存儲(chǔ)的時(shí)間是UTC，會(huì)跟我們的本地時(shí)間相差8個(gè)小時(shí)。因此這邊需要特殊處理一下時(shí)間。

上述就是小編為大家分享的asp.net core集成MongoDB有哪些步驟了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

文章題目：asp.netcore集成MongoDB有哪些步驟
當(dāng)前網(wǎng)址：http://bm7419.com/article30/gipeso.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站收錄、虛擬主機(jī)、網(wǎng)站建設(shè)、網(wǎng)站維護(hù)、網(wǎng)站內(nèi)鏈

廣告

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