spring3 struts2 ibatis3 整合在使用事物时对异常的处理

问答首页 → Java企业应用

0 0

spring3 struts2 ibatis3 整合在使用事物时对异常的处理30

我现在故意执行sql报错测试事物的
我要执行两次添加操作两次添加同样的数据报唯一约束的错然后让他回滚返回根据条件返回值

这是我想要的效果

现在是发现有异常就回滚可是由于有异常

方法中的

if(res1==res2&&res1==1)
return 0;

else return -1;

就不执行了

现在想让事物可以正常使用，也能根据执行sql的结果进行判断。

对于异常该怎么处理。

--------------------------------------------------------------------------------userdao

package com.haitu.dao.impl;

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

import org.apache.ibatis.session.SqlSession;

import com.haitu.model.UserInf;

public class UserDao implements com.haitu.dao.UserDaoInf{
   private SqlSession sqlSession ;

   public UserDao(SqlSession sqlSession) {
  // TODO Auto-generated constructor stub
    this.sqlSession=sqlSession;
  }

public int addUser(UserInf userInf) {

     int res1= sqlSession.update("UserInf.addUser",userInf);
     int res2= sqlSession.update("UserInf.addUser",userInf);

//？？？？？？此处执行事物问题执行两次添加操作两次添加同样的数据报唯一约束的错然后让他回滚
//由于出现异常下面的判断代码执行不了

if(res1==res2&&res1==1)
return 0;

    else return -1;
  }

public List<UserInf> selectUser() {
   return sqlSession.selectList("UserInf.selectUser");
  }
}

------------------------------------------------------------------spring配置：

<?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">

<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
  <property name="locations" value="WEB-INF/jdbc.properties"></property>
</bean>


<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
   <property name="driverClass" value="${driverClass}"> </property>
  <property name="jdbcUrl" value="${jdbcUrl}"> </property>
  <property name="user" value="${user}"> </property>
  <property name="password" value="${password}"> </property>
  <property name="maxPoolSize" value="${maxPoolSize}"> </property>
  <property name="minPoolSize" value="${minPoolSize}"> </property>
  <property name="maxIdleTime" value="${maxIdleTime}"> </property>
  <property name="idleConnectionTestPeriod" value="${idleConnectionTestPeriod}"> </property>
</bean>


<bean id="sqlMapClient"
  class="org.mybatis.spring.SqlSessionFactoryBean">
  <property name="dataSource">
   <ref local="dataSource" />
  </property>
   <property name="configLocation" value="classpath:ibatis.xml"></property>
  </bean>


<bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg index="0" ref="sqlMapClient" />
    </bean>

    
    <bean id="UserDao" class="com.haitu.dao.impl.UserDao">
   
   <constructor-arg ref="sqlSession" />
</bean>

    
<bean id="UserAction" class="com.haitu.action.UserAction" scope="prototype" >
    <property name="userDao" ref="UserDao"></property>
  </bean>

<bean id="transactionManager"
  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource">
   <ref local="dataSource" />
  </property>
</bean>

<aop:config>
    <aop:pointcut id="daoMethods" expression="execution(public * com.haitu.dao.UserDaoInf.*(..))"/>
    <aop:advisor advice-ref="txAdvice" pointcut-ref="daoMethods"/>
   </aop:config>

<tx:advice id="txAdvice" transaction-manager="transactionManager">
  <tx:attributes>
    <tx:method name="*" rollback-for="Exception" propagation="REQUIRED"/>
  </tx:attributes>
</tx:advice>

</beans>

--------------------------------------------------------------------------------struts2配置：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE struts PUBLIC
"-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"
"http://struts.apache.org/dtds/struts-2.0.dtd">

<constant name="struts.enable.DynamicMethodInvocation" value="true" />
    <constant name="struts.devMode" value="true" />
    <constant name="struts.locale" value="zh_CN" />
      <constant name="struts.i18n.encoding" value="UTF-8" />

    <package name="default" namespace="/" extends="struts-default">
        <default-action-ref name="index" />
         <action name="index">
            <result type="redirectAction">
                <param name="actionName">HelloWorld</param>
                <param name="namespace">/example</param>
            </result>
        </action>

        
         <action name="userinf_*" class="UserAction" method="{1}">
             <result type="stream" name="plain">
                       <param name="contentType">text/html</param>
             <param name="inputName">inputStream</param>
             </result>
         </action>
    </package>


</struts>

--------------------------------------------------------------------------------ibatis配置：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration PUBLIC "-//ibatis.apache.org//DTD Config 3.0//EN" "http://ibatis.apache.org/dtd/ibatis-3-config.dtd">

<typeAliases>
  <typeAlias type="com.haitu.model.UserInf" alias="UserInf" />
  </typeAliases>

<mappers>
  <mapper resource="com/haitu/model/UserInf.xml" />
  </mappers>

</configuration>

--------------------------------------------------------------------------------useraction 中的方法

public String addUserInf()    {
  try {
    inputStream = new StringBufferInputStream(new String("{success: true, msg:\"添加成功\"}".getBytes("utf-8"),"iso-8859-1"));
   } catch (Exception e) {
   // TODO: handle exception
  }

       int res=userDao.addUser(userinf);
      System.out.println("----------------"+res);
         return "plain";

}

2012年3月28日 17:00

ping792
0
0 0 0

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

0 0

public int addUser(UserInf userInf)  throws Exception{
    
   try {
     int res1= sqlSession.update("UserInf.addUser",userInf);
     int res2= sqlSession.update("UserInf.addUser",userInf);
  
  if(res1==res2&&res1==1)
     return 0;

    else return -1;
  }
} catch(Exception e){throw new Exception(e);}

应该要将RuntimeException抛出！

2012年3月30日 19:06

successfulroof
340
0 0 7

添加评论

0 0

呃。。。错了，没注意return。
你又想容易处理发生的异常，又要返回，肯定不可能的。因为发生异常后，不处理的话，你的return就没有意义了，程序已经跳转到别的逻辑了。

你可以把我上面的代码里面的catch里面不要抛出来异常，让程序返回，但是，也要把异常返回回来，你可以把参数改成map，把需要返回的正常结果，和异常对象都放进map里面，程序执行完以后，从map里取return的值，然后看是否有异常，有的话，就再抛出去，让容器给你处理，回滚事物什么的。

但是。。。。这样的程序。。。太烂了，会被后面维护的人骂死。

2012年3月28日 19:03

mavlarn
4
0 0 3

添加评论

0 0

都异常了，后面的代码必然执行不了，如果一定要执行，可以这样：

public int addUser(UserInf userInf)  {
     
  try{
     int res1= sqlSession.update("UserInf.addUser",userInf);
     int res2= sqlSession.update("UserInf.addUser",userInf);
//？？？？？？此处执行事物问题   执行两次添加操作  两次添加同样的数据  报唯一约束的错  然后让他回滚
  } catch (Exception e) {
   //由于出现异常下面的判断代码执行不了 
  if(res1==res2&&res1==1)
     return 0;
    else return -1;

  throw e; //重新把异常抛出去
  }
}

2012年3月28日 18:56

mavlarn
4
0 0 3

添加评论

已解决问题

未解决问题

排行榜

查看全部排名>>