Spring整合Hibernate后调用session.save方法报错但事务不回滚

0 0

Spring整合Hibernate后调用session.save方法报错但事务不回滚0

在DAO的saveRecord方法中执行session.save后，手动让程序throw了一个Exception，然而事务没有回滚，而让这条记录增到了数据库中，这是什么原因？

我使用的Spring声明式事务管理，事务管理器是"..orm.hibernate4.HibernateTransactionManager"，具体见配置文件，Spring版本4.0.2，Hibernate版本4.3.5，使用的数据库是MySQL，是不是Spring事务管理器没有对这个方法起作用，恰好Hibernate或者MySQL是自动提交的？

package com.sample.dao.impl;

import java.io.Serializable;
import java.util.List;

import javax.annotation.Resource;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.stereotype.Repository;

import com.sample.dao.BaseDAO;
import com.sample.po.Employee;

@Repository("empDAOHiber")
public class EmpDAOHibernate extends BaseDAO<Employee> {
	
	private SessionFactory sessionFactory;
	
	@Resource
	public void setSessionFactory(SessionFactory sessionFactory) {
		this.sessionFactory = sessionFactory;
	}

	private Session getCurSession(){
		return sessionFactory.getCurrentSession();
	}

	@Override
	public Serializable saveRecord(Employee obj) throws Exception{
		Serializable s1 = this.getCurSession().save(obj);
		if(1 == 1){
			throw new Exception("xxxxxxxxxxxxx!!!!");
		}
		return s1;
	}
	
}

下面是配置文件：看不清的请下附件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
    <!-- 开启切面 -->
	<aop:aspectj-autoproxy />
	<!-- 打开注解 -->
	<context:annotation-config />
	<!-- 打开自动扫描 -->
	<context:component-scan base-package="com.sample.dao.impl" />
    <!-- 加载properties文件 -->
	<context:property-placeholder location="classpath:jdbc-datasource.properties" />
	<!-- 定义DataSource -->
	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
		<property name="driverClassName" value="${driverClassName}" />
		<property name="url" value="${url}" />
		<property name="username" value="${username}" />
		<property name="password" value="${password}" />
		<!-- 连接池启动时的初始值 -->
		<property name="initialSize" value="${initialSize}" />
		<!-- 连接池的最大值 -->
		<property name="maxActive" value="${maxActive}" />
		<!-- 最大空闲值.当经过一个高峰时间后，连接池可以慢慢将已经用不到的连接慢慢释放一部分，一直减少到maxIdle为止 -->
		<property name="maxIdle" value="${maxIdle}" />
		<!--  最小空闲值.当空闲的连接数少于阀值时，连接池就会预申请去一些连接，以免洪峰来时来不及申请 -->
		<property name="minIdle" value="${minIdle}" />
	</bean>
	
	<!-- Hibernate Session 工厂 -->  
    <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">  
        <property name="dataSource">  
            <ref local="dataSource" />
        </property>
        <property name="configLocation" value="classpath:hibernate.cfg.xml"/>  
        <!-- 自动扫描注解方式配置的hibernate类文件 -->  
        <property name="packagesToScan">  
            <list>  
                <value>com.sample.po</value>
            </list>  
        </property>  
    </bean>  
  
    <!-- 配置事务管理器 -->  
    <bean id="txManager"  
        class="org.springframework.orm.hibernate4.HibernateTransactionManager">  
        <property name="sessionFactory">
        	<ref local="sessionFactory" />
        </property>  
    </bean>  
	
	<!-- 声明式事务（配置方式） -->
	<tx:advice id="txAdvice" transaction-manager="txManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED" />
			<tx:method name="update*" propagation="REQUIRED" />
			<tx:method name="delete*" propagation="REQUIRED" />
			<tx:method name="save*" propagation="REQUIRED" />
			<tx:method name="execute*" propagation="REQUIRED" />
			
			<tx:method name="get*" propagation="REQUIRED" read-only="true" />
			<tx:method name="find*" propagation="REQUIRED" read-only="true" />
			<tx:method name="*" propagation="REQUIRED" read-only="true" />
		</tx:attributes>
	</tx:advice>
	
	<aop:config>
		<aop:pointcut id="transactionPointcut"
			expression="execution(* com.sample..dao.impl.*.*(..))" />
		<aop:advisor advice-ref="txAdvice" pointcut-ref="transactionPointcut" />
	</aop:config>
</beans>

Spring Hibernate

2014年5月25日 20:29

wawxy2009
-1
0 0 5

5个答案按时间排序按投票排序

0 0

怀疑是你的
<aop:config>
        <aop:pointcut id="transactionPointcut"
            expression="execution(* com.sample..dao.impl.*.*(..))" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="transactionPointcut" />
    </aop:config>

这个配置的有问题，一般的aop:pointcut 里面的包的路径应该是service这一层，你配置到dao这层去了，你换个试试！

2014年5月30日 16:44

chidaohebeiji
55
0 0 5

2条评论

0 0

还有，一般基于注解都是这么写的：

	@Resource
	public SessionFactory sessionFactory;
	
	public Session getSession(){
		return sessionFactory.getCurrentSession();
	}
	
	@Resource
	public JdbcTemplate jdbcTemplate;

	<!-- 事务管理 -->
	<bean id="transactionManager"
			class="org.springframework.orm.hibernate3.HibernateTransactionManager">
			<property name="sessionFactory" ref="sessionFactory" />
	</bean>
	
	<!-- 基于注解方式的事物管理 -->
	<tx:annotation-driven transaction-manager="transactionManager"/>
	
    <!-- jdbcTemplate -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

2014年5月26日 19:11

QuarterLifeForJava
69
0 1 11

添加评论

0 0

有可能是 MySQL 引擎的问题。查看一下 MySQL 表的引擎是什么，如果是 MyISAM，那就是不支持事务的。

2014年5月26日 13:54

bylijinnan
42
0 1 9

2条评论

0 0

如果采用三层架构：controller->service->dao，那么既然你在dao抛出异常，应该要在service捕获，如果service不捕获，就必须在controller捕获
service可写为：

@Service("trainService")
@Transactional
public class TrainServiceImpl implements TrainService{
     public JSONArray a(){
         try{
             //TODO
         }catch(Exception e){
             e.printstacttrace();
         }
     }
}

或者controller

@Controller
@RequestMapping("/train.do")
public class TrainController {
@RequestMapping(params = "method=addClass")
	@Transactional(rollbackFor = Exception.class)
	public void addClass(HttpServletRequest request, HttpServletResponse response) {
		try{
                //TODO
}catch(e){

}

}

}

2014年5月26日 12:15

QuarterLifeForJava
69
0 1 11