JDBC管理事务

1.事务

一个包含多个步骤的业务操作。如果这个业务操作，被事务管理，则这多个步骤要么同时成功，要么同时失败。

要么都成功，要么都失败
ACID原则
原子性：要么都完成，要么都不完成
一致性：结果总数不变
隔离性：多个进程互不干扰
持久性：一旦提交不可逆，持久化到数据库

隔离性的问题：
脏读：一个事务读取了另一个没有提交的事务
不可重复读：在同一个事务内，重复读取表中的数据，表数据发生了改变
虚读(幻读)：在一个事务内，读取到了别人插入的数据，导致前后读出来的结果不一致

2.操作

开启事务

提交事务

回滚事务

3.使用Connection对象来管理事务

• 开启事务：void setAutoCommit(boolean autoCommit)   调用该方法设置参数为false，即开启事务

　　　　在执行SQL之前开启事务

• 提交事务：void commit()  

　　　　当所有SQL都执行完提交事务

• 回滚事务：void rollback()

　　　　在catch中回滚事务

代码实现：
（1）开启事务conn.setAutoCommit(false);
（2）一组业务执行完毕，提交事务
（3）可以在catch语句汇总显示定义回滚，但默认失败就会回滚，不定义也会回滚

package cn.company.jdbc;

import cn.company.jdbc.utils.JdbcUtils;

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

public class TestTransaction {
    public static void main(String[] args) throws SQLException {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;

        try {
            conn = JdbcUtils.getConnection();
            // 关闭数据库的自动提交，自动会开启事务
            conn.setAutoCommit(false); // 开启事务
            String sql1 = "update account set money = money - 100 where name='A'";
            st = conn.prepareStatement(sql1);
            st.executeUpdate();

            int x = 1/0;  // 报错

            String sql2 = "update account set money = money + 100 where name='B'";
            st = conn.prepareStatement(sql2);
            st.executeUpdate();

            // 业务完毕，提交事务
            conn.commit();
            System.out.println("成功！");
        } catch (Exception e) {
            try {
                if (conn != null) {
                    System.out.println("回滚！");
                    conn.rollback(); // 如果失败则回滚事务
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            JdbcUtils.releaseConnection(conn,st,rs);
        }

    }
}

　　

 创建一个表db1

CREATE DATABASE db1 CHARACTER SET utf8 COLLATE utf8_general_ci;

USE db1;

CREATE TABLE `account` (
  `id` INT NOT NULL,
  `name` VARCHAR(40) NOT NULL,
  `balance` INT(40) NOT NULL,
  PRIMARY KEY(`id`)
) ENGINE=INNODB DEFAULT CHARSET=utf8;

INSERT INTO account
VALUES(1,'A','2000'),
(2,'B','2000');

ALTER TABLE `account` change `balance` `money` INT(40) NOT NULL;

　

当出现错误，就会回滚，两个操作都不会去执行

没有报错，就会去执行，两个操作都会去执行