JDBC处理事务

雨点打透心脏的1/2处 2022-08-22 06:15 194阅读 0赞

事务是为了保证数据库安全性而设计的，一般的jdbc都是将事务设置成自动提交的，可以手动设置成不自动提交。

**1 设定不自动提交**

假设存在表user

<table> 
 <thead> 
  <tr> 
   <th>id</th> 
   <th>money</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>1</td> 
   <td>100</td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td>310</td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td>200</td> 
  </tr> 
 </tbody> 
</table>

现在想如果id=2的money<300 ,则将id=1的money-10，同时将id=2的money+10；将其作为一个事务，同时做成功，或同时不成功。

需要的操作即

*  关闭自动提交
 *  手动提交
 *  处理异常，回滚

package cn.itcast.jdbc;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class TxTest { 
    
        public static void main(String[]args) throws SQLException{
            test();
        }
    
        static void test() throws SQLException {
            Connection conn = null;
            Statement st = null;
            ResultSet rs = null;
    
            try {
                conn = JdbcUtils.getConnection();
                conn.setAutoCommit(false);      //关闭自动提交
    
                st = conn.createStatement();
                String sql="update user set money =money-10 where id=1";
                st.executeUpdate(sql);
    
                sql="select money from user where id=2";
                rs=st.executeQuery(sql);
                float money=0.0f;
                if(rs.next())
                    money=rs.getFloat(1);
                if(money>300)
                    throw new RuntimeException("超过最大值");
    
                sql="update user set money =money+10 where id=2";
                st.executeUpdate(sql);
    
                conn.commit();      //提交
            } catch(SQLException e){
                if(conn!=null)
                    conn.rollback();        //出现异常，回滚
                throw e;
            }finally {
                JdbcUtils.free(rs, st, conn);
            }
        }
    }

当id=2的money>300时抛出异常，回滚事务，整个事务都取消，money不变。

**2 设置事务保存点savePoint**

再上一个例子中，事务如果发生回滚，会将整个事务全部撤销，如果不想全部撤销，而是只撤销其中的一部分，可以使用保存点(Savepoint)

package cn.itcast.jdbc;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Savepoint;
    import java.sql.Statement;
    
    public class SavePointTest { 
    
        public static void main(String[] args) throws SQLException {
            test();
        }
    
        static void test() throws SQLException {
            Connection conn = null;
            Statement st = null;
            ResultSet rs = null;
            Savepoint sp = null;
    
            try {
                conn = JdbcUtils.getConnection();
                conn.setAutoCommit(false); // 关闭自动提交
    
                st = conn.createStatement();
                String sql = "update user set money =money-10 where id=1";
                st.executeUpdate(sql);
    
                sql = "update user set money =money-10 where id=3";
                st.executeUpdate(sql);
    
                // 设置保存点
                sp = conn.setSavepoint(); 
    
                sql = "select money from user where id=2";
                rs = st.executeQuery(sql);
                float money = 0.0f;
                if (rs.next())
                    money = rs.getFloat(1);
                if (money > 300)
                    throw new RuntimeException("超过最大值");
    
                sql = "update user set money =money+10 where id=2";
                st.executeUpdate(sql);
    
                // 提交
                conn.commit(); 
            } catch (RuntimeException e) {
                if (conn != null && sp != null) {
                    // 出现异常，回滚到sp
                    conn.rollback(sp); 
                    conn.commit();
                }
                throw e;
            } catch (SQLException e) {
                if (conn != null)
                    // 出现异常，回滚
                    conn.rollback();
                throw e;
            } finally {
                JdbcUtils.free(rs, st, conn);
            }
        }
    }

在这个例子中如果发生了异常，那么id=1和id=3的操作不会被撤销，事务只回滚到Savepoint的位置。