接口:public interface UserService {    
public void addUser(String username, String password);    
  
public void deleteUser(int id);    
  
public void updateUser(int id, String username);    
  
public List queryUser(String username);    
}  接口的实现:public class UserServiceImpl implements UserService {      
    private DataSource dataSource;      
    public void addUser(String username, String password) {      
        //正确的sql      
        String sql = "insert into aaa (t1,t2,t3) values (seq_food.nextval,'"+username+"','"+password+"')";      
        System.out.println(sql);      
        JdbcTemplate jdbcTemplate = new JdbcTemplate(getDataSource());      
        jdbcTemplate.update(sql);   
    }      
     
    public void deleteUser(int id) {      
     
    }      
     
    public void updateUser(int id, String username) {      
        //错误的sql,测试回滚      
         String sql = "update aa set t2='"+username+"' where t1='"+id+"'";      
        System.out.println(sql);      
        JdbcTemplate jdbcTemplate = new JdbcTemplate(getDataSource());      
        jdbcTemplate.update(sql);      
    }      
     
    public List queryUser(String username) {      
     
        return null;      
    }      
     
    public DataSource getDataSource() {      
        return dataSource;      
    }      
     
    public void setDataSource(DataSource dataSource) {      
        this.dataSource = dataSource;      
    }      
     
}测试servlet:public class UserServlet extends HttpServlet {      
     
          
    public void doGet(HttpServletRequest request, HttpServletResponse response)      
            throws ServletException, IOException {      
     
        doPost(request, response);      
    }      
     
          
    public void doPost(HttpServletRequest request, HttpServletResponse response)      
            throws ServletException, IOException {      
        request.setCharacterEncoding("utf-8");      
        response.setContentType("text/html; charset=utf-8");      
        ApplicationContext ctx = WebApplicationContextUtils.getWebApplicationContext(getServletContext());      
        try {      
            UserService userService = (UserService) ctx.getBean("userService");      
            userService.addUser("1", "2");      
            userService.updateUser(10032190, "zf");      
        } catch (DataAccessException e) {      
            e.printStackTrace();      
        }      
              
    }      
     
}spring配置文件:<?xml version="1.0" encoding="GB2312"?>      
<beans xmlns="http://www.springframework.org/schema/beans"     
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"     
       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-2.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">      
          
    <bean id="dataSource"       
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">      
        <property name="driverClassName">      
            <value>org.logicalcobwebs.proxool.ProxoolDriver</value>      
        </property>      
        <property name="url">      
            <value>proxool.foodManage</value>      
        </property>      
    </bean>      
          
    <bean id="jdbcTemplate"     
        class="org.springframework.jdbc.core.JdbcTemplate">      
        <property name="dataSource" ref="dataSource"></property>      
    </bean>      
    <!-- 事务管理 -->      
    <bean id="txManager"     
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">      
        <property name="dataSource" ref="dataSource"/>      
    </bean>      
          
    <tx:advice id="txAdvice" transaction-manager="txManager">      
        <tx:attributes>      
            <tx:method name="query*" propagation="REQUIRED" read-only="true" rollback-for="Exception"/>      
            <tx:method name="*" propagation="REQUIRED" rollback-for="Exception"/>      
        </tx:attributes>      
    </tx:advice>      
          
    <aop:config>      
        <aop:pointcut id="userServiceOperation" expression="execution(* cn.com.xy.service.*.*(..))"/>      
        <aop:advisor advice-ref="txAdvice" pointcut-ref="userServiceOperation"/>      
    </aop:config>      
          
    <bean id="userService" class="cn.com.xy.imp.UserServiceImpl">      
        <property name="dataSource" ref="dataSource" />      
    </bean>      
</beans>做了一个简单的测试,使用上述的配置和测试代码,运行后,没有更新成功,但还是插入了一条新数据,事务回滚没有起作用,正确的应该是既不更新也不插入,编程式事务测试是好的,但是声明式事务就不对了,可能spring的配置不对,还望大家帮忙看看。

解决方案 »

  1.   

     userService.addUser("1", "2");      
     userService.updateUser(10032190, "zf");   这两个方法放到了action中,事务的层面是service,你这么做相当于启动了两个完全独立的事务
    逻辑不对,呵呵
      

  2.   

    呵呵,目前应用比较简单,就想这么搞,spring配置文件怎么改?有没有方法可以做到?
      

  3.   

    好的方法就是在业务层再写一个方法,来调用add和update,然后在action中调用一个方法
      

  4.   

    我觉得改spring的配置应该就可以了吧?呵呵。
      

  5.   

    不行,事务是在<aop:pointcut id="userServiceOperation" expression="execution(* cn.com.xy.service.*.*(..))"/>  这里你得做法不行,也不合理
      

  6.   

    不想一个小应用就搞的这么复杂,能不能在action里启动事务?
      

  7.   

    如果你把事务加载action上,那么模型不是模型,控制器不是控制,这样才复杂而且action是与web服务器相关联的,加上一层事务代理,不知道会有什么问题发生我的回答到此结束,呵呵