package edu.test;  
  
import java.sql.SQLException;  
import org.hibernate.HibernateException;  
import org.hibernate.Query;  
import org.hibernate.Session;  
import org.hibernate.SessionFactory;  
import org.hibernate.stat.EntityStatistics;  
import org.hibernate.stat.Statistics;  
import org.springframework.orm.hibernate3.HibernateCallback;  
import org.springframework.orm.hibernate3.HibernateTemplate;  
import utils.SpringBeanUtils;  
import edu.po.Users;  
  
/** 
 * Title: HibernateEhCacheTest.java 
 * Description: Hibernate二级缓存测试 
 * @author yh.zeng 
 * @date 2017-7-4 
 */  
public class HibernateEhCacheTest {  
  
    static SessionFactory  sessionFactory = SpringBeanUtils.getSessionFactory("sessionFactory");  
      
    public static void main(String args[]) {  
          
        //Session.get()方法支持二级缓存  
        System.out.println("###############session.get()###############");  
        Session session1 = sessionFactory.openSession();  
        session1.beginTransaction();  
        Users user1 = (Users)session1.get(Users.class, 6);  
        System.out.println("用户名：" + user1.getUsername());  
        session1.getTransaction().commit();  
        session1.close();  
  
        Session session2 = sessionFactory.openSession();  
        session2.beginTransaction();  
        Users user2 = (Users)session2.get(Users.class, 6);  
        System.out.println("用户名：" + user2.getUsername());  
        session2.getTransaction().commit();  
        session2.close();  
          
        //Query.list()方法支持查询缓存  
        System.out.println("###############Query.list()###############");  
        Session session3 = sessionFactory.openSession();  
        session3.beginTransaction();  
        Query query = session3.createQuery("from Users where id = :id");  
        query.setParameter("id", 6);  
        query.setCacheable(true); //启用查询缓存  
        Users user3 = (Users)query.list().get(0);  
        System.out.println("用户名：" + user3.getUsername());  
        session3.getTransaction().commit();  
        session3.close();  
          
          
        Session session4 = sessionFactory.openSession();  
        session4.beginTransaction();  
        Query query2 = session4.createQuery("from Users where id = :id");  
        query2.setParameter("id", 6);  
        query2.setCacheable(true); //启用查询缓存  
        Users user4 = (Users)query2.list().get(0);  
        System.out.println("用户名：" + user4.getUsername());  
        session4.getTransaction().commit();  
        session4.close();  
          
        //Query.iterate()方法不支持查询缓存  
        System.out.println("###############Query.iterate()###############");  
        Session session5 = sessionFactory.openSession();  
        session5.beginTransaction();  
        Query query3 = session5.createQuery("from Users where id = :id");  
        query3.setParameter("id", 6);  
        query3.setCacheable(true); //启用查询缓存  
        Users user5 = (Users)query3.iterate().next();  
        System.out.println("用户名：" + user5.getUsername());  
        session5.getTransaction().commit();  
        session5.close();  
          
        Session session6 = sessionFactory.openSession();  
        session6.beginTransaction();  
        Query query4 = session6.createQuery("from Users where id = :id");  
        query4.setParameter("id", 6);  
        query4.setCacheable(true); //启用查询缓存  
        Users user6 = (Users)query4.iterate().next();  
        System.out.println("用户名：" + user6.getUsername());  
        session6.getTransaction().commit();  
        session6.close();  
          
        //Session.load()方法支持二级缓存  
        System.out.println("###############Session.load()###############");  
        Session session7 = sessionFactory.openSession();  
        session7.beginTransaction();  
        Users user7 = (Users)session7.load(Users.class, 6);  
        System.out.println("用户名：" + user7.getUsername());  
        session7.getTransaction().commit();  
          
        Session session8 = sessionFactory.openSession();  
        session8.beginTransaction();  
        Users user8 = (Users)session8.load(Users.class, 6);  
        System.out.println("用户名：" + user8.getUsername());  
        session8.getTransaction().commit();  
          
        //HibernateTemplate.find支持查询缓存  
        System.out.println("###############HibernateTemplate.find()###############");  
        HibernateTemplate hibernateTemplate = new HibernateTemplate(sessionFactory);  
        hibernateTemplate.setCacheQueries(true); //开启查询缓存  
        Users user9 = (Users)hibernateTemplate.find("from Users where id = ?",6).get(0);  
        System.out.println("用户名：" + user9.getUsername());  
          
        HibernateTemplate hibernateTemplate2 = new HibernateTemplate(sessionFactory);  
        hibernateTemplate2.setCacheQueries(true); //开启查询缓存  
        Users user10 = (Users)hibernateTemplate2.find("from Users where id = ?",6).get(0);  
        System.out.println("用户名：" + user10.getUsername());  
          
        //HibernateTemplate.execute支持查询缓存  
        System.out.println("###############HibernateTemplate.execute()###############");  
        HibernateTemplate hibernateTemplate3 = new HibernateTemplate(sessionFactory);  
        hibernateTemplate3.setCacheQueries(true); //开启查询缓存  
        Users user11 = hibernateTemplate3.execute(new HibernateCallback<Users>() {  
            @Override  
            public Users doInHibernate(Session session) throws HibernateException,  
                    SQLException {  
                // TODO Auto-generated method stub  
                Query query = session.createQuery("from Users where id = :id");  
                query.setParameter("id", 6);  
                return (Users)query.list().get(0);  
            }  
        });  
        System.out.println("用户名：" + user11.getUsername());  
          
        HibernateTemplate hibernateTemplate4 = new HibernateTemplate(sessionFactory);  
        hibernateTemplate4.setCacheQueries(true); //开启查询缓存  
        Users user12 = hibernateTemplate4.execute(new HibernateCallback<Users>() {  
            @Override  
            public Users doInHibernate(Session session) throws HibernateException,  
                    SQLException {  
                // TODO Auto-generated method stub  
                Query query = session.createQuery("from Users where id = :id");  
                query.setParameter("id", 6);  
                return (Users)query.list().get(0);  
            }  
        });  
        System.out.println("用户名：" + user12.getUsername());  
          
        //Cache统计统计信息  
        Statistics statistics= sessionFactory.getStatistics();  
        System.out.println(statistics);  
        System.out.println("放入"+statistics.getSecondLevelCachePutCount());  
        System.out.println("命中"+statistics.getSecondLevelCacheHitCount());  
        System.out.println("错过"+statistics.getSecondLevelCacheMissCount());  
        //详细的Cache统计信息  
        for (int i = 0; i < statistics.getEntityNames().length; i++) {  
            String entityName = statistics.getEntityNames()[i];  
            EntityStatistics entityStatistics = statistics.getEntityStatistics(entityName);  
            StringBuilder cacheOperator = new StringBuilder();  
            cacheOperator.append("CategoryName：" ).append(entityStatistics.getCategoryName())  
                         .append("，DeleteCount：").append(entityStatistics.getDeleteCount())  
                         .append("，FetchCount：").append(entityStatistics.getFetchCount())  
                         .append("，InsertCount：").append(entityStatistics.getInsertCount())  
                         .append("，LoadCount：").append(entityStatistics.getLoadCount())                        
                         .append("，OptimisticFailureCount：").append(entityStatistics.getOptimisticFailureCount())     
                         .append("，UpdateCount：").append(entityStatistics.getUpdateCount());                           
            System.out.println(cacheOperator.toString());  
        }  
    }  
}