IUnitOfWork

• The object.

Returns

• obj – The obj.

Parameters

object UnProxy(object obj)

Convert a proxied object into the real thing.

UnProxy(object)

• action – The action.

Parameters

void SaveWithoutChangeTracking(Action action)

Saves all of the changes in the current UnitOfWork session to the Database executing the passed in action while Change Tracking is disabled.

SaveWithoutChangeTracking(Action)

• The Task.

Returns

Task SaveAsync()

Saves all of the changes in the object in the current UnitOfWork session to the Database async.

SaveAsync()

Code Sample

public override AddBillToResult Execute(IUnitOfWork unitOfWork, AddBillToParameter parameter, AddBillToResult result)
{
    var customerRepository = unitOfWork.GetRepository<Customer>();
 
    var billTo = customerRepository.Create();
    var setBillToInitialValuesResult = this.customerPipeline.SetBillToInitialValues(new SetBillToInitialValuesParameter(billTo));
    if (setBillToInitialValuesResult.ResultCode != ResultCode.Success)
    {
        return this.CreateErrorServiceResult(result, setBillToInitialValuesResult.SubCode, setBillToInitialValuesResult.Message);
    }
 
    billTo.IsGuest = parameter.IsGuest;
    billTo.FirstName = parameter.FirstName ?? string.Empty;
    billTo.LastName = parameter.LastName ?? string.Empty;
    billTo.CompanyName = parameter.CompanyName ?? string.Empty;
    billTo.Attention = parameter.Attention ?? string.Empty;
    billTo.Address1 = parameter.Address1 ?? string.Empty;
    billTo.Address2 = parameter.Address2 ?? string.Empty;
    billTo.Address3 = parameter.Address3 ?? string.Empty;
    billTo.Address4 = parameter.Address4 ?? string.Empty;
    billTo.City = parameter.City ?? string.Empty;
    billTo.PostalCode = parameter.PostalCode ?? string.Empty;
    billTo.Phone = parameter.Phone ?? string.Empty;
    billTo.Fax = parameter.Fax ?? string.Empty;
    billTo.Email = parameter.Email ?? string.Empty;
 
    this.customerUtilities.SetCountry(unitOfWork, parameter.CountryId, billTo);
    this.customerUtilities.SetState(unitOfWork, parameter.StateId, billTo);
 
    customerRepository.Insert(billTo);
    unitOfWork.Save();
 
    result.BillTo = billTo;
 
    return this.NextHandler.Execute(unitOfWork, parameter, result);
}

The example below adds a new bill-to customer based on data sent along with the API request.

Example

This method is typically called after updating or deleting existing business objects or creating new business objects.

Remarks

void Save()

Saves all of the changes in the current UnitOfWork session to the Database.

Save()

void RollbackTransaction()

Rolls back a previously started Database Transaction

RollbackTransaction()

• T : class, IBusinessObject

Type Constraints

• obj – The obj.

Parameters

void Refresh<T>(T obj)

Refresh an object from the database.

Refresh<T>(T)

• T : class, IBusinessObject

Type Constraints

• value – The value.

Parameters

void Reattach<T>(T value)

Reattaches a previously Evicted object to the session.

Reattach<T>(T)

Code Sample

public override AddAccountResult Execute(IUnitOfWork unitOfWork, AddAccountParameter parameter, AddAccountResult result)
{
    if (!RegularExpressionLibrary.IsValidEmail(parameter.Email))
    {
        return this.CreateErrorServiceResult(
            result,
            SubCode.InvalidEmailAddress,
            MessageProvider.Current.UpdateAccountInfo_EmailAddress_ValidEmail);
    }
 
    if (this.authenticationService.Value.RequiresUniqueEmail())
    {
        var emailAlreadyExists = unitOfWork.GetTypedRepository<IUserProfileRepository>().GetTable().Any(o => o.Email.Equals(parameter.Email));
 
        if (emailAlreadyExists)
        {
            return this.CreateErrorServiceResult(
                result,
                SubCode.AccountServiceEmailAlreadyExists,
                MessageProvider.Current.CreateNewAccountInfo_EmailAddress_AlreadyExists);
        }
    }
 
    return this.NextHandler.Execute(unitOfWork, parameter, result);
}

The example below validates the email address when creating a new account. The GetTypedRepository<T>() method is used to return the IUserProfileRepository and check if the email address is already being used by another user.

Example

This method is useful if you need to use a method on a repository that is specific to that repository implementation. For example, the IUserProfileRepository has a method GetByUserName that finds a user by username rather than by id, which is another way to retrieve an object from the database.

Remarks

T : class, IRepository

Type Constraints

The repository.

Returns

T GetTypedRepository<T>()

Returns a specific type of IRepository that will be tracked within this UnitOfWork's session.

GetTypedRepository<T>()

Code Sample

public override RemoveCartResult Execute(IUnitOfWork unitOfWork, RemoveCartParameter parameter, RemoveCartResult result)
{
    var cart = result.GetCartResult.Cart;
    if (cart.Id == Guid.Empty || cart.Status == CustomerOrder.StatusType.Void)
    {
        return this.NextHandler.Execute(unitOfWork, parameter, result);
    }
 
    unitOfWork.GetRepository<CustomerOrder>().Delete(result.GetCartResult.Cart);
 
    return this.NextHandler.Execute(unitOfWork, parameter, result);
}

The example below uses the GetRepository<T> method to return an IRepository<CustomerOrder> to delete a specific customer order.

Example

Unlike the GetTypedRepository<T> method, this method returns a generic repository, rather than a specific repository, that operates on a specific business object.

Remarks

• T : class, IBusinessObject

Type Constraints

• The IRepository.

Returns

IRepository<T> GetRepository<T>()

Returns an IRepository for an object that will be tracked within this UnitOfWork's session.

GetRepository<T>()

• The IRepository.

Returns

• type – The type.

Parameters

IRepository GetRepository(Type type)

Returns an IRepository for an object that will be tracked within this UnitOfWork's session.

GetRepository(Type)

• obj – The obj.

Parameters

void Evict(object obj)

Removes a single object from the UnitOfWork session. The object is still a valid object, but will no longer persist to the database.

Evict(object)

• obj – The obj.

Parameters

void EagerLoad(object obj)

Forces a load of a proxy, does not cascade.

EagerLoad(object)

void CommitTransaction()

Commits a previously started Database Transaction.

CommitTransaction()

void Close()

Close the Session.

Close()

• dispose – If true, the underlying data provider will be disposed.

Parameters

void Clear(bool dispose = true)

This method clears the objects out of the UnitOfWork session, the objects will still be valid objects, but they will no longer be persisted to the database. This method is useful when working with large sets of data for example during a refresh.

Clear(bool)

• isolationLevel – Isolation level.

Parameters

void BeginTransaction(IsolationLevel isolationLevel)

This method starts a Database Transaction using the specified isolation level.

BeginTransaction(IsolationLevel)

Code Sample

this.UnitOfWork.BeginTransaction();
try
{
    foreach (var contentKey in contentKeys)
    {
        this.RecursiveDelete(contentKey, isVariant);
    }
 
    this.UnitOfWork.Save();
    this.UnitOfWork.CommitTransaction();
}
catch (Exception)
{
    this.UnitOfWork.RollbackTransaction();
    throw;
}

Below is the typical usage of this method along with the other methods that handle the lifetime of a database transaction.

Example

void BeginTransaction()

This method starts a Database Transaction.

BeginTransaction()

Methods

IDataProvider DataProvider {get;}

The Persistant Data Provider.

DataProvider

Properties

The first time the UnitOfWork is accessed, it will create an instance of the UnitOfWork in HttpContext.Current.Items which lasts for the current web request. Subsequent access of UnitOfWork will return this instance.

The IUnitOfWork interface is the abstraction layer to the object session management of the system.