关于我们

质量为本、客户为根、勇于拼搏、务实创新

< 返回新闻公共列表

云南大王-C#操作MongoDB的帮助类

发布时间:2020-04-13 00:00:00
  之前做项目,需要记录一些请求URL,响应时间,异常日志,变更日志等信息,项目本身用的是Sql Server,考虑到这些信息增长速度快,占用空间大,且平时除了统计下网站信息,查看下日志,并不会进行关联查询和操作,所以决定这些信息不配录入我的主库,当时百度上看了看,发现MongoDB不错,所以用了2个小时研究了下,就写入项目中了。。。   好了,不多说,直接把DLL和代码记下来,以便以后直接使用。   C#版的MongoDB驱动是用官方提供的mongo-csharp-driver   具体下载地址:http://github.com/mongodb/mongo-csharp-driver/downloads   引用:MongoDB.Driver.dll,MongoDB.Bson.dll      具体代码部分: /// /// MongoDB帮助类 /// public class MongoDBHelper { /// /// 数据库连接字符串 /// private const string strconn = "mongodb://127.0.0.1:27017"; /// /// 数据库名称 /// private const string dbName = "pxdnet"; MongoServer server = new MongoClient(strconn).GetServer(); static MongoDatabase db; /// /// 构造函数 /// public MongoDBHelper() { if(db == null) { db = server.GetDatabase(dbName); } } /// /// 获取数据库 /// /// public static MongoDatabase GetDB() { return new MongoClient(strconn).GetServer().GetDatabase(dbName); } /// /// 新增 /// /// /// public static T Add(T entity) { var col = GetDB().GetCollection(typeof(T).Name); col.Insert(entity); return entity; } /// /// 编辑 /// /// /// /// public static void Update(T entity, ObjectId id) { var col = GetDB().GetCollection(typeof(T).Name); BsonDocument bsd = BsonExtensionMethods.ToBsonDocument(entity); IMongoQuery query = Query.EQ("_id", id); col.Update(query, new UpdateDocument(bsd)); } /// /// 删除 /// remark:条件删除 /// /// /// public static void Delete(Dictionary dics) { var col = GetDB().GetCollection(typeof(T).Name); var query = new QueryDocument(dics); var result = col.Remove(query); } /// /// 删除 /// remark:根据ObjectId删除 /// /// /// public static void Delete(ObjectId id) { var col = GetDB().GetCollection(typeof(T).Name); IMongoQuery query = Query.EQ("_id", id); col.Remove(query); } /// /// 查询全部 /// /// /// public static List QueryList() { var col = GetDB().GetCollection(typeof(T).Name); var result = col.FindAllAs(); return result.ToList(); } /// /// 根据条件查询 /// /// /// /// public static List QueryList(Dictionary dics) { var col = GetDB().GetCollection(typeof(T).Name); var query = new QueryDocument(dics); var result = col.FindAs(query); return result.ToList(); } } View Code     由于用到的功能不多,主要是插入和查询,偶尔记录下响应时间会用到更新操作,所以简单的封装了增删改查,如果需要更多其他操作的朋友,可以看下这篇帖子,介绍的挺全的。   https://www.cnblogs.com/cuihongyu3503319/p/9354209.html

/template/Home/Zkeys/PC/Static