分享

Hibernate的flush()和evict() (ID生成方式不同,FLUSH也不同)

 hh3755 2014-07-31
转自:http://langhua9527./blog/343311
隔离级别  脏读 不可重复读 幻读

ReadUncommitted  Y Y Y
ReadCommitted N Y Y
RepeatableRead N N Y
Serializable N N N

ReadCommited是oracle的默认隔离级别。可以通过悲观锁,消除不可重复读。
RepeatableRead是Mysql的默认级别。


session flush方法主要做了两件事:
* 清理缓存
* 执行sql

session在什么情况下执行flush
* 默认在事务提交时
* 显示的调用flush
* 在执行查询前,如:iterate 
* session 清理缓存的特例:
当对象使用 native 生成器 时 会立刻清理缓存向数据库中插入记录。

hibernate按照save(insert),update、delete顺序提交相关操作
Java代码  收藏代码
  1. /**   
  2.      * 测试uuid主键生成策略   
  3.      */    
  4.     public void testSave1() {     
  5.         Session session = null;     
  6.         Transaction tx = null;     
  7.         try {     
  8.             session = HibernateUtils.getSession();     
  9.             tx = session.beginTransaction();     
  10.     
  11.             User1 user = new User1();     
  12.             user.setName("李四");     
  13.             user.setPassword("123");     
  14.             user.setCreateTime(new Date());     
  15.             user.setExpireTime(new Date());     
  16.                  
  17.             //因为user的主键生成侧路采用的是uuid,所以调用完成save后,只是将user纳入到了session的管理     
  18.             //不会发出insert语句,但是id已经生成,session中existsInDatebase状态为false     
  19.             session.save(user);     
  20.                  
  21.             //调用flush,hibernate会清理缓存,执行sql     
  22.             //如果数据库的隔离级别设置为为提交读,那么我们可以看到flush过的数据     
  23.             //并且session中existsInDatebase状态为true     
  24.             session.flush();     
  25.                  
  26.             //提交事务     
  27.             //默认情况下commit操作会先执行flush清理缓存,所以不用显示的调用flush     
  28.             //commit后数据是无法回滚的     
  29.             tx.commit();     
  30.         }catch(Exception e) {     
  31.             e.printStackTrace();     
  32.             tx.rollback();     
  33.         }finally {     
  34.             HibernateUtils.closeSession(session);     
  35.         }     
  36.     }     
  37.          
  38.     /**   
  39.      * 测试native主键生成策略   
  40.      */    
  41.     public void testSave2() {     
  42.         Session session = null;     
  43.         Transaction tx = null;     
  44.         try {     
  45.             session = HibernateUtils.getSession();     
  46.             tx = session.beginTransaction();     
  47.     
  48.             User2 user = new User2();     
  49.             user.setName("张三1");     
  50.             user.setPassword("123");     
  51.             user.setCreateTime(new Date());     
  52.             user.setExpireTime(new Date());     
  53.                  
  54.             //因为user的主键生成策略为native,所以调用session.save后,将执行insert语句,返回有数据库生成的id     
  55.             //纳入了session的管理,修改了session中existsInDatebase状态为true     
  56.             //如果数据库的隔离级别设置为为提交读,那么我们可以看到save过的数据     
  57.             session.save(user);     
  58.             tx.commit();     
  59.         }catch(Exception e) {     
  60.             e.printStackTrace();     
  61.             tx.rollback();     
  62.         }finally {     
  63.             HibernateUtils.closeSession(session);     
  64.         }     
  65.     }     
  66.          
  67.          
  68.     /**   
  69.      * 测试uuid主键生成策略   
  70.      */    
  71.     public void testSave3() {     
  72.         Session session = null;     
  73.         Transaction tx = null;     
  74.         try {     
  75.             session = HibernateUtils.getSession();     
  76.             tx = session.beginTransaction();     
  77.     
  78.             User1 user = new User1();     
  79.             user.setName("王五");     
  80.             user.setPassword("123");     
  81.             user.setCreateTime(new Date());     
  82.             user.setExpireTime(new Date());     
  83.                  
  84.             //因为user的主键生成侧路采用的是uuid,所以调用完成save后,只是将user纳入到了session的管理     
  85.             //不会发出insert语句,但是id已经生成,session中existsInDatebase状态为false     
  86.             session.save(user);     
  87.                  
  88.             //将user对象从session中逐出,即session的EntityEntries属性中逐出     
  89.             session.evict(user);     
  90.                  
  91.             //无法成功提交,因为hibernate在清理缓存时,在session的insertions集合中取出user对象进行insert操作后     
  92.             //需要更新entityEntries属性中的existsInDatabase为true,而我们采用evict已经将user从session的entityEntries     
  93.             //中逐出了,所以找不到相关数据,无法更新,抛出异常     
  94.             tx.commit();     
  95.         }catch(Exception e) {     
  96.             e.printStackTrace();     
  97.             tx.rollback();     
  98.         }finally {     
  99.             HibernateUtils.closeSession(session);     
  100.         }     
  101.     }     
  102.          
  103.     /**   
  104.      * 测试uuid主键生成策略   
  105.      */    
  106.     public void testSave4() {     
  107.         Session session = null;     
  108.         Transaction tx = null;     
  109.         try {     
  110.             session = HibernateUtils.getSession();     
  111.             tx = session.beginTransaction();     
  112.     
  113.             User1 user = new User1();     
  114.             user.setName("王五");     
  115.             user.setPassword("123");     
  116.             user.setCreateTime(new Date());     
  117.             user.setExpireTime(new Date());     
  118.                  
  119.             //因为user的主键生成侧路采用的是uuid,所以调用完成save后,只是将user纳入到了session的管理     
  120.             //不会发出insert语句,但是id已经生成,session中existsInDatebase状态为false     
  121.             session.save(user);     
  122.                  
  123.             //flush后hibernate会清理缓存,会将user对象保存到数据库中,将session中的insertions中的user对象     
  124.             //清除,并且设置session中existsInDatebase的状态为true     
  125.             session.flush();     
  126.                  
  127.             //将user对象从session中逐出,即session的EntityEntries属性中逐出     
  128.             session.evict(user);     
  129.                  
  130.             //可以成功提交,因为hibernate在清理缓存时,在session的insertions集合中无法找到user对象     
  131.             //所以就不会发出insert语句,也不会更新session中的existsInDatabase的状态     
  132.             tx.commit();     
  133.         }catch(Exception e) {     
  134.             e.printStackTrace();     
  135.             tx.rollback();     
  136.         }finally {     
  137.             HibernateUtils.closeSession(session);     
  138.         }     
  139.     }     
  140.          
  141.     /**   
  142.      * 测试native主键生成策略   
  143.      */    
  144.     public void testSave5() {     
  145.         Session session = null;     
  146.         Transaction tx = null;     
  147.         try {     
  148.             session = HibernateUtils.getSession();     
  149.             tx = session.beginTransaction();     
  150.     
  151.             User2 user = new User2();     
  152.             user.setName("张三11");     
  153.             user.setPassword("123");     
  154.             user.setCreateTime(new Date());     
  155.             user.setExpireTime(new Date());     
  156.                  
  157.             //因为user的主键生成策略为native,所以调用session.save后,将执行insert语句,返回有数据库生成的id     
  158.             //纳入了session的管理,修改了session中existsInDatebase状态为true     
  159.             //如果数据库的隔离级别设置为为提交读,那么我们可以看到save过的数据     
  160.             session.save(user);     
  161.                  
  162.             //将user对象从session中逐出,即session的EntityEntries属性中逐出     
  163.             session.evict(user);     
  164.                  
  165.             //可以成功提交,因为hibernate在清理缓存时,在session的insertions集合中无法找到user对象     
  166.             //所以就不会发出insert语句,也不会更新session中的existsInDatabase的状态     
  167.             tx.commit();     
  168.         }catch(Exception e) {     
  169.             e.printStackTrace();     
  170.             tx.rollback();     
  171.         }finally {     
  172.             HibernateUtils.closeSession(session);     
  173.         }     
  174.     }     
  175.          
  176.     /**   
  177.      * 测试assigned主键生成策略   
  178.      *    
  179.      */    
  180.     public void testSave6() {     
  181.         Session session = null;     
  182.         Transaction tx = null;     
  183.         try {     
  184.             session = HibernateUtils.getSession();     
  185.             tx = session.beginTransaction();     
  186.     
  187.             User3 user = new User3();     
  188.             user.setId("001");     
  189.             user.setName("张三");     
  190.                  
  191.             session.save(user);     
  192.                  
  193.             user.setName("王五");     
  194.             session.update(user);     
  195.                  
  196.             User3 user3 = new User3();     
  197.             user3.setId("002");     
  198.             user3.setName("李四");     
  199.             session.save(user3);     
  200.                  
  201.             //Hibernate: insert into t_user3 (name, password, create_time, expire_time, user_id) values (?, ?, ?, ?, ?)     
  202.             //Hibernate: insert into t_user3 (name, password, create_time, expire_time, user_id) values (?, ?, ?, ?, ?)     
  203.             //Hibernate: update t_user3 set name=?, password=?, create_time=?, expire_time=? where user_id=?     
  204.             //hibernate按照save(insert),update、delete顺序提交相关操作     
  205.             tx.commit();     
  206.         }catch(Exception e) {     
  207.             e.printStackTrace();     
  208.             tx.rollback();     
  209.         }finally {     
  210.             HibernateUtils.closeSession(session);     
  211.         }     
  212.     }        
  213.          
  214.     /**   
  215.      * 测试assigned主键生成策略   
  216.      *    
  217.      */    
  218.     public void testSave7() {     
  219.         Session session = null;     
  220.         Transaction tx = null;     
  221.         try {     
  222.             session = HibernateUtils.getSession();     
  223.             tx = session.beginTransaction();     
  224.     
  225.             User3 user = new User3();     
  226.             user.setId("003");     
  227.             user.setName("张三");     
  228.                  
  229.             session.save(user);     
  230.                  
  231.             user.setName("王五");     
  232.             session.update(user);     
  233.                  
  234.             session.flush();     
  235.                  
  236.             User3 user3 = new User3();     
  237.             user3.setId("004");     
  238.             user3.setName("李四");     
  239.             session.save(user3);     
  240.                  
  241.             //Hibernate: insert into t_user3 (name, password, create_time, expire_time, user_id) values (?, ?, ?, ?, ?)     
  242.             //Hibernate: update t_user3 set name=?, password=?, create_time=?, expire_time=? where user_id=?     
  243.             //Hibernate: insert into t_user3 (name, password, create_time, expire_time, user_id) values (?, ?, ?, ?, ?)     
  244.             //因为我们在session.udpate(user)后执行了flush,所以在清理缓存时执行flush前的sql不会生成     
  245.             //sql会按照我们的意愿执行     
  246.             tx.commit();     
  247.         }catch(Exception e) {     
  248.             e.printStackTrace();     
  249.             tx.rollback();     
  250.         }finally {     
  251.             HibernateUtils.closeSession(session);     
  252.         }     
  253.     }    


Hibernate的flush机制:http://sind./blog/255429

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多