MongoDB 是一個基于分布式文件存儲的數據庫。由 C++ 語言編寫。旨在為 WEB 應用提供可擴展的高性能數據存儲解決方案。今天主要給大家介紹一下C#編程語言下Mongodb的用法。開發環境為VS2015示例主要包括數據的增刪改查、分頁查詢、文件存儲等功能。有需要的朋友可以一起學習一下。

1、需要引用Mongodb程序集

MongoDB.Bson.dll

MongoDB.Driver.dll

2、創建Mongodb工具類庫 MongodbHelper.cs

using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;
using MongoDB.Driver.GridFS;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Linq;namespace MongodbHelper
{/// <summary>/// MongoDB的基本增刪改查/// </summary>public class MongodbTool{private readonly MongoDatabase _db;//數據庫默認地址private readonly string host = ConfigurationManager.AppSettings["db_host"];//數據庫默認名稱private readonly string db_name = ConfigurationManager.AppSettings["db_name"];public MongodbTool(){var client = new MongoClient(host); //ip及端口var server = client.GetServer();_db = server.GetDatabase(db_name); //數據庫名稱}#region 通用增刪改查/// <summary>/// 新增單個實體模型 modifiy by 2020-11-11/// </summary>/// <typeparam name="T"></typeparam>/// <param name="entity"></param>/// <returns>True:成功,False:失敗</returns>public bool Insert<T>(T entity){bool isOk = true;try{BsonDocument doc = entity.ToBsonDocument();WriteConcernResult result = this._db.GetCollection(typeof(T).Name).Insert(doc);isOk = result.Ok;}catch (Exception ex){}return isOk;}/// <summary>/// 新增實體集合模型/// </summary>/// <typeparam name="T"></typeparam>/// <param name="entity"></param>/// <returns>True:成功,False:失敗</returns>public bool Add<T>(IEnumerable<T> entity){bool isOk = true;try{int s = 1;IEnumerable<WriteConcernResult> results = this._db.GetCollection(typeof(T).Name).InsertBatch(entity);foreach (var item in results){if (item.Ok)isOk = true;elseisOk = false;}}catch (Exception ex){}return isOk;}/// <summary>/// 查詢單條數據/// </summary>/// <typeparam name="T"></typeparam>/// <param name="Field">查詢屬性字段</param>/// <param name="Value">字段值</param>/// <returns>返回當前實體</returns>public T FindOne<T>(string Field, string Value){T oneEntity = default(T);try{FindOneArgs args = new FindOneArgs{Query = Query.EQ(Field, Value)};oneEntity = this._db.GetCollection(typeof(T).Name).FindOneAs<T>(args);this._db.GetCollection(typeof(T).Name).FindAs<T>(Query.GTE(Field, Value)).ToList();}catch (Exception ex){}return oneEntity;}/// <summary>/// 查詢多條數據/// </summary>/// <typeparam name="T"></typeparam>/// <param name="Field">查詢屬性字段</param>/// <param name="Value">字段值</param>/// <returns>返回當前實體集合</returns>public List<T> FindMore<T>(string Field, string Value){List<T> list = new List<T>();try{list = this._db.GetCollection(typeof(T).Name).FindAs<T>(Query.GTE(Field, Value)).ToList();}catch (Exception ex){}return list;}/// <summary>/// 查詢文檔所有數據/// </summary>/// <typeparam name="T"></typeparam>/// <returns></returns>public List<T> FindAllMore<T>(){List<T> list = new List<T>();try{list = this._db.GetCollection(typeof(T).Name).FindAllAs<T>().ToList();}catch (Exception ex){}return list;}/// <summary>/// 分頁查詢文檔/// </summary>/// <typeparam name="T"></typeparam>/// <param name="pageIndex">頁次</param>/// <param name="pageRow">每頁顯示記錄數</param>/// <param name="total">總記錄數</param>/// <returns></returns>public List<T> FindMoreForPage<T>(int pageIndex, int pageRow, ref long total){List<T> list = new List<T>();try{total = this._db.GetCollection(typeof(T).Name).FindAllAs<T>().Count();    //獲取總記錄數if (pageIndex == 1){list = this._db.GetCollection(typeof(T).Name).FindAllAs<T>().SetLimit(pageRow).ToList();}else{var bd = this._db.GetCollection(typeof(T).Name).FindAll().SetSortOrder("_id:1").SetLimit((pageIndex - 1) * pageRow).Last();   //獲取最后一個ID主鍵var el = bd.GetElement(0);var value = el.Value;list = this._db.GetCollection(typeof(T).Name).FindAs<T>(Query.GT("_id", value)).SetSortOrder("_id:1").SetLimit(pageRow).ToList();}}catch (Exception ex){}return list;}/// <summary>///  by 2020 ADD/// </summary>/// <typeparam name="T"></typeparam>/// <param name="query">查詢條件</param>/// <param name="pageIndex">當前頁</param>/// <param name="rows">行數</param>/// <param name="totalCount">總行數</param>/// <returns></returns>public List<T> FindPageNewAdd<T>(IMongoQuery query, int pageIndex, int rows, ref long totalCount){List<T> list = new List<T>();int skipCount = 0;try{if (pageIndex > 1){skipCount = (pageIndex - 1) * rows;}else{pageIndex = 1;}totalCount = this._db.GetCollection(typeof(T).Name).FindAs<T>(query).Count();if (totalCount > 0){list = this._db.GetCollection(typeof(T).Name).FindAs<T>(query).SetFlags(QueryFlags.NoCursorTimeout).SetSortOrder().SetSkip(skipCount).SetLimit(rows).ToList();}}catch (Exception){throw;}return list;}/// <summary>/// 按條件分頁查詢/// </summary>/// <typeparam name="T"></typeparam>/// <param name="query">查詢條件</param>/// <param name="pageIndex">頁次</param>/// <param name="pageRow">每頁顯示記錄數</param>/// <param name="total">總記錄數</param>/// <returns></returns>public List<T> FindMoreForPageByCondion<T>(IMongoQuery query, int pageIndex, int pageRow, ref long total){List<T> list = new List<T>();try{total = this._db.GetCollection(typeof(T).Name).FindAs<T>(query).Count();//獲取總記錄數if (pageIndex == 1){list = this._db.GetCollection(typeof(T).Name).FindAs<T>(query).SetSortOrder(SortBy.Descending("CreateDate")).SetLimit(pageRow).ToList();}else{var bd = this._db.GetCollection(typeof(T).Name).Find(query).SetSortOrder("_id:1").SetLimit((pageIndex - 1) * pageRow).Last();   //獲取最后一個ID主鍵var el = bd.GetElement(0);var value = el.Value;list = this._db.GetCollection(typeof(T).Name).FindAs<T>(query).SetSortOrder("_id:1").SetSkip(pageRow).SetLimit(pageRow).ToList();}}catch (Exception ex){}return list;}/// <summary>/// 更新實體單個字段值/// </summary>/// <typeparam name="T"></typeparam>/// <param name="whereField">條件字段</param>/// <param name="whereValue">條件字段值</param>/// <param name="updateField">修改字段</param>/// <param name="updateValue">修改字段值</param>/// <returns></returns>public bool UpdateEntity<T>(string whereField, string whereValue, string updateField, string updateValue){bool isOk = true;try{var query = Query.EQ(whereField, whereValue);var update = Update.Set(updateField, updateValue);WriteConcernResult result = this._db.GetCollection(typeof(T).Name).Update(query, update);if (!result.Ok)isOk = false;}catch (Exception ex){}return isOk;}/// <summary>/// 更新整個實體模型字段/// </summary>/// <typeparam name="T">泛型參數</typeparam>/// <param name="whereField">條件字段</param>/// <param name="whereValue">條件值</param>/// <param name="updateEntity">實體模型</param>/// <returns>True:成功,False:失敗</returns>public bool UpdateEntityMoreFields<T>(string whereField, string whereValue, T updateEntity){bool isOk = true;try{var query = Query.EQ(whereField, whereValue);BsonDocument bsonDoc = updateEntity.ToBsonDocument(typeof(T));var update = new UpdateDocument{{"$set",bsonDoc}};WriteConcernResult result = this._db.GetCollection(typeof(T).Name).Update(query, update);if (!result.Ok)isOk = false;}catch (Exception ex){}return isOk;}/// <summary>/// 刪除實體文檔/// </summary>/// <typeparam name="T">泛型參數</typeparam>/// <param name="whereField">條件字段</param>/// <param name="whereValue">條件值</param>/// <returns></returns>public bool DelEntity<T>(string whereField, string whereValue){bool isOk = true;try{var query = Query.EQ(whereField, whereValue);WriteConcernResult result = this._db.GetCollection(typeof(T).Name).Remove(query);if (!result.Ok)isOk = false;}catch (Exception ex){}return isOk;}#endregion#region GridFS 文件操作/// <summary>////// </summary>/// <returns></returns>public MongoCursor<MongoGridFSFileInfo> FindAll(){return this._db.GetGridFS(MongoGridFSSettings.Defaults).FindAll();}/// <summary>////// </summary>/// <param name="filePath"></param>public void UploadFile(string filePath){FileInfo fi = new FileInfo(filePath);this._db.GetGridFS(MongoGridFSSettings.Defaults).Upload(filePath, fi.Name);}/// <summary>////// </summary>/// <param name="filePath"></param>/// <param name="fileName"></param>public void UploadFile(string filePath, string fileName){this._db.GetGridFS(MongoGridFSSettings.Defaults).Upload(filePath, fileName);}/// <summary>///下載文件保存到默認目錄/// </summary>/// <param name="fileName"></param>/// <param name="filePath"></param>public void DownloadFile(string fileName){this._db.GetGridFS(MongoGridFSSettings.Defaults).Download(fileName);}/// <summary>///下載文件保存到其他目錄/// </summary>/// <param name="fileName"></param>/// <param name="filePath"></param>public void DownloadFileOther(string localFileName, string remoteFileName){this._db.GetGridFS(MongoGridFSSettings.Defaults).Download(localFileName,remoteFileName);}/// <summary>////// </summary>/// <param name="fileName"></param>public void DeleteFile(string fileName){this._db.GetGridFS(MongoGridFSSettings.Defaults).Delete(fileName);}/// <summary>////// </summary>public void DeleteAll(){foreach (var inst in this._db.GetGridFS(MongoGridFSSettings.Defaults).FindAll()){inst.Delete();}} #endregion}
}

3、創建實體 User.cs

using MongoDB.Bson;
namespace MongoHelper.Model
{public class User{public ObjectId _id;public string name { get; set; }public int age { get; set; }}
}

4、調用示例代碼

var list = new List<User>();for (int i = 0; i < 100; i++){User user = new User();user.age = 20 + i;user.name = "測試" + i;list.Add(user);}//新增實體//tool.Add(list);//更新實體//tool.UpdateEntity<User>("name", "測試", "age", "99");//刪除操作//tool.DelEntity<User>("name","測試");long total = 0;//構造查詢條件IMongoQuery query = Query.And(Query.Matches("name", "1"));//分頁查詢數據var ll = tool.FindMoreForPageByCondion<User>(query, 0, 10, ref total);// 文件操作var model = tool.FindAllMore<User>();string folder = @"E:\photo";DirectoryInfo di = new DirectoryInfo(folder);//循環讀取文件上傳foreach (var file in di.GetFiles()){tool.UploadFile(file.FullName, file.Name);}var fileModel = tool.FindAll().First();// 保存文件指定目錄tool.DownloadFileOther("D:\\"+fileModel.Name, fileModel.Name);//下載文件到當前目錄pictureBox1.ImageLocation = "D:\\"+fileModel.Name;

具體的代碼地址：https://gitee.com/hgm1989/mongodb-demo

如有問題可以隨時溝通交流。

IT技術分享社區

個人博客網站：https://programmerblog.xyz