JDBC p3 事务

事务

• 基本介绍
  
  
  
  • JDBC 程序中当一个Connection对象创建时，默认情况下是自动提交事务：每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。
    
  • JDBC程序中为了多个SQL语句作为一个整体执行，需要使用事务。
    
  • 调用 Connection 的 setAutoCommit(false) 可以取消自动提交事务（相当与开启了事务）。
    
  • 在所有的 SQL 语句都成功执行后，调用 commit(); 方法提交事务。
    
  • 在其中某个操作失败或出现异常时，调用 rollback(); 方法回滚事务。
    
  
  
• 案例：模拟经典的转账的业务
  MySQL代码：
  1. CREATE TABLE account(
  2.         id INT PRIMARY KEY AUTO_INCREMENT,
  3.         name VARCHAR(32) NOT NULL DEFAULT '',
  4.         balance DOUBLE NOT NULL DEFAULT 0
  5. ) CHARACTER SET utf8;
  7. INSERT INTO account VALUES(NULL, '马云', 3000);
  8. INSERT INTO account VALUES(NULL, '马化腾', 10000);
  10. SELECT * FROM account;

  复制代码
  Java代码：
  1. package com.hspedu.jdbc.transaction_;
  3. import com.hspedu.jdbc.utils.JDBCUtils;
  4. import org.junit.jupiter.api.Test;
  6. import java.sql.Connection;
  7. import java.sql.PreparedStatement;
  8. import java.sql.SQLException;
  10. /**
  11. * Description: 演示在jdbc 中如何使用事务
  12. */
  13. public class Transaction_ {
  15.     //没有使用事务，模拟银行转账出现异常
  16.     @Test
  17.     public void noTransaction(){
  18.         //1. 得到连接
  19.         Connection connection = null; //默认情况下，connection 默认自动提交， 执行一句sql语句，就会提交事务
  21.         //2. SQL语句
  22.         String sql = "update account set balance = balance - 100 where id = ?";
  23.         String sql2 = "update account set balance = balance + 100 where id = ?";
  25.         PreparedStatement preparedStatement = null;
  27.         //3. 创建PreparedStatement 对象
  28.         try {
  30.             connection = JDBCUtils.getConnection();
  32.             preparedStatement = connection.prepareStatement(sql);
  33.             preparedStatement.setInt(1, 1);
  34.             preparedStatement.executeUpdate();
  36.              int i = 1 / 0; //抛出异常接下来的语句就不会执行
  37.             preparedStatement = connection.prepareStatement(sql2);
  38.             preparedStatement.setInt(1, 2);
  40.             preparedStatement.executeUpdate();
  41.         } catch (SQLException e) {
  42.             e.printStackTrace();
  43.         }finally {
  44.             //关闭资源
  45.             JDBCUtils.close(null, preparedStatement, connection);
  46.         }
  47.     }
  50.     //使用事务
  51.     @Test
  52.     public void UseTransaction() {
  53.         //1. 得到连接
  54.         Connection connection = null; //默认情况下，connection 默认自动提交， 执行一句sql语句，就会提交事务
  56.         //2. SQL语句
  57.         String sql = "update account set balance = balance - 100 where id = ?";
  58.         String sql2 = "update account set balance = balance + 100 where id = ?";
  60.         PreparedStatement preparedStatement = null;
  62.         //3. 创建PreparedStatement 对象
  63.         try {
  65.             connection = JDBCUtils.getConnection();
  66.             connection.setAutoCommit(false);//相当与开启了事务
  68.             preparedStatement = connection.prepareStatement(sql);
  69.             preparedStatement.setInt(1, 1);
  70.             preparedStatement.executeUpdate();
  72.             int i = 1 / 0; //抛出异常接下来的语句就不会执行
  73.             preparedStatement = connection.prepareStatement(sql2);
  74.             preparedStatement.setInt(1, 2);
  75.             preparedStatement.executeUpdate();
  77.             //这里提交事务
  78.             connection.commit();
  79.         } catch (SQLException  | ArithmeticException  e) {
  80.             System.out.println("执行发生了异常，撤销执行的SQL");
  81.             e.printStackTrace();
  82.             //可以在这里进行回顾，即撤销执行的sql语句
  83.             try {
  84.                 connection.rollback();//默认回滚到事务开始的时候，可以填入回滚点savePoint
  85.             } catch (SQLException ex) {
  86.                 throw new RuntimeException(ex);
  87.             }
  88.         } finally {
  89.             //关闭资源
  90.             JDBCUtils.close(null, preparedStatement, connection);
  91.         }
  92.     }
  93. }

  复制代码
  
  
  • 模拟1号向2号转账100元转账异常，调用noTransaction()方法，不使用事务，可以发现结果如下：
    
    发生异常后，1号的存款转出了 100元，2号没有收到100元，100元没了。
    
  • 如果调用的是useTransaction()方法，使用事务（connection.setAutoCommit(false) 取消事务自动提交）结果如下：
    
    没有变化，控制台打印了 “执行发生了异常，撤销执行的SQL”，出现了异常后try-catch并进行了事务的回滚
    
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！