详谈Spring框架之事务管理

 <!-- 配置c3p0数据源,只是进行了最简单的配置 -->  <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">    <property name="user" value="root"></property>    <property name="password" value="hss325730"></property>    <property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/test"></property>    <property name="driverClass" value="com.mysql.jdbc.Driver"></property>  </bean>    <!-- 配置Spring的 JdbcTemplate -->  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">    <property name="dataSource" ref="dataSource"></property>  </bean>    <!-- 配置Bean -->  <bean id="bookDao" class="com.zhoujian.spring.transcation.xml.BookDaoImpl">    <property name="tempate" ref="jdbcTemplate"></property>  </bean>  <bean id="bookService" class="com.zhoujian.spring.transcation.xml.service.impl.BookServiceImpl">    <property name="dao" ref="bookDao"></property>  </bean>  <bean id="batchBuy" class="com.zhoujian.spring.transcation.xml.service.impl.BatchBuyImpl">    <property name="service" ref="bookService"></property>  </bean>    <!-- 配置事务管理器 -->  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">    <property name="dataSource" ref="dataSource"></property>  </bean>    <!-- 配置事务管理器属性 并与事务管理器关联-->  <tx:advice id="myAdvice" transaction-manager="transactionManager">    <tx:attributes>      <!-- 在这里一般都是使用通配符进行配置, 或者直接配置指定的方法 -->      <tx:method name="buy" propagation="REQUIRES_NEW"/>      <tx:method name="get*" propagation="REQUIRED"/>      <tx:method name="*"/>    </tx:attributes>  </tx:advice>    <!-- 配置开启事务的切入点,使用AOP进行切入点的配置,并与事务管理器属性关联起来 -->  <aop:config>    <aop:pointcut expression="execution(* com.zhoujian.spring.transcation.xml.service.*.*(..))" id="myPointcut"/>    <aop:advisor advice-ref="myAdvice" pointcut-ref="myPointcut"/>  </aop:config>

 <!-- 配置自动扫描 -->  <context:component-scan base-package="com.zhoujian.spring"></context:component-scan>    <!-- 配置c3p0数据源,只是进行了最简单的配置 -->  <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">    <property name="user" value="root"></property>    <property name="password" value="hss325730"></property>    <property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/test"></property>    <property name="driverClass" value="com.mysql.jdbc.Driver"></property>  </bean>

<!-- 配置Spring的 JdbcTemplate -->  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">    <property name="dataSource" ref="dataSource"></property>  </bean>

<!-- 配置事务管理器 -->  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">    <property name="dataSource" ref="dataSource"></property>  </bean>

 <!-- 启动事务注解 -->  <tx:annotation-driven transaction-manager="transactionManager"/>

package com.zhoujian.spring.transcation; import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import org.springframework.transaction.annotation.Transactional; @Service("bookService")public class BookServiceImpl implements BookService {    @Autowired  private BookDao dao;   //这里是在指定方法上面开启事务  @Transactional  @Override  public void buy(String userId, String bookId) {        Integer price = dao.getBookPrice(bookId);        dao.updateBookCount(bookId);        dao.updateUserAccount(userId, price);  } }

package com.zhoujian.spring.transcation;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import org.springframework.transaction.annotation.Propagation;import org.springframework.transaction.annotation.Transactional;@Service("batchBuy")public class BatchBuyImpl implements BatchBuy {  @Autowired  private BookService service;      /**   * 1、关于事务的传播行为(当前事务方法调用另外的事务方法时,面对的事务怎么使用的问题),   * 常用的有两种(Propagation.REQUIRED, Propagation.REQUIRES_NEW)   * Spring 默认使用 Propagation.REQUIRED,表示使用当前事务方法持有的事务   *    * 例如: 事务方法A 调用事务方法B,    * 如果事务的传播行为使用Propagation.REQUIRED时,表示支持已经存在的事务,   * 如果在调用A方法之前不存在任何事务,那么此时会创建一个新的事务,在这里则都使用方法A所持有的事务,   * 　对于该配置，如果B过程中发生异常需要回滚,那么A中所进行的所有数据库操作也将同时被回滚,   * 因为这两个方法使用了同一个事务;   *    *    * 如果事务的传播行为使用Propagation.REQUIRES_NEW时, 表示将A方法所持有的事务挂起,   * 使用B方法自己的事务,当B方法事务完成之后,A事务才被唤醒   */  @Transactional(propagation=Propagation.REQUIRED)  @Override  public void buy(String userId, List<String> bookIds) {    for(String bookId : bookIds){      service.buy(userId, bookId);    }  }}

package com.zhoujian.spring.transcation;import java.util.Arrays;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class TranscationTest {  private static ApplicationContext ac = null;  private static BookDao dao = null;  private static BookService service;  private static BatchBuy buy;    static{    ac = new ClassPathXmlApplicationContext("bean-transcation.xml");    dao = ac.getBean("bookDao", BookDao.class);    service = ac.getBean("bookService", BookService.class);    buy = ac.getBean("batchBuy", BatchBuy.class);  }    @Test  public void test1(){    buy.buy("001", Arrays.asList("1","2"));  }    @Test  public void test() {    service.buy("001", "1");  }}