实战Angular2+web api增删改查 (一）
|
Angular2是一个前端开发框架，在引入ts之后使得我们这些C#开发者能够更快的熟悉该框架，angular2开发首先要知道这是一个SPA（单页应用），我们要摆脱以往的asp.net中的MVC模式的固有思路，angular2开发重点是组件（Component），所以开发之前尤其要能清楚这个概念。 在与angular2配合使用的后端（RestFul）我采用的是基于asp.net的web api2.0，这也是目前比较流行的一种方式。我在webapi开发中在数据层使用的是基于NHibernate的Repository+UnitWork模式，自然也会用到依赖注入，我选的依赖注入工具是AutoFac。在前端与后端的数据传递使用DTO，为了方便，使用的是AutoMapper做数据映射。下面从底层开始，以一个简单实例演示整个过程。 领域模型在建模时曾考虑使用EF6，目前也有很多关于EF6的争议就是EF中实际已包含了Repository和UnitOfWork模式，那么在使用EF时就不必再使用这种模式了，为了能够熟练这种模式我选用了NHibernate作为ORM框架。 数据实体类publicclassTGroup:EntityBase{ publicTGroup(){ Users=newList<TUser>(); } publicvirtualstringID{get;set;} publicvirtualstringGROUPNAME{get;set;} publicvirtualdecimal?NORDER{get;set;} publicvirtualstringPARENTID{get;set;} publicvirtualDateTime?CREATED{get;set;} publicvirtualstringGROUPTYPE{get;set;} publicvirtualstringGROUPCODE{get;set;} publicvirtualIList<TUser>Users{get;set;} } 数据实体类都继承于EntityBase，EntityBase是一个空的类，目前没有任何属性及方法，只是为了在使用Repositroy模式时方便，其实可以抽象出诸如ID这样的公共属性出来。 关系映射<?xmlversion="1.0"encoding="utf-8"?> <hibernate-mappingassembly="URS.Data"namespace="URS.Data.Model"xmlns="urn:nhibernate-mapping-2.2"> <classname="TGroup"table="T_GROUP"lazy="true"> <idname="ID"column="ID"/> <propertyname="GROUPNAME"> <columnname="GROUPNAME"sql-type="VARCHAR2"not-null="false"/> </property> <propertyname="NORDER"> <columnname="NORDER"sql-type="NUMBER"not-null="false"/> </property> <propertyname="PARENTID"> <columnname="PARENTID"sql-type="VARCHAR2"not-null="false"/> </property> <propertyname="CREATED"> <columnname="CREATED"sql-type="DATE"not-null="false"/> </property> <propertyname="GROUPTYPE"> <columnname="GROUPTYPE"sql-type="VARCHAR2"not-null="false"/> </property> <propertyname="GROUPCODE"> <columnname="GROUPCODE"sql-type="VARCHAR2"not-null="true"/> </property> <bagname="Users"inverse="true"cascade="all"> <keycolumn="GROUPID"/> <one-to-manyclass="TUser"/> </bag> </class> </hibernate-mapping> 在实体类中就可以看出这是一个一对多关系，TGroup包含了一个TUser集合，所以在映射时使用的bag中描绘了这个一对多关系，这里需要说明的是我所使用的是oracle数据库。 NHibernate配置<?xmlversion="1.0"encoding="utf-8"?> <hibernate-configurationxmlns="urn:nhibernate-configuration-2.2"> <session-factory> <propertyname="connection.driver_class">NHibernate.Driver.OracleManagedDataClientDriver</property> <propertyname="connection.connection_string">UserId=urs;Password=urs;DataSource=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=localhost)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=ORA11G)))</property> <propertyname="show_sql">true</property> <propertyname="dialect">NHibernate.Dialect.Oracle10gDialect</property> <propertyname="query.substitutions">true1,false0,yes'Y',no'N'</property> <propertyname="current_session_context_class">call</property> <mappingassembly="URS.Data"/> </session-factory> </hibernate-configuration> 这是一个使用oracle的odp的连接配置，这个配置文件需要放在WebAPI解决方案下 Repository模式IRepository接口publicinterfaceIRepository<TEntity>:IDependencywhereTEntity:EntityBase {
TEntityGet(objectid);
IList<TEntity>GetAll();
voidAdd(TEntityentity);
voidUpdate(TEntityentity);
voidDelete(TEntityentity);
voidDelete(objectid); } 这里的IRepository接口只提取了部分通用的CURD操作，这里需要注意的是该接口继承了IDependency，这是为了我们下面使用依赖注入的一个空接口，下面会说到这样的目的。 Repository基类publicclassNHRepositoryBase<TEntity>:IRepository<TEntity>whereTEntity:EntityBase {
protectedvirtualISessionSession {
get
{
returnSessionBuilder.GetCurrentSession(); } } publicvirtualTEntityGet(objectid) {
returnSession.Get<TEntity>(id);
} publicvirtualIList<TEntity>GetAll() {
returnSession.CreateCriteria<TEntity>()
.List<TEntity>(); } publicvirtualvoidAdd(TEntityentity) {
try
{
Session.Save(entity); } catch(Exceptionex) {
throwex;
} } publicvirtualvoidUpdate(TEntityentity) {
try
{
Session.SaveOrUpdate(entity); } catch(Exceptionex) {
throwex;
} } publicvirtualvoidDelete(TEntityentity) {
try
{
Session.Delete(entity); } catch(Exceptionex) {
throwex;
} } publicvirtualvoidDelete(objectid) {
try
{
TEntityentity=this.Get(id);
Session.Delete(entity); } catch(Exceptionex) {
throwex;
} } } 由于我们使用的是NHibernate，所以我们需要一个全局的ISession，SessionBuilder是我封装的一个类，用来处理ISession，保障一个应用中只有一个ISession实例。 业务RepositorypublicclassGroupRepository:NHRepositoryBase<TGroup>,IGroupRepository {
} 由于Repository基类中包含了通用的CURD操作，所以这个GroupRepository只需继承这个基类即可，如果还有其他操作或属性则再进一步抽象出IGroupRepository，这里我还没打算加入其他操作所以IGroupRepository是个空的接口，以后也许会加入其他方法或属性。 UnitOfWork模式unitofwork模式重点是处理事务，对变化的数据一次提交保证数据完整性。 IUnitOfWork接口publicinterfaceIUnitOfWork:IDisposable,IDependency {
IRepository<TEntity>BaseRepository<TEntity>()whereTEntity:EntityBase; voidBeginTransaction();
voidCommit();
voidRollback();
} 这个接口同样也继承了IDependency，也是为了后面的依赖注入。在这个接口中我还定义了一个IRepository<TEntity>的属性，这是一个能够根据实体类来获取其对应的Repository。 UnitOfWork实现publicclassNHUnitOfWork:IUnitOfWork {
privateITransaction_transaction; privateHashtable_repositories; publicISessionSession {
get
{
returnSessionBuilder.GetCurrentSession(); } } publicNHUnitOfWork()
{
} publicvoidBeginTransaction() {
this._transaction=Session.BeginTransaction();
} publicvoidCommit() {
try
{
//committransactionifthereisoneactive
if(_transaction!=null&&_transaction.IsActive) _transaction.Commit(); } catch
{
//rollbackiftherewasanexception
if(_transaction!=null&&_transaction.IsActive) _transaction.Rollback(); throw;
} //finally
//{
//Session.Dispose();
//}
} publicvoidRollback() {
//try
{
if(_transaction!=null&&_transaction.IsActive) _transaction.Rollback(); } //finally
//{
//Session.Dispose();
//}
} publicvoidDispose() {
Session.Dispose(); } publicIRepository<T>BaseRepository<T>()whereT:EntityBase {
if(_repositories==null) _repositories=newHashtable(); vartype=typeof(T).Name; if(!_repositories.ContainsKey(type))
{
varrepositoryType=typeof(NHRepositoryBase<>); varrepositoryInstance=
Activator.CreateInstance(repositoryType
.MakeGenericType(typeof(T)));
_repositories.Add(type,repositoryInstance); } return(IRepository<T>)_repositories[type]; } } 这里使用了反射创建Repository实例，这里是创建的通用基类型的Repository实例，好处就是当我们在业务逻辑层使用UnitOfWork时如果是通用的操作，则不用注入Repository了，否则可能要构造中可能要注入很多业务Repository，比较麻烦，当然如果不是通用操作的话，还是要注入的，下面会讲到。 业务逻辑层应用publicclassGroupService:IGroupService {
privateIUnitOfWork_unitOfWork; privateIGroupRepository_groupRepository; publicGroupService(IUnitOfWorkunitOfWork,IGroupRepositorygroupRepository) {
_unitOfWork=unitOfWork; _groupRepository=groupRepository; } publicIList<TGroup>GetAll() {
IRepository<TGroup>repo=_unitOfWork.BaseRepository<TGroup>(); returnrepo.GetAll();
} publicTGroupGetByID(stringid) {
IRepository<TGroup>repo=_unitOfWork.BaseRepository<TGroup>(); returnrepo.Get(id);
} publicvoidAdd(TGroupentity) {
_unitOfWork.BeginTransaction(); IRepository<TGroup>repo=_unitOfWork.BaseRepository<TGroup>(); repo.Add(entity); _unitOfWork.Commit(); } publicvoidDelete(stringid) {
_unitOfWork.BeginTransaction(); IRepository<TGroup>repo=_unitOfWork.BaseRepository<TGroup>(); repo.Delete(id); _unitOfWork.Commit(); } publicvoidUpdate(TGroupentity) {
_unitOfWork.BeginTransaction(); IRepository<TGroup>repo=_unitOfWork.BaseRepository<TGroup>(); repo.Update(entity); _unitOfWork.Commit(); } } 这里通过在构造函数中注入IUnitOfWork，IGroupRepository，这里可以看到，由于在本例中使用的都是通用的数据CURD，所以实际上IGroupRepository并没有使用，而实际使用的是IUnitOfWork中创建的IRepository<TGroup>，由于这个例子比较简单，如果是由复杂业务逻辑的话，那么需要在_unitOfWork.BeginTransaction()到_unitOfWork.Commit()之间完成业务处理即可保障数据提交的一致性，如果这中间有异常，IUnitOfWork会回滚，这就意味着要么全部提交，要不都不提交。 这里的GroupService继承了IGroupService，而IGroupService也会继承IDependency，下面将在WebApi的解决方案中介绍AutoFac的依赖注入使用方法。 （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |