目录
写在前面
本篇文章也算nhibernate入门系列的结尾了，在总结nhibernate系列的过程中，遇到了很多问题，学习的过程也是解决bug的过程，在学习nhibernate的过程中还学习了单元测试的使用，这个是附属产品，我也没有想到，算是意外收获吧。这个系列学完了，正好公司有个项目，马上就要立项，正好能将学到的东西运用到实际的项目中，想想就让人激动。当然，我相信在实际的项目中，肯定还会遇到问题，但是通过本系列的学习，我已经不怕遇到bug了，解决bug的过程也是成长。废话不多说了，进入本篇学习的内容吧。这篇继续上一篇NHibernate二级缓存剩下的内容，比如你修改、删除数据时，二级缓存是什么策略呢？我们如果使用缓存查询呢？如何管理NHibernate二级缓存呢？
文档与系列文章
[NHibernate]持久化类(Persistent Classes)
[NHibernate]集合类（Collections）映射
[NHibernate]缓存（NHibernate.Caches)
[NHibernate]NHibernate.Tool.hbm2net
[NHibernate]Nhibernate如何映射sqlserver中image字段
[NHibernate]条件查询Criteria Query
[Nhibernate]SchemaExport工具的使用（一）——通过映射文件修改数据表
[Nhibernate]SchemaExport工具的使用（二）——创建表及其约束、存储过程、视图
更新数据
在启用二级缓存时候，我们将数据查询出来后，如果对数据进行了修改，再查看二级缓存中的数据，此时的数据是什么呢？
一个例子
修改CustomerData类，添加如下三个方法用于测试
/// <summary>
/// 开启二级缓存的情况下，修改customer对象
/// </summary>
/// <param name="customer"></param>
public void ISessionFactoryCacheUpdate(Customer customer)
{
ISession session = NHibernateHelper.GetSession();
using (var trans=session.BeginTransaction())
{
try
{
session.SaveOrUpdate(customer);
session.Flush();
trans.Commit();
}
catch (Exception)
{
trans.Rollback();
throw;
}
}
}
/// <summary>
/// 根据客户id查询
/// </summary>
/// <param name="customerID"></param>
/// <returns></returns>
public Customer GetCustomerById(Guid customerID)
{
ISession session = NHibernateHelper.GetSession();
return session.Get<Customer>(customerID);
}
/// <summary>
/// 开启二级缓存情况下，重置ISession然后，根据客户id查询
/// </summary>
/// <param name="customerID"></param>
/// <returns></returns>
public Customer GetCustomerById2(Guid customerID)
{
//重置Session
ISession session = NHibernateHelper.ResetSession();
return session.Get<Customer>(customerID);
}
单元测试
[TestMethod]
public void ISessionFactoryCacheUpdateTest()
{
string strCustomerName = "zhangsan2222";
Console.WriteLine("第一次读取Customer数据");
Customer customer = _customerData.GetCustomerById(new Guid("DDF63750-3307-461B-B96A-7FF356540CB8"));
Console.WriteLine("修改读取的customer对象的名字");
customer.NameAddress.CustomerName = strCustomerName;
Console.WriteLine("更新数据库");
_customerData.ISessionFactoryCacheUpdate(customer);
Console.WriteLine("重置Session，第二次读取Customer数据");
Customer c2 = _customerData.GetCustomerById2(new Guid("DDF63750-3307-461B-B96A-7FF356540CB8"));
Assert.AreEqual(c2.NameAddress.CustomerName, strCustomerName);
}
测试结果
![[Nhibernate]二级缓存（二）](https://image.shishitao.com:8440/aHR0cHM6Ly9pbWFnZXMwLmNuYmxvZ3MuY29tL2Jsb2cvNTExNjE2LzIwMTQxMS8zMDE1MzEzOTYwNjcxMDAueC1wbmc%3D.x-png?w=700&webp=1 "[Nhibernate]二级缓存（二）")
在第一次查询数据时，由于一级、二级缓存中都不存在需要的数据，这时NHibernate从数据库中查询数据。我们修改这条数据并提交到数据库中，NHibernate执行一条更新语句，由于我们设置了读写缓存策略，NHibernate更新了二级缓存中的数据内容，第二次读取这条数据，NHibernate首先从内置缓存(一级缓存)中查找是否存在所需要数据，由于不是在同一个ISession中，所以内置ISession缓存（一级缓存）中不存在所需数据，NHibernate则查询二级缓存，这时由于第一次查询了这条数据，所以在二级缓存中存在所需数据，则直接使用缓存中数据。这时缓存中的数据也是最新的。
至于删除、插入数据我想也是类似的。这里我就不写测试了。
上篇文章多少接触了缓存查询的东西，这里在系统的说一下它吧
在NHibernate中，除了缓存持久化类和集合外，查询结果集也可以缓存。如果程序中经常使用同样的条件查询数据，则可以使用查询缓存。在配置文件中可以指定启动查询缓存。
<!--启用查询缓存-->
<property name ="cache.use_query_cache">true</property>
查询缓存后，NHibernate将创建两个缓存区域：
一个用于保存查询结果集，由NHibernate.Cache.StandardQueryCache实现。
一个用来保存最近更新的查询表的时间截，由NHibernate.Cache.UpdateTimestampsCache实现。
查询缓存中的结果集并不是永久有效的。当缓存的查询语句对应的数据库发生改变时，该缓存结果随之失效。因而对大多数查询而言，查询缓存的益处不是很大，所以NHibernate在默认情况下不对查询进行缓存。
如果需要对查询缓存，还需要显式的使用IQuery.SetCacheable(true)方法。IQuery调用这个方法后，NHibernate将根据查询语句、查询参数、结果集起始范围等信息组成一个IQueryKey。接着根据这个IQueryKey到查询缓存中查找相应数据，查询成功则直接返回查找结果。否则，查询数据库，获取结果集，并把结果集根据IQueryKey放入查询缓存。如果IQueryKey数据发生改变(增加、删除、修改等)，这些IQueryKey及其对象的结果集将从缓存中删除。
显式启用缓存查询
一个例子：显式使用IQuery.SetCacheable(true)方法缓存查询结果，第二次查询相同条件时，直接从缓存查询中读取。
/// <summary>
/// 根据客户姓名进行模糊查询
/// </summary>
/// <param name="strName">查询条件</param>
/// <returns>满足条件的客户信息</returns>
public IList<Customer> SearchByName(string strName)
{
ISession session = NHibernateHelper.GetSession();
//from后面跟的是持久化类Customer而不是数据表名TB_Customer
return session.CreateQuery("from Customer as customer where customer.NameAddress.CustomerName like '%" + strName + "%'")
//显示启用缓存查询
.SetCacheable(true)
.List<Customer>();
}
/// <summary>
/// 重置Session根据客户姓名进行模糊查询
/// </summary>
/// <param name="strName">查询条件</param>
/// <returns>满足条件的客户信息</returns>
public IList<Customer> SearchByName2(string strName)
{
//重置session
ISession session = NHibernateHelper.ResetSession();
//from后面跟的是持久化类Customer而不是数据表名TB_Customer
return session.CreateQuery("from Customer as customer where customer.NameAddress.CustomerName like '%" + strName + "%'")
//显示启用缓存查询
.SetCacheable(true)
.List<Customer>();
}
单元测试
[TestMethod]
public void SearchByNameTest()
{
Console.WriteLine("第一次查询某数据，显式缓存查询结果");
IList<Customer> customers = _customerData.SearchByName("z");
Assert.AreEqual(, customers.Count);
Console.WriteLine("重置session");
Console.WriteLine("第二次查询某数据，显式缓存查询结果");
IList<Customer> customers2 = _customerData.SearchByName2("z");
Assert.AreEqual(, customers.Count);
}
数据库中数据
![[Nhibernate]二级缓存（二）](https://image.shishitao.com:8440/aHR0cHM6Ly9pbWFnZXMwLmNuYmxvZ3MuY29tL2Jsb2cvNTExNjE2LzIwMTQxMS8zMDE1NTMzMzQzNDcxNTEueC1wbmc%3D.x-png?w=700&webp=1 "[Nhibernate]二级缓存（二）")
测试结果
![[Nhibernate]二级缓存（二）](https://image.shishitao.com:8440/aHR0cHM6Ly9pbWFnZXMwLmNuYmxvZ3MuY29tL2Jsb2cvNTExNjE2LzIwMTQxMS8zMDE1NTQ0Nzk5Njc4MzgueC1wbmc%3D.x-png?w=700&webp=1 "[Nhibernate]二级缓存（二）")
在第一次查询时，显示的缓存了查询的结果集，所以第二次查询的时候直接使用二级缓存中的数据了。
指定命名缓存区域
我们还可以使用.SetCacheRegion("cacheRegion")给查询缓存指定了特定的命名缓存区域，该查询缓存的缓存策略将由二级缓存的命名区域负责：
/// <summary>
/// 根据客户姓名进行模糊查询
/// </summary>
/// <param name="strName">查询条件</param>
/// <returns>满足条件的客户信息</returns>
public IList<Customer> SearchByName(string strName)
{
ISession session = NHibernateHelper.GetSession();
//from后面跟的是持久化类Customer而不是数据表名TB_Customer
return session.CreateQuery("from Customer as customer where customer.NameAddress.CustomerName like '%" + strName + "%'")
//显示启用缓存查询
.SetCacheable(true)
//指定缓存区域
.SetCacheRegion("querycache")
.List<Customer>();
}
/// <summary>
/// 重置Session根据客户姓名进行模糊查询
/// </summary>
/// <param name="strName">查询条件</param>
/// <returns>满足条件的客户信息</returns>
public IList<Customer> SearchByName2(string strName)
{
//重置session
ISession session = NHibernateHelper.ResetSession();
//from后面跟的是持久化类Customer而不是数据表名TB_Customer
return session.CreateQuery("from Customer as customer where customer.NameAddress.CustomerName like '%" + strName + "%'")
//显示启用缓存查询
.SetCacheable(true)
//指定缓存区域
.SetCacheRegion("querycache")
.List<Customer>();
}
第一次查询出来的结果集被存储在名为queryCache的缓存区域，第二次同样在这个缓存区域里寻找需要数据，如果第二次没有指定或者指定别的缓存区域则没有需要的数据，就要到数据库中查询了。（测试结果与上面的相同，就不再贴图）。
命名查询
可以在映射文件中定义命名查询，<query>元素提供了很多属性，可以用于缓存结果，在Customer.hbm.xml映射文件中定义名为selectCustomer的查询并查询所有Customer并启用缓存查询。配置如下
<!--query节点位于class节点外，hibernate-mapping节点内，不然会出现MappingException: Named query not known异常-->
<query cacheable="true" cache-mode="normal" name="selectCustomer">
<!--此时使用Customer是持久化类，而不是数据库表名称-->
from Customer
</query>
CustomerData类中添加如下的方法，用于测试：
1 /// <summary>
2 /// 使用命名查询的方式
3 /// </summary>
4 /// <returns></returns>
5 public IList<Customer> NamedQueryCache()
6 {
7 ISession session = NHibernateHelper.GetSession();
8 return session.GetNamedQuery("selectCustomer").List<Customer>();
9 }
10 /// <summary>
11 /// 重置session后使用命名查询的方式
12 /// </summary>
13 /// <returns></returns>
14 public IList<Customer> NamedQueryCache2()
15 {
16 ISession session = NHibernateHelper.ResetSession();
17 return session.GetNamedQuery("selectCustomer").List<Customer>();
18 }
单元测试
[TestMethod]
public void NamedQueryCache()
{
Console.WriteLine("--->第一次使用命名查询");
IList<Customer> c1 = _customerData.NamedQueryCache();
Assert.AreEqual(, c1.Count);
Console.WriteLine("--->第二次使用命名查询");
IList<Customer> c2 = _customerData.NamedQueryCache2();
Assert.AreEqual(, c2.Count);
}
运行测试，测试结果
![[Nhibernate]二级缓存（二）](https://image.shishitao.com:8440/aHR0cHM6Ly9pbWFnZXMwLmNuYmxvZ3MuY29tL2Jsb2cvNTExNjE2LzIwMTQxMS8zMDE2MjgyMDIxNTkxMjcueC1wbmc%3D.x-png?w=700&webp=1 "[Nhibernate]二级缓存（二）")
NHibernate提供的查询(HQL、条件查询、原生SQL查询)类似，不再重复举例。
二级缓存管理
NHibernate二级缓存由ISessionFactory创建并由ISessionFactory自行维护。我们使用NHibernate操作数据时，ISessionFactory能够自动同步缓存，保证缓存的有效性。但是当我们批量操作数据时，往往NHibernate不能维护缓存持久有效。ISessionFactory提供了可编程方式的缓存管理方法。
ISessionFactory提供了一系列的EvictXXX()方法可以方便的从二级缓存中删除一个实例、删除一个集合、一个命名缓存等操作
- Evict(persistentClass)：从二级缓存中删除persistentClass类所有实例
- Evict(persistentClass, id)：从二级缓存中删除指定的持久化实例
- EvictEntity(entityName)：从二级缓存中删除命名实例
- EvictCollection(roleName)：从二级缓存中删除集合
- EvictCollection(roleName, id)：从二级缓存中删除指定的集合
- EvictQueries()：从二级缓存中刷新全部查询结果集
- EvictQueries(cacheRegion)：从二级缓存中刷新指定查询结果集
ISession内置缓存可以共享ISessionFactory缓存，通过指定ISession的CacheMode可以控制ISession和ISessionFactory的交互方式。ISession可以通过以下五种方式和ISessionFactory交互：
- Ignore：更新数据时将二级缓存失效，其它时间不和二级缓存交互
- Put：向二级缓存写数据，但不从二级缓存读数据
- Get：从二级缓存读数据，仅在数据更新时向二级缓存写数据
- Normal：默认方式。从二级缓存读/写数据
- Refresh：向二级缓存写数据，想不从二级缓存读数据，可以通过在nhibernate配置文件设置cache.use_minimal_puts从数据库中读取数据时，强制二级缓存刷新
ISessionFactory提供了一系列的EvictXXX()方法从二级缓存中删除一个实例。
一个例子：在第一次读取持久化实例时，结果集保存在二级缓存中，使用Evict方法从二级缓存中删除所有持久化实例，第二次查询相同数据，二级缓存中不存在则重新从数据库中查询。
在CustomerData类中添加如下方法
/// <summary>
/// 使用SessionFactory的Evict方法管理二级缓存
/// </summary>
public void SessionFactoryEvict(Type type)
{
ISessionFactory sessionFactoty = NHibernateHelper.GetSessionFactory();
sessionFactoty.Evict(type);
//也可以sessionFactoty.EvictEntity("Wolfy.Shop.Domain.Entities.Customer");
}
单元测试
[TestMethod]
public void ISessionFactoryCacheManageTest()
{
Console.WriteLine("第一次加载两个customer实例");
Customer customer1 = _customerData.GetCustomerById(new Guid("DDF63750-3307-461B-B96A-7FF356540CB8"));
Customer customer2 = _customerData.GetCustomerById(new Guid("095659B0-8D3F-4DC3-8861-9D7D8A9BA570"));
Console.WriteLine("从二级缓存中删除Customer类所有实例");
_customerData.SessionFactoryEvict(typeof(Customer));
Console.WriteLine("重置session并进行第二次读取持久化实例");
Customer customer3 = _customerData.GetCustomerById2(new Guid("DDF63750-3307-461B-B96A-7FF356540CB8"));
Assert.IsNotNull(customer3);
}
运行测试，测试结果
![[Nhibernate]二级缓存（二）](https://image.shishitao.com:8440/aHR0cHM6Ly9pbWFnZXMwLmNuYmxvZ3MuY29tL2Jsb2cvNTExNjE2LzIwMTQxMS8zMDE2NDczNTQ2NTc3MjUueC1wbmc%3D.x-png?w=700&webp=1 "[Nhibernate]二级缓存（二）")
因为二级缓存是共享的，将ISession重置后，一级缓存也将跟ISession重置，第二次查询的时候，缓存中已经没有对象了，又从数据库中查询了一次。
强制刷新缓存区域
使用ISession提供的.SetCacheMode(CacheMode.Refresh) 方法可以强制刷新缓存区域，这样可以避免数据不一致问题。
1 /// <summary>
2 /// 根据客户姓名进行模糊查询
3 /// </summary>
4 /// <param name="strName">查询条件</param>
5 /// <returns>满足条件的客户信息</returns>
6 public IList<Customer> SearchByName(string strName)
7 {
8 ISession session = NHibernateHelper.GetSession();
9 //from后面跟的是持久化类Customer而不是数据表名TB_Customer
10 return session.CreateQuery("from Customer as customer where customer.NameAddress.CustomerName like '%" + strName + "%'")
11 //显示启用缓存查询
12 .SetCacheable(true)
13 //指定缓存区域
14 .SetCacheRegion("querycache")
15 //强制刷新缓存区域
16 .SetCacheMode(CacheMode.Refresh)
17 .List<Customer>();
18 }
19 /// <summary>
20 /// 重置Session根据客户姓名进行模糊查询
21 /// </summary>
22 /// <param name="strName">查询条件</param>
23 /// <returns>满足条件的客户信息</returns>
24 public IList<Customer> SearchByName2(string strName)
25 {
26 //重置session
27 ISession session = NHibernateHelper.ResetSession();
28 //from后面跟的是持久化类Customer而不是数据表名TB_Customer
29 return session.CreateQuery("from Customer as customer where customer.NameAddress.CustomerName like '%" + strName + "%'")
30 //显示启用缓存查询
31 .SetCacheable(true)
32 //指定缓存区域
33 .SetCacheRegion("querycache")
34 //强制刷新缓存区域
35 .SetCacheMode(CacheMode.Refresh)
36 .List<Customer>();
37 }
测试
[TestMethod]
public void SearchByNameTest2()
{
Console.WriteLine("第一次查询某数据，显式缓存查询结果");
IList<Customer> customers = _customerData.SearchByName("z");
Assert.AreEqual(, customers.Count);
Console.WriteLine("重置session");
Console.WriteLine("第二次查询某数据，显式缓存查询结果");
Console.WriteLine("----指定特定的命名缓存区域并强制刷新缓存区域----");
IList<Customer> customers2 = _customerData.SearchByName2("z");
Assert.AreEqual(, customers.Count);
}
测试结果
![[Nhibernate]二级缓存（二）](https://image.shishitao.com:8440/aHR0cHM6Ly9pbWFnZXMwLmNuYmxvZ3MuY29tL2Jsb2cvNTExNjE2LzIwMTQxMS8zMDE2NTcxOTY1MjQxMjEueC1wbmc%3D.x-png?w=700&webp=1 "[Nhibernate]二级缓存（二）")
通过测试结果，也看出在第二次查询的时候，因为强制刷新了缓存区域，所以又重新访问数据库加载了一次数据。
总结
关于二级缓存的使用方法就介绍到这里，本篇文章也算是nhibernate入门系列的结尾篇了，关于nhibernate的高级功能，只能在遇到的时候总结，然后加入本系列了。
系列文章所有demo下载连接：链接：http://pan.baidu.com/s/1sjJja6x 密码：r9vh
参考文章