JDBC：控制事务

野性酷女 2024-03-22 15:01 25阅读 0赞

### 控制事务 ###

#### 依赖 ####

<dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
         <version>5.1.37</version>
     </dependency>

#### jdbc.properties ####

url=jdbc:mysql:///db
    user=root
    password=root
    driver=com.mysql.jdbc.Driver

#### 工具类 ####

import java.io.FileReader;
    import java.io.IOException;
    import java.net.URL;
    import java.sql.*;
    import java.util.Properties;
    
    /**
     * JDBC工具类
     */
    public class JDBCUtils {
        
        private static String url;
        private static String user;
        private static String password;
        private static String driver;
        /**
         * 文件的读取，只需要读取一次即可拿到这些值。使用静态代码块
         */
        static{
        
            //读取资源文件，获取值。
    
            try {
        
                //1. 创建Properties集合类。
                Properties pro = new Properties();
    
                //获取src路径下的文件的方式--->ClassLoader 类加载器
                ClassLoader classLoader = JDBCUtils.class.getClassLoader();
                URL res  = classLoader.getResource("jdbc.properties");
                String path = res.getPath();
                //2. 加载文件
                pro.load(new FileReader(path));
    
                //3. 获取数据，赋值
                url = pro.getProperty("url");
                user = pro.getProperty("user");
                password = pro.getProperty("password");
                driver = pro.getProperty("driver");
                //4. 注册驱动
                Class.forName(driver);
            } catch (IOException e) {
        
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
        
                e.printStackTrace();
            }
        }
    
    
        /**
         * 获取连接
         * @return 连接对象
         */
        public static Connection getConnection() throws SQLException {
        
    
            return DriverManager.getConnection(url, user, password);
        }
    
        /**
         * 释放资源
         * @param stmt
         * @param conn
         */
        public static void close(Statement stmt,Connection conn){
        
            if( stmt != null){
        
                try {
        
                    stmt.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
    
            if( conn != null){
        
                try {
        
                    conn.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
        }
    
    
        /**
         * 释放资源
         * @param stmt
         * @param conn
         */
        public static void close(ResultSet rs,Statement stmt, Connection conn){
        
            if( rs != null){
        
                try {
        
                    rs.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
    
            if( stmt != null){
        
                try {
        
                    stmt.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
    
            if( conn != null){
        
                try {
        
                    conn.close();
                } catch (SQLException e) {
        
                    e.printStackTrace();
                }
            }
        }
    
    }

#### 说明 ####

1. 事务：一个包含多个步骤的业务操作。如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败。
    2. 操作：
    	1. 开启事务
    	2. 提交事务
    	3. 回滚事务
    3. 使用Connection对象来管理事务
    	* 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
    		* 在执行sql之前开启事务
    	* 提交事务：commit() 
    		* 当所有sql都执行完提交事务
    	* 回滚事务：rollback() 
    		* 在catch中回滚事务

#### 代码 ####

import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    /**
     * 事务操作
     */
    public class JDBCDemo {
        
    
        public static void main(String[] args) {
        
            Connection conn = null;
            PreparedStatement pstmt1 = null;
            PreparedStatement pstmt2 = null;
    
            try {
        
                //1.获取连接
                conn = JDBCUtils.getConnection();
                //开启事务
                conn.setAutoCommit(false);
    
                //2.定义sql
                //2.1 张三 - 500
                String sql1 = "update account set balance = balance - ? where id = ?";
                //2.2 李四 + 500
                String sql2 = "update account set balance = balance + ? where id = ?";
                //3.获取执行sql对象
                pstmt1 = conn.prepareStatement(sql1);
                pstmt2 = conn.prepareStatement(sql2);
                //4. 设置参数
                pstmt1.setDouble(1,500);
                pstmt1.setInt(2,1);
    
                pstmt2.setDouble(1,500);
                pstmt2.setInt(2,2);
                //5.执行sql
                pstmt1.executeUpdate();
                // 手动制造异常
                int i = 3/0;
    
                pstmt2.executeUpdate();
                //提交事务
                conn.commit();
            } catch (Exception e) {
        
                //事务回滚
                try {
        
                    if(conn != null) {
        
                        conn.rollback();
                    }
                } catch (SQLException e1) {
        
                    e1.printStackTrace();
                }
                e.printStackTrace();
            }finally {
        
                JDBCUtils.close(pstmt1,conn);
                JDBCUtils.close(pstmt2,null);
            }
        }
    }