Heim > Datenbank > MySQL-Tutorial > Hauptteil

ORM利器:NHibernate(三)五部曲+简单对象CRUD+HQL

WBOY
Freigeben: 2016-06-07 15:59:17
Original
934 Leute haben es durchsucht

前面的两篇文章中,我们对NHibernate已经做了大致了解 《ORM利器:NHibernate(一)简介》Nhibernate的作用:解决了对象和数据库的转化问题 《ORM利器:NHibernate(二)使用CodeSmith快速生成映射文件和映射类 》利用CodeSmith由表导出映射类(就是通常所说

前面的两篇文章中,我们对NHibernate已经做了大致了解

《ORM利器:NHibernate(一)简介》Nhibernate的作用:解决了对象和数据库的转化问题

《ORM利器:NHibernate(二)使用CodeSmith快速生成映射文件和映射类 》利用CodeSmith由表导出映射类(就是通常所说的Entity)和映射文件(告诉你表和对象之间是如何建立一一对应的关系的)。

接下来将会对NHibernate的使用做Demo解析,分为五部曲:

  1. 创建表。若要把对象转换为数据库中的表,自然要有对一个的表。因此,首先要在数据库中创建把.Net类持久化的对应表。创建类。创建需要被持久化的.Net类.对象。创建映射文件。 描述对象和库之间的关系,告诉NH怎样持久化这些类的属性.创建NH的配置文件,以告诉NH怎样连接数据库,以何种方式连接不同种类的数据库。使用NH提供的API。维护对象和库之间的关系,对对象的CRUD和对数据库的DML.
    步骤详情: 第一部:创建表(步骤很简单,这里不做解释)
    第二部:创建类+第三部:创建映射文件(本Demo利用CodeSmith自动生成,详细请参见《ORM利器:NHibernate(二)使用CodeSmith快速生成映射文件和映射类 》)
    第四部:创建NH配置文件 主要用于连接数据库:驱动的提供者、驱动的位置、数据库的身份验证信息等,和我们曾经写过的数据库连接语句无意,只不过放在了配置文件中而已。而且NH采用代理工厂,针对不同的数据库产品进行生产,提供了更好的灵活性,如果你需要把SQLServer数据库,更改为Oracle数据库,只需要更改相应的配置信息就可以。
    <?xml version="1.0" encoding="utf-8" ?>
    <configuration>
      <configSession>
        <section name="hibernate-configuration" type="NHibernate.Cfg.ConfigurationSectionHandler,NHibernate" requireParmission="false"/>
      </configSession>
      <hibernate-configuration  xmlns="urn:nhibernate-configuration-2.2" >
        <!--Session工厂,用户级别的对象-->
        <session-factory name="NHibernate.Test">
          <!--驱动是由谁提供的-->
          <property name="connection.provider">NHibernate.Connection.ConnectionProvider,NHibernate</property>      
          <!--驱动类的位置-->
          <property name="connection.driver_class">NHibernate.Driver.SqlClientDriver</property>     
          <!--身份验证登陆-->
          <property name="connection.connection_string">Server=(local);initial catalog=NHibernate;Integrated Security=SSPI</property>
          <property name="dialect">NHibernate.Dialect.MsSql2008Dialect</property>
          <!--是否显示sql语句-->
          <property name="show_sql">False</property>      
          <!--代理工厂,针对不同的数据库产品进行生产-->
          <property name="proxyfactory.factory_class">NHibernate.ByteCode.Linfu.ProcxyFactoryFactory,NHibernate.ByteCode.Linfu</property>      
        </session-factory>
      </hibernate-configuration>
    </configuration>
    Nach dem Login kopieren
    如果你觉得配置文件很复杂、记不住,也没有关系。NH为我们提供了很多配置文件的模板以供参考,这里我们采用SQLServer,因此可以参照:Configuration_Templates—MSSQL.cfg.xml

    第五部:使用NH提供的API。维护对象和库之间的关系,对对象的CRUD和对数据库的DML

    1、目录结构如下:

    1)新建类库Test:

    用于存放所有的对象和.NET映射文件(如此处的Person.cs对象,Person.hbm.xml映射文件),为了让NHibernate能够找到所有的映射文件,必须设置为“嵌入资源”,生成Test.dll文件备用。

    2)添加引用:

    外部引用NHibernate和NHibernate.ByteCode.Linfu.项目引用Test.dll

    \

    2、添加窗体Form1,如图所示:

    \

    3、窗体Form1中的代码如下所示:

    首先,通过config读取配置文件,读取所有映射文件,加载程序集(必须是嵌入资源)
    其次,通过SessionFactory创建session工厂,负责持久化的连接以及OR映射(该对象的开销比较大,一般建议用单例模式实现)
    然后,通过session创建一个可以用于用户级别的操作对象。
    开启事务对象trans = session.BeginTransaction();

    上面的思路和我们曾经使用过的SQLServer是一个道理。接下来看一下不同点:

    以前D层和数据库打交道的时候,我们通常使用sql语句,而后直接对数据库进行操作。而在NH中所有的操作(增删改查)全都是针对“对象”而言的,如果想要把对象保存在数据库中,就需要先将对象必须转化为数据库能识别的sql语句,由于在SessionFactory中已经保存了所有的OR映射,ISession能根据相应的方言实现sql语句。

    下文的代码中已经实现了简单操作对象。主要是通过session的get、save、delete方法来实现。若要实现复杂的查询不免会比较繁琐。NHibernate提供了一种强大的查询语言HQL(Hibernate Query Language),它的语法非常类似于Sql,不同的是只能用于对数据进行查询操作,不能用于数据增、删、改。它是完全面向对象的,具备继承、多态和关联等特性。

    using System;
    using System.Collections;
    using System.Collections.Generic;
    using System.Windows.Forms;
    using NHibernate;
    using NHibernate.Cfg;
    using Test.Model;
    using System.Linq;
    
    namespace WinFormTest
    {
        public partial class Form1 : Form
        {
            //创建session
            ISession session = null;
            //创建session工厂
            ISessionFactory factory = null;
            //创建事务
            ITransaction trans = null;
    
            public Form1()
            {
                InitializeComponent();
            }
    
            private void Form1_Load(object sender, EventArgs e)
            {
    
                //读取配置文件
                //读取所有映射文件,加载程序集,必须是嵌入资源
                Configuration config = new Configuration().AddAssembly("Test.Model");
                //创建session工厂,负责持久化的连接以及OR映射,该对象的开销比较大,一般建议用单例模式实现
                factory = config.BuildSessionFactory();
                //创建一个可以用于用户级别的操作对象
                session = factory.OpenSession();
    
            }
    
            //添加用户
            private void btnAdd_Click(object sender, EventArgs e)
            {
                //开启事务对象
                trans = session.BeginTransaction();
                //使用NHibernate现有API
                //体验过程
                try
                {
                    //对象的实例化方式
                    Person p = new Person();
                    p.Name = this.txtName.Text;
                    //把对象保存在数据库中
                    //将对象必须转化为数据库能识别的sql语句
                    //由于在SessionFactory中已经保存了所有的OR映射
                    //ISession能根据相应的方言实现sql语句
                    session.Save(p);
                    trans.Commit();
                }
                catch (Exception)
                {
                    //出错后,事务回滚
                    trans.Rollback();
                }
            }
    
            //查询用户
            private void btnFind_Click(object sender, EventArgs e)
            {
                //trans = session.BeginTransaction();
                //查找ID编号为2的人
                //2-->ID属性&mdash;&mdash;OR&mdash;&mdash;>SQL的Where语句
                Person p = (Person)session.Get(typeof(Person), int.Parse(this.txtID.Text));
                //Console.WriteLine(p.ToString());
                this.txtName.Text = p.Name;
            }
    
            //删除用户
            private void btnDelete_Click(object sender, EventArgs e)
            {
                try
                {
                    //开启事务
                    trans = session.BeginTransaction();
                    //根据提供的ID查找该对象
                    Person p = (Person)session.Get(typeof(Person), int.Parse(this.txtID.Text));
                    //对象删除
                    session.Delete(p);
                    trans.Commit();
                }
                catch (Exception)
                {
                    trans.Rollback();
                }
            }
    
            //更新用户
            private void btnUp_Click(object sender, EventArgs e)
            {
                try
                {
                    //开启事务
                    trans = session.BeginTransaction();
                    //根据提供的ID查找该对象
                    Person p = (Person)session.Get(typeof(Person), int.Parse(this.txtID.Text));
                    //修改对象属性
                    p.Name = this.txtName.Text;
                    session.Update(p);
                    trans.Commit();
                }
                catch (Exception)
                {
                    trans.Rollback();
                }
            }
    
            //IQuery接口,是针对对象查询
            private void btnHQL_Click(object sender, EventArgs e)
            {
                //HQL体验&mdash;&mdash;HQL是针对对象的查询语言
                //查询所有人的信息
                //IQuery query = session.CreateQuery("from Person");
                //IList<Person> persons = query.List<Person>();
                //persons.p1();
    
                //查询编号为2的人的信息
                //IQuery query = session.CreateQuery("from Person where Id=3");
                //query.List<Person>().p1();
    
                //查询名字中有字母a的人
                //session.CreateQuery("from Person where Name like &#39;%a%&#39;").List<Person>().p1();
                //session.CreateQuery("from Person where t_Name like &#39;%a%&#39;").List<Person>().p1();
                //session.CreateQuery("from Person where name like &#39;%a%&#39;").List<Person>().p1();//错误
    
                //查找全部
                //session.CreateQuery("select p from Person p").List<Person>().p1();
                //session.CreateQuery("select * from Person ").List<Person>().p1();//错误,没有*
    
                //查找编号大于5的人的信息
                //session.CreateQuery("from Person p where p.Id>5 ").List<Person>().p1();
    
    
    
                //聚合函数的使用--统计人数
                //session.CreateQuery("select count(p.Id) from Person p ").List().p2();
    
                //传参1
                //IQuery query = session.CreateQuery("from Person p where p.Id>?");
                //query.SetParameter(0,7);
                //query.List<Person>().p1();
                //传参2
                //IQuery query = session.CreateQuery("from Person p where p.Id>:id");
                //query.SetParameter("id", 7);
                //query.List<Person>().p1();
    
                //插入数据&mdash;&mdash;Insert/Update/Delete不建议在HQL里面操作
                //IQuery query = session.CreateQuery("insert into t_Person(t_Name) values(?)");
                //query.SetParameter(0,"kkk");
                //query.ExecuteUpdate();
    
                //查询指定范围的数据&mdash;&mdash;查询第3-7条记录
                IQuery query = session.CreateQuery("from Person");
                query.List<Person>().Skip<Person>(3).Take<Person>(5).ToList<Person>(); ;
                //用ICriteria来实现该功能可能更方便
            }
    
            //对IList<Person>类型数据的输出,建议用C#3.0的拓展方法来实现
            public static class ExtraClass
            {
                public static void p1(this IList<Person> p)
                {
                    //获取可枚举的接口对象
                    IEnumerator<Person> ie = p.GetEnumerator();
                    Console.WriteLine("\n-----------------------\n");
                    //遍历
                    while (ie.MoveNext())
                    {
                        Console.WriteLine(ie.Current.ToString());
                    }
                    Console.WriteLine("\n-----------------------\n");
                }
                public static void p2(this IList p)
                {
                    IEnumerator ie = p.GetEnumerator();
                    Console.WriteLine("\n-----------------------\n");
                    while (ie.MoveNext())
                    {
                        Console.WriteLine(ie.Current.ToString());
                    }
                    Console.WriteLine("\n-----------------------\n");
                }
            }
        }
    }
    
    Nach dem Login kopieren

    总结:对于NHibernate的操作,本文通过五部曲进行细致的讲解:1、创建表;2、创建类;3、创建映射文件(表和类是如何对应的);4、NH配置文件(连接数据库);5、利用API操作。

    其中,2、3 我们采用CodeSmith自动生成映射类和映射文件;4就是我们曾做的连接数据库操作;5通过NHibernate提供的API,通过对对象操作,已达到操作数据库的目的,避免了冗长复杂的sql语句。

    希望大家重点理解创建的过程,以及API的使用。

Verwandte Etiketten:
Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage