Spring.Net+NHibenate+Asp.Net mvc +ExtJs 系列 3 ----数据访问层-阿里云开发者社区

开发者社区> 长征6号> 正文

Spring.Net+NHibenate+Asp.Net mvc +ExtJs 系列 3 ----数据访问层

简介:
+关注继续查看

   在上一篇中,我们已经搭建起了整个解决方案的项目,并且建好了数据库,完成了实体类和Nhibernate映射文件.在本文中,将定义数据访问接口,并利用Nhibernate实现接口,利用Spring.net配置起来dao.并对其进行单元测试.

   数据访问层也和Petshop等框架一样,分为数据访问的接口以及实现,不过这里的数据访问实现相比之下就清晰和明显了的多,Nhibernate本身就是支持多数据库的,所以这样做不是为了多数据库,而是为了Nhibernate的可插拨,即使哪一天发现由于一些问题,比如说性能问题,可以重新实现IDAL接口,而不会对业务层造成比较大的改动.

   说到这里,其实我们还不太清楚前台到底需要哪些功能,所以我们就先简单的实现实体的增删改查吧.等需要其它的功能时,再来完善接口和实现.

   DirectCenter.IDAL不依赖于Spring或者是Nhibernate,只需要添加项目引用DirectCenter.Model.以用户来说吧,添加接口IUserDao.cs

IUserDao.cs
using System.Collections;
using DirectCenter.Model;

namespace DirectCenter.IDAL
{
publicinterface IUserDao
{
User FindById(string userId);
void Delete(User user);
User Save(User user);
User SaveOrUpdate(User user);
}
}

 

   同样,我们添加ICompanyDao和IDepartmentDao.

   接下来,我们实现刚才的数据接口,DirectCenter.DAL项目中添加对DirectCenter.IDAL和DirectCenter.Model的项目引用,然后再添加引用Spring.Data.NHibernate20,Spring.Data,Spring.Core(在lib/Spring.net下面).

     一种方式是可以直接使用Nhibernate完成数据访问:

       

UserDao.cs
public User Save(User user)
{
//通过一种方式获取Session
Session session = SessionFactory.OpenSession();
session.Save(user);
}

 

     不过我们不打算使用这种单纯Nhibernate的方式,而是使用继承spring对hibernate的封装类HibernateDaoSupport,这样我们把Spring.net作为Nhibernate的容器可以方便的进行统一管理和利用一些特性.

    

UserDao.cs
using System.Collections;

using Spring.Data.NHibernate.Support;

using DirectCenter.IDAL;
using DirectCenter.Model;

namespace DirectCenter.DAL
{
publicclass UserDao:HibernateDaoSupport,IUserDao
{
public User Save(User user)
{
HibernateTemplate.Save(user);
return user;
}
public User SaveOrUpdate(User user)
{
HibernateTemplate.SaveOrUpdate(user);
return user;
}
publicvoid Delete(User user)
{
HibernateTemplate.Delete(user);
}
public User FindById(string userId)
{
return HibernateTemplate.Get(typeof(User), userId) as User;
}

}
}

 

   同时添加CompanyDao和DepartmentDao.

    一个HibernateTemplate怎么就完成了上面的这些操作.Nhibernate相关的呢?Session在哪里?通过查看代码,我们知道HibernateTemplate是HibernateDaoSupport的一个属性,我们就截取HibernateTemplate的一些代码片断来简单看一下:

   

HibernateTemplate.cs
///<summary>
/// Gets or sets the session factory that should be used to create
/// NHibernate ISessions.
///</summary>
///<value>The session factory.</value>
publicoverride ISessionFactory SessionFactory
{
get { return sessionFactory; }
set
{
sessionFactory = value;
}
}


///<summary>
/// Gets or sets the template flush mode.
///</summary>
///<remarks>
/// Default is Auto. Will get applied to any <b>new</b> ISession
/// created by the template.
///</remarks>
///<value>The template flush mode.</value>
publicoverride TemplateFlushMode TemplateFlushMode
{
get { return templateFlushMode; }
set { templateFlushMode = value; }
}

///<summary>
/// Gets or sets a value indicating whether to
/// cache all queries executed by this template.
///</summary>
///<remarks>
/// If this is true, all IQuery and ICriteria objects created by
/// this template will be marked as cacheable (including all
/// queries through find methods).
///<p>To specify the query region to be used for queries cached
/// by this template, set the QueryCacheRegion property.
///</p>
///</remarks>
///<value><c>true</c> if cache queries; otherwise, <c>false</c>.</value>
publicoverridebool CacheQueries
{
get { return cacheQueries; }
set { cacheQueries = value; }
}


publicobject Load(Type entityType, object id, LockMode lockMode)
{
return Execute(new LoadByTypeHibernateCallback(entityType, id, lockMode),true);

}

internalclass LoadByTypeHibernateCallback : IHibernateCallback
{
private Type entityType;
privateobject id;
private LockMode lockMode;

public LoadByTypeHibernateCallback(Type entityType, object id, LockMode lockMode)
{
this.entityType = entityType;
this.id = id;
this.lockMode = lockMode;

}

///<summary>
/// Gets called by HibernateTemplate with an active
/// Hibernate Session. Does not need to care about activating or closing
/// the Session, or handling transactions.
///</summary>
///<remarks>
///<p>
/// Allows for returning a result object created within the callback, i.e.
/// a domain object or a collection of domain objects. Note that there's
/// special support for single step actions: see HibernateTemplate.find etc.
///</p>
///</remarks>
publicobject DoInHibernate(ISession session)
{
if (lockMode !=null)
{
return session.Load(entityType, id, lockMode);
}
else
{
return session.Load(entityType, id);
}
}



}

    本质还是通过调用Nhibernate的Session来完成的,具体的原来请查看相关资料或源代码.

    但是只有上面的代码肯定是不行的,我们在哪里连接数据库呢?通过IOC向HibernateTemplate中注入SessionFactory,然后在Spring.net中声明一个SessionFactory的对象.

    DirectCenter.App添加一个Dao.xml,主要是是进行数据访问的配置.

     

Dao.xml
<?xml version="1.0" encoding="utf-8" ?>
<objects xmlns="http://www.springframework.net"
xmlns:db
="http://www.springframework.net/database">
<!-- 用以我们在其它的应用程序中,配置数据访问 -->
<object type="Spring.Objects.Factory.Config.PropertyPlaceholderConfigurer, Spring.Core">
<property name="ConfigSections" value="databaseSettings"/>
</object>

<!-- 数据库和Nhibernate的相关配置 -->
<db:provider id="DbProvider"
provider
="SqlServer-2.0"
connectionString
="Data Source=miaozy;Database=DirectCenter;Integrated Security=true;User Instance=false;"/>

<!--SessionFactory对象,其中包括一些比较重要的属性 -->
<object id="NHibernateSessionFactory" type="Spring.Data.NHibernate.LocalSessionFactoryObject, Spring.Data.NHibernate20">
<property name="DbProvider" ref="DbProvider"/>
<property name="MappingAssemblies">
<list>
<value>DirectCenter.Model</value>
</list>
</property>
<property name="HibernateProperties">
<dictionary>
<entry key="hibernate.connection.provider"
value
="NHibernate.Connection.DriverConnectionProvider"/>
<entry key="dialect"
value
="NHibernate.Dialect.MsSql2000Dialect"/>
<entry key="hibernate.connection.driver_class"
value
="NHibernate.Driver.SqlClientDriver"/>

</dictionary>
</property>
<property name="ExposeTransactionAwareSessionFactory" value="true"/>
</object>

<!--将id为NHibernateSessionFactory的对象注入到HibernateTemplate中-->
<object id="HibernateTemplate" type="Spring.Data.NHibernate.HibernateTemplate">
<property name="SessionFactory" ref="NHibernateSessionFactory"/>
<property name="TemplateFlushMode" value="Auto"/>
<property name="CacheQueries" value="true"/>
</object>

<!-- 我们的数据访问类,将HibernateTemplate注入进来-->
<object id="UserDao" type="DirectCenter.DAL.UserDao, DirectCenter.DAL">
<property name="HibernateTemplate" ref="HibernateTemplate"/>
</object>

<object id="CompanyDao" type="DirectCenter.DAL.CompanyDao, DirectCenter.DAL">
<property name="HibernateTemplate" ref="HibernateTemplate"/>
</object>

<object id="DepartmentDao" type="DirectCenter.DAL.DepartmentDao, DirectCenter.DAL">
<property name="HibernateTemplate" ref="HibernateTemplate"/>
</object>

</objects>

 

    注意: 1.NHibernateSessionFactory的MappingAssemblies属性,是我们实体映射文件所在的程序集,也可以通过MappingResources属性引入映射文件,通过ConfigFilenames属性引入Nhibernate的配置文件hibernate.cfg.xml

            2.这里的HibernateProperties属性是指定的是dialect,而不是hibernate.dialect.这是Nhibernate 2.0更新的.不然会提示"Could not find the dialect in the configuration"

 

接下来,就让测试一下我们的代码吧.稍微检验一下我们的成果.为DirectCenter.UnitTest项目添加相关的引用,其中重要的是NUnit.Framework和Spring.Testing.NUnit.
添加测试类,UserDaoTest.cs

 

UserDaoTest.cs
using System;

using NUnit.Framework;
using Spring.Testing.NUnit;

using DirectCenter.Model;
using DirectCenter.IDAL;

namespace DirectCenter.UnitTest
{
[TestFixture]
publicclass UserDaoTest : AbstractTransactionalDbProviderSpringContextTests
{
protectedoverridestring[] ConfigLocations
{
get
{
returnnew String[] { "objects.xml" };
}
}

protected IUserDao UserDao
{
get
{
return applicationContext.GetObject("UserDao") as IUserDao;
}
}
[Test]
publicvoid SaveUserTest()
{
User user =new User();
user.UserID ="buyer000";
user.Password ="1356";
user.UserName ="刘翔";
user.ValidFrom = Convert.ToDateTime("2008-8-18");
user.ValidTo = Convert.ToDateTime("2012-8-18");
user.CreateTime = DateTime.Now;
UserDao.Save(user);
}
}
}

 

objectx.xml中引入我们的配置文件dao.xml ,另外应用程序配置文件App.Config中有Spring.Net和Nhibernate的相关配置信息,就不贴太多代码了.呵呵

利用nunit运行SaveUserTest,发现显示测试成功了,不过查看数据库为什么没有添加进去呢??? ?

淡定淡定,因为我们并没有提交,在最后加上   transactionManager.Commit(transactionStatus);再看一下结果..剩余的我还都并没有测试,如果你尝试,就尝试其它的dao的方法吧...

 

回过头来,看我们的Dao的实现,基本上都是那几种,而且继承于HibernateDaoSupport ,这样使我们的数据访问直接依赖于Spring.net和Nhibernate,以后想直接拿掉Spring.net或者是更换版本都会有些困难,怎么办呢.可以写一个基类继承于HibernateDaoSupport ,并且通过泛型或者是获以当前类型统一完成这些操作.这个我看下,可以放在最后再来讲一下我的实现.

 

 ps.希望这篇文章能够给也在使用类似框架的朋友带来些收获,这样也不会违背放在首页的原则.目的还是想以这个框架的整合为主,以及我在使用的过程中遇到的一些问题和大家分享.至于Spring.Net或者是Nhibernate,Asp.net mvc相关的技术,请参考相关的学习资料.或者是在这里给我留言.

 

 本次代码下载

作者:孤独侠客似水流年
出处:http://lonely7345.cnblogs.com
本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。

 

分类: .NET

本文转自孤独侠客博客园博客,原文链接:http://www.cnblogs.com/lonely7345/archive/2008/09/09/1287212.html,如需转载请自行联系原作者

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
【转】ADO.NET连接访问dbf数据库问题
from:http://space.cnblogs.com/question/7423/    悬赏园豆:20 [已解决问题] 浏览: 2067次   我发现当dbf文件的长度超过8的时候,使用OleDbCommand 查询就会出现“jet 数据库引擎找不到对象”的错误,我搜索到(http://space.cnblogs.com/question/2046/)说解决了这个问题,方法是将表的名字加个中括号。
1108 0
SAS学习笔记之《SAS编程与数据挖掘商业案例》(1)系统简介和编程基础
SAS学习笔记之《SAS编程与数据挖掘商业案例》(1)系统简介和编程基础 1. SAS系统简介 1.1 SAS是先编译后执行的语言,data步标志着编译的开始。 数据指针:当前内存缓存区,输入数据所在位置。 PDV:Program Data Vector,在DATA步中所有涉及的变量被编程当前向量的一部分。 2. SAS编程基础 2.1 SAS逻
1488 0
iis站点 asp.net网站访问弹出提示框
www.lovegarden.cc 这个网站已经出现2次这种情况了。 访问,弹出提示框,需要输入用户名和密码。 解决方法: 在用户组里新建一个用户,test002,密码,密码永不过期。 在iis站点,权限里添加该用户。“允许匿名访问”,用户选择 test002。 ok了。
563 0
+关注
1224
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载