MongoDB 是一個(gè)基于分布式文件存儲(chǔ)的數(shù)據(jù)庫。由 C++ 語言編寫。旨在為 WEB 應(yīng)用提供可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)解決方案。今天主要給大家介紹一下C#編程語言下Mongodb的用法。開發(fā)環(huán)境為VS2015示例主要包括數(shù)據(jù)的增刪改查、分頁查詢、文件存儲(chǔ)等功能。有需要的朋友可以一起學(xué)習(xí)一下。

1、需要引用Mongodb程序集

MongoDB.Bson.dll

MongoDB.Driver.dll

2、創(chuàng)建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;//數(shù)據(jù)庫默認(rèn)地址private readonly string host = ConfigurationManager.AppSettings["db_host"];//數(shù)據(jù)庫默認(rèn)名稱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); //數(shù)據(jù)庫名稱}#region 通用增刪改查/// <summary>/// 新增單個(gè)實(shí)體模型 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>/// 新增實(shí)體集合模型/// </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>/// 查詢單條數(shù)據(jù)/// </summary>/// <typeparam name="T"></typeparam>/// <param name="Field">查詢屬性字段</param>/// <param name="Value">字段值</param>/// <returns>返回當(dāng)前實(shí)體</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>/// 查詢多條數(shù)據(jù)/// </summary>/// <typeparam name="T"></typeparam>/// <param name="Field">查詢屬性字段</param>/// <param name="Value">字段值</param>/// <returns>返回當(dāng)前實(shí)體集合</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>/// 查詢文檔所有數(shù)據(jù)/// </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">每頁顯示記錄數(shù)</param>/// <param name="total">總記錄數(shù)</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(); //獲取總記錄數(shù)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(); //獲取最后一個(gè)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">當(dāng)前頁</param>/// <param name="rows">行數(shù)</param>/// <param name="totalCount">總行數(shù)</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">每頁顯示記錄數(shù)</param>/// <param name="total">總記錄數(shù)</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();//獲取總記錄數(shù)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(); //獲取最后一個(gè)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>/// 更新實(shí)體單個(gè)字段值/// </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>/// 更新整個(gè)實(shí)體模型字段/// </summary>/// <typeparam name="T">泛型參數(shù)</typeparam>/// <param name="whereField">條件字段</param>/// <param name="whereValue">條件值</param>/// <param name="updateEntity">實(shí)體模型</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>/// 刪除實(shí)體文檔/// </summary>/// <typeparam name="T">泛型參數(shù)</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>///下載文件保存到默認(rèn)目錄/// </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、創(chuàng)建實(shí)體 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、調(diào)用示例代碼

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);}//新增實(shí)體//tool.Add(list);//更新實(shí)體//tool.UpdateEntity<User>("name", "測試", "age", "99");//刪除操作//tool.DelEntity<User>("name","測試");long total = 0;//構(gòu)造查詢條件IMongoQuery query = Query.And(Query.Matches("name", "1"));//分頁查詢數(shù)據(jù)var ll = tool.FindMoreForPageByCondion<User>(query, 0, 10, ref total);// 文件操作var model = tool.FindAllMore<User>();string folder = @"E:\photo";DirectoryInfo di = new DirectoryInfo(folder);//循環(huán)讀取文件上傳foreach (var file in di.GetFiles()){tool.UploadFile(file.FullName, file.Name);}var fileModel = tool.FindAll().First();// 保存文件指定目錄tool.DownloadFileOther("D:\\"+fileModel.Name, fileModel.Name);//下載文件到當(dāng)前目錄pictureBox1.ImageLocation = "D:\\"+fileModel.Name;

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

如有問題可以隨時(shí)溝通交流。

IT技術(shù)分享社區(qū)

個(gè)人博客網(wǎng)站：https://programmerblog.xyz

文章推薦程序員效率：畫流程圖常用的工具程序員效率：整理常用的在線筆記軟件遠(yuǎn)程辦公：常用的遠(yuǎn)程協(xié)助軟件，你都知道嗎？51單片機(jī)程序下載、ISP及串口基礎(chǔ)知識硬件：斷路器、接觸器、繼電器基礎(chǔ)知識

總結(jié)

以上是生活随笔為你收集整理的后端：C#操作Mongodb用法笔记的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。