關於Asp.Net Core MongoDB的實例代碼

廢話不說直接上程式碼；

using MongoDB.Bson.Serialization.Attributes;namespace XL.Core.MongoDB
{public interface IEntity<tkey>{/// <summary>/// 主键/// </summary>        [BsonId]
        TKey Id { get; set; }
    }
}</tkey>

View Code

    [BsonIgnoreExtraElements(Inherited = true)]public abstract class Entity : IEntity<string>{/// <summary>/// 主键/// </summary>        [BsonRepresentation(BsonType.ObjectId)]public virtual string Id { get; set; }
        
    }</string>

View Code

#

    public interface IRepository<t> : IQueryable<t> where T : IEntity<tkey>{#region Fileds/// <summary>/// MongoDB表/// </summary>IMongoCollection<t> DbSet { get; }/// <summary>/// MongoDB库/// </summary>IMongoDatabase DbContext { get; }#endregion#region Find/// <summary>/// 根据主键获取对象/// </summary>/// <param>/// <returns></returns>        T GetById(TKey id);/// <summary>/// 获取对象/// </summary>/// <param>/// <returns></returns>IEnumerable<t> Get(Expression<func>> predicate);/// <summary>/// 获取对象/// </summary>/// <param>/// <param>/// <returns></returns>Task<ienumerable>> GetAsync(Expression<func>> predicate,
            CancellationToken cancellationToken = default(CancellationToken));#endregion#region Insert/// <summary>/// 插入文档/// </summary>/// <param>/// <returns></returns>        T Insert(T entity);/// <summary>/// 异步插入文档/// </summary>/// <param>/// <param>/// <returns></returns>Task InsertAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));/// <summary>///     Adds the new entities in the repository./// </summary>/// <param>The entities of type T.void Insert(IEnumerable<t> entities);/// <summary>/// 插入文档/// </summary>/// <param>/// <param>/// <returns></returns>Task InsertAsync(IEnumerable<t> entities, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Update/// <summary>/// 更新文档/// </summary>/// <param>/// <returns></returns>        UpdateResult Update(T entity);/// <summary>/// 异步更新文档/// </summary>/// <param>/// <param>/// <returns></returns>Task<updateresult> UpdateAsync(T entity, CancellationToken cancellationToken = default(CancellationToken));#endregion#region Delete/// <summary>/// 根据主键ID/// </summary>/// <param>/// <returns></returns>        T Delete(TKey id);/// <summary>/// 异步根据ID删除文档/// </summary>/// <param>/// <param>/// <returns></returns>Task<t> DeleteAsync(TKey id, CancellationToken cancellationToken = default(CancellationToken));/// <summary>/// 异步删除/// </summary>/// <param>/// <param>/// <returns></returns>Task<deleteresult> DeleteAsync(Expression<func>> predicate,
            CancellationToken cancellationToken = default(CancellationToken));/// <summary>/// 删除/// </summary>/// <param>/// <returns></returns>DeleteResult Delete(Expression<func>> predicate);#endregion#region Other/// <summary>/// 计数/// </summary>/// <param>/// <returns></returns>long Count(Expression<func>> predicate);/// <summary>/// 计数/// </summary>/// <param>/// <param>/// <returns></returns>Task<long> CountAsync(Expression<func>> predicate,
            CancellationToken cancellationToken = new CancellationToken());/// <summary>/// 是否存在/// </summary>/// <param>/// <returns></returns>bool Exists(Expression<func>> predicate);#endregion#region Query/// <summary>/// 分页/// 注：只适合单属性排序/// </summary>/// <param>/// <param>/// <param>/// <param>/// <returns></returns>IEnumerable<t> Paged(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1);/// <summary>/// /// </summary>/// <param>/// <param>/// <param>/// <param>/// <param>/// <returns></returns>Task<list>> PagedAsync(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1,
            CancellationToken cancellationToken = new CancellationToken());#endregion}  public interface IRepository<t> : IRepository<t>where T : IEntity<string>{
    }</string></t></t></func></func></list></func></func></t></func></func></long></func></func></func></deleteresult></t></updateresult></t></t></func></ienumerable></func></t></t></tkey></t></t>

1-View Code

########################################################################################################################################## ######

  public class MongoRepository<t> : IRepository<t> where T : IEntity<string>{#region Constructorprotected MongoRepository(IMongoCollection<t> collection)
        {
            DbSet = collection;
            DbContext = collection.Database;
        }#endregionpublic IEnumerator<t> 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<t> DbSet { get; }public IMongoDatabase DbContext { get; }#endregion#region Findpublic T GetById(string id)
        {return Get(a => a.Id.Equals(id)).FirstOrDefault();
        }public IEnumerable<t> 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<t> entities)
        {
            DbSet.InsertMany(entities);
        }public Task InsertAsync(IEnumerable<t> 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<t>.Filter.Eq(e => e.Id, entity.Id),new BsonDocumentUpdateDefinition<t>(doc));
        }public Task<updateresult> UpdateAsync(T entity, CancellationToken cancellationToken = new CancellationToken())
        {var doc = entity.ToBsonDocument();return DbSet.UpdateOneAsync(Builders<t>.Filter.Eq(e => e.Id, entity.Id),new BsonDocumentUpdateDefinition<t>(doc), cancellationToken: cancellationToken);
        }#endregion#region Deletepublic T Delete(string id)
        {return DbSet.FindOneAndDelete(a => a.Id.Equals(id));
        }public Task<t> DeleteAsync(string id, CancellationToken cancellationToken = new CancellationToken())
        {return DbSet.FindOneAndDeleteAsync(a => a.Id.Equals(id), null, cancellationToken);
        }public Task<deleteresult> 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<long> 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<t> Paged(Expression<func>> predicate, Expression<func>> sortBy,int pageSize, int pageIndex = 1)
        {var sort = Builders<t>.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<t>.Sort.Descending(sortBy);return DbSet.Find(predicate).Sort(sort).Skip(pageSize * pageIndex - 1).Limit(pageSize).ToList();
            }, cancellationToken);
        }#endregion#region Helper/// <summary>/// 获取类型的所有属性信息/// </summary>/// <typeparam></typeparam>/// <typeparam></typeparam>/// <param>/// <returns></returns>private PropertyInfo[] GetPropertyInfos<tproperty>(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}</func></tproperty></t></func></func></list></t></func></func></t></func></func></long></func></func></func></deleteresult></t></t></t></updateresult></t></t></t></t></func></ienumerable></func></t></t></t></t></string></t></t>

######View Code#########使用如下：##############

    public class MongoDBSetting
    {public string DataBase { get; set; }public string UserName { get; set; }public string Password { get; set; }public List<mongoservers> Services { get; set; }
    }public class MongoServers
    {public string Host { get; set; }public int Port { get; set; } = 27017;
    }</mongoservers>

######View Code######### ###############

 public class LogsContext
    {private readonly IMongoDatabase _db;public LogsContext(IOptions<mongodbsetting> options)

        {var permissionSystem =MongoCredential.CreateCredential(options.Value.DataBase, options.Value.UserName,
                    options.Value.Password);var services = new List<mongoserveraddress>();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<errorlogs> ErrorLog => _db.GetCollection<errorlogs>("Error");public IMongoCollection<errorlogs> WarningLog => _db.GetCollection<errorlogs>("Warning");
    }</errorlogs></errorlogs></errorlogs></errorlogs></mongoserveraddress></mongodbsetting>

######View Code################ ##

 public static IServiceCollection UserMongoLog(this IServiceCollection services,
            IConfigurationSection configurationSection)
        {
            services.Configure<mongodbsetting>(configurationSection);
            services.AddSingleton<logscontext>();return services;
        }</logscontext></mongodbsetting>

######View Code###################

public interface IErrorLogService : IRepository<errorlog>{
    }public class ErrorLogService : MongoRepository<errorlog>, IErrorLogService
    {public ErrorLogService(LogsContext dbContext) : base(dbContext.ErrorLog)
        {
        }
    }</errorlog></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的實例代碼的詳細內容。更多資訊請關注PHP中文網其他相關文章！