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;

 

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

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

原文地址:https://www.cnblogs.com/GumpYan/p/14074969.html