解析ABP框架领域层中的实体类与仓储类

领域层
实体是ddd（领域驱动设计）的核心概念之一。eric evans是这样描述的“很多对象不是通过它们的属性定义的，而是通过一连串的连续性事件和标识定义的”（引用领域驱动设计一书）。

译者注：对象不是通过它们的属性来下根本性的定义，而应该是通过它的线性连续性和标识性定义的。。所以，实体是具有唯一标识的id且存储在数据库中。实体通常被映射成数据库中的一个表。

实体类(entity classes)
在abp中，实体继承自entity类，请看下面示例：

public class person : entity
{
  public virtual string name { get; set; }

  public virtual datetime creationtime { get; set; }

  public task()
  {
    creationtime = datetime.now;
  }
}

person 类被定义为一个实体。它具有两个属性，它的父类中有id属性。id是该实体的主键。所以，id是所有继承自entity类的实体的主键（所有实体的主键都是id字段）。

id(主键)数据类型可以被更改。默认是int（int32）类型。如果你想给id定义其它类型，你应该像下面示例一样来声明id的类型。

public class person : entity<long>
{
  public virtual string name { get; set; }

  public virtual datetime creationtime { get; set; }

  public task()
  {
    creationtime = datetime.now;
  }
}

你可以设置为string，guid或者其它数据类型。

实体类重写了 equality (==) 操作符用来判断两个实体对象是否相等（两个实体的id是否相等）。还定义了一个istransient()方法来检测实体是否有id属性。

接口约定
在很多应用程序中，很多实体具有像creationtime的属性（数据库表也有该字段）用来指示该实体是什么时候被创建的。apb提供了一些有用的接口来实现这些类似的功能。也就是说，为这些实现了这些接口的实体，提供了一个通用的编码方式（通俗的说只要实现指定的接口就能实现指定的功能）。

(1)审计（auditing）

实体类实现 ihascreationtime 接口就可以具有creationtime的属性。当该实体被插入到数据库时， abp会自动设置该属性的值为当前时间。

public interface ihascreationtime
{
  datetime creationtime { get; set; }
}

person类可以被重写像下面示例一样实现ihascreationtime 接口：

public class person : entity<long>, ihascreationtime
{
  public virtual string name { get; set; }

  public virtual datetime creationtime { get; set; }

  public task()
  {
    creationtime = datetime.now;
  }
}

icreationaudited 扩展自 ihascreationtime 并且该接口具有属性 creatoruserid ：

public interface icreationaudited : ihascreationtime
{
  long? creatoruserid { get; set; }
}

当保存一个新的实体时，abp会自动设置creatoruserid 的属性值为当前用户的id

你可以轻松的实现icreationaudited接口，通过派生自实体类 creationauditedentity (因为该类已经实现了icreationaudited接口，我们可以直接继承creationauditedentity 类就实现了上述功能)。它有一个实现不同id数据类型的泛型版本(默认是int)，可以为id（entity类中的id）赋予不同的数据类型。
下面是一个为实现类似修改功能的接口

public interface imodificationaudited
{
  datetime? lastmodificationtime { get; set; }
  long? lastmodifieruserid { get; set; }
}

当更新一个实体时，abp会自动设置这些属性的值。你只需要在你的实体类里面实现这些属性。

如果你想实现所有的审计属性，你可以直接扩展 iaudited 接口；示例如下：

public interface iaudited : icreationaudited, imodificationaudited
{
    
}

作为一个快速开发方式，你可以直接派生自auditedentity 类，不需要再去实现iaudited接口（auditedentity 类已经实现了该功能，直接继承该类就可以实现上述功能），auditedentity 类有一个实现不同id数据类型的泛型版本(默认是int)，可以为id（entity类中的id）赋予不同的数据类型。

(2)软删除(soft delete)

软删除是一个通用的模式被用来标记一个已经被删除的实体，而不是实际从数据库中删除记录。例如：你可能不想从数据库中硬删除一条用户记录，因为它被许多其它的表所关联。为了实现软删除的目的我们可以实现该接口 isoftdelete：

public interface isoftdelete{
  bool isdeleted { get; set; }
}

abp实现了开箱即用的软删除模式。当一个实现了软删除的实体正在被被删除，abp会察觉到这个动作，并且阻止其删除，设置isdeleted 属性值为true并且更新数据库中的实体。也就是说，被软删除的记录不可以从数据库中检索出，abp会为我们自动过滤软删除的记录。（例如：select查询，这里指通过abp查询，不是通过数据库中的查询分析器查询。）

如果你用了软删除，你有可能也想实现这个功能，就是记录谁删除了这个实体。要实现该功能你可以实现ideletionaudited 接口，请看下面示例：

public interface ideletionaudited : isoftdelete
{
  long? deleteruserid { get; set; }
  datetime? deletiontime { get; set; }
}

正如你所看到的ideletionaudited 扩展自 isoftdelete接口。当一个实体被删除的时候abp会自动的为这些属性设置值。
如果你想为实体类扩展所有的审计接口（例如：创建（creation），修改（modification）和删除（deletion）），你可以直接实现ifullaudited接口，因为该接口已经继承了这些接口，请看下面示例：

public interface ifullaudited : iaudited, ideletionaudited
{
    
}

作为一个快捷方式，你可以直接从fullauditedentity 类派生你的实体类，因为该类已经实现了ifullaudited接口。

注意：所有的审计接口和类都有一个泛型模板为了导航定义属性到你的user 实体（例如：icreationaudited<tuser>和fullauditedentity<tprimarykey, tuser>），这里的tuser指的进行创建，修改和删除的用户的实体类的类型，详细请看源代码（abp.domain.entities.auditing空间下的fullauditedentity<tprimarykey, tuser>类），tprimarykey 只的是entity基类id类型，默认是int。

(3)激活状态/闲置状态(active/passive)

有些实体需要被标记为激活状态或者闲置状态。那么你可以为实体采取active/passive状态的行动。基于这个原因而创建的实体，你可以扩展ipassivable 接口来实现该功能。该接口定义了isactive 的属性。

如果你首次创建的实体被标记为激活状态，你可以在构造函数设置isactive属性值为true。

这是不同于软删除（isdeleted）。如果实体被软删除，它不能从数据库中被检索到（abp已经过滤了软删除记录）。但是对于激活状态/闲置状态的实体，你完全取决于你怎样去获取这些被标记了的实体。

ientity接口
事实上entity 实现了ientity 接口（和entity<tprimarykey> 实现了 ientity<tprimarykey>接口）。如果你不想从entity 类派生，你能直接的实现这些接口。其他实体类也可以实现相应的接口。但是不建议你用这种方式。除非你有一个很好的理由不从entity 类派生。

仓储（repositories）
仓储定义：“在领域层和数据映射层的中介,使用类似集合的接口来存取领域对象”(martin fowler)。

实际上，仓储被用于领域对象在数据库上的操作(实体entity和值对象value types)。一般来说,我们针对不同的实体(或聚合根aggregate root)会创建相对应的仓储。

irepository接口
在abp中,仓储类要实现irepository接口。最好的方式是针对不同仓储对象定义各自不同的接口。

针对person实体的仓储接口声明的示例如下所示:

public interface ipersonrepository : irepository<person> 
{
}

ipersonrepository继承自irepository<tentity>，用来定义id的类型为int(int32)的实体。如果你的实体id数据类型不是int,你可以继承irepository<tentity, tprimarykey>接口，如下所示:

public interface ipersonrepository : irepository<person, long> 
{ 
}

对于仓储类，irepository定义了许多泛型的方法。比如: select,insert,update,delete方法(crud操作)。在大多数的时候,这些方法已足已应付一般实体的需要。如果这些方对于实体来说已足够,我们便不需要再去创建这个实体所需的仓储接口/类。在implementation章节有更多细节。

(1)查询(query)

irepository定义了从数据库中检索实体的常用方法。

a、取得单一实体(getting single entity)：

tentity get(tprimarykey id);
task<tentity> getasync(tprimarykey id);
tentity single(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);

get方法被用于根据主键值(id)取得对应的实体。当数据库中根据主键值找不到相符合的实体时,它会抛出例外。single方法类似get方法,但是它的输入参数是一个表达式而不是主键值(id)。因此,我们可以写lambda表达式来取得实体。示例如下:

var person = _personrepository.get(42);
var person = _personrepository.single(p => o.name == "halil ibrahim kalkan");

注意,single方法会在给出的条件找不到实体或符合的实体超过一个以上时,都会抛出例外。

firstordefault也一样,但是当没有符合lambda表达式或id的实体时,会回传null(取代抛出异常)。当有超过一个以上的实体符合条件,它只会返回第一个实体。

load并不会从数据库中检索实体,但它会创建延迟执行所需的代理对象。如果你只使用id属性,实际上并不会检索实体,它只有在你存取想要查询实体的某个属性时才会从数据库中查询实体。当有性能需求的时候,这个方法可以用来替代get方法。load方法在nhibernate与abp的整合中也有实现。如果orm提供者(provider)没有实现这个方法,load方法运行的会和get方法一样。

abp有些方法具有异步(async)版本，可以应用在异步开发模型上(见async方法相关章节)。

b、取得实体列表(getting list of entities)：

list<tentity> getalllist();
task<list<tentity>> getalllistasync();
list<tentity> getalllist(expression<func<tentity, bool>> predicate);
task<list<tentity>> getalllistasync(expression<func<tentity, bool>> predicate);
iqueryable<tentity> getall();

getalllist被用于从数据库中检索所有实体。重载并且提供过滤实体的功能,如下:

var allpeople = _personrespository.getalllist();
var somepeople = _personrepository.getalllist(person => person.isactive && person.age > 42);

getall返回iqueryable<t>类型的对象。因此我们可以在调用完这个方法之后进行linq操作。示例:

//例子一
var query = from person in _personrepository.getall()
where person.isactive
orderby person.name
select person;
var people = query.tolist();
//例子二
list<person> personlist2 = _personrepository.getall().where(p => p.name.contains("h")).orderby(p => p.name).skip(40).take(20).tolist();

 如果调用getall方法,那么几乎所有查询都可以使用linq完成。甚至可以用它来编写join表达式。

说明：关于iqueryable<t>
当你调用getall这个方法在repository对象以外的地方,必定会开启数据库连接。这是因为iqueryable<t>允许延迟执行。它会直到你调用tolist方法或在foreach循环上(或是一些存取已查询的对象方法)使用iqueryable<t>时,才会实际执行数据库的查询。因此,当你调用tolist方法时,数据库连接必需是启用状态。我们可以使用abp所提供的unitofwork特性在调用的方法上来实现。注意,application service方法预设都已经是unitofwork。因此,使用了getall方法就不需要如同application service的方法上添加unitofwork特性。

有些方法拥有异步版本,可应用在异步开发模型(见关于async方法章节)。

自定义返回值(custom return value)

abp也有一个额外的方法来实现iqueryable<t>的延迟加载效果,而不需要在调用的方法上添加unitofwork这个属性卷标。

t query<t>(func<iqueryable<tentity>,t> querymethod);

查询方法接受lambda(或一个方法)来接收iqueryable<t>并且返回任何对象类型。示例如下:

var  people = _personrepository.query(q => q.where(p => p.name.contains("h")).orderby(p => p.name).tolist());
因为是采用lambda(或方法)在仓储对象的方法中执行,它会在数据库连接开启之后才被执行。你可以返回实体集合,或一个实体,或一个具部份字段(注: 非select *)或其它执行查询后的查询结果集。

(2)新增(insert)

irepository接口定义了简单的方法来提供新增一个实体到数据库:

tentity insert(tentity entity);
task<tentity> insertasync(tentity entity);
tprimarykey insertandgetid(tentity entity);
task<tprimarykey> insertandgetidasync(tentity entity);
tentity insertorupdate(tentity entity);
task<tentity> insertorupdateasync(tentity entity);
tprimarykey insertorupdateandgetid(tentity entity);
task<tprimarykey> insertorupdateandgetidasync(tentity entity);

新增方法会新增实体到数据库并且返回相同的已新增实体。insertandgetid方法返回新增实体的标识符(id)。当我们采用自动递增标识符值且需要取得实体的新产生标识符值时非常好用。insertofupdate会新增或更新实体,选择那一种是根据id是否有值来决定。最后,insertorupdatedandgetid会在实体被新增或更新后返回id值。

所有的方法都拥有异步版本可应用在异步开发模型(见关于异步方法章节)

(3)更新(update)

irepository定义一个方法来实现更新一个已存在于数据库中的实体。它更新实体并返回相同的实体对象。

tentity update(tentity entity);
task<tentity> updateasync(tentity entity);

(4)删除(delete)

irepository定了一些方法来删除已存在数据库中实体。

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);

第一个方法接受一个现存的实体,第二个方法接受现存实体的id。

最后一个方法接受一个条件来删除符合条件的实体。要注意,所有符合predicate表达式的实体会先被检索而后删除。因此,使用上要很小心,这是有可能造成许多问题,假如果有太多实体符合条件。

所有的方法都拥有async版本来应用在异步开发模型(见关于异步方法章节)。

(5)其它方法(others)

irepository也提供一些方法来取得数据表中实体的数量。

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<tentity, bool>> predicate);

 所有的方法都拥有async版本被应用在异步开发模型(见关于异步方法章节)。

(6)关于异步方法(about async methods)

abp支持异步开发模型。因此,仓储方法拥有async版本。在这里有一个使用异步模型的application service方法的示例:

public class personappservice : abpwpfdemoappservicebase, ipersonappservice
{
  private readonly irepository<person> _personrepository;

  public personappservice(irepository<person> personrepository)
  {
    _personrepository = personrepository;
  }

  public async task<getpeopleoutput> getallpeople()
  {
    var people = await _personrepository.getalllistasync();
      
    return new getpeopleoutput
    {
      people = mapper.map<list<persondto>>(people)
    };
  }
}

getallpeople方法是异步的并且使用getalllistasync与await保留关键字。

async不是在每个orm框架都有提供。

上例是从ef所提供的异步能力。如果orm框架没有提供async的仓储方法则它会以同步的方式操作。同样地,举例来说,insertasync操作起来和ef的新增是一样的,因为ef会直到单元作业(unit of work)完成之后才会写入新实体到数据库中(dbcontext.savechanges)。

仓储的实现
abp在设计上是采取不指定特定orm框架或其它存取数据库技术的方式。只要实现irepository接口,任何框架都可以使用。

仓储要使用nhibernate或ef来实现都很简单。

entityframework
当你使用nhibernate或entityframework,如果提供的方法已足够使用,你就不需要为你的实体创建仓储对象了。我们可以直接注入irepository<tentity>(或irepository<tentity, tprimarykey>)。下面的示例为application service使用仓储对象来新增实体到数据库:

public class personappservice : ipersonappservice
{
  private readonly irepository<person> _personrepository;

  public personappservice(irepository<person> personrepository)
  {
    _personrepository = personrepository;
  }

  public void createperson(createpersoninput input)
  {    
    person = new person { name = input.name, emailaddress = input.emailaddress };
    
    _personrepository.insert(person);
  }
}

 personappservice的建构子注入了irepository<person>并且使用其insert方法。当你有需要为实体创建一个客制的仓储方法,那么你就应该创建一个仓储类给指定的实体。

管理数据库连接
数据库连接的开启和关闭，在仓储方法中,abp会自动化的进行连接管理。

当仓储方法被调用后,数据库连接会自动开启且启动事务。当仓储方法执行结束并且返回以后,所有的实体变化都会被储存, 事务被提交并且数据库连接被关闭,一切都由abp自动化的控制。如果仓储方法抛出任何类型的异常,事务会自动地回滚并且数据连接会被关闭。上述所有操作在实现了irepository接口的仓储类所有公开的方法中都可以被调用。

如果仓储方法调用其它仓储方法(即便是不同仓储的方法),它们共享同一个连接和事务。连接会由仓储方法调用链最上层的那个仓储方法所管理。更多关于数据库管理,详见unitofwork文件。

储的生命周期
所有的仓储对象都是暂时性的。这就是说,它们是在有需要的时候才会被创建。abp大量的使用依赖注入，当仓储类需要被注入的时候,新的类实体会由注入容器会自动地创建。见相根据注入文件有更多信息。

仓储的最佳实践
对于一个t类型的实体,是可以使用irepository<t>。但别任何情况下都创建定制化的仓储,除非我们真的很需要。预定义仓储方法已经足够应付各种案例。
假如你正创建定制的仓储(可以实现irepository<tentity>)
仓储类应该是无状态的。这意味着, 你不该定义仓储等级的状态对象并且仓储方法的调用也不应该影响到其它调用。　　　　
当仓储可以使用相根据注入，尽可较少或是不相根据于其它服务。