C# 玩轉MongoDB（一）

隨着NoSQL的應用越來越廣泛，很多面試都需要熟悉了解NoSQL【如：Redis，MongoDB等】，本文以一個簡單的小例子，簡述如何通過C#來操作MongoDB，進行數據的讀寫操作，僅供學習分享使用，如有不足之處，還請指正。

涉及知識點

• MongoDB的基礎知識，CRUD(增刪改查)等【關於MongoDB的基礎知識，如果不太了解的，可參考前面幾篇博文】。
• C#面向對象基礎知識，WinForm基礎編程。

MongoDB驅動安裝

項目--右鍵--管理Nuget程序包--打卡Nuget包管理器--瀏覽搜索MongoDB.Driver--安裝。如下所示：

示例截圖

示例雖小，實現了查詢，條件查詢，明細顯示，新增等功能，如下所示：

 

 新增功能

 

C#操作MongoDB步驟

 其實關於數據庫的操作步驟，基本上大同小異，如下所示：

1. 連接服務，得到客戶端
2. 獲取要使用的數據庫
3. 獲取操作的集合
4. 執行命令

核心源碼

為了代碼的公用，本例對MongoDB的操作代碼進行了封裝，如下所示：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MongoDB.Driver;
using MongoDB.Bson;
using MongoDB.Bson.Serialization;
using System.Web.Script.Serialization;

namespace DemoMongo.Common
{
    /// <summary>
    /// Mongo幫助類
    /// </summary>
    public class MongoHelper<T>
    {
        private string connStr = "";//服務器網址

        private string dbName = "";//數據庫名稱

        private IMongoClient client;//連接客戶端

        private IMongoDatabase db;//連接數據庫

        private string collName ;//集合名稱

        public MongoHelper() { 
        
        }

        public MongoHelper(string connStr,string dbName,string collName) {
            this.connStr = connStr;
            this.dbName = dbName;
            this.collName = collName;
            this.Init();
        }

        /// <summary>
        /// 初始化連接客戶端
        /// </summary>
        private void Init()
        {
            if (client == null)
            {
                client = new MongoClient(this.connStr);
            }
            if (db == null) {
                db = client.GetDatabase(this.dbName);
            }
        }

        /// <summary>
        /// 插入對象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="obj"></param>
        public void Insert(T obj)
        {
            IMongoCollection<T> collention = db.GetCollection<T>(collName);
            collention.InsertOneAsync(obj);
        }

        /// <summary>
        /// 字典形式插入
        /// </summary>
        /// <param name="dicInfo"></param>
        public void Insert(Dictionary<string,string> dicInfo)
        {
            var collection = db.GetCollection<BsonDocument>(collName);
            var document = new BsonDocument(dicInfo);
            collection.InsertOne(document);
        }

        /// <summary>
        /// 無條件查詢，即返回全部
        /// </summary>
        /// <returns></returns>
        public List<T> Query() {
            var collection = db.GetCollection<BsonDocument>(collName);
            var rest =  collection.Find(Builders<BsonDocument>.Filter.Empty);
            return rest.As<T>().ToList();
        }

        /// <summary>
        /// 按名稱進行查詢
        /// </summary>
        /// <param name="name"></param>
        /// <returns></returns>
        public List<T> Query(object name) {
            var collection = db.GetCollection<T>(collName);
            var rest = collection.Find(Builders<T>.Filter.Eq("name",name));
            return rest.As<T>().ToList();
        }


        /// <summary>
        /// 只查詢一條
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public string QueryOne(string Id) { 
            var collection = db.GetCollection<T>(collName);
            var rest = collection.Find(Builders<T>.Filter.Eq("Id",new ObjectId(Id))).Limit(1);
           
            T t = rest.As<T>().ToList()[0];
            JavaScriptSerializer jserializer = new JavaScriptSerializer();
            string strJson = jserializer.Serialize(t);
            return strJson;
        }
    }
}

代碼調用

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Configuration;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using DemoMongo.Common;

namespace DemoMongo
{
    public partial class FrmMain : Form
    {
        private MongoHelper<Student> helper;

        public FrmMain()
        {
            InitializeComponent();
            string connStr = ConfigurationManager.AppSettings["connStr"];
            string dbName = ConfigurationManager.AppSettings["dbName"];
            string collName = "student";
            helper = new MongoHelper<Student>(connStr,dbName,collName);

        }

        private void FrmMain_Load(object sender, EventArgs e)
        {
            List<Student> list = helper.Query();
            this.dgView.AutoGenerateColumns = false;
            this.bsView.DataSource = list;
            this.dgView.DataSource = bsView;
        }

        private void btnQuery_Click(object sender, EventArgs e)
        {
            string name = this.txtName.Text.Trim();
            
            List<Student> list = new List<Student>();
            if (string.IsNullOrEmpty(name))
            {
                list = helper.Query();
            }
            else {
                //注意：此處姓名在MongoDB中存儲的數據類型不是固定的，可能是字符串也可能是整數，所以需要判斷，否則查詢不出來
                int name1 = 0;
                if (int.TryParse(name, out name1))
                {
                    list = helper.Query(name1);
                }
                else {
                    list = helper.Query(name);
                }
                
            }
            this.dgView.AutoGenerateColumns = false;
            this.bsView.DataSource = list;
            this.dgView.DataSource = bsView;
        }

        private void btnAdd_Click(object sender, EventArgs e)
        {
            FrmAdd add = new FrmAdd(this.helper);
            add.ShowDialog();
            btnQuery_Click(sender, e);
        }

        private void dgView_CellClick(object sender, DataGridViewCellEventArgs e)
        {
            //只有當第0列被點擊時才生效
            if (e.ColumnIndex == 0)
            {
                string id = ((Student)dgView.CurrentRow.DataBoundItem).Id.ToString();
                string student = helper.QueryOne(id);
                this.txtContent.Text = JsonHelper.ConvertJsonString(student);
            }
        }

    }
}

以上就是C#對於MongoDB的基礎操作，旨在拋磚引玉，共同進步。

備注

踏莎行·候館梅殘

【作者】歐陽修  【朝代】宋

 

候館梅殘，溪橋柳細。草薰風暖搖征轡。離愁漸遠漸無窮，迢迢不斷如春水。

寸寸柔腸，盈盈粉淚。樓高莫近危闌倚。平蕪盡處是春山，行人更在春山外。