NHibernate Linq查询 扩展增强 (第九篇)

发布日期:2018-02-09    浏览次数:530

  在上一篇的Linq to NHibernate的介绍当中,全部是namespace NHibernate命名空间中的IQueryOver<TRoot, TSubType>接口提供的。IQueryOver<TRoot, TSubType>这个借口实际上会被翻译成条件查询(Criteria Queries)。

  实际上Linq to NHibernate更加强大。我们先引入命名空间NHibernate.Linq,这里面有Linq to NHibernate更强大的扩展。

一、Fetch立即加载(避免延迟加载)

  我们先来看看,NHibernate的延迟加载可能存在的问题:

  延迟加载产生的SQL执行方式:

        static void Main(string[] args)
        {
            ISessionFactory sessionFactory = new Configuration().Configure().BuildSessionFactory();

            using (ISession session = sessionFactory.OpenSession())
            {
                IList<PersonModel> ListPerson = session.QueryOver<PersonModel>().List();
                foreach (PersonModel p in ListPerson)
                {
                    Console.WriteLine(p.PersonId + p.PersonName + p.Country.CountryName);
                }
            }

            Console.ReadKey();
        }

  执行结果为:

  

  这延迟加载玩大发了吧。foreach()一次,读一条记录,这...  看到上面语句的FROM Country了吗,其实主要是读Person的时候没有把Country也读出来,弄得每次foreach()的时候必须在到数据库读取Person对应的Country造成的,如果我们不想因为跨表查询到Country就要在加载的时候,把Person所对应的Country也加载过来。

  立即加载,还好,有Fetch方法,我们来看看如下代码:

        static void Main(string[] args)
        {
            ISessionFactory sessionFactory = new Configuration().Configure().BuildSessionFactory();

            using (ISession session = sessionFactory.OpenSession())
            {
                IList<PersonModel> ListPerson = session.Query<PersonModel>().Fetch(p => p.Country).ToList();
                foreach (PersonModel p in ListPerson)
                {
                    Console.WriteLine(p.PersonId + p.PersonName + p.Country.CountryName);
                }
            }

            Console.ReadKey();
        }

  执行的SQL语句为:

  

  这个还像话,就应该这样吗。NHibernate默认开启延迟加载特性,以便其他查询顺利应用延迟加载带来的益处。而当我们不希望延迟加载的时候,可以通过Fetch()编程的方式控制。不错。以上程序,Fetch的作用是加载Person时,强制加载与Person关联的Country。

  若是需要加分页什么的:

IList<ArticleBase> ListArticlePic = NHH.GetSession().QueryOver<ArticleBase>()
.Where(m => m.Knowledge && m.IsAudit).OrderBy(m => m.Id).Desc.Fetch(m => m.ArtContent).Eager.Skip(SkipCount).Take(10).List();

  1、Eager: 立即加载;

  2、Default:根据配置设定的方式加载;

  3、Lazy: 延时加载

   下面再来说说立即加载一些其他的东西,我们将原来的数据库改成如下:

  

  1、多个关联

  Person除了有一个所属国家外,还有一个所属学校。那么我们要输出一个Person的CountryName与SchoolName。又应该怎么处理呢?

        static void Main(string[] args)
        {
            ISessionFactory SessionFactory = (new Configuration()).Configure().BuildSessionFactory();

            using (ISession session = SessionFactory.OpenSession())
            {
                IList<PersonModel> ListPerson = session.Query<PersonModel>().Fetch(p => p.Country).Fetch(p => p.School).ToList();
                foreach (PersonModel p in ListPerson)
                {
                    Console.WriteLine(p.Name + ":" + p.Country.CountryName + ":" + p.School.SchoolName);
                }
            }
            Console.ReadKey();
        }

  我们得Fetch().Fetch()把数据一次性加载过来,否则还是会出现foreach()一次,查询一次School的情况。

  以上代码输出如下:

  

  2、嵌套关联

  在上一节的图中,Person属于Country,而Country又属于一个Area。如果我们Fetch()了Country,那么如果要输出AreaName还是要再次查数据库。因此,我们希望在读取Perosn时,顺带读出关联的Country,再顺带读出关联的Area怎么做到呢?

        static void Main(string[] args)
        {
            ISessionFactory SessionFactory = (new Configuration()).Configure().BuildSessionFactory();

            using (ISession session = SessionFactory.OpenSession())
            {
                IList<PersonModel> ListPerson = session.Query<PersonModel>().Fetch(p => p.Country).ThenFetch(c => c.Area).ToList();
                foreach (PersonModel p in ListPerson)
                {
                    Console.WriteLine(p.Name + ":" + p.Country.CountryName + ":" + p.Country.Area.AreaName);
                }
            }
            Console.ReadKey();
        }

  输出结果如下:

  

  以上代码一次过读出所需的数据,毫不做作。

   Fetch与FetchMany的区别

   Fetch与FetchMany的区别与Select与SelectMany的区别一样。看了一下,方法签名,主要是有一个参数的区别。

        public static INhFetchRequest<TOriginating, TRelated> Fetch<TOriginating, TRelated>(this IQueryable<TOriginating> query, Expression<Func<TOriginating, TRelated>> relatedObjectSelector);
        public static INhFetchRequest<TOriginating, TRelated> FetchMany<TOriginating, TRelated>(this IQueryable<TOriginating> query, Expression<Func<TOriginating, IEnumerable<TRelated>>> relatedObjectSelector);

  留意到方法签名只是查了一点点,但是对于根据Area获取Country再获取Person来说,就非FetchMany不可了。因为Fetch()的参数不允许为集合。

  例如,我们查出所有的地区,然后列出地区的所有国家,再列出所有的PersonName:

     //-------------------------------------------------------------------------------------------------此处c是IEnumerable<ContryModel>
     IList<AreaModel> ListArea = NSession.Query<AreaModel>().FetchMany(a => a.ListCountry).ThenFetchMany(c => c.ListPerson).ToList();
     //IList<AreaModel> ListArea = NSession.Query<AreaModel>().Fetch(a => a.ListCountry).ThenFetch(c => c.ListPerson).ToList(); 这么写编译器就报错
     foreach (AreaModel area in ListArea)
     {
          Console.WriteLine(area.AreaName);
          foreach (CountryModel c in area.ListCountry)
          {
               Console.WriteLine(c.CountryName);
               foreach (PersonModel p in c.ListPerson)
               {
                   Console.WriteLine(p.Name);
               }
          }
     }

  输出如下:

  

   区别在于FetchMany,ThenFetchMany接受IEnumerable<T>类型的数据输入,而Fetch,FetchMany不支持。

二、Linq使用Cache

  Linq-Cache说明:

    • Cacheable 为一个查询显示启用二级缓存;

    • CacheMode 缓存模式, 有如下可选:

      1. Ignore:更新数据时将二级缓存失效,其它时间不和二级缓存交互
      2. Put:向二级缓存写数据,但不从二级缓存读数据
      3. Get:从二级缓存读数据,仅在数据更新时向二级缓存写数据
      4. Normal:默认方式。从二级缓存读/写数据
      5. Refresh:向二级缓存写数据,想不从二级缓存读数据,通过在配置文件设置 cache.use_minimal_puts从数据库中读取数据时,强制二级缓存刷新
    • CacheRegion 给查询缓存指定了特定的命名缓存区域, 如果两个查询相同, 但是指定的 CacheRegion 不同, 则也会从数据库查询数据。

  1、在使用缓存之前,先来开启NHibernate二级缓存。

      <!-- 配置二级缓存实现程序 -->
      <property name="cache.provider_class">NHibernate.Cache.HashtableCacheProvider</property>
      <!-- 开启二级缓存 -->
      <property name="cache.use_second_level_cache">true</property>
      <!-- 在查询中开启二级缓存 -->
      <property name="cache.use_query_cache">true</property>
      <!-- 配置映射的二级缓存 -->
      <class-cache class="Model.PersonModel,Model" usage="read-write"/>

  2、在要使用缓存的实体类的映射文件上,Id节点前加上这一行:

    <!-- 配置缓存策略 -->
    <cache usage="read-write"/>

  然后,还是利用上面的例子来测试。

        static void Main(string[] args)
        {
            ISessionFactory _sessionFactory = new Configuration().Configure().BuildSessionFactory();
            
            using(ISession NSession = _sessionFactory.OpenSession())
            {
                IList<PersonModel> ListPerson = NSession.Query<PersonModel>().Cacheable().CacheMode(CacheMode.Normal).CacheRegion("AllCategories").ToList();
                foreach (PersonModel p in ListPerson)
                {
                    Console.WriteLine(p.Name);
                }
            }
            Console.WriteLine("=========================================================");
            using (ISession NSession = _sessionFactory.OpenSession())
            {
                IList<PersonModel> ListPerson2 = NSession.Query<PersonModel>().Cacheable().CacheMode(CacheMode.Normal).CacheRegion("AllCategories").ToList();
                foreach (PersonModel p in ListPerson2)
                {
                    Console.WriteLine(p.Name);
                }
            }
            Console.ReadKey();
        }

  输出结果如下:

  

   这个没什么好说的了,看懂那3个方法的说明好了。

本文网址:https://www.wyxxw.cn/blog-detail-2-6-161.html

返回列表

非特殊说明,本文版权归原作者所有,转载请注明出处

提示:本站所有资源仅供学习与参考,请勿用于商业用途。图片来自互联网~如侵犯您的权益,请联系QQ:1067507709.

提示:转载请注明来自:http://www.cnblogs.com/kissdodog/p/3325429.html 。 转载人:momo