解析ABP框架中的事务处理和工作单元
通用连接和事务管理方法
连接和事务管理是使用数据库的应用程序最重要的概念之一。当你开启一个数据库连接,什么时候开始事务,如何释放连接...诸如此类的。
正如大家都知道的,.net使用连接池（connection pooling）。因此,创建一个连接实际上是从连接池中取得一个连接,会这么做是因为创建新连接会有成本。如果没有任何连接存在于连接池中,一个新的连接对象会被创建并且添加到连接池中。当你释放连接,它实际上是将这个连接对象送回到连接池。这并不是实际意义上的释放。这个机制是由.net所提供的。因此,我们应该在使用完之后释放掉连接对象。这就是最佳实践。
在应用程序中，有两个通用的方来创建/释放一个数据库连接:
第一个方法:在web请求到达的时候，创建一个连接对象。(application_beginrequest这个位于global.asax中的事件),使用同一个连接对象来处理所有的数据库操作，并且在请求结束的时候关闭/释放这个连接 (application_endrequest事件)。
这是个简易但却没效率的方法,原因：
- 或许这个web请求不需要操作数据库,但是连接却会开启。这对于连接池来说是个毫无效率的使用方式。
- 这可能会让web请求的运行时间变长,并且数据库操作还会需要一些执行。这也是一种没效率的连接池使用方式。
- 这对于web应用来说是可行的。如果你的应用程序是widnows service,这可能就无法被实现了。
- 同样的这是一个使用事务式的数据库操作最佳场景。如果有一个操作发生失败,所有的操作都会回滚。因为事务会锁住数据库中的一些数据列(事件数据表),它必定要是短暂的。
第二个方法: 创建一个连接当需要的时候(只要在使用它之前)并且释放它在使用它之后。这是相当高效的,但是就得乏味而且反复的去进行（创建/释放连接）。
abp的连接和事务管理
abp综合上述两个连接管理的方法，并且提供一个简单而且高效的模型。
1.仓储类(repository classes)
仓储是主要的数据库操作的类。abp开启了一个数据库连接并且在进入到仓储方法时会启用一个事务。因此,你可以安全地使用连接于仓储方法中。在仓储方法结束后,事务会被提交并且会释放掉连接。假如仓储方法抛出任何异常,事务会被回滚并且释放掉连接。在这个模式中,仓储方法是单元性的(一个工作单元unit of work)。abp在处理上述那些动作都是全自动的。在这里,有一个简单的仓储:
public class contentrepository : nhrepositorybase<content>, icontentrepository
{
public list<content> getactivecontents(string searchcondition)
{
var query = from content in session.query<content>()
where content.isactive && !content.isdeleted
select content;
if (string.isnullorempty(searchcondition))
{
query = query.where(content => content.text.contains(searchcondition));
}
return query.tolist();
}
}
这个示例使用nhibernate作为orm框架。如上所示,不需要撰写任何数据库连接操作(nhibernate中的session)的程序代码。
假如仓储方法调用另一个仓储方法(一般来说,若工作单元方法调用另一个工作单元的方法),都使用同一个连接和事务。第一个被调用到的仓储方法负责管理连接和事务,而其余被它调用的仓储方法则只单纯使用不管理。
2.应用服务(application service classes)
一个应用服务的方法也被考虑使用工作单元。如果我们拥有一个应用服务方法如下:
public class personappservice : ipersonappservice
{
private readonly ipersonrepository _personrepository;
private readonly istatisticsrepository _statisticsrepository;
public personappservice(ipersonrepository personrepository, istatisticsrepository statisticsrepository)
{
_personrepository = personrepository;
_statisticsrepository = statisticsrepository;
}
public void createperson(createpersoninput input)
{
var person = new person { name = input.name, emailaddress = input.emailaddress };
_personrepository.insert(person);
_statisticsrepository.incrementpeoplecount();
}
}
在createperson方法中,我们新增一个person使用person仓储并且使用statistics仓储增加总people数量。两个仓储共享同一个连接和事务于这个例子中,因为这是一个应用服务的方法。abp开启一个数据库连接并且开启一个事务于进入到creationperson这个方法,若没有任何异常抛出,接着提交这个事务于方法结尾时,若有异常被抛出,则会回滚这个事务。在这种机制下,所有数据库的操作在createperson中,都成了单元性的了(工作单元)。
3.工作单元(unit of work)
工作单元在后台替仓储和应用服务的方法工作。假如你想要控制数据库的连接和事务,你就需要直接操作工作单元。下面有两个直接使用的示例:
首要且最好的使用unitofworkattribute的方式如下:
[unitofwork]
public void createperson(createpersoninput input)
{
var person = new person { name = input.name, emailaddress = input.emailaddress };
_personrepository.insert(person);
_statisticsrepository.incrementpeoplecount();
}
因此,createperson方法转变成工作单元并且管理数据库连接和事务,两个仓储对象都使用相同的工作单元。要注意,假如这是应用服务的方法则不需要添加unitofwork属性，见工作单元方法:第三章,3.3.5。
第二个示例是使用iunitofworkmanager.begin(...)方法如下所示:
public class myservice
{
private readonly iunitofworkmanager _unitofworkmanager;
private readonly ipersonrepository _personrepository;
private readonly istatisticsrepository _statisticsrepository;
public myservice(iunitofworkmanager unitofworkmanager, ipersonrepository personrepository, istatisticsrepository statisticsrepository)
{
_unitofworkmanager = unitofworkmanager;
_personrepository = personrepository;
_statisticsrepository = statisticsrepository;
}
public void createperson(createpersoninput input)
{
var person = new person { name = input.name, emailaddress = input.emailaddress };
using (var unitofwork = _unitofworkmanager.begin())
{
_personrepository.insert(person);
_statisticsrepository.incrementpeoplecount();
unitofwork.complete();
}
}
}
你可以注入并且使用iunitofworkmanager，如上所示。因此,你可以创建更多的有限范围 （limited scope）的工作单元。在这个机制中,你通常可以手动调用complete方法。如果你不调用,事务会回滚并且所有的异常都不会被储存。begin方法被重写从而设置工作单元的选项。这很棒,不过除非你有很好的理由,否则还是少用unitofwork属性。
工作单元
1.禁用工作单元(disabling unit of work)
你或许会想要禁用应用服务方法的工作单元(因为它默认是启用的)。要想做到这个,使用unitofworkattribute的isdisabled属性。示例如下:
[unitofwork(isdisabled = true)]
public virtual void removefriendship(removefriendshipinput input)
{
_friendshiprepository.delete(input.id);
}
平常时, 你不会需要这么做,这是因为应用服务的方法都应该是单元性且通常是使用数据库。在有些情况下,你或许会想要禁用应用服务的工作单元:
（1）你的方法不需要任何数据库操作且你不想要开启那些不需要的数据库连接
（2）你想要使用工作单元于unitofworkscope类的有限范围内,如上所述
注意,如果工作单元方法调用这个removefriendship方法,禁用被忽略且它和调用它的方法使用同一个工作单元。因此,使用禁用这个功能要很小心。同样地,上述程序代码工作的很好,因为仓储方法默认即为工作单元。
2.无事务的工作单元(non-transactional unit of work)
工作单元默认上是具事务性的(这是它的天性)。因此,abp启动/提交/回滚一个显性的数据库等级的事务。在有些特殊案例中,事务可能会导致问题,因为它可能会锁住有些数据列或是数据表于数据库中。在此这些情境下, 你或许会想要禁用数据库等级的事务。unitofwork属性可以从它的建构子中取得一个布尔值来让它如非事务型工作单元般工作着。示例为:
[unitofwork(false)]
public gettasksoutput gettasks(gettasksinput input)
{
var tasks = _taskrepository.getallwithpeople(input.assignedpersonid, input.state);
return new gettasksoutput
{
tasks = mapper.map<list<taskdto>>(tasks)
};
}
建议可以这么做[unitofwork(istransaction:false)]。(具有可读性并且明确)。
注意,orm框架(像是nhibernate和entityframework)会在单一命令中于内部进行数据储存。假设你更新了一些的实体于非事务的uow。即便于这个情境下所有的更新都会于单一数据库命令的工作单元尾部完成。但是,如果你直接执行sql查询,它会立即被执行。
这里有一个非事务性uow的限制。如果你已经位于事务性uow区域内,设定istransactional为false这个动作会被忽略。
使用非事务性uow要小心,因为在大多数的情况下,数据整合应该是具事务性的。如果你的方法只是读取数据,不改变数据,那么当然可以采用非事务性。
3.工作单元调用其它工作单元(a unit of work method calls another)
若工作单元方法(一个贴上unitofwork属性标签的方法)调用另一个工作单元方法,他们共享同一个连接和事务。第一个方法管理连接,其它的方法只是使用它。这在所有方法都执行在同一个线程下是可行的(或是在同一个web请求内)。实际上,当工作单元区域开始,所有的程序代码都会在同一个线程中执行并共享同一个连接事务,直到工作单元区域终止。这对于使用unitofwork属性和unitofworkscope类来说都是一样的。如果你创建了一个不同的线程/任务,它使用自己所属的工作单元。
自动化的saving changes (automatically saving changes)
当我们使用工作单元到方法上,abp自动的储存所有变化于方法的末端。假设我们需要一个可更新person名称的方法:
[unitofwork]
public void updatename(updatenameinput input) {
var person = _personrepository.get(input.personid);
person.name = input.newname;
}
就这样,名称就被修改了!我们甚至没有调用_personrepository.update方法。orm框架会持续追踪实体所有的变化于工作单元内,且反映所有变化到数据库中。
注意,这不需要在应用服务声明unitofwork,因为它们默认就是采用工作单元。
4.仓储接口的getall()方法(irepository.getall())
当你在仓储方法外调用getall方法, 这必定得有一个开启状态的数据库连接,因为它返回iqueryable类型的对象。这是需要的,因为iqueryable延迟执行。它并不会马上执行数据库查询,直到你调用tolist()方法或在foreach循环中使用iqueryable(或是存取被查询结果集的情况下)。因此,当你调用tolist()方法,数据库连接必需是启用状态。示例:
[unitofwork]
public searchpeopleoutput searchpeople(searchpeopleinput input)
{
//get iqueryable<person>
var query = _personrepository.getall();
//add some filters if selected
if (!string.isnullorempty(input.searchedname))
{
query = query.where(person => person.name.startswith(input.searchedname));
}
if (input.isactive.hasvalue)
{
query = query.where(person => person.isactive == input.isactive.value);
}
//get paged result list
var people = query.skip(input.skipcount).take(input.maxresultcount).tolist();
return new searchpeopleoutput { people = mapper.map<list<persondto>>(people) };
}
在这里,searchpeople方法必需是工作单元,因为iqueryable在被调用tolist()方法于方法本体内,并且数据库连接必须于iqueryable.tolist()被执行时开启。
一如getall()方法,如果需要数据库连接且没有仓储的情况下,你就必须要使用工作单元。注意,应用服务方法默认就是工作单元。
5.工作单元属性的限制(unitofwork attribute restrictions)
在下面情境下你可以使用unitofwork属性标签:
（1）类所有public或public virtual这些基于界面的方法(像是应用服务是基于服务界面)
（2）自我注入类的public virtual方法(像是mvc controller和web api controller)
（3）所有protected virtual方法。
建议将方法标示为virtual。你无法应用在private方法上。因为,abp使用dynamic proxy来实现,而私有方法就无法使用继承的方法来实现。当你不使用依赖注入且自行初始化类,那么unitofwork属性(以及任何代理)就无法正常运作。
选项
有许多可以用来控制工作单元的选项。
首先,我们可以在startup configuration中改变所有工作单元的所有默认值。这通常是用了我们模块中的preinitialize方法来实现。
public class simpletasksystemcoremodule : abpmodule
{
public override void preinitialize()
{
configuration.unitofwork.isolationlevel = isolationlevel.readcommitted;
configuration.unitofwork.timeout = timespan.fromminutes(30);
}
//...other module methods
}
方法
工作单元系统运作是无缝且不可视的。但是,在有些特例下,你需要调用它的方法。
savechanges：
abp储存所有的变化于工作单元的尾端,你不需要做任何事情。但是,有些时候,你或许会想要在工作单元的过程中就储存所有变化。在这个案例中,你可以注入iunitofworkmanager并且调用iunitofworkmanager.current.savechanges()方法。示例中以entity framework在储存变化时取得新增实体的id。注意,当前工作单元是具事务性的,所有在事务中的变化会在异常发生时都被回滚,即便是已调用savechange。
事件
工作单元具有completed/failed/disposed事件。你可以注册这些事件并且进行所需的操作。注入iunitofworkmanager并且使用iunitofworkmanager.current 属性来取得当前已激活的工作单元并且注册它的事件。
你或许会想要执行有些程序代码于当前工作单元成功地完成。示例:
public void createtask(createtaskinput input)
{
var task = new task { description = input.description };
if (input.assignedpersonid.hasvalue)
{
task.assignedpersonid = input.assignedpersonid.value;
_unitofworkmanager.current.completed += (sender, args) => { /* todo: send email to assigned person */ };
}
_taskrepository.insert(task);
}