C#使用Mongodb方法

资料来源：网络整理时间：2023/2/14 0:43:35 共计：3603 浏览

封装好的增删改查方法：

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.Attributes; using System.Linq.Expressions; namespace Langu.DbHelper { /// <summary> /// MongoDb 数据库操作类 /// </summary> public class MongoHelper<T> where T : BaseEntity { /// <summary> /// 数据库对象 /// </summary> private IMongoDatabase database; /// <summary> /// 构造函数 /// </summary> /// <param name="conString">连接字符串</param> public MongoHelper(String conString) { var url = new MongoUrl(conString); MongoClientSettings mcs = MongoClientSettings.FromUrl(url); mcs.MaxConnectionLifeTime = TimeSpan.FromMilliseconds(1000); var client = new MongoClient(mcs); this.database = client.GetDatabase(url.DatabaseName); } /// <summary> /// 创建集合对象 /// </summary> /// <param name="collName">集合名称</param> ///<returns>集合对象</returns> private IMongoCollection<T> GetColletion(String collName) { return database.GetCollection<T>(collName); } #region 增加 /// <summary> /// 插入对象 /// </summary> /// <param name="collName">集合名称</param> /// <param name="t">插入的对象</param> public void Insert(String collName, T t) { var coll = GetColletion(collName); coll.InsertOne(t); } /// <summary> /// 批量插入 /// </summary> /// <param name="collName">集合名称</param> /// <param name="ts">要插入的对象集合</param> public void InsertBath(String collName, IEnumerable<T> ts) { var coll = GetColletion(collName); coll.InsertMany(ts); } #endregion #region 删除 /// <summary> /// 按BsonDocument条件删除 /// </summary> /// <param name="collName">集合名称</param> /// <param name="document">文档</param> /// <returns></returns> public Int64 Delete(String collName, BsonDocument document) { var coll = GetColletion(collName); var result = coll.DeleteOne(document); return result.DeletedCount; } /// <summary> /// 按json字符串删除 /// </summary> /// <param name="collName">集合名称</param> /// <param name="json">json字符串</param> /// <returns></returns> public Int64 Delete(String collName, String json) { var coll = GetColletion(collName); var result = coll.DeleteOne(json); return result.DeletedCount; } /// <summary> /// 按条件表达式删除 /// </summary> /// <param name="collName">集合名称</param> /// <param name="predicate">条件表达式</param> /// <returns></returns> public Int64 Delete(String collName, Expression<Func<T, Boolean>> predicate) { var coll = GetColletion(collName); var result = coll.DeleteOne(predicate); return result.DeletedCount; } /// <summary> /// 按检索条件删除 /// 建议用Builders<T>构建复杂的查询条件 /// </summary> /// <param name="collName">集合名称</param> /// <param name="filter">条件</param> /// <returns></returns> public Int64 Delete(String collName, FilterDefinition<T> filter) { var coll = GetColletion(collName); var result = coll.DeleteOne(filter); return result.DeletedCount; } #endregion #region 修改 /// <summary> /// 修改文档 /// </summary> /// <param name="collName">集合名称</param> /// <param name="filter">修改条件</param> /// <param name="update">修改结果</param> /// <param name="upsert">是否插入新文档（filter条件满足就更新，否则插入新文档）</param> /// <returns></returns> public Int64 Update(String collName, Expression<Func<T, Boolean>> filter, UpdateDefinition<T> update, Boolean upsert = false) { var coll = GetColletion(collName); var result = coll.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert }); return result.ModifiedCount; } /// <summary> /// 用新对象替换新文档 /// </summary> /// <param name="collName">集合名称</param> /// <param name="filter">修改条件</param> /// <param name="t">新对象</param> /// <param name="upsert">是否插入新文档（filter条件满足就更新，否则插入新文档）</param> /// <returns>修改影响文档数</returns> public Int64 Update(String collName, Expression<Func<T, Boolean>> filter, T t, Boolean upsert = false) { var coll = GetColletion(collName); BsonDocument document = t.ToBsonDocument<T>(); document.Remove("_id"); UpdateDocument update = new UpdateDocument("$set", document); var result = coll.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert }); return result.ModifiedCount; } #endregion /// <summary> /// 查询，复杂查询直接用Linq处理 /// </summary> /// <param name="collName">集合名称</param> /// <returns>要查询的对象</returns> public IQueryable<T> GetQueryable(String collName) { var coll = GetColletion(collName); return coll.AsQueryable<T>(); } #region 查询 #endregion } /// <summary> /// 实体基类，方便生成_id /// </summary> public class BaseEntity { [BsonRepresentation(BsonType.ObjectId)] public String Id { get; set; } /// <summary> /// 给对象初值 /// </summary> public BaseEntity() { this.Id = ObjectId.GenerateNewId().ToString(); } } } 调用方法：

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using Langu.DbHelper; using System.Threading; using System.Linq.Expressions; using MongoDB.Driver; namespace Client { class Program { static void Main(string[] args) { //连接字符串 127.0.0.1 服务器IP 27100 mongodb服务端口号 mydb 数据库名称 String conString = "mongodb://127.0.0.1:27100/mydb"; //实例化MongoHelper对象（泛型版本），构造函数要求传入连接字符串 MongoHelper<User> mongoHelper = new MongoHelper<User>(conString); //查询集合 user中有多少数据量 var cnt = mongoHelper.GetQueryable("user").Count(); Console.WriteLine(cnt); Console.ReadKey(); } } internal class User : BaseEntity { public int Age { get; set; } public String Name { get; set; } } }

版权说明：
本网站凡注明“广州京杭原创”的皆为本站原创文章，如需转载请注明出处！
本网转载皆注明出处，遵循行业规范，如发现作品内容版权或其它问题的，请与我们联系处理！
欢迎扫描右侧微信二维码与我们联系。

·上一条：MongoDB Windows环境安装及配置 | ·下一条：C# Mongodb 封装类