如何在.Net中使用MongoDB

首先在项目中引入 MongoDB.Bson.dll，MongoDB.Driver.dll,MongoDB.Driver.Core.dll 我使用的是2.0版本的现在好多文章都是介绍使用1+版本的这也是我写此文的目的引入驱动DLL后，就可以开始撸代码了
部分代码如下
private static MongoClient client;private static IMongoDatabase database;//本地配置private const string MongoDBConnectionStr = "mongodb://localhost";//数据库名称private static string DefaultDataBaseName = "Test"; public MongoDBHelper(){ GetConnection(DefaultDataBaseName);} /// <summary>/// 构造函数指定数据库/// </summary>/// <param name="dataBaseName"></param>public MongoDBHelper(string dataBaseName){ GetConnection(dataBaseName);} private static void GetConnection(string dataBaseName){ client = new MongoClient(MongoDBConnectionStr); database = client.GetDatabase(dataBaseName);} /// <summary>/// 异步插入一条数据，手动输入collection name/// </summary>public Task InsertAsync<T>(string collectionName, T obj){ if (database == null) { throw new Exception("没有指定数据库"); } var collection = database.GetCollection<T>(collectionName); return collection.InsertOneAsync(obj);} /// <summary>/// 异步插入一条数据，采用类型T的完全限定名作为collection name/// </summary>public Task InsertAsync<T>(T obj){ return InsertAsync(typeof(T).FullName, obj);} /// <summary>/// 异步插入多条数据，手动输入collection name/// </summary>public Task BatchInsertAsync<T>(string collectionName, IEnumerable<T> objs){ if (database == null) { throw new Exception("没有指定数据库"); } if (objs == null) { throw new ArgumentException(); } var collection = database.GetCollection<T>(collectionName); return collection.InsertManyAsync(objs);} /// <summary>/// 异步插入多条数据，采用类型T的完全限定名作为collection name/// </summary>public Task BatchInsertAsync<T>(IEnumerable<T> objs){ return BatchInsertAsync(typeof(T).FullName, objs);} /// <summary>/// 插入一条数据/// </summary>public void Insert<T>(T obj){ InsertAsync(obj).Wait();} /// <summary>/// 插入多条数据/// </summary>public void Insert<T>(IEnumerable<T> objs){ BatchInsertAsync(objs).Wait();} /// <summary>/// MongoDB C# Driver的Find方法，返回IFindFluent。手动输入collection name/// </summary>public IFindFluent<T, T> Find<T>(string collectionName, FilterDefinition<T> filter, FindOptions options = null){ if (database == null) { throw new Exception("没有指定数据库"); } var collection = database.GetCollection<T>(collectionName); return collection.Find(filter, options);} /// <summary>/// MongoDB C# Driver的Find方法，返回IFindFluent。采用类型T的完全限定名作为collection name/// </summary>public IFindFluent<T, T> Find<T>(FilterDefinition<T> filter, FindOptions options = null){ return Find(typeof(T).FullName, filter, options);} /// <summary>/// 取符合条件的数据 sort中多个排序条件逗号分隔，默认asc/// </summary>public List<T> Get<T>(Expression<Func<T, bool>> condition, int skip, int limit, string sort){ return Get(new List<Expression<Func<T, bool>>> { condition }, skip, limit, sort);} public List<T> Get<T>(Expression<Func<T, bool>> condition){ return Get(condition, 0, 0, null);} /// <summary>/// 取符合条件的数据 sort中多个排序条件逗号分隔，默认asc/// </summary>public List<T> Get<T>(List<Expression<Func<T, bool>>> conditions, int skip, int limit, string sort){ if (conditions == null || conditions.Count == 0) { conditions = new List<Expression<Func<T, bool>>> { x => true }; } var builder = Builders<T>.Filter; var filter = builder.And(conditions.Select(x => builder.Where(x))); var ret = new List<T>(); try { List<SortDefinition<T>> sortDefList = new List<SortDefinition<T>>(); if (sort != null) { var sortList = sort.Split(','); for (var i = 0; i < sortList.Length; i++) { var sl = Regex.Replace(sortList[i].Trim(), @"\s+", " ").Split(' '); if (sl.Length == 1 || (sl.Length >= 2 && sl[1].ToLower() == "asc")) { sortDefList.Add(Builders<T>.Sort.Ascending(sl[0])); } else if (sl.Length >= 2 && sl[1].ToLower() == "desc") { sortDefList.Add(Builders<T>.Sort.Descending(sl[0])); } } } var sortDef = Builders<T>.Sort.Combine(sortDefList); ret = Find(filter).Sort(sortDef).Skip(skip).Limit(limit).ToListAsync().Result; } catch (Exception e) { //异常处理 } return ret;} public List<T> Get<T>(List<Expression<Func<T, bool>>> conditions){ return Get(conditions, 0, 0, null);}

您可能感兴趣问答

Collapsible

热门标签

热点问答