事务概念

柔情只为你懂 2022-10-02 04:44 123阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

@Test
        public void testSaveMoney(){
            Connection conn =null;
            PreparedStatement pstmt = null;
             
            String accountId="123456789";
            double money  =100;
            ResultSet rs = null;
            String sql = "Insert into inaccount (accountid,inbalance) values(?,?)";
            try {
                conn = DBUtil.getCon();
                pstmt = conn.prepareStatement(sql);
                pstmt.setString(1, accountId);
                pstmt.setDouble(2, money);
                pstmt.executeUpdate();
                 
                sql = "update account set balance=balance+? where accountid=?";
                pstmt = conn.prepareStatement(sql);
                pstmt.setDouble(1, money);
                pstmt.setString(2, accountId);
                boolean flag = true;
                if(flag){
                    throw new SQLException("因网络或不明原因出异常！");
                }
                pstmt.executeUpdate();
                 
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally{
                DBUtil.close(conn, pstmt, rs);
            }
             
        }

如果不使用事务操作，对于一个银行业务来说是致命的，上面的这个示例，造成的结果就是一个inaccount表中会插入一条数据，而account表中没有任何改变。

事务的类型：

1.  自动提交：执行update马上保存数据  
    
2.  手动提交：执行update不保存数据，先放入缓存，只有执行Commit，才保存

设置事务：

@Test
        public void testSaveMoney(){
            Connection conn =null;
            PreparedStatement pstmt = null;
             
            String accountId="123456789";
            double money  =100;
            ResultSet rs = null;
            String sql = "Insert into inaccount (accountid,inbalance) values(?,?)";
            try {
                conn = DBUtil.getCon();
                conn.setAutoCommit(false);
                pstmt = conn.prepareStatement(sql);
                pstmt.setString(1, accountId);
                pstmt.setDouble(2, money);
                pstmt.executeUpdate();
                 
                sql = "update account set balance=balance+? where accountid=?";
                pstmt = conn.prepareStatement(sql);
                pstmt.setDouble(1, money);
                pstmt.setString(2, accountId);
                boolean flag = true;
                if(flag){
                    throw new SQLException("因网络或不明原因出异常！");
                }
                pstmt.executeUpdate();
                //提交事务
                conn.commit();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                //回滚事务,回滚到conn.setAutoCommit(false);
                try {
                    conn.rollback();
                } catch (SQLException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }
                e.printStackTrace();
            }finally{
                DBUtil.close(conn, pstmt, rs);
            }
             
        }

在事务没有提交之前，数据时先放到缓存中的，但是事务提交时会将数据保存到表中并清空缓存，rollback的原理也是清空缓存这样就不会出现上面的问题

转载于:https://my.oschina.net/duanvincent/blog/394154

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/77ea12d03a824ce6bb075e3c507c0b76.png