JDBC事务-白红宇

JDBC事务

阅读量：5292 次

发布时间：2019-06-14

本文共 5787 字，大约阅读时间需要 19 分钟。

一、什么是事务

　　指作为单个逻辑工作单元执行的一系列操作，要么完全地执行，要么完全地不执行。

　　一组sql语句（insert、update、delete），全部成功整体才算成功，一个失败整体也算失败。

　　特点：要么全成功，要么全失败。

　　举例：

　　　　转账 a给b转账100元，a 和 b的账户中都有1000元，转账完成后会是什么结果？

　　　　正常情况下：

　　　　　　　　　update t_account set money = money -100 where name='a';

　　　　　　　　　update t_account set money = money +100 where name='b';

　　　　　　　　结果： a=900; b=1100

　　　　异常情况下：

　　　　　　　　update t_account set money = money -100 where name='a';

　　　　　　　　　　发生异常；

　　　　　　　　update t_account set money = money +100 where name='b';

　　　　　　　　结果： a=900； b=1000

　　　　例子中异常情况是不能接受的，两个操作要么都成功要么都失败。

二、JDBC中的事务管理

　添加事务　

　　需求：a 向 b 转账 100元, 模拟异常。（强调事务的重要性：要么全执行，要么全撤销。）

@Test    public void demo2() {        // 需求：a 向 b 转账 100元。(添加事务)        Connection conn = null;        PreparedStatement stmt = null;        try {            // 获得连接            conn = JDBCUtils.getConnection();            // 开启事务 要放到获取连接之后            conn.setAutoCommit(false);            // 获得发送sql的对象            // a-100            String sql = "update account set money=money-100 where name='a'";            stmt = conn.prepareStatement(sql);            // 发送sql 获得结果            stmt.executeUpdate();            // 制造异常            int j = 1 / 0;            System.out.println(j);            // b+100            String sql2 = "update account set money=money+100 where name='b'";            stmt = conn.prepareStatement(sql2);            // 发送sql 获得结果            stmt.executeUpdate();            System.out.println("一切成功, 事务提交");            conn.commit();        } catch (Exception e) {            System.out.println("出现异常, 回滚事务");            try {                if (conn != null) {                    conn.rollback();                }            } catch (SQLException e1) {                e1.printStackTrace();            }            e.printStackTrace();        } finally {            // 释放资源            JDBCUtils.release(conn, stmt);        }    }

　　事务的回滚点

　　　　public interface Savepoint

　　　　保存点是可以从 Connection.rollback 方法引用的当前事务中的点。将事务回滚到保存点时，在该保存点之后所作的全部更改都将被撤消。　　

　　　　WHY：　　　

　　　　　　如果没有游戏的存档，每次玩单机游戏都会从第一关重新开始, 你愿意吗？

　　　　　　如果使用了游戏的存档，下次在玩游戏时，就会从存档处开始玩。

　　　　　　你是愿意从头开始，还是愿意从存档处开始继续玩。

　　　　举例：

　　　　　　向数据库中插入10000 条数据，每隔500条设置一个回滚点。9876 制造异常，数据库保存多少条记录

@Test    public void demo5() {        // 需求：向数据库中插入10000 条数据，(添加事务) 每隔500条设置一个回滚点,9876 制造异常，数据库保存多少条记录        Connection conn = null;        PreparedStatement stmt = null;        // 设置回滚点        Savepoint sp = null;        try {            // 获得连接            conn = JDBCUtils.getConnection();            // 开启事务            conn.setAutoCommit(false);            // 初始化回滚点            sp = conn.setSavepoint();            // 获得发送sql 的对象            String sql = "insert into emp(id,name,age) values(null, ?, ?)";            stmt = conn.prepareStatement(sql);            // 插入10000 条            for (int i = 1; i <= 10000; i++) {                // 设置参数                stmt.setString(1, "name" + i);                stmt.setInt(2, i % 30 + 1);                // 发送sql                stmt.executeUpdate();                // 每隔500条设置一个回滚点                if (i % 500 == 0) {                    sp = conn.setSavepoint();                }                // 9876 制造异常                if (i == 9876) {                    int j = 1 / 0;                    System.out.println(j);                }            }            System.out.println("一切成功 提交事务");            conn.commit();        } catch (Exception e) {            System.out.println("出现异常 回滚事务");            try {                if (conn != null) {                    // 作用: 撤销回滚点之后的语句操作, 并没有把 回滚点以前的提交                    conn.rollback(sp);                    // 提交回滚点以前的操作                    conn.commit();                }            } catch (SQLException e1) {                e1.printStackTrace();            }            e.printStackTrace();        } finally {            JDBCUtils.release(conn, stmt);        }    }