using System; using System.Collections.Generic; using System.Linq; using System.Text; using MongoDB.Driver; namespace TalentCloud.Base.MongodbHelper { public class MongodbHelper { public void Demo() { MongodbHelper MongodbHelper = new MongodbHelper(); UsersInfo UsersInfo = new UsersInfo(); UsersInfo.Name = "ads"; UsersInfo.Sex = "男"; MongodbHelper.Insert<UsersInfo>(MongoEnum.MongoDbEnum.LoginUserInfo, "UsersInfo", UsersInfo); List<UsersInfo> aa = MongodbHelper.Query<UsersInfo>(MongoEnum.MongoDbEnum.LoginUserInfo, "UsersInfo"); MongodbHelper.Update(MongoEnum.MongoDbEnum.LoginUserInfo, "UsersInfo", MongodbHelper.NewFilter("Name", "ssn2"), MongodbHelper.NewUpdate("Name", "ssn3")); List<UsersInfo> aa2 = MongodbHelper.Query<UsersInfo>(MongoEnum.MongoDbEnum.LoginUserInfo, "UsersInfo", MongodbHelper.NewFilter("Name", "ssn2")); List<UsersInfo> aa1 = MongodbHelper.Query<UsersInfo>(MongoEnum.MongoDbEnum.LoginUserInfo, "UsersInfo"); MongodbHelper.Delete(MongoEnum.MongoDbEnum.LoginUserInfo, "UsersInfo", MongodbHelper.NewFilter("Name", "ssn")); } /// <summary> /// 插入数据 /// </summary> /// <typeparam name="T">泛型数据</typeparam> /// <param name="dbName">插入的数据库</param> /// <param name="ObjName">插入的对象名，类似表名</param> /// <param name="data">数据对象</param> public void Insert<T>(string dbName, string ObjName, T data) { MongoDatabase db = MongodbUtil.GetMongodbDatabase(dbName); //获得Users集合,如果数据库中没有，先新建一个 MongoCollection MongoCollection = db.GetCollection(ObjName); //执行插入操作 MongoCollection.Insert<T>(data); } /// <summary> /// 更新数据 /// </summary> /// <param name="dbName"></param> /// <param name="ObjName"></param> /// <param name="query"> 定义获取“Name”值为“xumingxiang”的查询条件 var query = new QueryDocument { { "Name", "xumingxiang" } };</param> /// <param name="update"> 定义更新文档 var update = new UpdateDocument { { "$set", new QueryDocument { { "Sex", "wowen" } } } };</param> /// 注意：千万要注意查询条件和数据库内的字段类型保持一致，否则将无法查找到数据。如：如果Sex是整型，一点要记得将值转换为整型。 public void Update(string dbName, string ObjName, QueryDocument query, UpdateDocument update) { MongoDatabase db = MongodbUtil.GetMongodbDatabase(dbName); //获取Users集合 MongoCollection MongoCollection = db.GetCollection(ObjName); //执行更新操作 MongoCollection.Update(query, update); } /// <summary> /// 删除数据 /// </summary> /// <param name="dbName"></param> /// <param name="ObjName"></param> /// <param name="query"> 定义获取“Name”值为“xumingxiang”的查询条件 var query = new QueryDocument { { "Name", "xumingxiang" } };</param> public void Delete(string dbName, string ObjName, QueryDocument query) { MongoDatabase db = MongodbUtil.GetMongodbDatabase(dbName); //获取Users集合 MongoCollection MongoCollection = db.GetCollection(ObjName); //执行删除操作 MongoCollection.Remove(query); } /// <summary> /// 查询全部数据 /// </summary> /// <param name="dbName">需要查询的库</param> public List<T> Query<T>(string dbName, string ObjName) { MongoDatabase db = MongodbUtil.GetMongodbDatabase(dbName); //获取Users集合 MongoCollection col = db.GetCollection(ObjName); //查询全部集合里的数据 return col.FindAllAs<T>().ToList(); } /// <summary> /// 查询指定查询条件的全部数据 /// </summary> /// <param name="dbName">需要查询的库</param> /// <param name="query">查询条件 var query = new QueryDocument { { "Name", "xumingxiang" } };</param> public List<T> Query<T>(string dbName, string ObjName, QueryDocument query) { MongoDatabase db = MongodbUtil.GetMongodbDatabase(dbName); //获取Users集合 MongoCollection col = db.GetCollection(ObjName); //查询指定查询条件的全部数据 return col.FindAs<T>(query).ToList(); ; } /// <summary> /// 查询指定查询条件的第一条数据 /// </summary> /// <param name="dbName">需要查询的库</param> /// <param name="query">查询条件 var query = new QueryDocument { { "Name", "xumingxiang" } };</param> public T QueryOne<T>(string dbName, string ObjName, QueryDocument query) { MongoDatabase db = MongodbUtil.GetMongodbDatabase(dbName); //获取Users集合 MongoCollection col = db.GetCollection(ObjName); //查询指定查询条件的全部数据 return col.FindOneAs<T>(query); ; } /// <summary> /// 创建查询条件 /// </summary> /// <returns></returns> public QueryDocument NewFilter(string key,string value) { return new QueryDocument { { key, value } }; } /// <summary> /// 创建更新条件 /// </summary> /// <returns></returns> public UpdateDocument NewUpdate(string key, string value) { return new UpdateDocument { { "$set", new QueryDocument { { key, value } } } }; } } }
using System; using System.Collections.Generic; using System.Linq; using System.Text; using MongoDB.Bson; using MongoDB.Driver; using System.Configuration; namespace TalentCloud.Base.MongodbHelper { public class MongodbUtil { public static string MongodbConnection { get {
//mongodb://127.0.0.1:27017 return ConfigurationManager.AppSettings["MongodbConnection"].ToString(); } } /// <summary> /// 获取MongoClient /// </summary> /// <returns></returns> public static MongoServer GetMongoServer() { //创建数据库链接 return MongoServer.Create(MongodbConnection); } /// <summary> /// 获取MongoServer /// </summary> /// <returns></returns> public static MongoServer GetMongoServer(string Connection) { //创建数据库链接 return MongoServer.Create(Connection); } //获取DbBase public static MongoDatabase GetMongodbDatabase(string dbName) { MongoServer MongoServer = GetMongoServer(); //获得数据库cnblogs MongoDatabase DbBase = MongoServer.GetDatabase(dbName); return DbBase; } } }
支持.net4.0
https://files.cnblogs.com/files/yyyuguo/mongodbDll.zip