实战Angular2+web api增删改查 (一)

前端之家收集整理的这篇文章主要介绍了实战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实例。

业务Repository

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

这里通过在构造函数中注入IUnitOfWorkIGroupRepository这里可以看到,由于在本例中使用的都是通用的数据CURD,所以实际上IGroupRepository并没有使用,而实际使用的是IUnitOfWork中创建的IRepository<TGroup>,由于这个例子比较简单,如果是由复杂业务逻辑的话,那么需要在_unitOfWork.BeginTransaction()到_unitOfWork.Commit()之间完成业务处理即可保障数据提交的一致性,如果这中间有异常,IUnitOfWork会回滚,这就意味着要么全部提交,要不都不提交。

这里的GroupService继承了IGroupService而IGroupService也会继承IDependency下面将在WebApi的解决方案中介绍AutoFac的依赖注入使用方法

猜你在找的Angularjs相关文章