HibernateTemplate中HibernateCallback的事务

2023-11-20 20:18

本文主要是介绍HibernateTemplate中HibernateCallback的事务,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目的:使用HibernateTemplate执行execute(new HibernateCallback())方法,从HibernateCallback中得到session,在此session中做多个操作,并希望这些操作位于同一个事务中。

借助这个属性,在它关闭session时,提交数据库事务。,因此如果你在源代码1中加上一句话:

public   static   void  main(String ss[])  {
        CtxUtil.getBaseManager().getHibernateTemplate().execute(
new HibernateCallback() {
            
public Object doInHibernate(Session session) throws HibernateException, SQLException {
                log.info(session.connection().getAutoCommit());
//打印一下事务提交方式
                
// 保存stu1
                Student stu1 = new Student();
                stu1.setName(
"aaaa");// 在数据库中,name字段不允许为null
                session.save(stu1);
                session.flush();

                Student stu2 
= new Student();
                session.save(stu2);
// 没有设置name字段,预期会报出例外
                session.flush();
                
return null;
            }

        }
);

    }

     运行后,它打出的结果是true,也就是说,虽然保存stu2时会报出例外,但如果commit属性为true,则每一个到达数据库的sql语句会立即被提交。换句话说,在调用完session.save(stu1)后,调用session.flush(),会发送sql语句到数据库,再根据commit属性为true,则保存stu1的操作已经被持久到数据库了,尽管后面的一条insert语句出了问题。
     因此,如果你想在HibernateCallback中使用session的事务,需要如下写:

public   static   void  main(String ss[])  {
        CtxUtil.getBaseManager().getHibernateTemplate().execute(
new HibernateCallback() {
            
public Object doInHibernate(Session session) throws HibernateException, SQLException {
                session.connection().setAutoCommit(
false);
                
//保存stu1
                Student stu1=new Student();
                stu1.setName(
"aaaa");//在数据库中,name字段不允许为null
                session.save(stu1);
                session.flush();
                
                Student stu2 
= new Student();
                session.save(stu2);
//没有设置name字段,预期会报出例外
                   session.flush();
                session.connection().commit();
                
//至于session的关闭就不用我们操心了
                return null;
            }

        }
);

    }

运行上述代码,没问题了。至此,可能有些读者早就对代码1不满意了:为什么每次save()以后要调用flush()?这是有原因的。下面我们来看看把session.flush()去掉后会出什么问题。改掉后的代码如下:

public   static   void  main(String ss[])  {
        CtxUtil.getBaseManager().getHibernateTemplate().execute(
new HibernateCallback() {
            
public Object doInHibernate(Session session) throws HibernateException, SQLException {
                session.connection().setAutoCommit(
false);
                
// 保存stu1
                Student stu1 = new Student();
                stu1.setName(
"aaaa");// 在数据库中,name字段不允许为null
                session.save(stu1);
                
// session.flush();

                Student stu2 
= new Student();
                session.save(stu2);
// 没有设置name字段,预期会报出例外
                
// session.flush();
                session.connection().commit();
                
return null;
            }

        }
);

    }

运行上述代码,后台报数据库的not null错误,这个是合理的,打开数据库,没有发现新增记录,这个也是合理的。你可能会说:由于事务失败,数据库当然不可能会有任何新增记录。好吧,我们再把代码改一下,去除not null的错误,以确保它能正常运行。代码如下:

public   static   void  main(String ss[])  {
        CtxUtil.getBaseManager().getHibernateTemplate().execute(
new HibernateCallback() {
            
public Object doInHibernate(Session session) throws HibernateException, SQLException {
                session.connection().setAutoCommit(
false);
                
// 保存stu1
                Student stu1 = new Student();
                stu1.setName(
"aaaa");// 在数据库中,name字段不允许为null
                session.save(stu1);
                
// session.flush();

                Student stu2 
= new Student();
                stu2.setName(
"asdfasdf");//好了,这个字段设过值,不会再报not null错误了
                session.save(stu2);
                
// session.flush();
                session.connection().commit();
                
return null;
            }

        }
);

    }


至此再运行上述代码,出现了一个奇怪的问题:
虽然控制台把insert语句打出来了,但是:数据库没有出现任何新的记录。
究其原因,有二:
一. session.connection().commit()确实导致数据库事务提交了,但是此刻session并没有向数据库发送任何语句。
二.在spring后继的flushIfNecessary()和closeSessionOrRegisterDeferredClose()方法中,第一个方法向数据库发送sql语句,第二个方法关闭session,同时关闭connection,然后问题在于:connection已经在程序中被手动设置为auttocommit=false了,因此在关闭数据库时,也不会提交事务。
解决这个问题很容易,在程序中手动调用session.flush()就可以了。如下代码:
通过设置HibernateTemplate的flushMode=FLUSH_NEVER来通知spring不进行session.flush()的调用,则spring的flushIfNecessary()将不进行任何操作,它的flushIfNecessary()源代码如下:

public   static   void  main(String ss[])  {
        CtxUtil.getBaseManager().getHibernateTemplate().execute(
new HibernateCallback() {
            
public Object doInHibernate(Session session) throws HibernateException, SQLException {
                session.connection().setAutoCommit(
false);
                
                
//保存stu1
                Student stu1=new Student();
                stu1.setName(
"aaaa");//在数据库中,name字段不允许为null
                session.save(stu1);
                
                Student stu2 
= new Student();
                session.save(stu2);
//没有设置name字段,预期会报出例外
                
                session.flush();//向数据库发送sql
                session.connection().commit();
                
return null;
            }

        }
);

    }


运行上述代码,打开数据库查看,没有新增任何记录。在代码中新加一行stu2.setName("aaa");再次运行代码,发现数据库表中多了两条记录。事务操作成功。
至此,虽然操作成功,但事情还没有结束。这是因为spring在调用doInHibernate()的后继的步骤中,还要进行flushIfNecessary()操作,这个操作其实最后调用的还是session.flush()。因为在程序中已经手动调用过session.flush(),所以由spring调用的session.flush()并不会对数据库发送sql(因为脏数据比对的原因)。虽然不会对结果有什么影响,但是多调了一次flush(),还是会对性能多少有些影响。能不能控制让spring不调用session.flush()呢?可以的,只要加上一句代码,如下所示:

public   static   void  main(String ss[])  {
        CtxUtil.getBaseManager().getHibernateTemplate().setFlushMode(
0);//0也就是FLUSH_NEVER
        CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
            
public Object doInHibernate(Session session) throws HibernateException, SQLException {
                session.connection().setAutoCommit(
false);
                
                
//保存stu1
                Student stu1=new Student();
                stu1.setName(
"aaaa");//在数据库中,name字段不允许为null
                session.save(stu1);
                
                Student stu2 
= new Student();
                stu2.setName(
"sdf");
                session.save(stu2);
//没有设置name字段,预期会报出例外
                
                session.flush();
                session.connection().commit();
                
return null;
            }

        }
);

    }

 

protected   void  flushIfNecessary(Session session,  boolean  existingTransaction)  throws  HibernateException  {
        
if (getFlushMode() == FLUSH_EAGER || (!existingTransaction && getFlushMode() != FLUSH_NEVER)) {
            logger.debug(
"Eagerly flushing Hibernate session");
            session.flush();
        }

    }

至此,代码1中的main()终于修改完毕。但事实上,这样的操作无疑是比较麻烦的,因此如果在spring中想利用session进行事务操作时,最好还是用TransactionTemplate(编程式事务)或是声明式事务比较方便一些。
本例通过这么一个虽然简单但又绕来绕去的例子,主要是说明hibernate事务的一些内在特性,以及HibernateTemplate中如何处理session和事务的开关,让读者对HibernateTemplate的源代码处理细节有一些了解,希望能给读者有抛砖引玉的作用。

这篇关于HibernateTemplate中HibernateCallback的事务的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/397171

相关文章

MySql 事务练习

事务(transaction) -- 事务 transaction-- 事务是一组操作的集合,是一个不可分割的工作单位,事务会将所有的操作作为一个整体一起向系统提交或撤销请求-- 事务的操作要么同时成功,要么同时失败-- MySql的事务默认是自动提交的,当执行一个DML语句,MySql会立即自动隐式提交事务-- 常见案例:银行转账-- 逻辑:A给B转账1000:1.查询

Lua 脚本在 Redis 中执行时的原子性以及与redis的事务的区别

在 Redis 中,Lua 脚本具有原子性是因为 Redis 保证在执行脚本时,脚本中的所有操作都会被当作一个不可分割的整体。具体来说,Redis 使用单线程的执行模型来处理命令,因此当 Lua 脚本在 Redis 中执行时,不会有其他命令打断脚本的执行过程。脚本中的所有操作都将连续执行,直到脚本执行完成后,Redis 才会继续处理其他客户端的请求。 Lua 脚本在 Redis 中原子性的原因

spring事务属性的xml格式配置

实际是使用代理做的事务优化 <!--配置事务的属性--><tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <!--匹配所有以add开头的方法--><tx:method name="add*" propagation="REQUIRED" /> <tx:metho

Spring Cloud整合Seata实现分布式事务

文章目录 1.Seata1.1 官网1.2 下载1.3 通过安装包运行seata1.3.1 解压seata-server-1.3.0.zip1.3.2 修改 conf/file.conf 配置文件1.3.3 修改conf/registry.conf配置文件1.3.4 添加seata配置信息到nacos1.3.5 配置seata服务端数据库表结构1.3.6 启动seata 2.Spring

分布式 事务的几种实现方案

背景 四月初,去面试了本市的一家之前在做办公室无人货架的公司,虽然他们现在在面临着转型,但是对于我这种想从传统企业往互联网行业走的孩子来说,还是比较有吸引力的。 在面试过程中就提到了分布式事务问题。我又一次在没有好好整理的问题上吃了亏,记录一下,还是长记性 !!! 先看面试过程 面试官先是在纸上先画了这样一张图: 让我看这张图按照上面的流程走,有没有什么问题?面试官并没有直接说出来这里面

分布式事务 全面解析

1 面试题 分布式事务了解吗?你们如何解决分布式事务问题的? 2 考点分析 只要聊到做了分布式系统,必问分布式事务,若你对分布式事务一无所知的话,确实很坑,起码得知道有哪些方案,一般怎么来做,每个方案的优缺点是什么。 现在面试,分布式系统成了标配,而分布式系统带来的分布式事务也成了标配. 你做系统肯定要用事务,那你用事务的话,分布式系统之后肯定要用分布式事务. 先不说你搞过没有,起码你

为 Key-Value 数据库实现MVCC 事务

ACID是软件领域使用最广泛的技术之一,它是关系数据库的基石,是企业级中间件不可或缺的部分,但通常通过黑盒的方式提供。但是在许多情况下,这种古老的事务方式已经不能够适应现代大规模系统和NoSQL数据库的需要了,现代系统要求更高的性能要求,更大的数据量,更高的可用性。在这种情况下,传统的事务模型被定制的事务或者半事务模型所取代,而在这些模型中事务性并不像以往那样被看重。   在本文中我们会讨论一

[MySQL实战45讲]MySQL笔记之事务

基本要素 ACID 1、原子性(Atomicity):事务开始后所有操作,要么全部做完,要么全部不做,不可能停滞在中间环节。事务执行过程中出错,会回滚到事务开始前的状态,所有的操作就像没有发生一样。也就是说事务是一个不可分割的整体,就像化学中学过的原子,是物质构成的基本单位。 2、一致性(Consistency):事务开始前和结束后,数据库的完整性约束没有被破坏 。比如A向B转账,不可能A扣

oracle事务隔离级别

文章目录 数据库事务概况1.事务相关概念2.事务的四个特性ACID : oracle事务隔离级别1 .两个事务并发访问数据库数据时可能存在的问题 数据库事务概况 一组SQL,一个逻辑工作单位,执行时整体修改或者整体回退。 1.事务相关概念 1)事务的提交和回滚:COMMIT/ROLLBACK 2)事务的开始和结束 开始事务:连接到数据库,执行DML、DCL、DDL语

Oracle数据库(Oracle存储结构、Oracle运行机制、日期相关的函数、序列、大对象数据类型、表的修改与约束、事务)

仅仅只是阅读浏览博客内容学习Oracle这种方式不行,更重要的是敲代码,推荐博客中代码建议阅读本博客的人去手动的敲一下代码! 推荐博客: http://blog.csdn.net/ochangwen/article/details/52214713 一、Oracle存储结构 在了解Oracle物理存储结构之前,首先了解一些表空间和数据库的结构组成。表空间是一个数据库被分成若干