使用NHibernate连接MySQL数据库及增删改查

深碍√TFBOYSˉ_ 2023-06-01 05:38 34阅读 0赞

# 学习资料 #

*  [http://www.sikiedu.com/course/51/task/891/show][http_www.sikiedu.com_course_51_task_891_show]
 *  [https://www.codeproject.com/Articles/26123/NHibernate-and-MySQL-A-simple-example][https_www.codeproject.com_Articles_26123_NHibernate-and-MySQL-A-simple-example]

--------------------

Visual Studio新建一个C\#控制台程序，设为启动项，在项目属性中设置目标框架为.NET Framework4.5。

添加两个DLL引用：MySQL.Data.dll和NHibernate.dll。后者在[NHibernate官网][NHibernate]中下载或者直接从Nuget安装。

新建一个文件hibernate.cfg.xml。该配置文件的内容复制于[NHibernate文档][NHibernate 1]（搜**Configure NHibernate**）。因为文档中连接的是SqlServer，而我们要用的是MySQL，所以要做如下修改。配置文档的写法参考[NHibernate连接MySQL案例][NHibernate_MySQL]。

![复制代码][copycode.gif]

<?xml version="1.0" encoding="utf-8" ?>
    <hibernate-configuration xmlns="urn:nhibernate-configuration-2.2">
      <session-factory>
        <property name="connection.provider">NHibernate.Connection.DriverConnectionProvider</property>
        <property name="dialect">NHibernate.Dialect.MySQL5Dialect</property> 
        <property name="connection.driver_class">NHibernate.Driver.MySqlDataDriver</property> 
        <property name="connection.connection_string">Server=localhost;Database=mygamedb;User ID=root;Password=root</property> 
    
        <property name="show_sql">true</property> 
    
        
        <mapping assembly="NHibernateConnectMySQL"/>
      </session-factory>
    </hibernate-configuration>

![复制代码][copycode.gif]

已知MySQL数据库中的表和内容如下图：

![759894-20170912114348032-1500260450.jpg][]

项目根目录新建Model文件夹，在该文件夹下新建User.cs类。内容如下：

![复制代码][copycode.gif]

namespace NHibernateConnectMySQL.Model
    {
        public class User
        {
            public virtual int Id { get; set; }
            public virtual string UserName { get; set; }
            public virtual string UserPwd { get; set; }
            public virtual DateTime UserRegisterTime { get; set; }
        }
    }

![复制代码][copycode.gif]

项目根目录新建Mappings文件夹，在该文件夹下新建User.hbm.xml文件（命名习惯上与要关联的User.cs类命名一致）。写法同样参考官方文档（搜The complete mapping file）。

![复制代码][copycode.gif]

<?xml version="1.0" encoding="utf-8" ?>
    <hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
                       assembly="FirstSolution"
                       namespace="NHibernateConnectMySQL.Model"> 
    
      <class name="User" table="user"> 
        <id name="Id" column="user_id" type="Int32"> 
          <generator class="native" /> 
        </id>
        <property name="UserName" column="user_name" type="String"/> 
        <property name="UserPwd" column="user_pwd" type="String"/> 
        <property name="UserRegisterTime" column="user_register_time" type="Date"/>
      </class>
    
    </hibernate-mapping>

![复制代码][copycode.gif]

在【属性】窗体修改hibernate.cfg.xml的【复制到输出路径】为【始终复制】。修改User.hbm.xml的【生成操作】为【嵌入的资源】。然后生成项目。可以在Debug目录下看到hibernate.cfg.xml文件直接被复制过来了，而User.hbm.xml的内容被集成到了exe文件中。

写代码完成NHibernate初始化操作，就是解析数据库链接配置文件（即hibernate.cfg.xml）和各种表映射文件（User.hbm.xml等等）。通常在项目的主函数中执行。

测试插入一条纪录，代码如下：

![复制代码][copycode.gif]

using NHibernate;
    using NHibernate.Cfg;
    using NHibernateConnectMySQL.Model;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    
    namespace NHibernateConnectMySQL
    {
        class Program
        {
            static void Main(string[] args)
            {
                // ---- NHibernate初始化 ----
                var conf = new Configuration();
                // 解析hibernate.cfg.xml
                conf.Configure(); // 参数为文件，缺省值就是hibernate.cfg.xml
                // 解析表映射文件（User.hbm.xml等），表映射文件已被集成到程序集中（嵌入的资源）
                //conf.AddAssembly("NHibernateConnectMySQL"); // 参数为文件所在的程序集，已在hibernate.cfg.xml中声明
                // ---- 完成初始化 ----
    
                // ---- 连接数据库 ----
                ISessionFactory sessionFactory = null;
                ISession session = null;
                ITransaction transaction = null;
                try
                {
                    // 连接数据库的会话工厂
                    sessionFactory = conf.BuildSessionFactory();
                    // 打开一个跟数据库的会话
                    session = sessionFactory.OpenSession();
                    // 开启事务
                    transaction = session.BeginTransaction();
    
                    User user1 = new User() { UserName = "jjssag2", UserPwd = "4606519" };
                    User user2 = new User() { UserName = "jjssag3", UserPwd = "46064519" };
                    session.Save(user1);
                    session.Save(user2);
    
                    // 提交事务
                    transaction.Commit();
    
                }
                catch (Exception e)
                {
                    Console.WriteLine(e);
                }
                finally
                {
                    if (transaction != null)
                    {
                        transaction.Dispose();
                    }
                    if (session != null)
                    {
                        session.Close();
                    }
                    if (sessionFactory != null)
                    {
                        sessionFactory.Close();
                    }
                }
    
                Console.ReadKey();
            }
        }
    }

![复制代码][copycode.gif]

--------------------

# 完善增删改查 #

项目目录如下：

![759894-20170913115338282-247348526.png][]

由于每次操作都要开启一个会话Session，都要使用事务Transaction，所以考虑将重复的内容进行封装，写一个NHibernateHelper.cs工具类。

![复制代码][copycode.gif]

using NHibernate.Cfg;
    using NHibernate;
    
    namespace NHibernateConnectMySQL
    {
        class NHibernateHelper
        {
            private static ISessionFactory _sessionFactory;
            public static ISessionFactory SessionFactory
            {
                get
                {
                    if (_sessionFactory == null)
                    {
                        var conf = new Configuration();
                        conf.Configure();
                        conf.AddAssembly("NHibernateConnectMySQL");
    
                        _sessionFactory = conf.BuildSessionFactory();
                    }
                    return _sessionFactory;
                }
            }
    
            public static ISession OpenSession()
            {
                return SessionFactory.OpenSession();
            }
    
        }
    }

![复制代码][copycode.gif]

Manager文件夹下是各个类的增删改查操作实现。

![复制代码][copycode.gif]

using System.Collections.Generic;
    using NHibernateConnectMySQL.Model;
    using NHibernate;
    using NHibernate.Criterion;
    
    namespace NHibernateConnectMySQL.Manager
    {
        class UserManager : IUserManager
        {
            // 插入一条纪录
            public void Add(User user)
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    using (ITransaction transaction = session.BeginTransaction())
                    {
                        session.Save(user);
                        transaction.Commit();
                    }
                }
            }
    
            // 删除一条纪录
            public void Delete(User user)
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    using (ITransaction transaction = session.BeginTransaction())
                    {
                        session.Delete(user);
                        transaction.Commit();
                    }
                }
            }
    
            // 更新一条纪录
            public void Update(User user)
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    using (ITransaction transaction = session.BeginTransaction())
                    {
                        session.Update(user);
                        transaction.Commit();
                    }
                }
            }
    
            // 查询一条纪录
            public User GetUserByID(int id)
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    // 查询不会对数据进行操作，可以不用事务
                    User user = session.Get<User>(id);
                    return user;
                }
            }
            
            // 查询一条纪录
            public User GetUserByUserName(string userName)
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    //ICriteria criteria = session.CreateCriteria(typeof(User));
                    // 添加查询条件为传入的参数等于实体类中的属性
                    //criteria.Add(Restrictions.Eq("UserName", userName));
                    //User user = criteria.UniqueResult<User>();
    
                    User user = session
                        .CreateCriteria(typeof(User))
                        .Add(Restrictions.Eq("UserName", userName))
                        .UniqueResult<User>();
                    return user;
                }
            }
    
            // 查询多条纪录
            public ICollection<User> GetAllUsers()
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    IList<User> list = session.CreateCriteria(typeof(User)).List<User>();
                    return list;
                }
            }
    
            // 校验登录
            public bool VerifyUser(string userName, string password)
            {
                using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
                {
                    User user = session
                        .CreateCriteria(typeof(User))
                        .Add(Restrictions.Eq("UserName", userName))
                        .Add(Restrictions.Eq("UserPwd", password))
                        .UniqueResult<User>();
    
                    if (user == null)
                        return false;
                    else
                        return true; 
                }
            }
    
        }
    }

![复制代码][copycode.gif]

在主函数中调用增删改查方法。

![复制代码][copycode.gif]

using NHibernateConnectMySQL.Manager;
    using System;
    
    namespace NHibernateConnectMySQL
    {
        class Program
        {
            static void Main(string[] args)
            {
                UserManager userManager = new UserManager();
    
                // 插入数据
                //User user = new User() { UserName = "3643uhyrjut", UserPwd = "123453143" };
                //UserManager userManager = new UserManager();
                //userManager.Add(user);
    
                // 查询单条纪录
                //User user = userManager.GetUserByUserName("agr43");
                //Console.WriteLine(user.UserPwd);
    
                // 查询多条纪录
                //ICollection<User> list = userManager.GetAllUsers();
                //foreach (User item in list)
                //{
                //    Console.WriteLine(item.UserPwd);
                //}
    
                // 验证登录
                //Console.WriteLine(userManager.VerifyUser("jjssag1", "4606519"));
    
                Console.ReadKey();
            }
        }
    }

![复制代码][copycode.gif]

--------------------

# 坑点 #

*  如果当前解决方案下有多个项目，在总的配置文件中（hibernate.cfg.xml）一定要指定是哪个程序集，或者代码中用conf.AddAssembly()指定！否则报错如下图：

![759894-20170913103112485-990775687.png][]

转载于:https://www.cnblogs.com/Jeely/p/11357733.html

[http_www.sikiedu.com_course_51_task_891_show]: http://www.sikiedu.com/course/51/task/891/show
[https_www.codeproject.com_Articles_26123_NHibernate-and-MySQL-A-simple-example]: https://www.codeproject.com/Articles/26123/NHibernate-and-MySQL-A-simple-example
[NHibernate]: http://nhibernate.info/
[NHibernate 1]: http://nhibernate.info/doc/tutorials/first-nh-app/your-first-nhibernate-based-application.html
[NHibernate_MySQL]: https://www.codeproject.com/articles/26123/nhibernate-and-mysql-a-simple-example
[copycode.gif]: /images/20230601/1e88d24a1357447e9221b2f82d0af9fc.png
[759894-20170912114348032-1500260450.jpg]: /images/20230601/489007ca4d0a43bfa56976cb43fd9a02.png
[759894-20170913115338282-247348526.png]: /images/20230601/ef07082431fe4c5abf5661e46b3e3c0d.png
[759894-20170913103112485-990775687.png]: /images/20230601/4b307601ccb4409283526a20aab14682.png