這篇文章主要講解了“ASP.NET的通用連接和事務(wù)管理方法是什么”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“ASP.NET的通用連接和事務(wù)管理方法是什么”吧！

創(chuàng)新互聯(lián)成立于2013年，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目網(wǎng)站制作、成都網(wǎng)站設(shè)計(jì)網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢想脫穎而出為使命，1280元召陵做網(wǎng)站,已為上家服務(wù),為召陵各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:18980820575

通用連接和事務(wù)管理方法

連接和事務(wù)管理是使用數(shù)據(jù)庫的應(yīng)用程序最重要的概念之一。當(dāng)你開啟一個(gè)數(shù)據(jù)庫連接,什么時(shí)候開始事務(wù),如何釋放連接...諸如此類的。

正如大家都知道的,.Net使用連接池（connection pooling）。因此,創(chuàng)建一個(gè)連接實(shí)際上是從連接池中取得一個(gè)連接,會(huì)這么做是因?yàn)閯?chuàng)建新連接會(huì)有成本。如果沒有任何連接存在于連接池中,一個(gè)新的連接對象會(huì)被創(chuàng)建并且添加到連接池中。當(dāng)你釋放連接,它實(shí)際上是將這個(gè)連接對象送回到連接池。這并不是實(shí)際意義上的釋放。這個(gè)機(jī)制是由.Net所提供的。因此,我們應(yīng)該在使用完之后釋放掉連接對象。這就是最佳實(shí)踐。

在應(yīng)用程序中，有兩個(gè)通用的方來創(chuàng)建/釋放一個(gè)數(shù)據(jù)庫連接:

第一個(gè)方法:在Web請求到達(dá)的時(shí)候，創(chuàng)建一個(gè)連接對象。(Application_BeginRequest這個(gè)位于global.asax中的事件),使用同一個(gè)連接對象來處理所有的數(shù)據(jù)庫操作，并且在請求結(jié)束的時(shí)候關(guān)閉/釋放這個(gè)連接 (Application_EndRequest事件)。

這是個(gè)簡易但卻沒效率的方法,原因：

• 或許這個(gè)Web請求不需要操作數(shù)據(jù)庫,但是連接卻會(huì)開啟。這對于連接池來說是個(gè)毫無效率的使用方式。

• 這可能會(huì)讓W(xué)eb請求的運(yùn)行時(shí)間變長,并且數(shù)據(jù)庫操作還會(huì)需要一些執(zhí)行。這也是一種沒效率的連接池使用方式。

• 這對于Web應(yīng)用來說是可行的。如果你的應(yīng)用程序是Widnows Service,這可能就無法被實(shí)現(xiàn)了。

同樣的這是一個(gè)使用事務(wù)式的數(shù)據(jù)庫操作最佳場景。如果有一個(gè)操作發(fā)生失敗,所有的操作都會(huì)回滾。因?yàn)槭聞?wù)會(huì)鎖住數(shù)據(jù)庫中的一些數(shù)據(jù)列(事件數(shù)據(jù)表),它必定要是短暫的。

第二個(gè)方法: 創(chuàng)建一個(gè)連接當(dāng)需要的時(shí)候(只要在使用它之前)并且釋放它在使用它之后。這是相當(dāng)高效的,但是就得乏味而且反復(fù)的去進(jìn)行（創(chuàng)建/釋放連接）。

ABP的連接和事務(wù)管理

ABP綜合上述兩個(gè)連接管理的方法，并且提供一個(gè)簡單而且高效的模型。

倉儲(chǔ)類(Repository classes)

倉儲(chǔ)是主要的數(shù)據(jù)庫操作的類。ABP開啟了一個(gè)數(shù)據(jù)庫連接并且在進(jìn)入到倉儲(chǔ)方法時(shí)會(huì)啟用一個(gè)事務(wù)。因此,你可以安全地使用連接于倉儲(chǔ)方法中。在倉儲(chǔ)方法結(jié)束后,事務(wù)會(huì)被提交并且會(huì)釋放掉連接。假如倉儲(chǔ)方法拋出任何異常,事務(wù)會(huì)被回滾并且釋放掉連接。在這個(gè)模式中,倉儲(chǔ)方法是單元性的(一個(gè)工作單元unit of work)。ABP在處理上述那些動(dòng)作都是全自動(dòng)的。在這里,有一個(gè)簡單的倉儲(chǔ):

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

這個(gè)示例使用NHibernate作為ORM框架。如上所示,不需要撰寫任何數(shù)據(jù)庫連接操作(NHibernate中的Session)的程序代碼。

假如倉儲(chǔ)方法調(diào)用另一個(gè)倉儲(chǔ)方法(一般來說,若工作單元方法調(diào)用另一個(gè)工作單元的方法),都使用同一個(gè)連接和事務(wù)。第一個(gè)被調(diào)用到的倉儲(chǔ)方法負(fù)責(zé)管理連接和事務(wù),而其余被它調(diào)用的倉儲(chǔ)方法則只單純使用不管理。

應(yīng)用服務(wù)(Application service classes)

一個(gè)應(yīng)用服務(wù)的方法也被考慮使用工作單元。如果我們擁有一個(gè)應(yīng)用服務(wù)方法如下:

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方法中,我們新增一個(gè)person使用person倉儲(chǔ)并且使用statistics倉儲(chǔ)增加總people數(shù)量。兩個(gè)倉儲(chǔ)共享同一個(gè)連接和事務(wù)于這個(gè)例子中,因?yàn)檫@是一個(gè)應(yīng)用服務(wù)的方法。ABP開啟一個(gè)數(shù)據(jù)庫連接并且開啟一個(gè)事務(wù)于進(jìn)入到CreationPerson這個(gè)方法,若沒有任何異常拋出,接著提交這個(gè)事務(wù)于方法結(jié)尾時(shí),若有異常被拋出,則會(huì)回滾這個(gè)事務(wù)。在這種機(jī)制下,所有數(shù)據(jù)庫的操作在CreatePerson中,都成了單元性的了(工作單元)。

工作單元(Unit of work)

工作單元在后臺替?zhèn)}儲(chǔ)和應(yīng)用服務(wù)的方法工作。假如你想要控制數(shù)據(jù)庫的連接和事務(wù),你就需要直接操作工作單元。下面有兩個(gè)直接使用的示例:

首要且最好的使用UnitOfWorkAttribute的方式如下:

[UnitOfWork]public void CreatePerson(CreatePersonInput input)
{    var person = new Person { Name = input.Name, EmailAddress = input.EmailAddress };
    _personRepository.Insert(person);
    _statisticsRepository.IncrementPeopleCount();
}

因此,CreatePerson方法轉(zhuǎn)變成工作單元并且管理數(shù)據(jù)庫連接和事務(wù),兩個(gè)倉儲(chǔ)對象都使用相同的工作單元。要注意,假如這是應(yīng)用服務(wù)的方法則不需要添加UnitOfWork屬性，見工作單元方法:第三章,3.3.5。

第二個(gè)示例是使用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，如上所示。因此,你可以創(chuàng)建更多的有限范圍 （limited scope）的工作單元。在這個(gè)機(jī)制中,你通常可以手動(dòng)調(diào)用Complete方法。如果你不調(diào)用,事務(wù)會(huì)回滾并且所有的異常都不會(huì)被儲(chǔ)存。Begin方法被重寫從而設(shè)置工作單元的選項(xiàng)。

這很棒,不過除非你有很好的理由,否則還是少用UnitOfWork屬性。

工作單元

禁用工作單元(Disabling unit of work)

你或許會(huì)想要禁用應(yīng)用服務(wù)方法的工作單元(因?yàn)樗J(rèn)是啟用的)。要想做到這個(gè),使用UnitOfWorkAttribute的IsDisabled屬性。示例如下:

[UnitOfWork(IsDisabled = true)]public virtual void RemoveFriendship(RemoveFriendshipInput input)
{
    _friendshipRepository.Delete(input.Id);
}

平常時(shí), 你不會(huì)需要這么做,這是因?yàn)閼?yīng)用服務(wù)的方法都應(yīng)該是單元性且通常是使用數(shù)據(jù)庫。在有些情況下,你或許會(huì)想要禁用應(yīng)用服務(wù)的工作單元:

• 你的方法不需要任何數(shù)據(jù)庫操作且你不想要開啟那些不需要的數(shù)據(jù)庫連接

• 你想要使用工作單元于UnitOfWorkScope類的有限范圍內(nèi),如上所述

注意,如果工作單元方法調(diào)用這個(gè)RemoveFriendship方法,禁用被忽略且它和調(diào)用它的方法使用同一個(gè)工作單元。因此,使用禁用這個(gè)功能要很小心。同樣地,上述程序代碼工作的很好,因?yàn)閭}儲(chǔ)方法默認(rèn)即為工作單元。

無事務(wù)的工作單元(Non-transactional unit of work)

工作單元默認(rèn)上是具事務(wù)性的(這是它的天性)。因此,ABP啟動(dòng)/提交/回滾一個(gè)顯性的數(shù)據(jù)庫等級的事務(wù)。在有些特殊案例中,事務(wù)可能會(huì)導(dǎo)致問題,因?yàn)樗赡軙?huì)鎖住有些數(shù)據(jù)列或是數(shù)據(jù)表于數(shù)據(jù)庫中。在此這些情境下, 你或許會(huì)想要禁用數(shù)據(jù)庫等級的事務(wù)。UnitOfWork屬性可以從它的建構(gòu)子中取得一個(gè)布爾值來讓它如非事務(wù)型工作單元般工作著。示例為:

[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)會(huì)在單一命令中于內(nèi)部進(jìn)行數(shù)據(jù)儲(chǔ)存。假設(shè)你更新了一些的實(shí)體于非事務(wù)的UoW。即便于這個(gè)情境下所有的更新都會(huì)于單一數(shù)據(jù)庫命令的工作單元尾部完成。但是,如果你直接執(zhí)行SQL查詢,它會(huì)立即被執(zhí)行。

這里有一個(gè)非事務(wù)性UoW的限制。如果你已經(jīng)位于事務(wù)性UoW區(qū)域內(nèi),設(shè)定isTransactional為false這個(gè)動(dòng)作會(huì)被忽略。

使用非事務(wù)性UoW要小心,因?yàn)樵诖蠖鄶?shù)的情況下,數(shù)據(jù)整合應(yīng)該是具事務(wù)性的。如果你的方法只是讀取數(shù)據(jù),不改變數(shù)據(jù),那么當(dāng)然可以采用非事務(wù)性。

工作單元調(diào)用其它工作單元(A unit of work method calls another)

若工作單元方法(一個(gè)貼上UnitOfWork屬性標(biāo)簽的方法)調(diào)用另一個(gè)工作單元方法,他們共享同一個(gè)連接和事務(wù)。第一個(gè)方法管理連接,其它的方法只是使用它。這在所有方法都執(zhí)行在同一個(gè)線程下是可行的(或是在同一個(gè)Web請求內(nèi))。實(shí)際上,當(dāng)工作單元區(qū)域開始,所有的程序代碼都會(huì)在同一個(gè)線程中執(zhí)行并共享同一個(gè)連接事務(wù),直到工作單元區(qū)域終止。這對于使用UnitOfWork屬性和UnitOfWorkScope類來說都是一樣的。如果你創(chuàng)建了一個(gè)不同的線程/任務(wù),它使用自己所屬的工作單元。

自動(dòng)化的saving changes (Automatically saving changes)

當(dāng)我們使用工作單元到方法上,ABP自動(dòng)的儲(chǔ)存所有變化于方法的末端。假設(shè)我們需要一個(gè)可更新person名稱的方法:

 [UnitOfWork]   public void UpdateName(UpdateNameInput input) {      var person = _personRepository.Get(input.PersonId);
      person.Name = input.NewName;
   }

就這樣,名稱就被修改了!我們甚至沒有調(diào)用_personRepository.Update方法。ORM框架會(huì)持續(xù)追蹤實(shí)體所有的變化于工作單元內(nèi),且反映所有變化到數(shù)據(jù)庫中。

注意,這不需要在應(yīng)用服務(wù)聲明UnitOfWork,因?yàn)樗鼈兡J(rèn)就是采用工作單元。

倉儲(chǔ)接口的GetAll()方法(IRepository.GetAll())

當(dāng)你在倉儲(chǔ)方法外調(diào)用GetAll方法, 這必定得有一個(gè)開啟狀態(tài)的數(shù)據(jù)庫連接,因?yàn)樗祷豂Queryable類型的對象。這是需要的,因?yàn)镮Queryable延遲執(zhí)行。它并不會(huì)馬上執(zhí)行數(shù)據(jù)庫查詢,直到你調(diào)用ToList()方法或在foreach循環(huán)中使用IQueryable(或是存取被查詢結(jié)果集的情況下)。因此,當(dāng)你調(diào)用ToList()方法,數(shù)據(jù)庫連接必需是啟用狀態(tài)。示例:

[UnitOfWork]public SearchPeopleOutput SearchPeople(SearchPeopleInput input)
{    //Get IQueryable<Person>var query = _personRepository.GetAll();    //Add some filters if selectedif (!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 listvar people = query.Skip(input.SkipCount).Take(input.MaxResultCount).ToList();    return new SearchPeopleOutput { People = Mapper.Map<List<PersonDto>>(people) };
}

在這里,SearchPeople方法必需是工作單元,因?yàn)镮Queryable在被調(diào)用ToList()方法于方法本體內(nèi),并且數(shù)據(jù)庫連接必須于IQueryable.ToList()被執(zhí)行時(shí)開啟。

一如GetAll()方法,如果需要數(shù)據(jù)庫連接且沒有倉儲(chǔ)的情況下,你就必須要使用工作單元。注意,應(yīng)用服務(wù)方法默認(rèn)就是工作單元。

工作單元屬性的限制(UnitOfWork attribute restrictions)

在下面情境下你可以使用UnitOfWork屬性標(biāo)簽:

• 類所有public或public virtual這些基于界面的方法(像是應(yīng)用服務(wù)是基于服務(wù)界面)

• 自我注入類的public virtual方法(像是MVC Controller和Web API Controller)

• 所有protected virtual方法。

建議將方法標(biāo)示為virtual。你無法應(yīng)用在private方法上。因?yàn)?ABP使用dynamic proxy來實(shí)現(xiàn),而私有方法就無法使用繼承的方法來實(shí)現(xiàn)。當(dāng)你不使用依賴注入且自行初始化類,那么UnitOfWork屬性(以及任何代理)就無法正常運(yùn)作。

選項(xiàng)

有許多可以用來控制工作單元的選項(xiàng)。

首先,我們可以在startup configuration中改變所有工作單元的所有默認(rèn)值。這通常是用了我們模塊中的PreInitialize方法來實(shí)現(xiàn)。

public class SimpleTaskSystemCoreModule : AbpModule
{    public override void PreInitialize()
    {
        Configuration.UnitOfWork.IsolationLevel = IsolationLevel.ReadCommitted;
        Configuration.UnitOfWork.Timeout = TimeSpan.FromMinutes(30);
    }    //...other module methods}

方法

工作單元系統(tǒng)運(yùn)作是無縫且不可視的。但是,在有些特例下,你需要調(diào)用它的方法。

SaveChanges

ABP儲(chǔ)存所有的變化于工作單元的尾端,你不需要做任何事情。但是,有些時(shí)候,你或許會(huì)想要在工作單元的過程中就儲(chǔ)存所有變化。在這個(gè)案例中,你可以注入IUnitOfWorkManager并且調(diào)用IUnitOfWorkManager.Current.SaveChanges()方法。示例中以Entity Framework在儲(chǔ)存變化時(shí)取得新增實(shí)體的Id。注意,當(dāng)前工作單元是具事務(wù)性的,所有在事務(wù)中的變化會(huì)在異常發(fā)生時(shí)都被回滾,即便是已調(diào)用SaveChange。

事件

工作單元具有Completed/Failed/Disposed事件。你可以注冊這些事件并且進(jìn)行所需的操作。注入IUnitOfWorkManager并且使用IUnitOfWorkManager.Current 屬性來取得當(dāng)前已激活的工作單元并且注冊它的事件。

你或許會(huì)想要執(zhí)行有些程序代碼于當(dāng)前工作單元成功地完成。示例:

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

感謝各位的閱讀，以上就是“ASP.NET的通用連接和事務(wù)管理方法是什么”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對ASP.NET的通用連接和事務(wù)管理方法是什么這一問題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點(diǎn)的文章，歡迎關(guān)注！

網(wǎng)頁題目：ASP.NET的通用連接和事務(wù)管理方法是什么
標(biāo)題路徑：http://aaarwkj.com/article28/iippjp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供響應(yīng)式網(wǎng)站、網(wǎng)站改版、網(wǎng)站設(shè)計(jì)、網(wǎng)站制作、動(dòng)態(tài)網(wǎng)站、移動(dòng)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)