版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_38409944/article/details/82714359
先来简单介绍下事务,我的理解就是 使得一系列对数据库的操作原子化。
举个栗子:
你给别人转账,你的钱少了,但是别人的账户余额没有同时增加。
或者你给别人转账,你的钱没少,别人账户余额增加了。
分析:
转账扣钱是一个操作,收账增钱又是另一个操作。
如果中途出现错误,只实现了一部分操作,那么问题可想而知。
而事务的作用就是将两个操作粘合在一起,具有原子性。
只有两个都成功,才操作成功,
只要其中一个不成功,整个操作就失败。
这里我们来实战一下,写一个小Demo:
实现图书的买卖操作,目的是 扣除用户余额,减少图书存量。
如果其中一步出错,那么终止另一个操作,使其无效。
代码我已经放到Git
上,有兴趣的可以直接下载过来:
https://github.com/jjc123/Book-sale/blob/master/README.md
编写数据库:
mysql> create table book_stock(
-> id int,
-> stock int
-> );
Query OK, 0 rows affected (1.18 sec)
mysql> create table account(
-> name varchar(11),
-> money int
-> );
Query OK, 0 rows affected (0.31 sec)
mysql> create table book_price(
-> id int,
-> price int
-> );
Query OK, 0 rows affected (0.43 sec)
INSERT INTO account(name,money) values('小明',100);
INSERT INTO book_stock(id,stock) values(1,0);
INSERT INTO book_price(id,price) values(1,60);
配置Maven:
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.8.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.0.8.RELEASE</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.11</version>
</dependency>
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.4</version>
</dependency>
</dependencies>
编写两个接口:
业务层:
public interface BookShopService {
void purchase(String username,int id);
}
Dao层:
public interface BookShopDao {
//根据id获取书价
int findBookPriceById(int id);
//根据id更新书的库存
void updateBookStock(int id);
//根据用户名和消费的金额更新用户余额
void updateUserAccount(String name,int price);
}
实现类:
@Repository("bookShopDao")
public class BookShopDaoImpl implements BookShopDao {
@Autowired
private JdbcTemplate jdbcTemplate;
/*
因为不是映射一整行 所以不需要RowMapper
*/
@Override
public int findBookPriceById(int id) {
String sql = "SELECT price FROM book_price WHERE id=?";
return jdbcTemplate.queryForObject(sql,Integer.class,1);
}
@Override
public void updateBookStock(int id) {
//验证库存是否足够,因为mysql不会帮我们验证约束
String sqlStock = "SELECT stock FROM book_stock WHERE id =?";
int stock =jdbcTemplate.queryForObject(sqlStock,Integer.class,id);
if(stock ==0){
throw new BookStockException("库存不足");
}
String sql ="UPDATE book_stock SET stock = stock-1 WHERE id =?";
jdbcTemplate.update(sql,id);
}
@Override
public void updateUserAccount(String name, int price) {
//验证账户余额
String sqlAccount = "SELECT money FROM account WHERE name = ?";
int money =jdbcTemplate.queryForObject(sqlAccount,Integer.class,name);
if(money <price){
throw new UserAccountException("余额不足");
}
String sql = "UPDATE account SET money = money - ? WHERE name= ?";
jdbcTemplate.update(sql,price,name);
}
}
@Service("bookShopService")
public class BookShopServiceImpl implements BookShopService {
@Autowired
private BookShopDao bookShopDao;
@Transactional
@Override
public void purchase(String username, int id) {
//获取书单价
int price = bookShopDao.findBookPriceById(id);
//更新书的库存
bookShopDao.updateBookStock(id);
//更新用户余额
bookShopDao.updateUserAccount(username,price);
}
}
还有两个自定义的异常类:
图书存货不足
public class BookStockException extends RuntimeException{
public BookStockException() {
}
public BookStockException(String message) {
super(message);
}
public BookStockException(String message, Throwable cause) {
super(message, cause);
}
public BookStockException(Throwable cause) {
super(cause);
}
public BookStockException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
super(message, cause, enableSuppression, writableStackTrace);
}
}
用户余额不足:
public class UserAccountException extends RuntimeException {
public UserAccountException() {
}
public UserAccountException(String message) {
super(message);
}
public UserAccountException(String message, Throwable cause) {
super(message, cause);
}
public UserAccountException(Throwable cause) {
super(cause);
}
public UserAccountException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
super(message, cause, enableSuppression, writableStackTrace);
}
}
配置数据源:
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/mybatis?useAffectedRows=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&useSSL=false
jdbc.username=root
jdbc.password=123456
配置xml文件:
<!--配置book下的bean-->
<context:component-scan base-package="book"></context:component-scan>
<context:property-placeholder location="db.properties"></context:property-placeholder>
<bean id="datasource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="url" value="${jdbc.url}"></property>
<property name="driverClassName" value="${jdbc.driver}"></property>
<property name="username" value="${jdbc.username}"></property>
<property name="password" value="${jdbc.password}"></property>
</bean>
<!--配置jdbcTemplate-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" p:dataSource="#{datasource}"></bean>
<!--配置事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" p:dataSource="#{datasource}"></bean>
<!--启动事务注解-->
<tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
测试类:
public class Main {
private static ApplicationContext applicationContext = null;
public static void main(String[] args) throws SQLException {
applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
BookShopService bookShopService = (BookShopService)applicationContext.getBean("bookShopService");
bookShopService.purchase("小明",1);
}
}
总结:
实现通过注解将指定目录下的bean加入到ioc容器中 Bean注解都是放在实现类,但是从容器调用的时候使用的是接口类
<context:component-scan base-package="book"></context:component-scan>
如果Bean类属性中有对象的话 需要使用自动配置将其配置到Bean中,如:
@Autowired
private JdbcTemplate jdbcTemplate;
关于约束问题:
//验证库存是否足够,因为mysql不会帮我们验证约束,所以我们要自已来验证
String sqlStock = "SELECT stock FROM book_stock WHERE id =?";
int stock =jdbcTemplate.queryForObject(sqlStock,Integer.class,id);
if(stock ==0){
throw new BookStockException("库存不足");
}
事务流程:
1. 置事务管理器
2. 启动事务注解
3. 在需要加事务的方法前加注解:@Transactional