一直有自己写个框架的想法,但是一直没有行动起来,最近比较闲,正好可以开工了.
现在已经完成了两部分.1.一个简单仓储,实现使用的是ef 2.IOC部分,这里是把内置的ioc替换成了aotofac,这部分感觉还是有一点缺陷的.下面说
仓储部分
这里主要是接口是实现,目前使用ef实现了仓储的接口.看一下代码
public interface IRepository<TEntity, TPrimaryKey>
where TEntity : class
{
#region Select/Get/Query
IQueryable<TEntity> GetAll();
IQueryable<TEntity> GetAllIncluding(params Expression<Func<TEntity, object[] propertySelectors);
List<TEntity> GetAllList();
Task<List<TEntity GetAllListAsync();
List<TEntity> GetAllList(Expression<Func<TEntity, bool predicate);
Task<List<TEntity GetAllListAsync(Expression<Func<TEntity, bool predicate);
T Query<T>(Func<IQueryable<TEntity>, T> queryMethod);
TEntity Get(TPrimaryKey id);
Task<TEntity> GetAsync(TPrimaryKey id);
TEntity Single(Expression<Func<TEntity, bool predicate);
Task<TEntity> SingleAsync(Expression<Func<TEntity, bool predicate);
TEntity FirstOrDefault(TPrimaryKey id);
Task<TEntity> FirstOrDefaultAsync(TPrimaryKey id);
TEntity FirstOrDefault(Expression<Func<TEntity, bool predicate);
Task<TEntity> FirstOrDefaultAsync(Expression<Func<TEntity, bool predicate);
TEntity Load(TPrimaryKey id);
#endregion
#region Insert
TEntity Insert(TEntity entity);
Task<TEntity> InsertAsync(TEntity entity);
#endregion
#region Update
TEntity Update(TEntity entity);
Task<TEntity> UpdateAsync(TEntity entity);
TEntity Update(TPrimaryKey id, Action<TEntity> updateAction);
Task<TEntity> UpdateAsync(TPrimaryKey id, Func<TEntity, Task> updateAction);
#endregion
#region Delete
void Delete(TEntity entity);
Task DeleteAsync(TEntity entity);
void Delete(TPrimaryKey id);
Task DeleteAsync(TPrimaryKey id);
void Delete(Expression<Func<TEntity, bool predicate);
Task DeleteAsync(Expression<Func<TEntity, bool predicate);
#endregion
#region Aggregates
int Count();
Task<int> CountAsync();
int Count(Expression<Func<TEntity, bool predicate);
Task<int> CountAsync(Expression<Func<TEntity, bool predicate);
long LongCount();
Task<long> LongCountAsync();
long LongCount(Expression<Func<TEntity, bool predicate);
Task<long> LongCountAsync(Expression<Func<TEntity, bool predicate);
#endregion
}
下面是实现的部分代码,代码比较占版面,就不贴全了.
public abstract class RepositoryBase<TEntity, TPrimaryKey> : IRepository<TEntity, TPrimaryKey>
where TEntity : class
{
public abstract IQueryable<TEntity> GetAll();
public abstract IQueryable<TEntity> GetAllIncluding(params Expression<Func<TEntity, object[] propertySelectors);
public virtual List<TEntity> GetAllList()
{
return GetAll().ToList();
}
public virtual async Task<List<TEntity GetAllListAsync()
{
return await Task.FromResult(GetAllList());
}
}
public class EfRepositoryBase<TDbContext, TEntity, TPrimaryKey> : RepositoryBase<TEntity, TPrimaryKey>
where TEntity : class
where TDbContext : DbContext
{
public virtual TDbContext Context { private set; get; }
public virtual DbSet<TEntity> Table => Context.Set<TEntity>();
public EfRepositoryBase(TDbContext context)
{
Context = context;
}
public override IQueryable<TEntity> GetAll()
{
return Table;
}
public override IQueryable<TEntity> GetAllIncluding(params Expression<Func<TEntity, object[] propertySelectors)
{
if (propertySelectors == null)
{
return GetAll();
}
var linq = GetAll();
foreach (var item in propertySelectors)
{
linq = linq.Include(item);
}
return linq;
}
}
注意看EfRepositoryBase继承了RepositoryBase,而RepositoryBase实现了IRepository.这里的RepositoryBase是所有实现的基类.GetAllList虚方法直接调用了抽象方法GetAll,这样在EfRepositoryBase中就可以减少很多代码了.
这里有个坑 EfRepositoryBase 是不能直接注册到IOC中的,因为EfRepositoryBase和IRepository的泛型参数个数不一致,ioc不能找到多出的一个泛型的值.使用仓储的时候继承EfRepositoryBase把dbcontext传进去就好了
public class TestRepository<TEntity, TPrimaryKey> : EfRepositoryBase<TestContext, TEntity, TPrimaryKey> where TEntity : class
{
public TestRepository(TestContext context)
: base(context)
{
}
}
IOC部分
asp.net core 微软提供了一个简单的IOC,但是接口比较少,替换成我们熟悉的ioc框架就方便多了. asp.net core 也有很方便的替换ioc的方法.简单说就是修改ConfigureServices方法的返回值为IServiceProvider.我使用了autofac,下面看代码.
public IServiceProvider ConfigureServices(IServiceCollection services)
{
services.AddMvc();
return services.AddLuna<AutofacModule>();
}
public static IServiceProvider AddLuna<TModule>([NotNull]this IServiceCollection services)
where TModule : IModule, new()
{
var builder = new ContainerBuilder();
builder.Populate(services);
builder.RegisterModule<TModule>();
return new AutofacServiceProvider(builder.Build());
}
public class AutofacModule : Module
{
protected override void Load(ContainerBuilder builder)
{
builder.RegisterType<TestContext>();
builder.RegisterGeneric(typeof(TestRepository<,>)).As(typeof(IRepository<,>))
.InstancePerLifetimeScope();
}
}
这里的Module和IModule是autofac的,功能已经实现了,但是作为框架来说直接暴露了autofac的东西显然是不合适的,下一步要实现一个框架自身的模块加载方式.
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
asp.net,core,仓储
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。