?
C#操作MongoDB帮助类(二)
lectionName);
var result = new PagingList();
result.Total = (int)collection.Count(query);
result.CurrentPageList =
collection.Find(query).SetSortOrder(sortBy).SetSkip((pageIndex - 1)*pageSize).SetLimit(pageSize).ToList();
return result;
}
///
/// 获取集合中的所有数据
///
/// 数据类型
/// 数据库连接串
/// 数据库名称
/// 集合名称
/// 数据对象集合
public static List GetAll(string connectionString, string dbName, string collectionName)
where T : EntityBase
{
var db = GetDatabase(connectionString, dbName);
var collection = db.GetCollection(collectionName);
return collection.FindAll().ToList();
}
5、删除数据
////// 删除集合中符合条件的数据 /// /// 数据库连接串 /// 数据库名称 /// 集合名称 /// 查询条件 public static void DeleteByCondition(string connectionString, string dbName, string collectionName, IMongoQuery query) { var db = GetDatabase(connectionString, dbName); var collection = db.GetCollection(collectionName); collection.Remove(query); } ////// 删除集合中的所有数据 /// /// 数据库连接串 /// 数据库名称 /// 集合名称 public static void DeleteAll(string connectionString, string dbName, string collectionName) { var db = GetDatabase(connectionString, dbName); var collection = db.GetCollection(collectionName); collection.RemoveAll(); }
?
?