废话不说直接上代码；
using MongoDB.Bson.Serialization.Attributes;namespace XL.Core.MongoDB{public interface IEntity{/// /// 主键/// [BsonId] TKey Id { get; set; } }}
View Code
[BsonIgnoreExtraElements(Inherited = true)]public abstract class Entity : IEntity{/// /// 主键/// [BsonRepresentation(BsonType.ObjectId)]public virtual string Id { get; set; } }
View Code
public interface IRepository : IQueryable where T : IEntity{#region Fileds/// /// MongoDB表/// IMongoCollection DbSet { get; }/// /// MongoDB库/// IMongoDatabase DbContext { get; }#endregion#region Find/// /// 根据主键获取对象/// /// /// T GetById(TKey id);/// /// 获取对象/// /// /// IEnumerable Get(Expression<Func> predicate);/// /// 获取对象/// /// /// /// Task<IEnumerable> GetAsync(Expression<Func> predicate, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Insert/// /// 插入文档/// /// /// T Insert(T entity);/// /// 异步插入文档/// /// /// /// Task InsertAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));/// /// Adds the new entities in the repository./// /// The entities of type T.void Insert(IEnumerable entities);/// /// 插入文档/// /// /// /// Task InsertAsync(IEnumerable entities, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Update/// /// 更新文档/// /// /// UpdateResult Update(T entity);/// /// 异步更新文档/// /// /// /// Task UpdateAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Delete/// /// 根据主键ID/// /// /// T Delete(TKey id);/// /// 异步根据ID删除文档/// /// /// /// Task DeleteAsync(TKey id, CancellationToken cancellationToken = default(CancellationToken));/// /// 异步删除/// /// /// /// Task DeleteAsync(Expression<Func> predicate, CancellationToken cancellationToken = default(CancellationToken));/// /// 删除/// /// /// DeleteResult Delete(Expression<Func> predicate);#endregion#region Other/// /// 计数/// /// /// long Count(Expression<Func> predicate);/// /// 计数/// /// /// /// Task CountAsync(Expression<Func> predicate, CancellationToken cancellationToken = new CancellationToken());/// /// 是否存在/// /// /// bool Exists(Expression<Func> predicate);#endregion#region Query/// /// 分页/// 注：只适合单属性排序/// /// /// /// /// /// IEnumerable Paged(Expression<Func> predicate, Expression<Func> sortBy,int pageSize, int pageIndex = 1);/// /// /// /// /// /// /// /// /// Task<List> PagedAsync(Expression<Func> predicate, Expression<Func> sortBy,int pageSize, int pageIndex = 1, CancellationToken cancellationToken = new CancellationToken());#endregion} public interface IRepository : IRepositorywhere T : IEntity{ }
View Code
public class MongoRepository : IRepository where T : IEntity{#region Constructorprotected MongoRepository(IMongoCollection collection) { DbSet = collection; DbContext = collection.Database; }#endregionpublic IEnumerator GetEnumerator() {return DbSet.AsQueryable().GetEnumerator(); } IEnumerator IEnumerable.GetEnumerator() {return GetEnumerator(); }#region 字段public Type ElementType => DbSet.AsQueryable().ElementType;public Expression Expression => DbSet.AsQueryable().Expression;public IQueryProvider Provider => DbSet.AsQueryable().Provider;public IMongoCollection DbSet { get; }public IMongoDatabase DbContext { get; }#endregion#region Findpublic T GetById(string id) {return Get(a => a.Id.Equals(id)).FirstOrDefault(); }public IEnumerable Get(Expression<Func> predicate) {return DbSet.FindSync(predicate).Current; }public async Task<IEnumerable> GetAsync(Expression<Func> predicate, CancellationToken cancellationToken = new CancellationToken()) {var task = await DbSet.FindAsync(predicate, null, cancellationToken);return task.Current; }#endregion#region Insertpublic T Insert(T entity) { DbSet.InsertOne(entity);return entity; }public Task InsertAsync(T entity, CancellationToken cancellationToken = new CancellationToken()) {return DbSet.InsertOneAsync(entity, null, cancellationToken); }public void Insert(IEnumerable entities) { DbSet.InsertMany(entities); }public Task InsertAsync(IEnumerable entities, CancellationToken cancellationToken = new CancellationToken()) {return DbSet.InsertManyAsync(entities, null, cancellationToken); }#endregion#region Updatepublic UpdateResult Update(T entity) {var doc = entity.ToBsonDocument();return DbSet.UpdateOne(Builders.Filter.Eq(e => e.Id, entity.Id),new BsonDocumentUpdateDefinition(doc)); }public Task UpdateAsync(T entity, CancellationToken cancellationToken = new CancellationToken()) {var doc = entity.ToBsonDocument();return DbSet.UpdateOneAsync(Builders.Filter.Eq(e => e.Id, entity.Id),new BsonDocumentUpdateDefinition(doc), cancellationToken: cancellationToken); }#endregion#region Deletepublic T Delete(string id) {return DbSet.FindOneAndDelete(a => a.Id.Equals(id)); }public Task DeleteAsync(string id, CancellationToken cancellationToken = new CancellationToken()) {return DbSet.FindOneAndDeleteAsync(a => a.Id.Equals(id), null, cancellationToken); }public Task DeleteAsync(Expression<Func> predicate, CancellationToken cancellationToken = new CancellationToken()) {return DbSet.DeleteManyAsync(predicate, cancellationToken); }public DeleteResult Delete(Expression<Func> predicate) {return DbSet.DeleteMany(predicate); }#endregion#region Otherpublic long Count(Expression<Func> predicate) {return DbSet.Count(predicate); }public Task CountAsync(Expression<Func> predicate, CancellationToken cancellationToken = new CancellationToken()) {return DbSet.CountAsync(predicate, null, cancellationToken); }public bool Exists(Expression<Func> predicate) {return Get(predicate).Any(); }#endregion#region Pagepublic IEnumerable Paged(Expression<Func> predicate, Expression<Func> sortBy,int pageSize, int pageIndex = 1) {var sort = Builders.Sort.Descending(sortBy);return DbSet.Find(predicate).Sort(sort).Skip(pageSize * pageIndex - 1).Limit(pageSize).ToList(); }public Task<List> PagedAsync(Expression<Func> predicate, Expression<Func> sortBy,int pageSize, int pageIndex = 1, CancellationToken cancellationToken = new CancellationToken()) {return Task.Run(() =>{var sort = Builders.Sort.Descending(sortBy);return DbSet.Find(predicate).Sort(sort).Skip(pageSize * pageIndex - 1).Limit(pageSize).ToList(); }, cancellationToken); }#endregion#region Helper/// /// 获取类型的所有属性信息/// /// /// /// /// private PropertyInfo[] GetPropertyInfos(Expression<Func> select) {var body = select.Body;switch (body.NodeType) {case ExpressionType.Parameter:var parameterExpression = body as ParameterExpression;if (parameterExpression != null) return parameterExpression.Type.GetProperties();break;case ExpressionType.New:var newExpression = body as NewExpression;if (newExpression != null)return newExpression.Members.Select(m => m as PropertyInfo).ToArray();break; }return null; }#endregion}
View Code
使用如下：
public class MongoDBSetting {public string DataBase { get; set; }public string UserName { get; set; }public string Password { get; set; }public List Services { get; set; } }public class MongoServers {public string Host { get; set; }public int Port { get; set; } = 27017; }
View Code
public class LogsContext {private readonly IMongoDatabase _db;public LogsContext(IOptions options) {var permissionSystem =MongoCredential.CreateCredential(options.Value.DataBase, options.Value.UserName, options.Value.Password);var services = new List();foreach (var item in options.Value.Services) { services.Add(new MongoServerAddress(item.Host, item.Port)); }var settings = new MongoClientSettings { Credentials = new[] {permissionSystem}, Servers = services };var _mongoClient = new MongoClient(settings); _db = _mongoClient.GetDatabase(options.Value.DataBase); }public IMongoCollection ErrorLog => _db.GetCollection("Error");public IMongoCollection WarningLog => _db.GetCollection("Warning"); }
View Code
public static IServiceCollection UserMongoLog(this IServiceCollection services, IConfigurationSection configurationSection) { services.Configure(configurationSection); services.AddSingleton();return services; }
View Code
public interface IErrorLogService : IRepository{ }public class ErrorLogService : MongoRepository, IErrorLogService {public ErrorLogService(LogsContext dbContext) : base(dbContext.ErrorLog) { } }
View Code
最后：
services.UserMongoLog(Configuration.GetSection("Mongo.Log"));
View Code
"Mongo.Log": {"DataBase": "PermissionSystem","UserName": "sa","Password": "shtx@123","Services": [ {"Host": "192.168.1.6","Port": "27017" } ] }
View Code
刚学洗使用MongoDB，才疏学浅，请大神多多指教
以上就是关于Asp.Net Core MongoDB的实例代码的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1432437.html
微信扫一扫 
支付宝扫一扫 
