MySql（二）_NHibernateHelper管理会话工厂

1.定义接口的好处：

 （1） 清楚的看到里面有哪些方法；

　( 2 )  可以更换实现类；Nhibernate实现件可以更换；

Manger文件夹（另外两个是Model、Mappings文件夹）

首先Model文件内，（对象）类名，对应着数据库中的表名；在类中定义属性（即对应表中的列名）

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace NBOWeb.Model
{
    class Unity
    {
        public virtual int Id { get; set; }

        public virtual string Name { get; set; }

        public virtual int Age { get; set; }

        public virtual int WorkAge { get; set; }

    }
}

在Mappings文件夹内，存放的是Model中所建立的类（对应的是数据库中的表）的配置文件，将所有的类中的属性与数据库中的表中的列名真正对应起来。注意Model中的类名与Mapping中的解析文件名一一对应。 “unity.cs”与表名一致，“unity.cs”与“unity.hbm.xml”一致。

<?xml version="1.0" encoding="utf-8" ?>
<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2"
                   assembly="NBOWeb"
                   namespace="NBOWeb.Model">
  <!--assembly= Sikiedu 这是程序集的名称  namespace 是指User在哪个命名空间下的   -->

  <class name="Unity" table="unity">
    <id name="Id" column="id" type="Int32">
      <generator class="native"></generator>
      <!--自动增涨-->
      <!--nativ 是本地 使用数据库自带的生成器-->
    </id>
    <property name="Name" column ="name" type="String" ></property>
    <property name="Age" column ="age" type="Int32" ></property>
    <property name="WorkAge" column ="workage" type="Int32" ></property>

  </class>

</hibernate-mapping>

Manager文件夹中，存放的是接口与接口的实现，“IUnityManger.cs”和“UnityManager.cs”           "IUnityManager.cs"存放的是各种要实现的方法或功能； “UnityManager”存放的是这些方法怎么具体实现的。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using NBOWeb.Model;

namespace NBOWeb.Manger
{
    interface IUnityManager
    {
        void Add(Unity unity);
        void Update(Unity unity);
        void Remove(Unity unity);
        Unity GetById(int id);
        Unity GetByName(string name);                 //先定义出来有哪些操作

        ICollection<Unity> GetAllUnityCollection();

        bool VerifyUnity(string name, int age);
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml;
using NBOWeb.Model;
using NHibernate;
using NHibernate.Criterion;

namespace NBOWeb.Manger
{
    class UnityManger : IUnityManager
    {
        

        public void Add(Unity unity)
        {
            //ISession session = NHibernateHelper.OpenSession();
            //session.Save(unity);
            //session.Close();



            //ISession session = NHibernateHelper.OpenSession()                     //当使用OpenSession方法的时候，将SessionFactory属性  中字段可读get创建           “属性”的加强
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
                using (ITransaction transaction = session.BeginTransaction())
                {
                    session.Save(unity);
                    transaction.Commit();
                }
            } //自动实现资源的释放    
        }

        public ICollection<Unity> GetAllUnityCollection()
        {
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
                //ICriteria criteria = session.CreateCriteria(typeof(Unity));                      // criteria标准
                //criteria.Add(Restrictions.Eq("Name",name));                                      //更新，根据主键来操作  Restrictions限制约束，严格相等
                //                                                                                 //将查询条件封装成了对象
                //Unity unity = criteria.UniqueResult<Unity>();                                    //调用唯一的结果,  //只会取到查询结果的第一行记录

                IList<Unity> unity = session.CreateCriteria(typeof(Unity)).List<Unity>();
                return unity;
            }
        }

        public Unity GetById(int id)
        {
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
                using (ITransaction transaction = session.BeginTransaction())
                {
                    Unity unity = session.Get<Unity>(id); //更新，根据主键来操作
                    transaction.Commit();
                    return unity;
                }
            }
        }

        public Unity GetByName(string name)
        {
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
                //ICriteria criteria = session.CreateCriteria(typeof(Unity));                      // criteria标准
                //criteria.Add(Restrictions.Eq("Name",name));                                      //更新，根据主键来操作  Restrictions限制约束，严格相等
                //                                                                                 //将查询条件封装成了对象
                //Unity unity = criteria.UniqueResult<Unity>();                                    //调用唯一的结果

                Unity unity = session.CreateCriteria(typeof(Unity)).Add(Restrictions.Eq("Name", name))
                    .UniqueResult<Unity>();
                return unity;
            }
        }

        public void Remove(Unity unity)
        {
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
                using (ITransaction transaction = session.BeginTransaction())
                {
                    session.Delete(unity); //更新，根据主键来操作
                    transaction.Commit();
                }
            }
        }

        public void Update(Unity unity)
        {
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
                using (ITransaction transaction = session.BeginTransaction())
                {
                    session.Update(unity); //更新，根据主键来操作
                    transaction.Commit();
                }
            }
        }

        public bool VerifyUnity(string name, int age)
        {
            using (ISession session = NHibernateHelper.OpenSession()) //需要释放的资源   using的用法
            {
         
                Unity unity = session
                    .CreateCriteria(typeof(Unity))                                     //建立unity标准格式
                    .Add(Restrictions.Eq("Name", name))                                //添加条件约束
                    .Add(Restrictions.Eq("Age", age))
                    .UniqueResult<Unity>();                                           //主键            加深对“主键”的理解
                if (unity==null)
                {
                    return false;
                }
                else
                {
                    return true;
                }
              
            }
        }
    }
}

NHibernateHelper.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using NHibernate;
using NHibernate.Cfg;

namespace NBOWeb
{
    class NHibernateHelper
    {
 
            private static ISessionFactory _sessionFactory;

        private static ISessionFactory SessionFactory
        {
            get
            {
                if (_sessionFactory==null)
                {
                    var configuration=new Configuration();
                    configuration.Configure();
                    configuration.AddAssembly("NBOWeb");

                    _sessionFactory = configuration.BuildSessionFactory();
                }
                return _sessionFactory;
            }
        }
             
        public static ISession OpenSession()
        {
            return SessionFactory.OpenSession();
        }

    }
}

接口，具体在进行学习。

总的运行

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using NHibernate;
using NHibernate.Cfg;
using NBOWeb.Model;
using NBOWeb.Manger;

namespace MySql_StudyTest
{
    class Program
    {
        static void Main(string[] args)
        {
            //var configuration=new Configuration();                        
            //configuration.Configure();             
            //configuration.AddAssembly("NBOWeb");
            //ISessionFactory sessionFactory = null;
            //ITransaction transaction = null;
            //ISession session = null;
            //try
            //{
            //    sessionFactory = configuration.BuildSessionFactory();
            //    session = sessionFactory.OpenSession();

            //    //Unity unity = new Unity() {Name = "L.Juhnko", Age = 29, WorkAge = 10  };
            //    //session.Save(unity);

            //    //事务，对数据库更改 
            //    transaction= session.BeginTransaction();//开启事务
            //    Unity unity1 = new Unity() { Name = "ko01", Age = 29, WorkAge = 10 };
            //    Unity unity2 = new Unity() { Name = "ko02", Age = 29, WorkAge = 10 };

            //    session.Save(unity1);
            //    session.Save(unity2);
            //    transaction.Commit();//事务提交
            //}
            //catch (Exception e)
            //{
            //    Console.WriteLine(e);

            //}
            //finally

            //{
            //    if (transaction!=null)
            //    {
            //        transaction.Dispose();
            //    }

            //    if (session!=null)
            //    {
            //        session.Close();
            //    }
            //    if (sessionFactory!=null)
            //    {
            //        sessionFactory.Close();
            //    }
            //}

            //Unity unity=new Unity()  { Id=0};        //创建一个Unity的对象
            //IUnityManager unityManager=new UnityManger();        //接口的应用            “接口” //此时与数据库未发生链接
            ////unityManager.Add(unity);

            ////unityManager.Update(unity);
            //unityManager.Remove(unity);

            //IUnityManager unityManager = new UnityManger();
            //Unity unity = unityManager.GetById(23);

            //Console.WriteLine("");
            //Console.WriteLine(unity.Id);
            //Console.WriteLine(unity.Name);   
            //Console.WriteLine(unity.Age);         
            //Console.WriteLine(unity.WorkAge);
            //Console.ReadKey();





            //IUnityManager unityManager=new UnityManger();
            //Unity unity = unityManager.GetByName("juhnko");

            //Console.WriteLine("");
            //Console.WriteLine(unity.Id);
            //Console.WriteLine(unity.Name);
            //Console.WriteLine(unity.Age);
            //Console.WriteLine(unity.WorkAge);
            //Console.ReadKey();







            //IUnityManager unityManager = new UnityManger();
            //ICollection<Unity> unity= unityManager.GetAllUnityCollection();
            //foreach (var u in unity)
            //{
            //    Console.WriteLine("用户名：{0}" + "	" + "Id:{1}" + "	" + "年龄：{2}" + "	" + "工作年龄：{3}"+ "
", u.Name, u.Id, u.Age, u.WorkAge);      
            //}
            //Console.ReadKey();



            IUnityManager unityManager = new UnityManger();
            Console.WriteLine(unityManager.VerifyUnity("juhnko",30));

            Console.ReadKey();

        }
    }
}