jdbc事务：模拟银行转账业务

小咪咪 2022-03-28 05:57 430阅读 0赞

事务  
1.事务简介  
事务（Transaction）：数据库中保证数据操作可靠的机制。常运用于交易业务。JDBC支持数据库中的事务概念，并且在JDBC中，事务默认是自动提交的。

这样就可能存在问题：某些业务逻辑必须在一个事务中完成。  
假设支付宝A账号上有3000元，需要转账1000元给另一个支付宝B账号，  
正确的流程是

事务必须遵循的特性介绍：ACID  
原子性（Atomicity）：事务必须是原子工作单元；对于同一个事务中的数据修改，要么全都执行，要么全都不执行  
一致性（Consistency）：事务在完成时，必须使所有的数据都保持一致状态。如数据库原来有什么样的约束，事务执行之后还需要存在这样的约束  
隔离性（Isolation）：由并发事务所作的修改必须与任何其它并发事务所作的修改隔离  
持久性（Durability）：事务完成之后，它对于系统的影响是永久性的 （持久保存到数据库文件）

事务是数据库的概念，JDBC支持事务，本质还是在数据库中实现的

2.JDBC事务API  
JDBC中和事务相关API：  
Connection.getAutoCommit() :获得当前事务的提交方式，默认为true  
Connection.setAutoCommit():设置事务的提交属性，参数是true：自动提交；false：不自动提交  
Connection.commit():提交事务  
Connection.rollback():回滚事务

3.JDBC事务编程  
JDBC处理事务的通常模式：  
1).先将事务的自动提交关闭；  
2).执行事务中的若干SQL语句；  
3).事务提交或SQL失败则回滚；  
4).恢复JDBC的事务提交状态或释放资源。

核心代码：  
try\{  
// 1.定义用于在事务中执行的SQL语句  
String sql1 = “update account set amount = amount - " + amount + " where id = '” + from+ “’”;  
String sql2 = “update account set amount = amount + " + amount + " where id = '” + to+ “’”;  
boolean autoCommit = con.getAutoCommit(); // 2.获得自动提交状态  
con.setAutoCommit(false); // 3.关闭自动提交  
stmt.executeUpdate(sql1); // 4.执行SQL语句  
stmt.executeUpdate(sql2);  
con.commit(); // 5.提交  
con.setAutoCommit(autoCommit); // 6.将自动提交功能恢复到原来的状态  
//其他语句  
\}catch(SQLException e)\{  
conn.rollback();//异常时回滚  
\}

案例：  
使用JDBC连接数据库，实现账号转账业务。从A账户转账给B账户1000元钱

方案：可以使用事务将两次更新操作封装成一个逻辑单元，要么都执行，要么都不执行，保证了数据的完整性

步骤：  
步骤一  
创建Account表，并插入测试数据。在Oracle数据库中，创建表并插入测试数据，SQL语句如下所示：  
create table account (  
id char(1),  
amount number(10)  
);  
insert into account values(‘A’, 3000);  
insert into account values(‘B’, 1000);  
commit;–注意要提交  
步骤二：  
新建JDBCDemo3工程，并导入JDBC及连接池相关Jar包  
步骤三：  
准备连接池工具类DbUtil\_Pool  
步骤四：  
准备JDBC操作数据库基本代码，创建 Transfer 类，并创建tran(String from,String to,int amount) 转账方法:  
步骤五:实现转账功能  
使用Connection的setAutoCommit方法、commit方法以及rollback方法来控制事务，以确保转账功能正确实现，代  
步骤六：  
测试转账功能

然后查看Oracle数据库中的account表，会发现A账户的金额减少了1000元，B账户的金额增加了1000元

完整代码  
package cn.lyc.dao;

import java.sql.Connection;  
import java.sql.PreparedStatement;  
import java.sql.SQLException;

import cn.lyc.util.DBUtils;

/\*\*

*  模拟银行转账业务
 *  @author JLB
 *

\*/  
public class TranDao \{

/**
     * 不加事务，在数据库中A用户的金额减了100，中间出异常，那么B用户却没有加100（不加事务的隐患）
     * @param money  加减的金额
     * @param username 转账用户
     * @param username2 收款用户
     * @return  返回的结果
     */
    public boolean tranAccount(int money, String username,String username2){
    	boolean flag = false;
    	
    	Connection conn = null;
    	PreparedStatement ps = null;
    	String fromSql = "update account_1 set money = money-? where username=?";
    	String fromTo = "update account_1 set money = money+? where username=?";
    	conn = DBUtils.getConnection();
    	try {
    		ps = conn.prepareStatement(fromSql);
    		ps.setDouble(1, money);
    		ps.setString(2, username);
    		int result1 = ps.executeUpdate();
    		
    		String str = null;
    		str.length();//模拟异常
    		
    		ps = conn.prepareStatement(fromTo);
    		ps.setDouble(1, money);
    		ps.setString(2, username2);
    		int result2 = ps.executeUpdate();
    		if(result1!=0 && result2!=0){
    			flag = false;
    		}
    	} catch (SQLException e) {
    		e.printStackTrace();
    	}
    	
    	return flag;
    }
    
    
    /**
     * 加事务，中间出异常，数据库中A用户的金额没有减了100，B用户也没有加100（加事务的安全性）
     * @param money
     * @param username
     * @param username2
     * @return
     */
    public boolean tranAccount2(int money, String username,String username2){
    	boolean flag = false;
    	
    	Connection conn = null;
    	PreparedStatement ps = null;
    	String fromSql = "update account_1 set money = money-? where username=?";
    	String fromTo = "update account_1 set money = money+? where username=?";
    	conn = DBUtils.getConnection();
    	
    	try {
    		conn.setAutoCommit(false);
    		ps = conn.prepareStatement(fromSql);
    		ps.setDouble(1, money);
    		ps.setString(2, username);
    		int result1 = ps.executeUpdate();
    		
    		String str = null;
    		str.length();//模拟异常
    		
    		ps = conn.prepareStatement(fromTo);
    		ps.setDouble(1, money);
    		ps.setString(2, username2);
    		int result2 = ps.executeUpdate();
    		if(result1!=0 && result2!=0){
    			flag = false;
    			conn.commit();//正确完成的操作，提交事务
    		}
    	} catch (Exception e) {
    		try {
    			conn.rollback();//转账出错，就让事务回滚
    		} catch (SQLException e1) {
    			e1.printStackTrace();
    		}
    		e.printStackTrace();
    	}
    	
    	return flag;
    }
    public static void main(String[] args) {
    	TranDao dao = new TranDao();
    	dao.tranAccount2(100, "A","B");
    }