ibatis+spring mvc事务不能回滚

0 0

ibatis+spring mvc事务不能回滚30

最近才接触spring MVC和ibates，现在我需要配置事务回滚，但是倒腾了一天还是不行，熟悉的朋友帮忙看看: applicationContext.xml文件配置：

<?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-4.0.xsd   
          http://www.springframework.org/schema/context   http://www.springframework.org/schema/context/spring-context-4.0.xsd   
          http://www.springframework.org/schema/aop    http://www.springframework.org/schema/aop/spring-aop-4.0.xsd   
          http://www.springframework.org/schema/tx     http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
          http://www.springframework.org/schema/cache  http://www.springframework.org/schema/cache/spring-cache-4.0.xsd
          http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd 
          http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd"
          default-autowire="byName">
    
    <context:component-scan base-package="com.suneee">           
	   <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
	</context:component-scan>
          
    <bean id="propertyConfigurer"
		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
		<property name="location">
			<value>classpath:com/suneee/config/mysql/jdbc.properties</value>
		</property>
	</bean>
	
	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
		<property name="driverClassName" value="${db.driverClassName}"/>
		<property name="url" value="${db.url}"/>
		<property name="username" value="${db.username}"/>
		<property name="password" value="${db.password}"/>
	</bean>	
    
    <!-- 配置数据源 -->	
	<bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
		<property name="dataSource" ref="dataSource"/>
		<property name="configLocation">
			<value>classpath:com/suneee/config/ibatis/SqlMapConfig.xml</value>
		</property>
	</bean>
	
	<!-- 配置事务管理器 -->
	<bean id="transactionManager"
		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" /> 
	</bean>
	
	<!-- 配置哪些类的方法需要进行事务管理 proxy-target-class="true" -->
    <aop:config >
       <aop:pointcut id="crudMethos" expression="execution(* com.suneee.service.*.*(..))"/>   
       <aop:advisor advice-ref="txAdvice" pointcut-ref="crudMethos" /> 
    </aop:config>
	
    <!--配置哪些方法,什么情况下需要回滚-->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
         <tx:attributes>
           <tx:method name="insert*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>  
           <tx:method name="delete*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>   
           <tx:method name="update*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>  
            
          <!--   <tx:method name="*" propagation="REQUIRED" read-only="true"/> -->  <!-- 除了上面标识的方法,其他方法全是只读方法 -->    
        
         </tx:attributes>
    </tx:advice> 
    
</beans>

springMVC.XML文件内容如下:

<?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:mvc="http://www.springframework.org/schema/mvc"
	xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
		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" default-autowire="byName">


    <!-- 自动扫描的包名 --> 
	<context:component-scan base-package="com.suneee">
  	     <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Service"/>
	</context:component-scan>
	
	<!-- 视图解释类 -->  
	<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
		<property name="prefix" value="/WEB-INF/jsp/"></property>
		<property name="suffix" value=".jsp"></property>
	</bean>
	
	<bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
	</bean>
	
    <!-- 拦截器 
	<mvc:interceptors>
		<mvc:interceptor>
			<mvc:mapping path="/*.do"/>
			<bean class="com.suneee.interceptor.MyInterceptor"></bean>
		</mvc:interceptor>
	</mvc:interceptors> -->
	
</beans>

UserService.java内容如下：

package com.suneee.service.impl;

import java.util.List;

import org.springframework.stereotype.Service;

import com.suneee.bean.User;
import com.suneee.service.IUserService;
import com.suneee.service.base.BaseService;


@Service("userService")
public class UserService extends BaseService<User> implements IUserService{

	@Override
	public List<User> findUser(User user) {
		return   queryForList("user_queryAll",user);
	}

	@Override
	public User insert(User user){
	  
		  insert("user_insert",user);
			 
		  user = null;//故意设置为null，抛出异常  
		  insert("user_inserts",user);
		  
	
	  return user;
	}

}

BaseService.java文件如下：

package com.suneee.service.base;

import java.sql.SQLException;
import java.util.List;

import org.springframework.orm.ibatis.SqlMapClientTemplate;

 
public class BaseService<T> extends SqlMapClientTemplate{
	public static final int PAGE_SIZE = 15;

	public Object insert(String sqlId,Object baseClass){
		Object baseClassResult = null;
		try {
			baseClassResult = (Object) super.getSqlMapClient().insert(sqlId,baseClass);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return baseClassResult;
	}
	
	public Object queryForObject(String sqlId,Object baseClass){
		Object baseClassResult = null;
		try {
			baseClassResult = (Object) super.getSqlMapClient().queryForObject(sqlId,baseClass);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return baseClassResult;
	}
	
	public Integer delete(String sqlId,Integer id){
		Integer number = null;
		try {
			number = super.getSqlMapClient().delete(sqlId, id);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return number;
	}
	
	public Integer deleteByObject(String sqlId,Object obj){
		Integer number = null;
		try {
			number = super.getSqlMapClient().delete(sqlId, obj);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return number;
	}
	
	public Object queryById(String sqlId,Integer id){
		Object baseClassResult = null;
		try {			
			baseClassResult = (Object) super.getSqlMapClient().queryForObject(sqlId,id);		
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return baseClassResult;
	}
	
	
	public List<Object> queryListByPage(String sqlId,Object obj){
		List<Object> list = null;
		try {
			list = (List<Object>) super.getSqlMapClient().queryForList(sqlId, obj);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return list;
	}
	
	public List<Object> queryListNoPage(String sqlId,Object obj){
		List<Object> list = null;
		try {
			list = (List<Object>) super.getSqlMapClient().queryForList(sqlId, obj);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return list;
	}
	
	public int update(String sqlId,Object obj){
		Integer number = null;
		try {
			number = super.getSqlMapClient().update(sqlId, obj);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return number;
	}
	
	 
	
	//批量入库
	public boolean insertBatch(String sqlId,List list){
		Object obj = null;
		try {
			super.getSqlMapClient().startBatch();
			for(int i=0; i<list.size(); i++){
				obj = list.get(i);
				super.getSqlMapClient().insert(sqlId,obj);
			}
			super.getSqlMapClient().executeBatch();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}		
	}
	
	
	public int getCount(String sqlId){
		Integer i = null;
		try {
			i =  (Integer) super.getSqlMapClient().queryForObject(sqlId);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return i;
	}
	
}

以上就是我项目各个地方的代码，第二个插入数据方法我故意设置为null，执行报错，但是第一个插入数据方法执行了数据插入，没有回滚，怎样才能回滚啊，声明式的事务配置有错还是什么原因，熟悉的兄弟看看，困扰了我一天多了