事务处理

417次阅读

共计 3824 个字符，预计需要花费 10 分钟才能阅读完成。

为了方便演示事务，我们需要创建一个 account 表：

CREATE TABLE account(id INT PRIMARY KEY AUTO_INCREMENT,
	NAME VARCHAR(30),
	balance NUMERIC(10.2)
);

INSERT INTO account(NAME,balance) VALUES('zs', 100000);
INSERT INTO account(NAME,balance) VALUES('ls', 100000);
INSERT INTO account(NAME,balance) VALUES('ww', 100000);

SELECT * FROM account;

银行转账！张三转 100 块到李四的账户，这其实需要两条 SQL 语句：

给张三的账户减去 100 元
给李四的账户加上 100 元

如果在第一条 SQL 语句执行成功后，在执行第二条 SQL 语句之前，程序被中断了（可能是抛出了某个异常，也可能是其他什么原因），那么李四的账户没有加上 100 元，而张三却减去了 100 元。这肯定是不行的！

你现在可能已经知道什么是事务了吧！== 事务中的多个操作，要么完全成功，要么完全失败！不可能存在成功一半的情况！== 也就是说给张三的账户减去 100 元如果成功了，那么给李四的账户加上 100 元的操作也必须是成功的；否则给张三减去 100 元，以及给李四加上 100 元都是失败的！

原子性（Atomicity）：事务中所有操作是不可再分割的原子单位。事务中所有操作要么全部执行成功，要么全部执行失败。

一致性（Consistency）：事务执行后，数据库状态与其它业务规则保持一致。如转账业务，无论事务执行成功与否，参与转账的两个账号余额之和应该是不变的。

隔离性（Isolation）：隔离性是指在并发操作中，不同事务之间应该隔离开来，使每个并发中的事务不会相互干扰。

持久性（Durability）：一旦事务提交成功，事务中所有的数据操作都必须被持久化到数据库中，即使提交事务后，数据库马上崩溃，在数据库重启时，也必须能保证通过某种机制恢复数据。

在默认情况下，MySQL 每执行一条 SQL 语句，都是一个单独的事务。如果需要在一个事务中包含多条 SQL 语句，那么需要开启事务和结束事务。

** 开启事务：**start transaction；

结束事务：commit或rollback。

在执行 SQL 语句之前，先执行 strat transaction，这就开启了一个事务（事务的起点），然后可以去执行多条 SQL 语句，最后要结束事务，commit 表示提交，即事务中的多条 SQL 语句所做出的影响会持久化到数据库中。或者 rollback，表示回滚，即回滚到事务的起点，之前做的所有操作都被撤消了！

下面演示 zs 给 li 转账 100 元的示例:

START TRANSACTION;
UPDATE account SET balance=balance-100 WHERE id=1;
UPDATE account SET balance=balance+100 WHERE id=2;
ROLLBACK ;

START TRANSACTION;
UPDATE account SET balance=balance-100 WHERE id=1;
UPDATE account SET balance=balance+100 WHERE id=2;
COMMIT ;

在 jdbc 中处理事务，都是通过 Connection 完成的！

同一事务中所有的操作，都在使用同一个 Connection 对象！

Connection 的三个方法与事务相关：

setAutoCommit(boolean)：设置是否为自动提交事务，如果 true（默认值就是 true）表示自动提交，也就是每条执行的 SQL 语句都是一个单独的事务，如果设置 false，那么就相当于开启了事务了；

con.setAutoCommit(false)表示开启事务！！！

commit()：提交结束事务；

con.commit(); 表示提交事务

rollback()：回滚结束事务。

con.rollback(); 表示回滚事务

jdbc 处理事务的代码格式：

try {

con.setAutoCommit(false);// 开启事务…

….

…

con.commit();//try 的最后提交事务

} catch() {

con.rollback();// 回滚事务

}

	public void transfer(boolean b) {Connection con = null;
		PreparedStatement pstmt = null;
		
		try {con = JdbcUtils.getConnection();
			// 手动提交
			con.setAutoCommit(false); 
			
			String sql = "update account set balance=balance+? where id=?";
			pstmt = con.prepareStatement(sql);
			
			// 操作
			pstmt.setDouble(1, -10000);
			pstmt.setInt(2, 1);
			pstmt.executeUpdate();
			
			// 在两个操作中抛出异常
			if(b) {throw new Exception();}
 			
			pstmt.setDouble(1, 10000);
			pstmt.setInt(2, 2);
			pstmt.executeUpdate();
			
			// 提交事务
			con.commit();} catch(Exception e) {// 回滚事务
			if(con != null) {try {con.rollback(); 
				} catch(SQLException ex) {}}
			throw new RuntimeException(e);
		} finally {// 关闭
			JdbcUtils.close(con, pstmt);
		}
	}