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

相关文章

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED(默认)2.2 SUPPORTS2

MySQL 事务的概念及ACID属性和使用详解

《MySQL事务的概念及ACID属性和使用详解》MySQL通过多线程实现存储工作,因此在并发访问场景中,事务确保了数据操作的一致性和可靠性,下面通过本文给大家介绍MySQL事务的概念及ACID属性和... 目录一、什么是事务二、事务的属性及使用2.1 事务的 ACID 属性2.2 为什么存在事务2.3 事务

Spring Boot 事务详解(事务传播行为、事务属性)

《SpringBoot事务详解(事务传播行为、事务属性)》SpringBoot提供了强大的事务管理功能,通过@Transactional注解可以方便地配置事务的传播行为和属性,本文将详细介绍Spr... 目录Spring Boot 事务详解引言声明式事务管理示例编程式事务管理示例事务传播行为1. REQUI

MySQL中的事务隔离级别详解

《MySQL中的事务隔离级别详解》在MySQL中,事务(Transaction)是一个执行单元,它要么完全执行,要么完全回滚,以保证数据的完整性和一致性,下面给大家介绍MySQL中的事务隔离级别详解,... 目录一、事务并发问题二、mysql 事务隔离级别1. READ UNCOMMITTED(读未提交)2

如何合理使用Spring的事务方式

《如何合理使用Spring的事务方式》:本文主要介绍如何合理使用Spring的事务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、介绍1.1、底层构造1.1.事务管理器1.2.事务定义信息1.3.事务状态1.4.联系1.2、特点1.3、原理2. Sprin

通过Spring层面进行事务回滚的实现

《通过Spring层面进行事务回滚的实现》本文主要介绍了通过Spring层面进行事务回滚的实现,包括声明式事务和编程式事务,具有一定的参考价值,感兴趣的可以了解一下... 目录声明式事务回滚:1. 基础注解配置2. 指定回滚异常类型3. ​不回滚特殊场景编程式事务回滚:1. ​使用 TransactionT

SpringKafka消息发布之KafkaTemplate与事务支持功能

《SpringKafka消息发布之KafkaTemplate与事务支持功能》通过本文介绍的基本用法、序列化选项、事务支持、错误处理和性能优化技术,开发者可以构建高效可靠的Kafka消息发布系统,事务支... 目录引言一、KafkaTemplate基础二、消息序列化三、事务支持机制四、错误处理与重试五、性能优

Spring事务中@Transactional注解不生效的原因分析与解决

《Spring事务中@Transactional注解不生效的原因分析与解决》在Spring框架中,@Transactional注解是管理数据库事务的核心方式,本文将深入分析事务自调用的底层原理,解释为... 目录1. 引言2. 事务自调用问题重现2.1 示例代码2.2 问题现象3. 为什么事务自调用会失效3

Seata之分布式事务问题及解决方案

《Seata之分布式事务问题及解决方案》:本文主要介绍Seata之分布式事务问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Seata–分布式事务解决方案简介同类产品对比环境搭建1.微服务2.SQL3.seata-server4.微服务配置事务模式1

MYSQL事务死锁问题排查及解决方案

《MYSQL事务死锁问题排查及解决方案》:本文主要介绍Java服务报错日志的情况,并通过一系列排查和优化措施,最终发现并解决了服务假死的问题,文中通过代码介绍的非常详细,需要的朋友可以参考下... 目录问题现象推测 1 - 客户端无错误重试配置推测 2 - 客户端超时时间过短推测 3 - mysql 版本问