数据库事务超全干货

╰+哭是因爲堅強的太久メ 2022-11-30 12:54 171阅读 0赞

**小伙伴们,在说干货之前,为了更通俗易懂,先来点小菜,岂不是更美滋滋吗~~~嚯嚯**

## **业务讲解：转账案例(小菜)** ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzA1MTMx_size_16_color_FFFFFF_t_70][]

①小明付钱：  update account set money=money-1000 where name=’xiaoming’;

②小红收钱：  update account set money=money+1000 where name=’xiaohong’;

### 流程图: ###

![20200824181723536.png][]

### 代码实现: ###

AccountTest:

public class AccountTest {
        private AccountService service = new AccountService();
        @Test
        public void run1(){
            //1、准备数据
            String userIn = "xiaohong";//收款人
            String userOut = "xiaoming";//付款人
            double money = 1000.0;//转账金额
            //2、调用service开始转账
            boolean flag = service.account(userIn,userOut,money);
            //3、根据service的结果，判断转账成功/失败
            if(flag){
                System.out.println("转账成功");
            }else{
                System.out.println("转账失败");
            }
        }
    }

AccountService

public class AccountService {
        private AccountDao dao = new AccountDao();
        /**
         * 转账功能
         * @param userIn
         * @param userOut
         * @param money
         * @return
         */
        public boolean account(String userIn, String userOut, double money) {
            try {
                //1、付款人 付款
                dao.userOut(userOut,money);
                //2、收款人 收款
                dao.userIn(userIn,money);
            } catch (Exception e) {
                //出了异常，转账失败
                return false;
            }
            //没出异常，转账成功
            return true;
        }
    }

AccountDao

/**
     * 付款人 付款
     * @param userOut
     * @param money
     */
    public void userOut(String userOut, double money) throws SQLException {
        //1、获取连接
        Connection con = JDBCUtils.getConnection();
        //2、获取发送SQL语句对象
        PreparedStatement ps = con.prepareStatement("update account set money=money-? where name=?");
        ps.setDouble(1,money);
        ps.setString(2,userOut);
        //3、发送SQL语句
        ps.executeUpdate();
        //4、关闭资源
        JDBCUtils.closeAll(con,ps,null);
    }
    
    /**
     * 收款人 收款
     * @param userIn
     * @param money
     */
    public void userIn(String userIn, double money) throws SQLException {
        //1、获取连接
        Connection con = JDBCUtils.getConnection();
        //2、获取发送SQL语句对象
        PreparedStatement ps = con.prepareStatement("update account set money=money+? where name=?");
        ps.setDouble(1,money);
        ps.setString(2,userIn);
        //3、发送SQL语句
        ps.executeUpdate();
        //4、关闭资源
        JDBCUtils.closeAll(con,ps,null);
    }

*  如果付款成功，收款失败，转账失败，会导致付款的钱无法还原而丢失。

> 解决：
> 
> 转账失败，所有的操作还原。
> 
> 转换成功，所有的操作永久保存数据库。

# 一.**数据库事务** #

## **1.简述** ##

> 概念：事务指的是逻辑上的一组操作,组成这组操作的各个单元要么全都成功,要么全都失败.

*  事务：数据的回收站
 *  作用：保证数据完整，保证数据的安全

## **2.MySQL事务操作** ##

MySQL有两种事务操作，

>  *  手动事务
>  *  自动事务（默认开启）

手动事务：

*  手动事务：先手动开启事务，再手动提交 或者手动回滚事务。

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="width:215.05pt;"> sql语句 </td> 
 <td style="width:211.05pt;"> 描述 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:215.05pt;"> start transaction; </td> 
 <td style="vertical-align:top;width:211.05pt;"> 开启事务 &nbsp; 开启了一次数据回收站功能。 &nbsp; 在当前事务中进行的任何数据的增删改都可以被永久保存/还原。 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:215.05pt;"> commit; </td> 
 <td style="vertical-align:top;width:211.05pt;"> 提交事务 &nbsp; 把当前事务中操作过的数据，永久保存。 关闭当前的手动事务 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:215.05pt;"> rollback; </td> 
 <td style="vertical-align:top;width:211.05pt;"> 回滚事务 &nbsp; 还原事务中操作过的数据。 关闭当前的手动事务 </td> 
 </tr> 
 </tbody> 
</table>

例如:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzA1MTMx_size_16_color_FFFFFF_t_70 1][]

> 手动事务的注意事项：
> 
> **1****、commit或rollback之后，若需要再次使用事务，必须再次开启事务。**
> 
> 2、**事务仅针对D****M****L（增删改）和DQL（查）语句**。
> 
>    **若遇到其他语句（例如：DDL语句），事务会强制提交并关闭**

*  自动事务：执行任何DML语句时，MySQL自动开启事务，并自动提交事务

注：自动事务无法回滚，只能提交

![20200824193641906.png][]

> 优点：提升程序员代码测试效率
> 
> 缺陷：一句一个事务，效率不高，无法自定义事务

> 自动事务关闭：
> 
> 临时关闭：
> 
> 手动开启事务：start transcation;
> 
> 本次永久关闭：
> 
> *set autocommit = 0;* *   \#**0:OFF  1:ON*

## 3.**JDBC事务操作** ##

> JDBC事务的两大前提：
> 
> 1、因为转账业务相当于转账事务，所以**事务控制代码需要加在****service****业务层**
> 
> 2、**一个事务中的所有的SQL语句，必须使用****同一个Connection对象**，这样才能保证正常的事务控制

Connection

<table style="width:453.2pt;"> 
 <tbody> 
 <tr> 
 <td style="width:219.55pt;"> 方法名 </td> 
 <td style="width:233.65pt;"> 描述 </td> 
 </tr> 
 <tr> 
 <td style="vertical-align:top;width:219.55pt;"> setAutoCommit(boolean flag) </td> 
 <td style="vertical-align:top;width:233.65pt;"> 设置事务是否为自动事务。 参数：true（默认）自动事务 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;false 手动事务，开启一次手动事务 &nbsp; setAutoCommit(false); 会通知JDBC发送start transaction;给MySQL执行 &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="width:219.55pt;"> commit(); </td> 
 <td style="width:233.65pt;"> 提交事务 &nbsp; 会通知JDBC发送commit;给MySQL执行 </td> 
 </tr> 
 <tr> 
 <td style="width:219.55pt;"> rollback(); </td> 
 <td style="width:233.65pt;"> 回滚事务 &nbsp; 会通知JDBC发送rollback;给MySQL执行 </td> 
 </tr> 
 </tbody> 
</table>

修改代码：

AccountService：

public boolean account(String userIn, String userOut, double money) {
        Connection con = null;
        try {
            //因为事务是在service层，一个事务下的所有操作应该在一个Connection对象中
            con = JDBCUtils.getConnection();
            //设置手动事务
            con.setAutoCommit(false);
            //1、付款人 付款
            dao.userOut(con, userOut, money);
            int a = 1 / 0;
            //2、收款人 收款
            dao.userIn(con, userIn, money);
            //没出异常，提交
            con.commit();
        } catch (Exception e) {
            //出了异常，转账失败
            try {
                if(con!=null)
                    con.rollback();
            } catch (SQLException e1) {
            }
            return false;
        } finally {
            //无论如何都要关闭连接
            try {
                JDBCUtils.closeAll(con,null,null);
            } catch (SQLException e) {
            }
        }
        //没出异常，转账成功
        return true;
    }

AccountDao：

<table style="width:492.65pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:492.65pt;"> /** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 付款人 付款 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param con &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param userOut &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param money &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;public void userOut(Connection con,&nbsp;String userOut, double money) throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1、获取连接 // &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Connection con = JDBCUtils.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2、获取发送SQL语句对象 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;PreparedStatement ps = con.prepareStatement("update account set money=money-? where name=?"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ps.setDouble(1,money); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ps.setString(2,userOut); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//3、发送SQL语句 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ps.executeUpdate(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//4、关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;JDBCUtils.closeAll(null,ps,null); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;/** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 收款人 收款 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param con &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param userIn &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* @param money &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;public void userIn(Connection con, String userIn, double money) throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//1、获取连接 // &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Connection con = JDBCUtils.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//2、获取发送SQL语句对象 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;PreparedStatement ps = con.prepareStatement("update account set money=money+? where name=?"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ps.setDouble(1,money); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ps.setString(2,userIn); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//3、发送SQL语句 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ps.executeUpdate(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//4、关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;JDBCUtils.closeAll(null,ps,null); &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

小结：

> 事务代码加在service层
> 
> 同一个事务下所有的sql语句，用的是同一个Connection对象

看完恭喜你,又知道了一点点!!!

**你知道的越多,不知道的越多! **

**~感谢志同道合的你阅读,  你的支持是我学习的最大动力 ! 加油 ,陌生人一起努力,共勉!!**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzA1MTMx_size_16_color_FFFFFF_t_70]: /images/20221123/721b09b5fdbc45209725f13f91eac188.png
[20200824181723536.png]: /images/20221123/a7de642cd350402c9c68567ac8942212.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzA1MTMx_size_16_color_FFFFFF_t_70 1]: /images/20221123/22d245c33fef4df8b4a067a6c5e7236a.png
[20200824193641906.png]: /images/20221123/d463a3fcde3e47ca8d0f1ba3a6d0980e.png