C#用NHibernate实现CRUD详解编程语言

hibernate.cfg.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>

UserInfo.hbm.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>

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; } 
    } 
}

NHibernateCRUD.cs

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; 
        } 
    } 
}

单元测试 NHibernateTest.cs

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 = "[email protected]", 
                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); 
        } 
    } 
}