问题描述：现在我们有一个数据库：spring
三张表：account、book、book_stock
account存储着用户以及账户余额。book存储着书号、名字和 购买一本所需金额。book_stock存储着书号以及对应的库存。
现在我们有这么一个需求：用户买一本书，先让书的库存减一，然后在让用户余额减去相应的金额。我们来看如何处理。
新建一个Java project，在项目下新建一个lib文件夹，在文件夹中加入以下包：
选中这些包，点击鼠标右键，选择build path，选择add to build path。
然后建立以下的目录结构：
一、配置连接数据库
db.propertIEs
jdbc.user=rootjdbc.password=123456jdbc.driverClass=com.MysqL.jdbc.Driverjdbc.jdbcUrl=jdbc:MysqL:///springjdbc.initPoolSize=5jdbc.maxPoolSize=10
在applicationContex.xml中
<?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:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd"> <!-- 导入资源文件 --> context:property-placeholder location="classpath:db.propertIEs"/> 配置 C3P0 数据源 bean ID="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"> property name="user" value="${jdbc.user}"></property="password"="${jdbc.password}"="jdbcUrl"="${jdbc.jdbcUrl}"="driverClass"="${jdbc.driverClass}"> ="initialPoolSize"="${jdbc.initPoolSize}"="maxPoolSize"="${jdbc.maxPoolSize}"> </bean> beans>
二、利用基于注解的方式配置bean
向applicationContext.xml中加入
context:component-scan base-package="com.gong.spring"context:component-scan>
三、配置JdbcTemplate，并利用JdbcTemplate *** 作数据库
向applicationContext.xml中加入
配置 Spirng 的 JdbcTemplate ="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" ref="dataSource">
BookShopDao.java
package com.gong.spring.tx;public interface BookShopDao { 根据书号获取书的单价 int findBookPriceByIsbn(String isbn); 更新书的库存，使书号对应的库存-1 voID updateBookStock(String isbn); 更新账户余额：使username的balance-price voID updateUserAccount(String username, price);}
BookShopDaoImpl.java
import org.springframework.beans.factory.annotation.autowired; org.springframework.jdbc.core.JdbcTemplate; org.springframework.stereotype.Repository;@Repository("bookShopDao")class BookShopDaoImpl implements BookShopDao { @autowired private JdbcTemplate jdbcTemplate; @OverrIDe findBookPriceByIsbn(String isbn) { String sql = "SELECT price FROM book WHERE isbn = ?"; return jdbcTemplate.queryForObject(sql,Integer.class,isbn); } @OverrIDe updateBookStock(String isbn) { String sql2 = "SELECT stock FROM book_stock WHERE isbn = ?"int stock = jdbcTemplate.queryForObject(sql2,isbn); 检查书的库存是否足够，如果不够，就抛出异常 if(stock == 0){ throw new BookStockException("库存不足!"); } String sql = "UPDATE book_stock SET stock = stock -1 WHERE isbn = ?"; jdbcTemplate.update(sql,1)"> price) { String sql2 = "SELECT balance FROM account WHERE username = ?"int balance = jdbcTemplate.queryForObject(sql2,username); if(balance < price){ new UserAccountException("余额不足!"); } String sql = "UPDATE account SET balance = balance - ? WHERE username = ?"自己定义该抛出的异常。BookStockException.java
class BookStockException extends RuntimeException{ /** * */ private static final long serialVersionUID = 1L; public BookStockException() { super(); Todo auto-generated constructor stub } BookStockException(String message,Throwable cause,boolean enableSuppression,1)">boolean writableStackTrace) { (message,cause,enableSuppression,writableStackTrace); BookStockException(String message) { (message); BookStockException(Throwable cause) { (cause); } }UserAccountException.java
class UserAccountException UserAccountException() { UserAccountException(String message,1)"> UserAccountException(String message) { UserAccountException(Throwable cause) { } }要定义自己异常的名称，需要让其继承RuntimeException，并实现构造方法。
然后是服务层的代码：
BookShopService.java
BookShopService { purchase(String username,String isbn); }只有一个方法体，就是购买的 *** 作。
BookShopServiceImpl.java
org.springframework.stereotype.Service;@Service("bookShopService"class BookShopServiceImpl BookShopService { @autowired BookShopDao bookShopDao; @OverrIDe 1. 获取书的单价 int price = bookShopDao.findBookPriceByIsbn(isbn); 2. 更新库存 bookShopDao.updateBookStock(isbn); 3. 更新余额 bookShopDao.updateUserAccount(username,price); }}最后，我们建立一个JUnit Test Case的文件进行测试：
SpringTransactionImpl.java
org.junit.Test; org.springframework.context.ApplicationContext; org.springframework.context.support.ClasspathXmlApplicationContext; SpringTransactionTest { private ApplicationContext ctx = null; private BookShopDao bookShopDao = private BookShopService bookShopService = ; { ctx = new ClasspathXmlApplicationContext("applicationContext.xml"); bookShopDao = ctx.getBean(BookShopDao.); bookShopService = ctx.getBean(BookShopService.); } @Test testBookShopService(){ bookShopService.purchase("AA","1001"); } @Test testBookShopDaoUpdateUserAccount(){ bookShopDao.updateUserAccount("AA",10 testBookShopDaoUpdateBookStock(){ bookShopDao.updateBookStock("1001" testBookShopDaoFindPriceByIsbn() { System.out.println(bookShopDao.findBookPriceByIsbn("1001")); }}这里面当然也可以测试 *** 作数据库的Dao的代码。我们现在就只关注testBookShopService方法，即购买 *** 作是否存在问题。
右键点击testBookShopService，选择run as JUnit-Test。执行成功后我们看数据库中的数据：
成功的买一本书号为1001 的书了。
账户余额减掉了100.
我们再执行一次testBookShopService方法：报错：余额不足，显然60不够买100的书。
但是呢，我们先执行的是库存减一 *** 作，此时库存：
明明没有买成功，但库存减了一，这就存在问题了。
有人也许会问，那我们先判断金额，再进行库存 *** 作不就可以了么？
这也存在问题：假设金额足够，但是库存为零。先执行金额减掉书的价值 *** 作，但是会报库存不足。相当于我钱付了，没买到书，这不就尴尬了。
这种情况下，我们就需要用到事务处理。
本章太长了，放在下节写吧。。。
总结以上是内存溢出为你收集整理的spring之为什么要使用事务？（一）全部内容，希望文章能够帮你解决spring之为什么要使用事务？（一）所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）