JDBC p3 事务-Toy模板网

这篇具有很好参考价值的文章主要介绍了JDBC p3 事务。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

事务

基本介绍
1. JDBC 程序中当一个Connection对象创建时，默认情况下是自动提交事务：每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。
2. JDBC程序中为了多个SQL语句作为一个整体执行，需要使用事务。
3. 调用 Connection 的 setAutoCommit(false) 可以取消自动提交事务（相当与开启了事务）。
4. 在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务。
5. 在其中某个操作失败或出现异常时，调用 rollback(); 方法回滚事务。

案例：模拟经典的转账的业务

MySQL代码：

CREATE TABLE account(
	id INT PRIMARY KEY AUTO_INCREMENT,
	name VARCHAR(32) NOT NULL DEFAULT '',
	balance DOUBLE NOT NULL DEFAULT 0
) CHARACTER SET utf8;

INSERT INTO account VALUES(NULL, '马云', 3000);
INSERT INTO account VALUES(NULL, '马化腾', 10000);

SELECT * FROM account;

Java代码：

package com.hspedu.jdbc.transaction_;

import com.hspedu.jdbc.utils.JDBCUtils;
import org.junit.jupiter.api.Test;

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

/**
 * Description: 演示在jdbc 中如何使用事务
 */
public class Transaction_ {

    //没有使用事务，模拟银行转账出现异常
    @Test
    public void noTransaction(){
        //1. 得到连接
        Connection connection = null; //默认情况下，connection 默认自动提交， 执行一句sql语句，就会提交事务

        //2. SQL语句
        String sql = "update account set balance = balance - 100 where id = ?";
        String sql2 = "update account set balance = balance + 100 where id = ?";

        PreparedStatement preparedStatement = null;

        //3. 创建PreparedStatement 对象
        try {

            connection = JDBCUtils.getConnection();

            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setInt(1, 1);
            preparedStatement.executeUpdate();

             int i = 1 / 0; //抛出异常接下来的语句就不会执行
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.setInt(1, 2);

            preparedStatement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            //关闭资源
            JDBCUtils.close(null, preparedStatement, connection);
        }
    }


    //使用事务
    @Test
    public void UseTransaction() {
        //1. 得到连接
        Connection connection = null; //默认情况下，connection 默认自动提交， 执行一句sql语句，就会提交事务

        //2. SQL语句
        String sql = "update account set balance = balance - 100 where id = ?";
        String sql2 = "update account set balance = balance + 100 where id = ?";

        PreparedStatement preparedStatement = null;

        //3. 创建PreparedStatement 对象
        try {

            connection = JDBCUtils.getConnection();
            connection.setAutoCommit(false);//相当与开启了事务

            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setInt(1, 1);
            preparedStatement.executeUpdate();

            int i = 1 / 0; //抛出异常接下来的语句就不会执行
            preparedStatement = connection.prepareStatement(sql2);
            preparedStatement.setInt(1, 2);
            preparedStatement.executeUpdate();

            //这里提交事务
            connection.commit();
        } catch (SQLException  | ArithmeticException  e) {
            System.out.println("执行发生了异常，撤销执行的SQL");
            e.printStackTrace();
            //可以在这里进行回顾，即撤销执行的sql语句
            try {
                connection.rollback();//默认回滚到事务开始的时候，可以填入回滚点savePoint
            } catch (SQLException ex) {
                throw new RuntimeException(ex);
            }
        } finally {
            //关闭资源
            JDBCUtils.close(null, preparedStatement, connection);
        }
    }
}

模拟1号向2号转账100元转账异常，调用noTransaction()方法，不使用事务，可以发现结果如下：

发生异常后，1号的存款转出了 100元，2号没有收到100元，100元没了。
如果调用的是useTransaction()方法，使用事务（connection.setAutoCommit(false) 取消事务自动提交）结果如下：

没有变化，控制台打印了 “执行发生了异常，撤销执行的SQL”，出现了异常后try-catch并进行了事务的回滚文章来源地址https://www.toymoban.com/news/detail-607716.html