我的java项目中spring事务总是出问题？

Posted 2023-03-22

我的项目用的是spring 4.1.6 hibernate 4.3.8 我的SessionFactory是这么配置的： <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> <property name="dataSource" ref="dataSource" /> <property name="hibernateProperties"> <props> <prop key="hibernate.jdbc.batch_size">$hibernate.jdbc.batch_size</prop> <prop key="current_session_context_class">org.springframework.orm.hibernate4.SpringSessionContext</prop> <prop key="hibernate.query.factory_class">org.hibernate.hql.internal.ast.ASTQueryTranslatorFactory</prop> <prop key="hibernate.cache.use_query_cache">$hibernate.cache.use_query_cache</prop> <prop key="hibernate.cache.use_second_level_cache">$hibernate.cache.use_second_level_cache</prop> <prop key="hibernate.cache.region.factory_class">org.hibernate.cache.ehcache.EhCacheRegionFactory</prop> </props> </property> <property name="mappingLocations"> <list> <value>classpath*:com/iresearch/demo/entity/*.hbm.xml</value> </list> </property> </bean>这个是TransactionManager的配置 <bean id="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager"> <property name="sessionFactory" ref="sessionFactory" /> </bean> 这是事务的配置： <tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <tx:method name="get*" read-only="true" /> <tx:method name="count*" read-only="true" /> <tx:method name="find*" read-only="true" /> <tx:method name="list*" read-only="true" /> <tx:method name="*" read-only="false" propagation="REQUIRED" /> </tx:attributes> </tx:advice> <aop:config> <aop:pointcut id="txPointcut" expression="execution(* com.iresearch..*.*(..))" /> <aop:advisor pointcut-ref="txPointcut" advice-ref="txAdvice" /> </aop:config>我的包结构是这样的com.iresearch.cloud.entity/dao/service/controller dao层是数据交互层 service是业务层对dao层进行调用我的dao中多数用了SessionFactory的getCurrentSession方法获取session 以及用了hibernateTemplate 在进行单元测试都正常 一旦进入web环境 就会出现org.hibernate.HibernateException: Could not obtain transaction-synchronized Session for current thread的异常 我在spring mvc的配置文件中加入拦截器OpenSessionInViewInterceptor这个问题就不出现了 但会出现org.springframework.dao.InvalidDataAccessApiUsageException: Write operations are not allowed in read-only mode (FlushMode.MANUAL): Turn your Session into FlushMode.COMMIT/AUTO or remove 'readOnly' marker from transaction definition.这个问题看起来我的问题是方法没有加上事务造成session的flushmode全是manual 但是我事务配的没错啊 我换了好几种事务配置方式就是execution表达式换了好几个 都是这样的问题怎么回事啊？

最近在项目的时候碰到pring事务不起作用的情况，后来解决了，这里我汇总下：

1、首先使用如下代码 确认你的bean 是代理对象吗？
必须是Spring定义（通过XML或注解定义都可以）的Bean才接受事务。
直接new出来的对象添加事务是不起作用的。
可以通过以下方式判断是否是代理对象：

AopUtils.isAopProxy(Object object)
AopUtils.isCglibProxy(Object object) //cglib
AopUtils.isJdkDynamicProxy(Object object) //jdk动态代理

2、入口函数必须是public，否则事务不起作用。这一点由Spring的AOP特性决定的。

3、切入点配置错误。
<!-- 使用annotation注解方式配置事务 -->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>
<!--使用切面方式配置事务-->
<tx:advice id="txadvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="*" isolation="READ_COMMITTED" propagation="REQUIRED" rollback-for="java.lang.Exception" />
</tx:attributes>
</tx:advice>

<aop:config>
<aop:pointcut id="pointcut" expression="execution(* com.tyyd..*Service.do*(..))"/>
<aop:advisor advice-ref="txadvice" pointcut-ref="pointcut"/>
</aop:config>

4、如果你使用了springmvc，可能是context:component-scan重复扫描引起的：

5、如使用mysql且引擎是MyISAM造成的（因为不支持事务），改成InnoDB即可。追问

我看了一下 5肯定不是问题原因 都是innoDB 4我只在spring mvc里扫描注解 不存在重复扫描 3貌似我配置没错误 2没看懂 我所有dao和service的方法都是public的 1三个方法参数传入service对象全是false

参考技术A

1、首先使用如下代码 确认你的bean 是代理对象吗？

必须是Spring定义（通过XML或注解定义都可以）的Bean才接受事务。

直接new出来的对象添加事务是不起作用的。

可以通过以下方式判断是否是代理对象：

AopUtils.isAopProxy(Object object)

AopUtils.isCglibProxy(Object object) //cglib

AopUtils.isJdkDynamicProxy(Object object) //jdk动态代理

2、入口函数必须是public，否则事务不起作用。这一点由Spring的AOP特性决定的。

3、切入点配置错误。

<!-- 使用annotation注解方式配置事务 -->

<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

<!--使用切面方式配置事务-->

<tx:advice id="txadvice" transaction-manager="transactionManager">

<tx:attributes>

<tx:method name="*" isolation="READ_COMMITTED" propagation="REQUIRED" rollback-for="java.lang.Exception" />

</tx:attributes>

</tx:advice>

<aop:config>

<aop:pointcut id="pointcut" expression="execution(* com.tyyd..*Service.do*(..))"/>

<aop:advisor advice-ref="txadvice" pointcut-ref="pointcut"/>

</aop:config>

4、如果你使用了springmvc，可能是context:component-scan重复扫描引起的：

5、如使用mysql且引擎是MyISAM造成的（因为不支持事务），改成InnoDB即可。

org.springframework.transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only

检查方法都是查询都没有异常，搜索百度了很多资料还是不解。

java - 如何在java桌面应用程序中使用spring（事务）和hibernate创建嵌入式H2 DB？

【中文标题】java - 如何在java桌面应用程序中使用spring（事务）和hibernate创建嵌入式H2 DB？

【英文标题】：How to create emdedded H2 DB with spring(transactional) and hibernate in java desktop application?

【发布时间】：2016-10-26 11:25:15

【问题描述】：

我正在尝试创建一个带有嵌入式 h2 db 的项目，并使用带有 hibernate 的 spring 框架。如果不存在，我的数据库将在初始化时创建。我的开发平台是intellij。

问题是当我运行应用程序时

@Autowired
private IPersonService personService; // comes null?

这是我的类和配置文件。

myDB.sql：

CREATE TABLE IF NOT EXISTS personel(
id IDENTITY AUTO_INCREMENT,
name VARCHAR(100) NOT NULL,
age VARCHAR(100));

hibernate.properties：

db.driverClassName=org.h2.Driver
db.url=jdbc:h2:~/h2SpringProject/database/SpringSample;mv_store=false;mvcc=false
db.username=admin
db.password=

这是我的 hibernate-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:jdbc="http://www.springframework.org/schema/jdbc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">



    <context:component-scan base-package="com.springapp"/>
    <context:annotation-config/>
    <context:property-placeholder location="hibernate.properties"/>
    <tx:annotation-driven transaction-manager="transactionManager"/>

    <bean id="dataSource"
          class="org.springframework.jdbc.datasource.SingleConnectionDataSource">
        <property name="driverClassName" value="$db.driverClassName"></property>
        <property name="url" value="$db.url"></property>
        <property name="username" value="$db.username"/>
        <property name="password" value="$db.password"/>
        <property name="suppressClose" value="true"/>
    </bean>


    <jdbc:initialize-database data-source="dataSource" ignore-failures="DROPS">
        <jdbc:script location="myDb.sql"/>
    </jdbc:initialize-database>


    <bean id="hibernateCfgProperties"
          class="org.springframework.beans.factory.config.PropertiesFactoryBean">
        <property name="properties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.H2Dialect</prop>
                <prop key="hibernate.hbm2ddl.auto">update</prop>
                <prop key="hibernate.show_sql">true</prop>
                <prop key="hibernate.format_sql">false</prop>
                <prop key="hibernate.use_sql_comments">true</prop>
                <prop key="hibernate.cache.use_second_level_cache">true</prop>
                <prop key="hibernate.cache.use_query_cache">true</prop>
                <prop key="hibernate.cache.region.factory_class">
                    org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory
                </prop>
            </props>
        </property>
    </bean>

    <bean id="sessionFactory"
          class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
        <property name="dataSource" ref="dataSource"/>
        <property name="hibernateProperties" ref="hibernateCfgProperties"/>
        <property name="packagesToScan" value="com.springapp.model"/>
    </bean>

    <bean id="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>

</beans>

人物类

@Entity
@Table(name = "personel")
public class Personel 

    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name = "id")
    private long id;

    @Column(name = "name")
    private String name;

    @Column(name = "age")
    private String age;
.......

IPersonDao 接口，这里是实现类

@Component
public class PersonelDaoImpl implements IPersonelDao 

    @Autowired
    private SessionFactory sessionFactory;


    public Session getCurrentSession() 
        return sessionFactory.getCurrentSession();
    

    @Override
    public void savePersonel(Personel personel) 
        getCurrentSession().saveOrUpdate(personel);
    

    @Override
    public void deletePersonel(long id) 
        getCurrentSession().delete(id);
    

    @Override
    public List<Personel> getPersonels() 
        return getCurrentSession().createQuery("from Personel").list();
    

有一个IPersonService接口，这里是实现类

@Service("PersonelService")
public class PersonelServiceImpl implements IPersonelService 

    @Autowired
    private IPersonelDao personelDao;

    @Override
    @Transactional
    public void savePersonel(Personel personel) 
        personelDao.savePersonel(personel);
    

    @Override
    @Transactional
    public void deletePersonel(long id) 
        personelDao.deletePersonel(id);
    

    @Override
    @Transactional
    public List<Personel> getPersonels() 
        return personelDao.getPersonels();
    

这是我的主要课程

public class MainApp 

    private static ApplicationContext applicationContext;

           public static void main(String[] args) 

        applicationContext = new ClassPathXmlApplicationContext("hibernate-config.xml");

    ForExample a = new ForExample();
    a.execute();
    



@Component
public class ForExample 

    @Autowired
    private IPersonelService personelService;

    public void execute()
        Personel p = new Personel();
        p.setName("thats Ok!");
        p.setAge("614345");

        personelService.savePersonel(p);
    

【问题讨论】：

class ForExample 不是 spring 托管 bean，所以不会发生 DI

我该如何解决？

ForExample 类应该是spring-managed bean，从应用程序上下文中获取。在这种情况下，依赖注入将起作用。你在某处有 ApplicationContext 的实例吗？类似ApplicationContext ctx = new ClasspathApplicationContext("config.xml");

是的，我有，在主方法 applicationContext = new ClassPathXmlApplicationContext("hibernate-config.xml"); （也是静态的）

使用 @Component 注释标记 ForExample 类，确保它落入组件扫描包中并且它应该可以工作。如果您不希望它是 Spring bean，请不要使用 @Autowired 注释并直接从上下文中获取依赖关系 ctx.getBean(IPersonService.class);

【参考方案1】：

public class MainApp 


        public static ApplicationContext applicationContext;

        private static IPersonelService personelService;


        public static void main(String[] args) 

            applicationContext = new ClassPathXmlApplicationContext("hibernate-config.xml");
            personelService = applicationContext.getBean(IPersonelService.class);

            Personel p = new Personel();
            p.setName("thatsOK!");
            p.setAge("614345");

            personelService.savePersonel(p);

        
    

因为 spring 在运行时不识别新的操作符..