MySQL事务和JDBC中的事务操作

news2025/5/11 20:48:52

一、什么是事务

事务是数据库操作的最小逻辑单元，具有"全有或全无"的特性。以银行转账为例：

典型场景：

从A账户扣除1000元
向B账户增加1000元
这两个操作必须作为一个整体执行，要么全部成功，要么全部失败

MySQL的事务特性：

默认自动提交模式（每条SQL作为独立事务）
通过START TRANSACTION显式开启事务
使用COMMIT提交或ROLLBACK回滚

二、使用事务

MySql数据库中使用事务，提供了两种方式（重点）

1、使用命令的方式

-- 开启事务
START TRANSACTION;
update t_account set money=money-1000 where username='冠希';
update t_account set money=money+1000 where username='美美';
-- 提供事务（事务已经结束了，数据永久的保存到数据库中了）
COMMIT;
-- 回滚事务（事务已经结束了，数据回滚到最初始化的状态）
ROLLBACK;

2、使用不默认提交的方式

show VARIABLES like '%commit%';-- 查看事务是否默认提交
set autocommit =off;-- 设置不默认提交
update t_account set money=money-1000 where username='冠希';
update t_account set money=money+1000 where username='美美';
COMMIT;-- 或者rollback

当会话结束此次关闭不默认提交的的事务就结束，新的会话还是默认提交事务。

3、JDBC中操作事务

JDBC事务验证实例：

package com.qcby.dao;

import com.qcby.utils.JdbcUtils2;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

public class JdbcUpdate {
    public static void main(String[] args) {
        Connection connection =null;
        Statement statement=null;
        //增删改不需要结果集
        //ResultSet resultSet=null;
        try {
            //jdbc连接数据库
            //1.加载驱动
            //2.获取连接（URL 用户名  密码）
            connection = JdbcUtils2.getConnection();
            //开启事务（关闭自动提交）
            connection.setAutoCommit(false);
            //3.编写sql
            String sql1="UPDATE account SET money = money + 1000 WHERE name = 'ccc'";
            String sql2="UPDATE account SET money = money - 1000 WHERE name = 'bbb'";
            //4.获取执行sql的stmt的对象
            statement = connection.createStatement();
            //返回的结果条数
            int i=statement.executeUpdate(sql1);
            //int m=10/0;
            int i2=statement.executeUpdate(sql2);
            //注意提交事务
            connection.commit();
            System.out.println("转账成功！");
        } catch (SQLException e) {
            //回滚事务（如果发生异常）
            try {
                if (connection != null) {
                    connection.rollback();
                    System.out.println("转账失败，已回滚！");
                }
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        }finally {
            //7.关闭资源（先开的后关 后开的先关）
            JdbcUtils2.close(connection, statement);
        }
    }
}

事务的特性：