Spring使用注解和配置文件配置事务

package com.atguigu.spring.tx;   public interface BookShopDao {       //根据书号获取书的单价     public int findBookPriceByIsbn(String isbn);          //更新数的库存. 使书号对应的库存 - 1     public void updateBookStock(String isbn);          //更新用户的账户余额: 使 username 的 balance - price     public void updateUserAccount(String username, int price); }

package com.atguigu.spring.tx;   import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Repository;   @Repository("bookShopDao") public class BookShopDaoImpl implements BookShopDao {       @Autowired     private JdbcTemplate jdbcTemplate;          @Override     public int findBookPriceByIsbn(String isbn) {         String sql = "SELECT price FROM book WHERE isbn = ?";         return jdbcTemplate.queryForObject(sql, Integer.class, isbn);     }       @Override     public void updateBookStock(String isbn) {         //检查书的库存是否足够, 若不够, 则抛出异常         String sql2 = "SELECT stock FROM book_stock WHERE isbn = ?";         int stock = jdbcTemplate.queryForObject(sql2, Integer.class, isbn);         if(stock == 0){             throw new BookStockException("库存不足!");         }                  String sql = "UPDATE book_stock SET stock = stock -1 WHERE isbn = ?";         jdbcTemplate.update(sql, isbn);     }       @Override     public void updateUserAccount(String username, int price) {         //验证余额是否足够, 若不足, 则抛出异常         String sql2 = "SELECT balance FROM account WHERE username = ?";         int balance = jdbcTemplate.queryForObject(sql2, Integer.class, username);         if(balance 

package com.atguigu.spring.tx;   public interface BookShopService {          public void purchase(String username, String isbn);      }

package com.atguigu.spring.tx;   import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional;   @Service("bookShopService") public class BookShopServiceImpl implements BookShopService {       @Autowired     private BookShopDao bookShopDao;          //添加事务注解     //1.使用 propagation 指定事务的传播行为, 即当前的事务方法被另外一个事务方法调用时     //REQUIRED:为默认取值, 被调用的事务一个执行失败整个大事务就回滚     //REQUIRES_NEW:调用的事务如果执行成功就保存结果不会被回滚，其他事务执行失败不会影响到它     //2.使用 isolation 指定事务的隔离级别, 最常用的取值为 READ_COMMITTED     //3.默认情况下 Spring 的声明式事务对所有的运行时异常进行回滚. 也可以通过对应的     //属性进行设置. 通常情况下取默认值即可.      //4.使用 readOnly 指定事务是否为只读. 表示这个事务只读取数据但不更新数据,      //这样可以帮助数据库引擎优化事务. 若方法只读取数据库值, 应设置 readOnly=true     //5.使用 timeout 指定事务最多可以占用的时间,若超过时间则强制回滚  //    @Transactional(propagation=Propagation.REQUIRES_NEW, //            isolation=Isolation.READ_COMMITTED, //            noRollbackFor={UserAccountException.class})     @Transactional(propagation=Propagation.REQUIRES_NEW,             isolation=Isolation.READ_COMMITTED,             readOnly=false,             timeout=3)     @Override     public void purchase(String username, String isbn) {                  try {             Thread.sleep(5000);         } catch (InterruptedException e) {}                  //1. 获取书的单价         int price = bookShopDao.findBookPriceByIsbn(isbn);                  //2. 更新数的库存         bookShopDao.updateBookStock(isbn);                  //3. 更新用户余额         bookShopDao.updateUserAccount(username, price);     }   }

package com.atguigu.spring.tx;   import java.util.List;   public interface Cashier {       public void checkout(String username, List isbns);      }

package com.atguigu.spring.tx;   import java.util.List;   import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional;   @Service("cashier") public class CashierImpl implements Cashier {       @Autowired     private BookShopService bookShopService;          @Transactional     @Override     public void checkout(String username, List isbns) {         for(String isbn: isbns){             bookShopService.purchase(username, isbn);         }     }   }

package com.atguigu.spring.tx;   import static org.junit.Assert.*;   import java.util.Arrays;   import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext;   public class SpringTransactionTest {       private ApplicationContext ctx = null;     private BookShopDao bookShopDao = null;     private BookShopService bookShopService = null;     private Cashier cashier = null;          {         ctx = new ClassPathXmlApplicationContext("applicationContext.xml");         bookShopDao = ctx.getBean(BookShopDao.class);         bookShopService = ctx.getBean(BookShopService.class);         cashier = ctx.getBean(Cashier.class);     }          @Test     public void testTransactionlPropagation(){         cashier.checkout("AA", Arrays.asList("1001", "1002"));     }          @Test     public void testBookShopService(){         bookShopService.purchase("AA", "1001");     }          @Test     public void testBookShopDaoUpdateUserAccount(){         bookShopDao.updateUserAccount("AA", 200);     }          @Test     public void testBookShopDaoUpdateBookStock(){         bookShopDao.updateBookStock("1001");     }          @Test     public void testBookShopDaoFindPriceByIsbn() {         System.out.println(bookShopDao.findBookPriceByIsbn("1001"));     }   }