0、目錄

一、前言及MongoDB的介紹

 最近在整合自己的框架，順便把MongoDBD的最簡單CRUD重構一下作為元件化整合到asp.net core專案中，當然此篇文章中沒有講解mongodb的叢集部署，等有機會分享一下。

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

1、mongodb是什麼？

MongoDB是一個基於分散式檔案儲存的資料庫，為web應用提供可擴充套件的高效能資料儲存解決方案，介於關係型資料庫和非關係型資料庫的產品，是非關係型資料庫中功能最豐富的。針對於資料處理是一把利器。

2、什麼是關係型資料庫和非關係型資料庫？

關係型資料庫：在我們所用過的sqlserver、mysql等，這些都是關係型資料庫，並且關係型資料庫是遵循ACID原則的，嚴格的一致性。

非關係型資料庫：也叫作NoSQL，用與超大規模資料的儲存，這些型別的資料儲存不需要固定的模式，無需多餘的操作就可以橫向擴充套件。

3、RDBMS VS NoSQL

RDBMS:

　　高度組織結構化資料

　　結構化查詢語言

　　資料和關係都儲存在單獨的表中

　　嚴格一致性

　　基礎事務

NoSQL：

　　沒有宣告性查詢語言

　　鍵-值對儲存，列儲存、文件儲存等

　　最終一致性

　　非結構化和不可預知資料

　　CAP定理、高可用、高效能、高擴充套件

我相信講到這裡，眼尖的同學應該有注意到 CAP定理和最終一致性，肯定會聯想到 分散式系統，在這裡給你大大的一個贊。在分散式系統中可以完美的結合nosql，提高我們的效能。

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

翻譯一下，即如下：

二、asp.net core整合mongoDB

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

大家可以自行去官網下載，然後針對於視覺化介面，我採用了 Robo 3T 這個工具。很簡潔美觀的視覺化工具。推薦大家使用。

安裝結束後會在windows服務中看到mongodb server

然後我們開啟一下Robo 3T，連線我們的mongodb。

2、開始在專案中配置一下我們的mongodb吧

第一步：我新建一個Core2.0類庫

引入了 “MongoDB.Driver” 這個nuget包。

然後擴充套件了 Startup.cs 中的Services的擴充套件方法

//擴充套件方法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;
            });
        }
    }

第二步：重構封裝了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>
        /// 根據查詢條件，獲取資料
        /// </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>
        /// 插入多條資料，資料用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
    }

第三步：新建一個asp.net core webapi 專案，引用此類庫進行演示

在專案中的 appsetting.json 新增 mongodb的連線字串：我在這邊使用自定義的一個數據名稱 testdb，在插入mongodb的時候會會自動在建立資料庫和集合以及文件。接著往下看

  "MongoConnection": { //mongodb資料庫連線
    "ConnectionString": "mongodb://127.0.0.1:27017",
    "Database": "testdb",
    "IsSSL": true
  },

第四步：新建一個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");

            //得到單條資料,無條件
            //var list = _context.GetSingle<MongoDBPostTest>();

            //得到單條資料,有條件
            //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;
    }

第五步：執行專案，執行一下。

我們執行一下插入多條的資料吧，執行成功。

然後我們看一下資料庫，發現已經生成了一個  testdb 資料庫，裡面包含了我們的資料內容

然後我們執行以下查的操作：把我們剛才插入的資料返回回來了。

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

三、總結

至此，mongodb的簡單運用已演示完畢，後期大家根據官方文件可進行擴充套件，越擴充套件到後面，會覺得越來越有意思。感謝大家的支援。Thank you。

參考文件：

asp.net Core 交流群：787464275 歡迎加群交流如果您認為這篇文章還不錯或者有所收穫，您可以點選右下角的【推薦】按鈕精神支援，因為這種支援是我繼續寫作，分享的最大動力！

微信公眾號：歡迎關注                                                 QQ技術交流群： 歡迎加群