`
yshao81710
  • 浏览: 91006 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Hibernate 缓存配置

阅读更多

 

hibernate一级缓存

一级缓存很短和session的生命周期一致,一级缓存也叫session级的缓存或事务级缓存

那些方法支持一级缓存:

* get()

* load()

* iterate(查询实体对象)

如何管理一级缓存:

* session.clear(),session.evict()

如何避免一次性大量的实体数据入库导致内存溢出

* 先flush,再clear

如果数据量特别大,考虑采用jdbc实现,如果jdbc也不能满足要求可以考虑采用数据本身的特定导入工具

hibernate二级缓存

二级缓存也称进程级的缓存或SessionFactory级的缓存,二级缓存可以被所有的session共享

二级缓存的生命周期和SessionFactory的生命周期一致,SessionFactory可以管理二级缓存

二级缓存的配置和使用:

* 将echcache.xml文件拷贝到src下

* 开启二级缓存,修改hibernate.cfg.xml文件 放在<mapping>前

   <property name="hibernate.cache.use_second_level_cache">true</property>

* 指定缓存产品提供商,修改hibernate.cfg.xml文件 放在<mapping>前

   <property name="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</property>

* 指定那些实体类使用二级缓存(两种方法)

   * 在映射文件中采用<cache>标签

   * 【推荐】在hibernate.cfg.xml文件中,采用<class-cache>标签 如: <class-cache class="com.bcm.model.Article" usage="read-write"/>

  

二级缓存是缓存实体对象的

hibernate查询缓存

查询缓存是针对普通属性结果集的缓存

对实体对象的结果集只缓存id

查询缓存的生命周期,当前关联的表发生修改,那么查询缓存生命周期结束

查询缓存的配置和使用:

* 在hibernate.cfg.xml文件中启用查询缓存,如:

<property name="hibernate.cache.use_query_cache">true</property>

* 在程序中必须手动启用查询缓存,如:

query.setCacheable(true);

package com.bjsxt.hibernate;

import java.io.Serializable;

import java.util.Iterator;

import java.util.List;

import org.hibernate.CacheMode;

import org.hibernate.Query;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import junit.framework.TestCase;

public class CacheLevel2Test extends TestCase {

/**

* 开启查询缓存,关闭二级缓存

*

* 开启一个session,分别调用query.list

*/

public void testCache1() {

   Session session = null;

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s.name from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   List names = query.list();

    for (Iterator iter=names.iterator();iter.hasNext(); ) {

     String name = (String)iter.next();

     System.out.println(name);

    }

   

    System.out.println("-------------------------------------");

    query = session.createQuery("select s.name from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   //没有发出查询sql,因为启用了查询缓存

    names = query.list();

    for (Iterator iter=names.iterator();iter.hasNext(); ) {

     String name = (String)iter.next();

     System.out.println(name);

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

}

/**

* 开启查询缓存,关闭二级缓存

*

* 开启两个session,分别调用query.list

*/

public void testCache2() {

   Session session = null;

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s.name from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   List names = query.list();

    for (Iterator iter=names.iterator();iter.hasNext(); ) {

     String name = (String)iter.next();

     System.out.println(name);

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

  

   System.out.println("-------------------------------------");

  

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s.name from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   //不会发出查询sql,因为查询缓存的生命周期和session无关

    List names = query.list();

    for (Iterator iter=names.iterator();iter.hasNext(); ) {

     String name = (String)iter.next();

     System.out.println(name);

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

}  

/**

* 开启查询缓存,关闭二级缓存

*

* 开启两个session,分别调用query.iterate

*/

public void testCache3() {

   Session session = null;

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s.name from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

    for (Iterator iter=query.iterate();iter.hasNext(); ) {

     String name = (String)iter.next();

     System.out.println(name);

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

  

   System.out.println("-------------------------------------");

  

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s.name from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

    //查询缓存只对query.list()起作用,query.iterate不起作用,也就是query.iterate不使用

    //查询缓存

    for (Iterator iter=query.iterate();iter.hasNext(); ) {

     String name = (String)iter.next();

     System.out.println(name);

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

}

/**

* 关闭查询缓存,关闭二级缓存

*

* 开启两个session,分别调用query.list查询实体对象

*/

public void testCache4() {

   Session session = null;

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s from Student s");

    //启用查询查询缓存

    //query.setCacheable(true);

   

    List students = query.list();

    for (Iterator iter=students.iterator();iter.hasNext(); ) {

     Student student = (Student)iter.next();

     System.out.println(student.getName());

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

  

   System.out.println("-------------------------------------");

  

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s from Student s");

    //启用查询查询缓存

    //query.setCacheable(true);

    //会发出查询sql,因为list默认每次都会发出查询sql

    List students = query.list();

    for (Iterator iter=students.iterator();iter.hasNext(); ) {

     Student student = (Student)iter.next();

     System.out.println(student.getName());

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

}  

/**

* 开启查询缓存,关闭二级缓存

*

* 开启两个session,分别调用query.list查询实体对象

*/

public void testCache5() {

   Session session = null;

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   List students = query.list();

    for (Iterator iter=students.iterator();iter.hasNext(); ) {

     Student student = (Student)iter.next();

     System.out.println(student.getName());

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

  

   System.out.println("-------------------------------------");

  

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   //会发出n条查询语句,因为开启了查询缓存,关闭了二级缓存,那么查询缓存会缓存实体对象的id

    //所以hibernate会根据实体对象的id去查询相应的实体,如果缓存中不存在相应的

    //实体那么将发出根据实体id查询的sql语句,否则不会发出sql使用缓存中的数据

   List students = query.list();

    for (Iterator iter=students.iterator();iter.hasNext(); ) {

     Student student = (Student)iter.next();

     System.out.println(student.getName());

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

}

/**

* 开启查询缓存,开启二级缓存

*

* 开启两个session,分别调用query.list查询实体对象

*/

public void testCache6() {

   Session session = null;

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   List students = query.list();

    for (Iterator iter=students.iterator();iter.hasNext(); ) {

     Student student = (Student)iter.next();

     System.out.println(student.getName());

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

  

   System.out.println("-------------------------------------");

  

   try {

    session = HibernateUtils.getSession();

    session.beginTransaction();

   

    Query query = session.createQuery("select s from Student s");

    //启用查询查询缓存

    query.setCacheable(true);

   

   //不会发出查询sql,因为开启了二级缓存和查询缓存,查询缓存缓存了实体对象的id列表

    //hibernate会根据实体对象的id列表到二级缓存中取得相应的数据

    List students = query.list();

    for (Iterator iter=students.iterator();iter.hasNext(); ) {

     Student student = (Student)iter.next();

     System.out.println(student.getName());

    }

    session.getTransaction().commit();

   }catch(Exception e) {

    e.printStackTrace();

    session.getTransaction().rollback();

   }finally {

    HibernateUtils.closeSession(session);

   }

}  

}

实体对象查询【重要】

* N + 1问题,在默认情况下(没有开通查询缓存),使用query.iterate查询,有可以能出现N+1问题

   所谓的N+1是在查询的时候发出了N+1条sql语句

   1: 首先发出一条查询对象id列表的sql

   N: 根据id列表到缓存中查询,如果缓存中不存在与之匹配的数据,那么会根据id发出相应的sql语句

* list和iterate的区别?

   * list每次都会发出sql语句,list会向缓存中放入数据,而不利用缓存中的数据

   * iterate:在默认情况下iterate利用缓存数据,但如果缓存中不存在数据有可以能出现N+1问题

无论list,load还是iterate,只要读出一个对象,都会填充缓存。但是list不会使用缓存,而iterate会先取数据库select id出来,然后一个id一个id的load,如果在缓存里面有,就从缓存取,没有的话就去数据库load

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics