2. 程式人生 > 實用技巧 >在.NET Core中使用MongoDB明細教程(1):驅動基礎及文件插入

在.NET Core中使用MongoDB明細教程(1):驅動基礎及文件插入

阿新 • • 發佈：2020-08-13

MongoDB，被歸類為NoSQL資料庫，是一個以類JSON格式儲存資料的面向文件的資料庫系統.MongoDB在底層以名為bson的二進位制編碼格式表示JSON文件，MongoDB bson實現是輕量級、快速和高度可遍歷的。這意味著MongoDB為使用者提供了JSON文件的易用性和靈活性，以及輕量級二進位制格式的速度和豐富性。其實在我看來在很多場景中MongoDb都可以取代關係型資料庫。

作者：依樂祝
原文地址：

在本教程系列中，我將向您展示如何使用.NET驅動程式提供的CRUD函式在.NET應用程式中使用MongoDB。MongoDB驅動允許您使用來自不同程式語言的MongoDB。在本系列教程中，我們將使用

C#驅動程式.

準備工作

在開始之前，我們需要開啟VisualStudio並建立一個新專案。我將在本教程中使用一個控制檯專案。為了演示我們需要安裝對應的NuGet包。這裡我們需要三個NuGet包，即：

  1. MongoDB.Bson獨立的BSON庫，它處理POCOS到BSON型別的轉換(這是MongoDB的檔案格式)，反之亦然。
  2. MongoDB.Driver.Core：--它本身就是一個驅動程式，具有驅動程式的核心元件(如如何連線到mongod例項，連線池)，用於從.net到MongoDB的通訊，並且它依賴於MongoDB.Bson.
  3. MongoDB.Driver*依賴於Driver.Core這反過來又依賴於MongoDB.Bson
    。它更容易在核心元件驅動程式上使用api，並具有非同步方法，並支援Linq.

執行以下命令，會同時安裝上面三個包：

Install-Package MongoDB.Driver

訪問資料庫

若要連線到資料庫，請使用MongoClient類訪問MongoDB例項，並通過它選擇要使用的資料庫。這個類有四個建構函式。

  • 預設情況下，連線到埠27017上的例項的無引數結構器：
var client = new MongoClient();
  • 接受連線字串：
var connectionString = "mongodb://localhost:27017";
var client = new MongoClient(connectionString);
  • 接受一個MongoUrl的例項，而MongoUrl跟使用connectionstring建構函式很類似，您可以通過使用預設建構函式來建立此類例項：
var client = new MongoClient(new MongoUrl("mongodb://localhost:27017"));

.或者使用靜態的Create方法：

var client = new MongoClient(MongoUrl.Create("mongodb://localhost:27017"));
  • 最後一個是接受一個MongoClientSettings的建構函式，這裡你可以設定很多東西，比如憑據、連線生存期和超時時間等等。下面是兩個例子：
var settings1 = MongoClientSettings
        .FromUrl(MongoUrl.Create("mongodb://localhost:27017"));

var settings2 = new MongoClientSettings
          {
          Server = new MongoServerAddress("localhost", 27017),
          UseSsl = false
          };

var client1 = new MongoClient(settings1);
var client2 = new MongoClient(settings2);

通常，你只需要使用包含一個connectionString引數的建構函式就可以了，我們將在本教程中使用此建構函式。程式碼如下所示：

using MongoDB.Driver;
using System;
namespace MongoDBDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            Test();
            Console.ReadLine();
        }

        static void Test()
        {
            var connectionString = "mongodb://localhost:27017";

            var client = new MongoClient(connectionString);
        }
    }
}

使用MongoClient例項，我們可以做很多事情，如刪除資料庫、獲取資料庫或檢索伺服器上的資料庫名稱列表等。這裡沒有一個用於建立資料庫方法，因為一旦您選擇一個數據庫並將資料插入其中，它將自動建立資料庫。

這裡我們使用的是GetDatabase方法，它將自動為我們建立一個數據庫。如下所示獲取一個名為bookstore 的資料庫：

IMongoDatabase db = client.GetDatabase("bookstore");

這個GetDatabase方法返回一個物件，該物件是資料庫的表示形式，我們可以從該物件訪問不同的集合並操作資料庫。這個MongoClient物件是執行緒安全的，因此您可以將其放在靜態欄位中，使其成為可以通過DI容器隨時獲得的Singleton物件，或者使用相同的連線設定例項化一個新的欄位(下面將使用相同的連線池)；通過這個物件，您可以選擇您想要使用的任何資料庫。

使用資料庫物件，可以從資料庫建立、重新命名、檢索或獲取集合列表。文件儲存在集合中，如果你對SQL比較熟悉的話，可以將集合視為表，將文件視為表中的記錄。

建立一個集合

若要建立集合，我們將使用 IMongoDatabase物件的CreateCollection 或CreateCollection Async方法來進行 。該方法接受三個引數(最後兩個引數是可選的)：

  1. 集合的名稱。
  2. 建立集合的選項
  3. 取消令牌
 void CreateCollection(
                string name,
                CreateCollectionOptions options = null,
                CancellationToken cancellationToken = default);

Task CreateCollectionAsync(
                string name, 
                CreateCollectionOptions options = null, 
                CancellationToken cancellationToken = default);

這個CreateCollectionOptions指定集合的特殊設定，例如它應該包含的最大文件數。下面是一個例子：

 IMongoDatabase database = client.GetDatabase("bookstore");
 await database.CreateCollectionAsync("books", new CreateCollectionOptions
            {
                Capped=true,
                MaxDocuments=100,
            });

大多數情況下，我們只需要建立一個集合，並使用預設的建立設定，因此我們只需要傳遞一個collection的名稱即可。

await database.CreateCollectionAsync("books");

建立集合的另一種方法是使用GetCollection它接受集合的名稱和集合設定選項作為引數。使用此方法，即使不存在該名稱的集合，一旦建立文件，它也會在此之前建立該集合。這通常是您想要的方式，因此這裡建議只在你需要建立一個有上限的集合時才使用CREATE進行集合的建立。

Capped集合是一個固定大小的集合，當它達到最大值時，它會自動覆蓋其最舊的條目。GetCollection方法是泛型的，在呼叫此方法時需要指定文件型別。該型別表示要處理的物件/文件的型別。它可以被強型別化為我們定義的任何類，或者使用BsonDocument型別表示一個允許我們處理集合中任何文件形狀的動態架構。

獲取一個集合

在討論了建立集合之後，還需要一個額外的步驟來檢查集合是否存在，建立它，然後將文件新增到集合中。如果集合不存在，GetCollection會自動建立一個集合，並將文件新增到該集合中。因此，即使有一個CreateCollection，我們通常還是希望使用GetCollection。就像資料庫一樣，集合也是執行緒安全的，並且建立起來非常j簡單。為了獲得一個集合，我們呼叫GetCollection方法來指定文件型別

 static async Task TestAsync()
        {
            var connectionString = "mongodb://localhost:27017";
            var client = new MongoClient(connectionString);
            IMongoDatabase database = client.GetDatabase("bookstore");
            IMongoCollection<BsonDocument> collection = database.GetCollection<BsonDocument>("books");
        }

BsonDocument是來自MongoDB.Bson包的型別，它表示BSON文件，使用這種型別，我們可以處理來自資料庫的任何形狀的資料。這包包含了所有基本BSON型別和其他一些用於使用BSON的方法。

在這個包中，我們有表示BSON型別的類，以及如何在.NET型別和BsonValue之間對映。下面簡單列舉一些：

  • 我們已經討論過的BsonDocument型別
  • 表示BSON元素的BsonElement
  • BsonValue是各種子類使用的抽象基類，如BsonString、BsonInt 32等。

這個BsonDocument是字串到bson值的字典，因此我們可以像初始化字典一樣來進行初始化：

 var document = new BsonDocument
            {
                  {"bookname", BsonValue.Create(".net core3.1 with mongodb")},
                  {"description", new BsonString("這是一本關於在.net core3.1中使用mongodb進行開發的教程")},
                  {"tags", new BsonArray(new[] {".net core", "mongodb"}) },
                  {"remark", "C#是世界上最好的語言" },
                  {"publishyear", 2020 }
            };

.或者使用Add方法，該方法具有多個過載：

 var document2 = new BsonDocument();
            document2.Add("bookname", ".net core3.1 with mongodb2");
            document2.Add("description", "這是一本關於在.net core3.1中使用mongodb進行開發的教程2");
            document2.Add("tags", new BsonArray(new[] { ".net core", "mongodb" }));
            document2.Add("remark", "C#是世界上最好的語言");
            document2.Add("publishyear", 2020);

.或者使用索引器：

var document3 = new BsonDocument();
            document3["bookname"] = ".net core3.1 with mongodb3";
            document3["description"] = "這是一本關於在.net core3.1中使用mongodb進行開發的教程3";
            document3["tags"] = new BsonArray(new[] { ".net core", "mongodb" });
            document3["remark"] = "C#是世界上最好的語言";
            document3["publishyear"] = 2020;

建立/插入文件

文件儲存在集合中，在查看了建立和獲取集合之後，我們將繼續在集合中插入新文件。Mongo集合例項提供了一次插入單個文件和一次插入多個文件的方法。

接下來讓我們一步一步來進行實現吧：

  • 獲取一個IMongocollection型別的物件，該物件表示我們要使用的集合：
 IMongoCollection<BsonDocument> collection = database.GetCollection<BsonDocument>("books");
  • 然後建立我們想要插入的文件：
 var document = new BsonDocument
            {
                  {"bookname", BsonValue.Create(".net core3.1 with mongodb")},
                  {"description", new BsonString("這是一本關於在.net core3.1中使用mongodb進行開發的教程")},
                  {"tags", new BsonArray(new[] {".net core", "mongodb"}) },
                  {"remark", "C#是世界上最好的語言" },
                  {"publishyear", 2020 }
            };
  • 最後插入該檔案：
await collection.InsertOneAsync(document);

要想看到這個效果，讓我們開始一個mongod例項，並從控制檯監視事件的同時執行以下完整程式碼：

class Program
    {
        static async Task Main(string[] args)
        {
            await TestAsync();
            Console.ReadLine();
        }

        /// <summary>
        /// 測試程式碼
        /// </summary>
        /// <returns></returns>
        static async Task TestAsync()
        {
            var connectionString = "mongodb://localhost:27017";

            var client = new MongoClient(connectionString);
            IMongoDatabase database = client.GetDatabase("bookstore");
            IMongoCollection<BsonDocument> collection = database.GetCollection<BsonDocument>("books");
            var document = new BsonDocument
            {
                  {"bookname", BsonValue.Create(".net core3.1 with mongodb")},
                  {"description", new BsonString("這是一本關於在.net core3.1中使用mongodb進行開發的教程")},
                  {"tags", new BsonArray(new[] {".net core", "mongodb"}) },
                  {"remark", "C#是世界上最好的語言" },
                  {"publishyear", 2020 }
            };
            await collection.InsertOneAsync(document);
        }
    }

...啟動你的mongo服務並執行程式，看到如下所示的資料：

這裡的InsertOneAsync方法還有一個同步的版本

collection.InsertOne(document);

我們還可以使用InsertMany或InsertManyAsync方法進行批量插入。假設我們圖書館又來了三本新書，我們可以使用這個方法同時插入所有的內容，並且它們將被插入到一個批中(假設您使用的是MongoDB2.6或更高版本)。要檢視此操作，我們將繼續更新程式碼並執行應用程式：

class Program
    {
        static async Task Main(string[] args)
        {
            await TestAsync();
            Console.ReadLine();
        }

        /// <summary>
        /// 測試程式碼
        /// </summary>
        /// <returns></returns>
        static async Task TestAsync()
        {
            var connectionString = "mongodb://localhost:27017";
            var client = new MongoClient(connectionString);
            IMongoDatabase database = client.GetDatabase("bookstore");
            IMongoCollection<BsonDocument> collection = database.GetCollection<BsonDocument>("books");
            await collection.InsertManyAsync(GetBooks());
          
        }

        static IEnumerable<BsonDocument> GetBooks() => new List<BsonDocument> {
            new BsonDocument
            {
                  {"bookname", BsonValue.Create(".net core3.1 with mongodb1")},
                  {"description", new BsonString("這是一本關於在.net core3.1中使用mongodb進行開發的教程1")},
                  {"tags", new BsonArray(new[] {".net core", "mongodb"}) },
                  {"remark", "C#是世界上最好的語言" },
                  {"publishyear", 2020 }
            },
            new BsonDocument
            {
                  {"bookname", BsonValue.Create(".net core3.1 with mongodb2")},
                  {"description", new BsonString("這是一本關於在.net core3.1中使用mongodb進行開發的教程2")},
                  {"tags", new BsonArray(new[] {".net core", "mongodb"}) },
                  {"remark", "C#是世界上最好的語言" },
                  {"publishyear", 2020 }
            },
            new BsonDocument
            {
                  {"bookname", BsonValue.Create(".net core3.1 with mongodb2")},
                  {"description", new BsonString("這是一本關於在.net core3.1中使用mongodb進行開發的教程2")},
                  {"tags", new BsonArray(new[] {".net core", "mongodb"}) },
                  {"remark", "C#是世界上最好的語言" },
                  {"publishyear", 2020 }
            },
        };
    }

這時候我們再進行夏查詢，看到所有資料都入庫了

除了使用BsonDocument，我們通常預先知道我們想要處理的是什麼樣的資料，並且我們可以為它們建立自定義的.NET類。遵循我們使用books集合的事例，讓我們建立一個Book類並插入使用此類表示的新書籍：

internal class Book
{
        public string BookName { get; set; }
        public string Description { get; set; }
        public IEnumerable<string> Tags { get; set; }
        public string Remark { get; set; }
        public int PublishYear { get; set; }
}
class Program
    {
        static async Task Main(string[] args)
        {
            await TestAsync();
            Console.ReadLine();
        }

        /// <summary>
        /// 測試程式碼
        /// </summary>
        /// <returns></returns>
        static async Task TestAsync()
        {
            var connectionString = "mongodb://localhost:27017";
            var client = new MongoClient(connectionString);
            IMongoDatabase database = client.GetDatabase("bookstore");
            IMongoCollection<Book> collection = database.GetCollection<Book>("books");
            await collection.InsertManyAsync(GetBooks());
        }

        static IEnumerable<Book> GetBooks() => new List<Book> { 
            new Book
            {
                BookName=".net core3.1 with mongodb21",
                Description="這是一本關於在.net core3.1中使用mongodb進行開發的教程21",
                Tags=new List<string>{ ".net core", "mongodb"},
                Remark="C#是世界上最好的語言",
                PublishYear=2020,
            },
            new Book
            {
                BookName=".net core3.1 with mongodb22",
                Description="這是一本關於在.net core3.1中使用mongodb進行開發的教程22",
                Tags=new List<string>{ ".net core", "mongodb"},
                Remark="C#是世界上最好的語言",
                PublishYear=2020,
            },
            new Book
            {
                BookName=".net core3.1 with mongodb23",
                Description="這是一本關於在.net core3.1中使用mongodb進行開發的教程23",
                Tags=new List<string>{ ".net core", "mongodb"},
                Remark="C#是世界上最好的語言",
                PublishYear=2020,
            },
        };
    }

使用上面的程式碼，我們可以將集合的文件型別更改為新類，並呼叫InsertManyAsync方法。執行下程式，然後查詢下集合資料如下所示：

總結

通過上面的示例程式碼的講解，你應該對如何通過MongoDB .NET 驅動程式來操作MongoDB集合跟文件有所瞭解了，並且你也應該知道如何進行文件的插入，在下一篇文章中，我將介紹如何對文件進行檢索以及為此構建的各種filter及linq查詢技巧，有興趣的可以關注下我的公眾號“DotNetCore實戰”第一時間進行更新！

參考資料：https://www.codementor.io/@pmbanugo/working-with-mongodb-in-net-1-basics-g4frivcvz

相關推薦

在.NET Core中使用MongoDB明細教程(1):驅動基礎及文件插入

MongoDB，被歸類為NoSQL資料庫，是一個以類JSON格式儲存資料的面向文件的資料庫系統.MongoDB在底層以名為bson的二進位制編碼格式表示JSON文件，MongoDB bson實現是輕量級、快速和高度可遍歷的。這意味著MongoDB為使

在.NET Core中使用MongoDB明細教程(2)：使用Filter語句檢索文件

在上篇文章我們介紹了一些驅動程式相關的基礎知識，以及如何將文件插入到集合中。在這篇文章中，我們將學習如何從資料庫中檢索文件。

.Net Core中簡單使用MongoDB

MongoDB 是由C++語言編寫的，是一個基於分散式且面向文件儲存的開源資料庫系統。

.Net Core使用MongoDB的詳細教程

前言 MongoDB 是由C++語言編寫的，是一個基於分散式且面向文件儲存的開源資料庫系統。

.net core系列之《.net core中使用整合IDistributedCache介面的Redis和MongoDB實現分散式快取》

https://blog.csdn.net/weixin_33970449/article/details/94177435 分散式的快取可以提高效能和可伸縮性的 ASP.NET Core 應用程式，尤其是託管在雲中或伺服器場中時。

mongodb官方的golang驅動基礎使用教程分享

前言 mongo資料庫在nodejs平臺有2個常用驅動，mongodb和mongoose，mongodb介面非常接近mongo資料庫原生的操作方式，是helloworld之類演示程式碼的首選mongo資料庫連線驅動，因此成為大部分nodejs初學者最先接觸的mon

在Asp.Net Core中使用ModelConvention實現全域性過濾器隔離

從何說起 這來自於我把專案遷移到Asp.Net Core的過程中碰到一個問題。在一個web程式中同時包含了MVC和WebAPI，現在需要給WebAPI部分單獨新增一個介面驗證過濾器 IActionFilter ，常規做法一般是寫好過濾器後給需要的

.Net Core中使用ExceptionFilter過濾器的方法

.Net Core中有各種Filter,分別是AuthorizationFilter、ResourceFilter、ExceptionFilter、ActionFilter、ResultFilter。可以把他們看作是.Net Core自帶的AOP的擴充套件封裝。

ASP.NET Core中的Http快取使用

Http響應快取可減少客戶端或代理對web伺服器發出的請求數。響應快取還減少了web伺服器生成響應所需的工作量。響應快取由Http請求中的header控制。

淺談ASP.NET Core 中jwt授權認證的流程原理

1，快速實現授權驗證 什麼是 JWT ？為什麼要用 JWT ？JWT 的組成？ 這些百度可以直接找到，這裡不再贅述。

.NET Core中建立和使用NuGet包的示例程式碼

在.NET Core的專案中，如果我們要在專案中引用其它DLL檔案，不建議直接在專案引用中新增DLL檔案（雖然在.NET Core專案中也可以這麼做），建議是去直接下載DLL檔案所屬的NuGet包。這樣最大的好處是我們可以將要引用DL

ASP.NET Core中的Controller使用示例

ASP.NET CORE出現之前我們實現的Controller，MVC都繼承自Controller基類，WebApi的話繼承自ApiController。現在ASP.NET CORE把MVC跟WebApi合併了，已經不再區分MVC或者WebApi。ASP.NET CORE的Controller繼承結構也發

詳解在.net core中完美解決多租戶分庫分表的問題

前幾天有人想做一個多租戶的平臺,每個租戶一個庫,可以進行水平擴充套件,應用端根據登入資訊,切換到不同的租戶庫

詳解ASP.NET Core中配置監聽URLs的五種方式

預設情況下，ASP. NET Core應用會監聽一下2個Url: http://localhost:5000 https://localhost:5001

ASP.NET Core中的Action的返回值型別實現

在Asp.net Core之前所有的Action返回值都是ActionResult，Json(),File()等方法返回的都是ActionResult的子類。並且Core把MVC跟WebApi合併之後Action的返回值體系也有了很大的變化。

Asp.net Core中實現自定義身份認證的示例程式碼

Asp.Net Core中雖然集成了許多常用的身份認證，但很多時候，我們還是需要實現自己的身份認證介面，本文這裡就簡單的介紹下如何實現自定義身份認證介面。

ASP.NET Core 中基於 API Key 對私有 Web API 進行保護

原文:ASP.NET Core 中基於 API Key 對私有 Web API 進行保護 這兩天遇到一個應用場景，需要對內網呼叫的部分 web api 進行安全保護，只允許請求頭賬戶包含指定 key 的客戶端進行呼叫。在網上找到一篇英文博文 ASP.N

詳解如何在C#/.NET Core中使用責任鏈模式

最近我有一個朋友在研究經典的“Gang Of Four”設計模式。他經常來詢問我在實際業務應用中使用了哪些設計模式。單例模式、工廠模式、中介者模式 - 都是我之前使用過，甚至寫過相關文章的模式。但是有一種模式是我還沒

Magicodes.IE在.NET Core中通过请求头导出多种格式文件

前言 在2.2里程碑中我们增加了一些新的功能,正如标题所写通过请求头进行导出我们不同格式的文件.下面我们来看一下如何使用.通过这种方式无论是对我们的数据多用途，还是说对我们的数据校验都做到了轻松易配。

Magicodes.IE在.NET Core中通過請求頭匯出多種格式檔案

前言 在2.2里程碑中我們增加了一些新的功能,正如標題所寫通過請求頭進行匯出我們不同格式的檔案.下面我們來看一下如何使用.通過這種方式無論是對我們的資料多用途，還是說對我們的資料校驗都做到了輕鬆易配。