ADO.NET与ORM的比较(2):NHibernate实现CRUD

简介:
说明:个人感觉在Java领域大型开发都离不了ORM的身影,所谓的SSH就是Spring+Struts+Hibernate,除了在学习基础知识的时候被告知可以使用JDBC操作数据库之外,大量的书籍中都是讲述使用Hibernate这个ORM工具来操作数据。在.NET中操作数据库的方式有多种,除了最直接的方式就是使用ADO.NET之外,还可以使用NHibernate这个Hibernate在.NET中的实现ORM,如果你对第三方的ORM持怀疑态度,你还可以使用来自微软的实现、根正苗红的Linq或者EntityFramework。
大部分从早期就开始使用.NET开发的程序员可能对ADO.NET有种迷恋,使用ADO.NET可以充分将我们早期的SQL知识发挥得淋漓尽致,并且出于对性能的考虑,有些人对.NET中的ORM还保持一种观望态度,包括我自己也是这种态度。不过即使在实际开发中不用,并不代表我们不能去了解和比较这些技术,任何事物的出现和消亡总有其原因的,我们可以了解它们的优点和长处。所以本人抽出了几个周末的时间分别用ADO.NET、NHibernate、Linq和EntityFramework来实现对数据库单表数据的创建、读取、更新和删除操作,也就是所谓的CRUD(C:Create/R:Read/U:Update/D:Delete)。
通过实现相同功能的比较,大家自己判断那种方式更适合自己。需要说明的是,如果在VS2008中使用EntityFramework就需要安装VS2008SP1。
在本篇周公将讲述如何利用NHibernate实现CRUD功能,为了便于对比,在本次中采用与上次同样的数据库和表,并且也实现同样的功能。NHibernate是一个ORM框架,所谓ORM就是Object Relational Mapping,是一种将关系型数据库中的数据与面向对象语言中对象建立映射关联的技术,我们可以想操作对象一样操作数据,NHibernate将我们对对象的变更保存到数据库中去,并且还负责以对象的方式从数据库中查询数据,这样就可以使开发人员从处理SQL和ADO.NET上节省一些时间和精力用于处理业务逻辑。
1、准备
首先我们需要从网上下载NHibernate框架,这个可以到它的官方网站 www.nhibernate.org上去下载,在周公写这篇文章的时候从网上能下载到的最新版本为2.1.2.GA。如果下载的是压缩包,请将压缩包解压,将会看到四分文件夹,它们的名称和作用分别如下:
Configuration_Templates:存放NHibernate连接数据库的配置文件的示例,在这个文件夹下分别有连接Firebird、SQL Server、MySQL、Oracle、PostgreSQL和SQLite数据库的配置示例,可以根据实际所使用的数据库选择示例中的代码并更改其中的数据源即可。
Required_Bins:存放NHibernate运行过程中所需要的类库文件,其中还包含了第三方的开源日志框架Log4Net,在不确定到底会使用那些类库的条件下建议将这个文件夹下所有的dll文件拷贝到项目的bin文件夹下。
Required_For_LazyLoading:存放延时加载特性支持所需的框架文件,在这个文件夹下提供了三种实现,选择一种将其下所有的dll文件拷贝到项目所在的bin文件夹下。在本示例中选择了Castle。
Tests:存放测试用文件,在此文件夹下还有一个名为ABC.hbm.xml的文件,这是一个数据表对应的配置文件的示例,在这个文件夹下的文件我们都用不着,不过在以后我们会用到.hbm.xml文件。
2、创建项目
我们创建一个项目,项目类型可以根据情况选择,因为我今后要使用NUnit来对项目进行单元测试,所以创建的类库项目。
创建项目成功之后将如下文件拷贝到项目的bin目录下:
Antlr3.Runtime.dll
Castle.Core.dll
Castle.DynamicProxy2.dll
Iesi.Collections.dll
log4net.dll
NHibernate.ByteCode.Castle.dll
NHibernate.dll
然后在项目中添加对这些dll的引用,如下图所示:
3、编写代码
3.1创建NHibernate配置文件
NHibernate的配置文件有相对比较固定的格式,这个可以从下载到框架文件压缩包解压得到,位于Configuration_Templates文件夹下。
向当前项目添加一个名为hibernate.cfg.xml的xml文件,在周公的机器上这个文件的格式内容如下:
<? xml  version ="1.0"  encoding ="utf-8"  ?>     
< hibernate-configuration     xmlns ="urn:nhibernate-configuration-2.2"  >     
< session-factory >     
     < property  name ="connection.driver_class" >NHibernate.Driver.SqlClientDriver </ property >     
     < property  name ="connection.connection_string" >     
     Data Source=zhou;Initial Catalog=AspNetStudy;User ID=sa;Password=jerry;        
     </ property >     
     < property  name ="adonet.batch_size" >10 </ property >     
     < property  name ="show_sql" >true </ property >     
     < property  name ="dialect" >NHibernate.Dialect.MsSql2005Dialect </ property >     
     < property  name ="use_outer_join" >true </ property >     
     < property  name ="command_timeout" >10 </ property >     
     < property  name ="query.substitutions" >true 1, false 0, yes 'Y', no 'N' </ property >     
     < property  name ="proxyfactory.factory_class" >     
     NHibernate.ByteCode.Castle.ProxyFactoryFactory,        
     NHibernate.ByteCode.Castle        
     </ property >     
     < mapping  assembly ="NHibernateDemo" />     
</ session-factory >     
</ hibernate-configuration >
如果你也是使用SQL Server2005作为数据库的话,那么需要更改connection.connection_string中的数据库连接信息为你本机的连接信息,并且实际情况更改assembly的值为你当前项目编译后的程序集名称。
在这里还需要注意的是需要将hibernate.cfg.xml的属性更改为复制属性改为始终复制,如下图所示:
3.2创建映射文件
映射文件包含了对象/关系所需要的元数据,其中包含了所使用的持久化类和到数据库的映射。NHibernate就是通过映射文件知道怎样加载和存储持久化对象。
在项目中增加一个名为UserInfo.hbm.xml的xml文件,这个xml文件的内容如下:
<? xml  version ="1.0"  encoding ="utf-8"  ?>     
< hibernate-mapping  xmlns ="urn:nhibernate-mapping-2.2"  assembly ="NHibernateDemo"  namespace ="NHibernateDemo" >     
< class  name ="UserInfo" >     
     < id  name ="UserId"  column ="UserId" >     
      < generator  class ="native" />     
     </ id >     
     < property  name ="UserName" />     
     < property  name ="RealName" />     
     < property  name ="Age" />     
     < property  name ="Sex" />     
     < property  name ="Mobile" />     
     < property  name ="Phone" />     
     < property  name ="Email" />     
</ class >     
</ hibernate-mapping >
注意:如果想要获得在编辑hibernate.cfg.xml或者UserInfo.hbm.xml时的智能提示,可以将下载NHibernate压缩包中的nhibernate-configuration.xsd和nhibernate-mapping.xsd文件拷贝到VS的一个特殊文件夹中,在本机上周公在C盘安装了VS2008,那么需要将上面提到的文件拷贝到C:\Program Files\Microsoft Visual Studio 9.0\Xml\Schemas目录下,你需要根据你的实际情况来拷贝。
需要更改这个文件的属性,改为“嵌入的资源”,如下图所示:
 
3.3创建持久化类
在当前项目中创建一个名为UserInfo.cs的类文件,这个类的代码如下:
using System;        
using System.Collections.Generic;        
using System.Text;        
     
namespace NHibernateDemo        
{        
         /// <summary>        
         /// 数据库中UserInfo表的持久化类        
         /// 作者:周公        
         /// 博客地址:http://blog.csdn.net/zhoufoxcn        
         /// 日期:2010-03-19        
         /// </summary>        
         public  class UserInfo        
        {        
                 public  virtual  int UserId { get; set; }        
                 public  virtual  string UserName { get; set; }        
                 public  virtual  string RealName { get; set; }        
                 public  virtual  int Age { get; set; }        
                 public  virtual  bool Sex { get; set; }        
                 public  virtual  string Mobile { get; set; }        
                 public  virtual  string Phone { get; set; }        
                 public  virtual  string Email { get; set; }        
        }        
}
注意:NHibernate通过使用属性的getter和setter操作来实现对象的持久化,并且要求类不能为sealed,方法和属性必须为virtual。
3.4编写辅助类
通过上面的文件NHibernate就可以实现关系映射了,这里编写相关的辅助类代码,如下:
using System;        
using System.Collections.Generic;        
using System.Text;        
using Iesi.Collections;        
using NHibernate;        
using NHibernate.Cfg;        
     
namespace NHibernateDemo        
{        
         /// <summary>        
         /// 说明:这个类是为了演示NHibernate中的CRUD的用法        
         /// 作者:周公(周金桥)        
         /// 日期:2010-03-07        
         /// </summary>        
         public  class NHibernateCRUD        
        {        
                 private ISessionFactory sessionFactory;        
                 public NHibernateCRUD()        
                {        
                        sessionFactory =  new Configuration().Configure().BuildSessionFactory();        
                }        
     
                 public ISession GetSession()        
                {        
                         return sessionFactory.OpenSession();        
                }        
                 /// <summary>        
                 /// 统计用户总数        
                 /// </summary>        
                 /// <returns></returns>        
                 public  int Count()        
                {     
方法一      #region 方法一        
                         //ISession session = GetSession();        
                         //ISQLQuery query = session.CreateSQLQuery("select count(1) from UserInfo");        
                         //int count = query.List<int>()[0];        
                         //session.Close();        
                         //return count;     
                        #endregion     
    
方法二      #region 方法二        
                        ISession session = GetSession();        
                        IQuery query = session.CreateQuery( "select count(c.UserId) from UserInfo c");        
                         //注意:不能对于count函数不能使用query.List<int>(),因为默认返回的数值类型是long        
                         //否则会抛出GenericADOException,异常描述是:Could not execute query[SQL: SQL not available]        
                         //InnerException: System.ArgumentException,InnerException描述是:"值“*”不是“System.Int32”类型,不能在此泛型集合中使用。\r\n参数名: value        
                         int count =( int)(query.List< long>()[0]);        
                        session.Close();        
                         return count;     
                        #endregion        
                }        
                 /// <summary>        
                 /// 创建用户        
                 /// </summary>        
                 /// <param name="info">用户实体</param>        
                 /// <returns></returns>        
                 public  int Create(UserInfo info)        
                {        
                        ISession session = GetSession();        
                         int newId=( int)(session.Save(info));        
                        session.Flush();        
                        session.Close();        
                         return newId;        
                }        
                 /// <summary>        
                 /// 读取用户信息        
                 /// </summary>        
                 /// <param name="userId">用户编号</param>        
                 /// <returns></returns>        
                 public UserInfo Read( int userId)        
                {        
                        ISession session = GetSession();        
                        UserInfo info=session.Get<UserInfo>(userId);        
                        session.Close();        
                         return info;        
                }        
                 /// <summary>        
                 /// 更新用户信息        
                 /// </summary>        
                 /// <param name="info">用户实体</param>        
                 /// <returns></returns>        
                 public  void Update(UserInfo info)        
                {        
                        ISession session = GetSession();        
                        session.Update(info);        
                        session.Flush();        
                        session.Close();        
                }        
                 /// <summary>        
                 /// 删除用户        
                 /// </summary>        
                 /// <param name="userId">用户编号</param>        
                 /// <returns></returns>        
                 public  void Delete( int userId)        
                {        
                        ISession session = GetSession();        
                         //在NHibernate中支持直接使用参数值、":"+参数名、?(类似于在Access中使用参数化SQL语句的方式,给参数赋值要按照参数出现的顺序来)等几种方式        
                        IQuery query = session.CreateQuery( "delete from UserInfo where UserId=:UserId");        
                         //如果采用":"+参数名方式使用参数,那么给参数赋值时不需要在参数名前加":"号,如query.SetInt32(":UserId", userId);就会报错        
                        query.SetInt32( "UserId", userId);        
                         int affectedRows = query.ExecuteUpdate();        
                        session.Close();        
                         //return affectedRows;        
                }        
     
                 /// <summary>        
                 /// 删除用户        
                 /// </summary>        
                 /// <param name="userId">用户实体</param>        
                 /// <returns></returns>        
                 public  void Delete(UserInfo info)        
                {        
                        ISession session = GetSession();        
                        session.Delete(info);        
                        session.Flush();        
                        session.Close();        
                }        
     
                 /// <summary>        
                 /// 获取用户表中编号最大的用户        
                 /// </summary>        
                 /// <returns></returns>        
                 public  int GetMaxUserId()        
                {        
                        ISession session = GetSession();        
                        IQuery query=session.CreateQuery( "select max(UserId) from UserInfo");        
                         int userId=query.List< int>()[0];        
                        session.Close();        
                         return userId;        
                }        
        }        
}
3.5单元测试代码
using System;        
using System.Collections.Generic;        
using System.Linq;        
using System.Text;        
using NUnit.Framework;        
using NHibernateDemo;        
     
namespace NUnitTest        
{        
        [TestFixture]        
         public  class NHibernateTest        
        {        
                 private NHibernateCRUD instance =  null;        
                [SetUp]        
                 public  void Initialize()        
                {        
                        instance =  new NHibernateCRUD();        
                }        
                [Test]        
                 /// <summary>        
                 /// 统计用户总数        
                 /// </summary>        
                 /// <returns></returns>        
                 public  void Count()        
                {        
                        Assert.Greater(instance.Count(), 0);        
                }        
                [Test]        
                 /// <summary>        
                 /// 创建用户        
                 /// </summary>        
                 /// <param name="info">用户实体</param>        
                 /// <returns></returns>        
                 public  void Create()        
                {        
                        UserInfo info =  new UserInfo()        
                        {        
                                Age = 12,        
                                Email =  "zzz@ccav.com",        
                                Mobile =  "13812345678",        
                                Phone =  "01012345678",        
                                RealName =  "测试" + DateTime.Now.Millisecond.ToString(),        
                                Sex =  true,        
                                UserName =  "zhoufoxcn" + DateTime.Now.Millisecond.ToString()        
                        };        
                        instance.Create(info);        
                }        
                [Test]        
                 /// <summary>        
                 /// 读取用户信息        
                 /// </summary>        
                 /// <param name="userId">用户编号</param>        
                 /// <returns></returns>        
                 public  void Read()        
                {        
                        UserInfo info = instance.Read(1);        
                        Assert.NotNull(info);        
                }        
                [Test]        
                 /// <summary>        
                 /// 更新用户信息        
                 /// </summary>        
                 /// <param name="info">用户实体</param>        
                 /// <returns></returns>        
                 public  void Update()        
                {        
                        UserInfo info = instance.Read(1);        
                        info.RealName =  "测试" + DateTime.Now.Millisecond.ToString();        
                        instance.Update(info);        
                }        
                [Test]        
                 /// <summary>        
                 /// 删除用户        
                 /// </summary>        
                 /// <param name="userId">用户编号</param>        
                 /// <returns></returns>        
                 public  void DeleteByID()        
                {        
                         int userId = instance.GetMaxUserId();        
                        instance.Delete(userId);        
                }        
     
                [Test]        
                 /// <summary>        
                 /// 删除用户        
                 /// </summary>        
                 /// <param name="userId">用户实体</param>        
                 /// <returns></returns>        
                 public  void Delete()        
                {        
                         int userId = instance.GetMaxUserId();        
                        UserInfo info = instance.Read(userId);        
                        Console.WriteLine( "MaxUserId=" + userId);        
                        instance.Delete(info);        
                }        
        }        
}    
4.点评
使用ORM的很大的一个好处就是很少或者根本不用编写数据库记录映射到对象的代码,并且在大部分情况下也不用编写SQL代码(取而代之的是HSQL)。在使用ADO.NET时代我经常有这样的体会,因为数据库的变动可能需要更改从显示到数据库访问层的相关代码,并且还需要更改自己编写的从数据库记录转换为对象的代码,而现在仅仅需要更改映射文件和持久化类的代码就可以了,除此之外我们还可以使用面向对象的方式对数据进行操作,大家可以看到在NHibernateCRUD中对数据库进行CRUD的代码比直接使用ADO.NET进行CRUD操的代码要简洁许多,这就是ORM的魅力。

当然使用ORM也会存在一些缺点,毕竟ORM在底层使用的是ADO.NET,对于一个有经验的开发人员来说,可能直接使用ADO.NET的性能比使用NHibernate的效率要高,通过NHibernate的缓存机制多少能在某种程度上缓解这个问题。不过当数据量在千万级左右时这个问题就显得比较突出了,在一些数据量在百万级以下的情况中,合理使用NHibernate是没有什么问题的。
















本文转自周金桥51CTO博客,原文链接: http://blog.51cto.com/zhoufoxcn/286570,如需转载请自行联系原作者



相关文章
|
4月前
|
SQL 开发框架 数据库
".NET开发者的超能力:AgileEAS.NET ORM带你穿越数据库的迷宫,让数据操作变得轻松又神奇!"
【8月更文挑战第16天】AgileEAS.NET是面向.NET平台的企业应用开发框架,核心功能包括数据关系映射(ORM),允许以面向对象方式操作数据库,无需编写复杂SQL。通过继承`AgileEAS.Data.Entity`创建实体类对应数据库表,利用ORM简化数据访问层编码。支持基本的CRUD操作及复杂查询如条件筛选、排序和分页,并可通过导航属性实现多表关联。此外,提供了事务管理功能确保数据一致性。AgileEAS.NET的ORM简化了数据库操作,提升了开发效率和代码可维护性。
55 5
|
2月前
|
SQL XML 关系型数据库
入门指南:利用NHibernate简化.NET应用程序的数据访问
【10月更文挑战第13天】NHibernate是一个面向.NET的开源对象关系映射(ORM)工具,它提供了从数据库表到应用程序中的对象之间的映射。通过使用NHibernate,开发者可以专注于业务逻辑和领域模型的设计,而无需直接编写复杂的SQL语句来处理数据持久化问题。NHibernate支持多种数据库,并且具有高度的灵活性和可扩展性。
44 2
|
2月前
|
SQL 开发框架 关系型数据库
值得推荐的.NET ORM框架
值得推荐的.NET ORM框架
|
4月前
|
缓存 数据库连接 API
Entity Framework Core——.NET 领域的 ORM 利器,深度剖析其最佳实践之路
【8月更文挑战第28天】在软件开发领域,高效的数据访问与管理至关重要。Entity Framework Core(EF Core)作为一款强大的对象关系映射(ORM)工具,在 .NET 开发中扮演着重要角色。本文通过在线书店应用案例,展示了 EF Core 的核心特性和优势。我们定义了 `Book` 实体类及其属性,并通过 `BookStoreContext` 数据库上下文配置了数据库连接。EF Core 提供了简洁的 API,支持数据的查询、插入、更新和删除操作。
127 0
|
SQL 开发框架 关系型数据库
16个值得推荐的.NET ORM框架
16个值得推荐的.NET ORM框架
599 1
|
7月前
|
安全 数据库 数据安全/隐私保护
七天.NET 8操作SQLite入门到实战 - 第五天引入SQLite-net ORM并封装常用方法
七天.NET 8操作SQLite入门到实战 - 第五天引入SQLite-net ORM并封装常用方法
204 0
|
3月前
|
开发框架 前端开发 JavaScript
ASP.NET MVC 教程
ASP.NET 是一个使用 HTML、CSS、JavaScript 和服务器脚本创建网页和网站的开发框架。
48 7
|
3月前
|
存储 开发框架 前端开发
ASP.NET MVC 迅速集成 SignalR
ASP.NET MVC 迅速集成 SignalR
75 0
|
4月前
|
开发框架 前端开发 .NET
ASP.NET MVC WebApi 接口返回 JOSN 日期格式化 date format
ASP.NET MVC WebApi 接口返回 JOSN 日期格式化 date format
56 0