步骤：

1. 正常配置jdbctemplate
2. 正常配置bean
3. 配置事物管理器
4. 配置事物管理器
5. 配置aop切入点,通过切入点把事物链接起来

思路：

接着上一个买书的例子吧，直接拷到新包下，把注解都干掉，需要自动引入的直接set方法

package com.spring.bean;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.spring.bean;import org.springframework.jdbc.core.JdbcTemplate;public class BookShopDaoImpl implements BookShopDao {    private JdbcTemplate jdbcTemplate;        public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {        this.jdbcTemplate = jdbcTemplate;    }        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 < price){            throw new UserAccountException("余额不足!");        }                String sql = "UPDATE account SET balance = balance - ? WHERE username = ?";        jdbcTemplate.update(sql, price, username);    }}

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

package com.spring.bean;public class BookShopServiceImpl implements BookShopService {    private BookShopDao bookShopDao;    public void setBookShopDao(BookShopDao bookShopDao) {        this.bookShopDao = bookShopDao;    }    @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.spring.bean;import java.util.List;public interface Cashier {    public void checkout(String username, List
     
       isbns);    }
     

package com.spring.bean;import java.util.List;public class CashierImpl implements Cashier {    private BookShopService bookShopService;    public void setBookShopService(BookShopService bookShopService) {        this.bookShopService = bookShopService;    }    @Override    public void checkout(String username, List
     
       isbns) {        for(String isbn: isbns){            bookShopService.purchase(username, isbn);        }    }}
     

自定义异常不贴了，和上节代码一样

bean配置文件

注意，

如果配置文件正确，报错空指针异常，一般是@Autowired的实体，，没用set方法创建实体

报错信息如下：

org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 15 in XML document from class path resource [beans.xml] is invalid; nested exception is org.xml.sax.SAXParseException; lineNumber: 15; columnNumber: 15; cvc-complex-type.2.4.c: 通配符的匹配很全面, 但无法找到元素 'aop:config' 的声明。

一般是配置文件的顶部没有导入相应的aop schema命名空间，把命名空间加上即可。