/// <summary>/// 工作单元中仓储接口CRUD操作/// 需要使用工作单元的仓储，需要实现本接口（IRepository,IExtensionRepository)/// </summary>public interface IUnitOfWorkRepository{/// <summary>/// 添加实体/// </summary>/// <param name="item"></param>void UoWInsert(IEntity item);/// <summary>/// 更新实体/// </summary>/// <param name="item"></param>void UoWUpdate(IEntity item);/// <summary>/// 移除实体/// </summary>/// <param name="item"></param>void UoWDelete(IEntity item);}

　　 /// <summary>/// 工作单元/// 所有数据上下文对象都应该继承它，面向仓储的上下文应该与具体实现（存储介质,ORM）无关/// </summary>public interface IUnitOfWork{/// <summary>/// 向工作单元中注册变更/// </summary>/// <typeparam name="T"></typeparam>/// <param name="entity"></param>/// <param name="type"></param>/// <param name="repository"></param>void RegisterChangeded(IEntity entity, SqlType type, IUnitOfWorkRepository repository);/// <summary>/// 向数据库提交变更/// </summary>void Commit();}

 　 /// <summary>/// 工作单元，主要用于管理事务性操作/// Author:Lind.zhang/// </summary>public class UnitOfWork : IUnitOfWork{#region Fields/// <summary>/// 操作行为字典/// </summary>private IDictionary<IEntity, IUnitOfWorkRepository> insertEntities;private IDictionary<IEntity, IUnitOfWorkRepository> updateEntities;private IDictionary<IEntity, IUnitOfWorkRepository> deleteEntities;#endregion#region Constructorpublic UnitOfWork(){insertEntities = new Dictionary<IEntity, IUnitOfWorkRepository>();updateEntities = new Dictionary<IEntity, IUnitOfWorkRepository>();deleteEntities = new Dictionary<IEntity, IUnitOfWorkRepository>();}#endregion#region IUnitOfWork 成员/// <summary>/// 事务提交/// </summary>public void Commit(){try{using (TransactionScope transactionScope = new TransactionScope()){foreach (var entity in insertEntities.Keys){insertEntities[entity].UoWInsert(entity);}foreach (var entity in updateEntities.Keys){updateEntities[entity].UoWUpdate(entity);}foreach (var entity in deleteEntities.Keys){deleteEntities[entity].UoWDelete(entity);}transactionScope.Complete();//提交事务，程序中如果出错，这行无法执行，即事务不会被提交，这就类似于rollback机制
                }}catch (Exception ex){Logger.LoggerFactory.Instance.Logger_Error(ex);}}/// <summary>/// 注册数据变更/// </summary>/// <typeparam name="T"></typeparam>/// <param name="entity"></param>/// <param name="type"></param>public void RegisterChangeded(IEntity entity, SqlType type, IUnitOfWorkRepository repository){switch (type){case SqlType.Insert:insertEntities.Add(entity, repository);break;case SqlType.Update:updateEntities.Add(entity, repository);break;case SqlType.Delete:deleteEntities.Add(entity, repository);break;default:throw new ArgumentException("you enter reference is error.");}}#endregion}

 　　　　　　 unitOfWork.RegisterChangeded(entity, SqlType.Update, userRepository);var userExtension = userExtRepository.Find(entity.Id);userExtension.NickName = Request.Form["UserExtension.NickName"];userExtension.School = Request.Form["UserExtension.School"];unitOfWork.RegisterChangeded(userExtension, SqlType.Update, userExtRepository);unitOfWork.Commit();