URF.NET
v5.1.0
工作单元和存储库框架|官方URF、可追踪实体和设计工厂团队
该框架（总下载量超过 100K+）最大限度地减少了 ORM 技术在应用程序中传播的表面积。该框架经过精心设计，重量轻，占地面积小，并且易于扩展和维护。当我们说轻量级时，我们真正的意思是轻量级，当将此框架与实体框架提供程序一起使用时，只有 10 个类。这个轻量级框架将允许您通过存储库、工作单元和领域驱动设计优雅、不引人注目且轻松地对您的应用程序和系统进行模式化。是否使用通用存储库？该框架允许通用存储库的自由，以及添加您自己的域特定存储库方法的能力，简而言之，具有可扩展和通用存储库的工作单元。
现场演示：longle.azurewebsites.net
public class CustomerController : ODataController { private readonly ICustomerService _customerService ; private readonly IUnitOfWorkAsync _unitOfWorkAsync ; public CustomerController ( IUnitOfWorkAsync unitOfWorkAsync , ICustomerService customerService ) { _unitOfWorkAsync = unitOfWorkAsync ; _customerService = customerService ; } // GET: odata/Customers [ HttpGet ] [ Queryable ] public IQueryable < Customer > GetCustomer ( ) { return _customerService . Queryable ( ) ; } // GET: odata/Customers(5) [ Queryable ] public SingleResult < Customer > GetCustomer ( [ FromODataUri ] string key ) { return SingleResult . Create ( _customerService . Queryable ( ) . Where ( t => t . CustomerID == key ) ) ; } // PUT: odata/Customers(5) public async Task < IHttpActionResult > Put ( string key , Customer customer ) { if ( ! ModelState . IsValid ) { return BadRequest ( ModelState ) ; } if ( key != customer . CustomerID ) { return BadRequest ( ) ; } customer . TrackingState = TrackingState . Modified ; _customerService . Update ( customer ) ; try { await _unitOfWorkAsync . SaveChangesAsync ( ) ; } catch ( DbUpdateConcurrencyException ) { if ( ! CustomerExists ( key ) ) { return NotFound ( ) ; } throw ; } return Updated ( customer ) ; } // POST: odata/Customers public async Task < IHttpActionResult > Post ( Customer customer ) { if ( ! ModelState . IsValid ) { return BadRequest ( ModelState ) ; } customer . TrackingState = TrackingState . Added ; _customerService . Insert ( customer ) ; try { await _unitOfWorkAsync . SaveChangesAsync ( ) ; } catch ( DbUpdateException ) { if ( CustomerExists ( customer . CustomerID ) ) { return Conflict ( ) ; } throw ; } return Created ( customer ) ; } //// PATCH: odata/Customers(5) [ AcceptVerbs ( " PATCH " , " MERGE " ) ] public async Task < IHttpActionResult > Patch ( [ FromODataUri ] string key , Delta < Customer > patch ) { if ( ! ModelState . IsValid ) { return BadRequest ( ModelState ) ; } Customer customer = await _customerService . FindAsync ( key ) ; if ( customer == null ) { return NotFound ( ) ; } patch . Patch ( customer ) ; customer . TrackingState = TrackingState . Modified ; try { await _unitOfWorkAsync . SaveChangesAsync ( ) ; } catch ( DbUpdateConcurrencyException ) { if ( ! CustomerExists ( key ) ) { return NotFound ( ) ; } throw ; } return Updated ( customer ) ; } // DELETE: odata/Customers(5) public async Task < IHttpActionResult > Delete ( string key ) { Customer customer = await _customerService . FindAsync ( key ) ; if ( customer == null ) { return NotFound ( ) ; } customer . TrackingState = TrackingState . Deleted ; _customerService . Delete ( customer ) ; await _unitOfWorkAsync . SaveChangesAsync ( ) ; return StatusCode ( HttpStatusCode . NoContent ) ; } // GET: odata/Customers(5)/CustomerDemographics [ Queryable ] public IQueryable < CustomerDemographic > GetCustomerDemographics ( [ FromODataUri ] string key ) { return _customerService . Queryable ( ) . Where ( m => m . CustomerID == key ) . SelectMany ( m => m . CustomerDemographics ) ; } // GET: odata/Customers(5)/Orders [ Queryable ] public IQueryable < Order > GetOrders ( [ FromODataUri ] string key ) { return _customerService . Queryable ( ) . Where ( m => m . CustomerID == key ) . SelectMany ( m => m . Orders ) ; } protected override void Dispose ( bool disposing ) { if ( disposing ) { _unitOfWorkAsync . Dispose ( ) ; } base . Dispose ( disposing ) ; } private bool CustomerExists ( string key ) { return _customerService . Query ( e => e . CustomerID == key ) . Select ( ) . Any ( ) ; } }
从Service中的Repository公开的所有方法都可以重写，以添加任何前置或后置域/业务逻辑。域业务逻辑应该位于服务层，而不是位于控制器或存储库中，以实现关注点分离。
ICustomerService ，它应该始终继承IService例如IServiceICustomerService的CustomerServicecontainer.RegisterType() ，有关连接 DI 和 IoC 的更多详细信息，请参阅下一个示例。 public interface ICustomerService : IService < Customer >
{
decimal CustomerOrderTotalByYear ( string customerId , int year ) ;
IEnumerable < Customer > CustomersByCompany ( string companyName ) ;
IEnumerable < CustomerOrder > GetCustomerOrder ( string country ) ;
}
public class CustomerService : Service < Customer > , ICustomerService
{
private readonly IRepositoryAsync < Customer > _repository ;
public CustomerService ( IRepositoryAsync < Customer > repository ) : base ( repository )
{
_repository = repository ;
}
public decimal CustomerOrderTotalByYear ( string customerId , int year )
{
// add any domain logic here
return _repository . GetCustomerOrderTotalByYear ( customerId , year ) ;
}
public IEnumerable < Customer > CustomersByCompany ( string companyName )
{
// add any domain logic here
return _repository . CustomersByCompany ( companyName ) ;
}
public IEnumerable < CustomerOrder > GetCustomerOrder ( string country )
{
// add any domain logic here
return _repository . GetCustomerOrder ( country ) ;
}
public override void Insert ( Customer entity )
{
// e.g. add any business logic here before inserting
base . Insert ( entity ) ;
}
public override void Delete ( object id )
{
// e.g. add business logic here before deleting
base . Delete ( id ) ;
}
} UnityConfig.cs
public class UnityConfig
{
private static Lazy < IUnityContainer > container = new Lazy < IUnityContainer > ( ( ) =>
{
var container = new UnityContainer ( ) ;
RegisterTypes ( container ) ;
return container ;
} ) ;
public static IUnityContainer GetConfiguredContainer ( )
{
return container . Value ;
}
public static void RegisterTypes ( IUnityContainer container )
{
container
// Register DbContext instead of IDataDataContext, which is now obsolete.
//.RegisterType(new PerRequestLifetimeManager())
. RegisterType < DbContext , NorthwindContext > ( new PerRequestLifetimeManager ( ) )
. RegisterType < IUnitOfWorkAsync , UnitOfWork > ( new PerRequestLifetimeManager ( ) )
. RegisterType < IRepositoryAsync < Customer > , Repository < Customer > > ( )
. RegisterType < IRepositoryAsync < Product > , Repository < Product > > ( )
. RegisterType < IProductService , ProductService > ( )
. RegisterType < ICustomerService , CustomerService > ( )
. RegisterType < INorthwindStoredProcedures , NorthwindContext > ( new PerRequestLifetimeManager ( ) )
. RegisterType < IStoredProcedureService , StoredProcedureService > ( ) ;
}
}
