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

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

学习资料

  • http://www.sikiedu.com/course/51/task/891/show
  • 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官网中下载或者直接从Nuget安装。

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

复制代码

  1. <?xml version="1.0" encoding="utf-8" ?>
  2. <hibernate-configuration xmlns="urn:nhibernate-configuration-2.2">
  3.   <session-factory>
  4.     <property name="connection.provider">NHibernate.Connection.DriverConnectionProvider</property>
  5.     <property name="dialect">NHibernate.Dialect.MySQL5Dialect</property> <!-- 数据库的版本 -->
  6.     <property name="connection.driver_class">NHibernate.Driver.MySqlDataDriver</property> <!-- 使用什么数据库 -->
  7.     <property name="connection.connection_string">Server=localhost;Database=mygamedb;User ID=root;Password=root</property> <!-- 端口号缺省值为3306 -->
  9.     <property name="show_sql">true</property> <!-- 是否打印执行的SQL语句 -->
  11.     <!-- 坑点：如果当前解决方案下有多个项目，一定要指定程序集！ -->
  12.     <mapping assembly="NHibernateConnectMySQL"/>
  13.   </session-factory>
  14. </hibernate-configuration>

复制代码

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

759894-20170912114348032-1500260450.jpg

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

复制代码

  1. namespace NHibernateConnectMySQL.Model
  2. {
  3.     public class User
  4.     {
  5.         public virtual int Id { get; set; }
  6.         public virtual string UserName { get; set; }
  7.         public virtual string UserPwd { get; set; }
  8.         public virtual DateTime UserRegisterTime { get; set; }
  9.     }
  10. }

复制代码

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

复制代码

  1. <?xml version="1.0" encoding="utf-8" ?>
  2. <hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
  3.                    assembly="FirstSolution"
  4.                    namespace="NHibernateConnectMySQL.Model"> <!-- 项目所在的程序集；该配置文件所关联的User.cs类所在的名称空间 -->
  6.   <class name="User" table="user"> <!-- 指定名称空间下的User类，要与数据库中的user表映射 -->
  7.     <id name="Id" column="user_id" type="Int32"> <!-- 配置主键。类中的Id属性映射表中的user_id列 -->
  8.       <generator class="native" /> <!-- 主键自增。使用数据库自带的生成器 -->
  9.     </id>
  10.     <property name="UserName" column="user_name" type="String"/> <!-- 只有主键用id，其他字段都用property -->
  11.     <property name="UserPwd" column="user_pwd" type="String"/> <!-- 是NHibernate定义的类型，查看文档http://nhibernate.info/doc/nhibernate-reference/index.html搜索type -->
  12.     <property name="UserRegisterTime" column="user_register_time" type="Date"/>
  13.   </class>
  15. </hibernate-mapping>

复制代码

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

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

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

复制代码

  1. using NHibernate;
  2. using NHibernate.Cfg;
  3. using NHibernateConnectMySQL.Model;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Text;
  9. namespace NHibernateConnectMySQL
  10. {
  11.     class Program
  12.     {
  13.         static void Main(string[] args)
  14.         {
  15.             // ---- NHibernate初始化 ----
  16.             var conf = new Configuration();
  17.             // 解析hibernate.cfg.xml
  18.             conf.Configure(); // 参数为文件，缺省值就是hibernate.cfg.xml
  19.             // 解析表映射文件（User.hbm.xml等），表映射文件已被集成到程序集中（嵌入的资源）
  20.             //conf.AddAssembly("NHibernateConnectMySQL"); // 参数为文件所在的程序集，已在hibernate.cfg.xml中声明
  21.             // ---- 完成初始化 ----
  23.             // ---- 连接数据库 ----
  24.             ISessionFactory sessionFactory = null;
  25.             ISession session = null;
  26.             ITransaction transaction = null;
  27.             try
  28.             {
  29.                 // 连接数据库的会话工厂
  30.                 sessionFactory = conf.BuildSessionFactory();
  31.                 // 打开一个跟数据库的会话
  32.                 session = sessionFactory.OpenSession();
  33.                 // 开启事务
  34.                 transaction = session.BeginTransaction();
  36.                 User user1 = new User() { UserName = "jjssag2", UserPwd = "4606519" };
  37.                 User user2 = new User() { UserName = "jjssag3", UserPwd = "46064519" };
  38.                 session.Save(user1);
  39.                 session.Save(user2);
  41.                 // 提交事务
  42.                 transaction.Commit();
  44.             }
  45.             catch (Exception e)
  46.             {
  47.                 Console.WriteLine(e);
  48.             }
  49.             finally
  50.             {
  51.                 if (transaction != null)
  52.                 {
  53.                     transaction.Dispose();
  54.                 }
  55.                 if (session != null)
  56.                 {
  57.                     session.Close();
  58.                 }
  59.                 if (sessionFactory != null)
  60.                 {
  61.                     sessionFactory.Close();
  62.                 }
  63.             }
  65.             Console.ReadKey();
  66.         }
  67.     }
  68. }

复制代码

完善增删改查

项目目录如下：

759894-20170913115338282-247348526.png

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

复制代码

  1. using NHibernate.Cfg;
  2. using NHibernate;
  4. namespace NHibernateConnectMySQL
  5. {
  6.     class NHibernateHelper
  7.     {
  8.         private static ISessionFactory _sessionFactory;
  9.         public static ISessionFactory SessionFactory
  10.         {
  11.             get
  12.             {
  13.                 if (_sessionFactory == null)
  14.                 {
  15.                     var conf = new Configuration();
  16.                     conf.Configure();
  17.                     conf.AddAssembly("NHibernateConnectMySQL");
  19.                     _sessionFactory = conf.BuildSessionFactory();
  20.                 }
  21.                 return _sessionFactory;
  22.             }
  23.         }
  25.         public static ISession OpenSession()
  26.         {
  27.             return SessionFactory.OpenSession();
  28.         }
  30.     }
  31. }

复制代码

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

复制代码

  1. using System.Collections.Generic;
  2. using NHibernateConnectMySQL.Model;
  3. using NHibernate;
  4. using NHibernate.Criterion;
  6. namespace NHibernateConnectMySQL.Manager
  7. {
  8.     class UserManager : IUserManager
  9.     {
  10.         // 插入一条纪录
  11.         public void Add(User user)
  12.         {
  13.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  14.             {
  15.                 using (ITransaction transaction = session.BeginTransaction())
  16.                 {
  17.                     session.Save(user);
  18.                     transaction.Commit();
  19.                 }
  20.             }
  21.         }
  23.         // 删除一条纪录
  24.         public void Delete(User user)
  25.         {
  26.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  27.             {
  28.                 using (ITransaction transaction = session.BeginTransaction())
  29.                 {
  30.                     session.Delete(user);
  31.                     transaction.Commit();
  32.                 }
  33.             }
  34.         }
  36.         // 更新一条纪录
  37.         public void Update(User user)
  38.         {
  39.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  40.             {
  41.                 using (ITransaction transaction = session.BeginTransaction())
  42.                 {
  43.                     session.Update(user);
  44.                     transaction.Commit();
  45.                 }
  46.             }
  47.         }
  49.         // 查询一条纪录
  50.         public User GetUserByID(int id)
  51.         {
  52.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  53.             {
  54.                 // 查询不会对数据进行操作，可以不用事务
  55.                 User user = session.Get<User>(id);
  56.                 return user;
  57.             }
  58.         }
  60.         // 查询一条纪录
  61.         public User GetUserByUserName(string userName)
  62.         {
  63.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  64.             {
  65.                 //ICriteria criteria = session.CreateCriteria(typeof(User));
  66.                 // 添加查询条件为传入的参数等于实体类中的属性
  67.                 //criteria.Add(Restrictions.Eq("UserName", userName));
  68.                 //User user = criteria.UniqueResult<User>();
  70.                 User user = session
  71.                     .CreateCriteria(typeof(User))
  72.                     .Add(Restrictions.Eq("UserName", userName))
  73.                     .UniqueResult<User>();
  74.                 return user;
  75.             }
  76.         }
  78.         // 查询多条纪录
  79.         public ICollection<User> GetAllUsers()
  80.         {
  81.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  82.             {
  83.                 IList<User> list = session.CreateCriteria(typeof(User)).List<User>();
  84.                 return list;
  85.             }
  86.         }
  88.         // 校验登录
  89.         public bool VerifyUser(string userName, string password)
  90.         {
  91.             using (ISession session = NHibernateHelper.SessionFactory.OpenSession())
  92.             {
  93.                 User user = session
  94.                     .CreateCriteria(typeof(User))
  95.                     .Add(Restrictions.Eq("UserName", userName))
  96.                     .Add(Restrictions.Eq("UserPwd", password))
  97.                     .UniqueResult<User>();
  99.                 if (user == null)
  100.                     return false;
  101.                 else
  102.                     return true; 
  103.             }
  104.         }
  106.     }
  107. }

复制代码

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

复制代码

  1. using NHibernateConnectMySQL.Manager;
  2. using System;
  4. namespace NHibernateConnectMySQL
  5. {
  6.     class Program
  7.     {
  8.         static void Main(string[] args)
  9.         {
  10.             UserManager userManager = new UserManager();
  12.             // 插入数据
  13.             //User user = new User() { UserName = "3643uhyrjut", UserPwd = "123453143" };
  14.             //UserManager userManager = new UserManager();
  15.             //userManager.Add(user);
  17.             // 查询单条纪录
  18.             //User user = userManager.GetUserByUserName("agr43");
  19.             //Console.WriteLine(user.UserPwd);
  21.             // 查询多条纪录
  22.             //ICollection<User> list = userManager.GetAllUsers();
  23.             //foreach (User item in list)
  24.             //{
  25.             //    Console.WriteLine(item.UserPwd);
  26.             //}
  28.             // 验证登录
  29.             //Console.WriteLine(userManager.VerifyUser("jjssag1", "4606519"));
  31.             Console.ReadKey();
  32.         }
  33.     }
  34. }

复制代码

坑点

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

759894-20170913103112485-990775687.png

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

发表评论

表情：
评论列表 （有 0 条评论，84人围观）

还没有评论，来说两句吧...

相关阅读