当前位置: 首页 > news >正文

事务--实操演示

目录

一、准备工作

二、在MySQL中操作事务(重点)

第一种方式:使用命令的方式

第二种方式:设置MySQL事务不默认提交的方式

三、在JDBC中操作事务(掌握)

第一种方式:使用命令的方式

第二种方式:设置MySQL事务不默认提交的方式


在这篇Mybatis---事务_mybits事务-CSDN博客 中有事务相关理论知识,在此实操演示一遍事务操作。

仍旧是以经典例子转账做演示:

一、准备工作

【win】+【R】 输入cmd;

 进到终端后输入【mysql -u root -p】然后输入密码;后续操作在这里展开演示。

输入【user】+【想要切换的数据库】 

 

输入【show tables】查看所有表

 

可以看见我这个数据库中有这么多表。

二、在MySQL中操作事务(重点)

 完成上述的准备工作后,  接下来就可以正常操作sql语句了:
e.g 先展示一下我们要演示操作的表吧!

我们将利用这个表模拟一个转账操作,其中张三给李四转1000元。下面是两种使用事务的方法的具体操作流程: 

第一种方式:使用命令的方式

开启事务

START TRANSACTION;

执行转账操作

  • 从张三账户扣除1000元

    UPDATE account SET money = money - 1000 WHERE name = '张三';
  • 给李四账户增加1000元

    UPDATE account SET money = money + 1000 WHERE name = '李四';

提交事务

  • 如果转账操作成功,提交事务

    COMMIT;
  • 如果转账操作失败,回滚事务

    ROLLBACK;
第二种方式:设置MySQL事务不默认提交的方式

查看当前事务是否默认提交

SHOW VARIABLES LIKE 'autocommit';

设置MySQL的数据库的事务不默认提交

SET autocommit = 0;

执行转账操作

  • 从张三账户扣除1000元

    UPDATE account SET money = money - 1000 WHERE name = '张三';
  • 给李四账户增加1000元

    UPDATE account SET money = money + 1000 WHERE name = '李四';

手动提交或回滚事务

  • 如果转账操作成功,提交事务

    COMMIT;
  • 如果转账操作失败,回滚事务

    ROLLBACK;

恢复默认提交设置(可选)

SET autocommit = 1;

上面两种情况下,一旦有操作不成功的情况,就可以输入ROLLBACK;回滚到转帐前。

三、在JDBC中操作事务(掌握)

第一种方式:使用命令的方式
import java.sql.*;

public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/yourdatabase";
        String user = "yourusername";
        String password = "yourpassword";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            // 开启事务
            conn.setAutoCommit(false);
            
            try {
                // 从张三账户扣除1000元
                String sql1 = "UPDATE account SET money = money - 1000 WHERE name = '张三'";
                try (Statement stmt = conn.createStatement()) {
                    stmt.executeUpdate(sql1);
                }
                
                // 给李四账户增加1000元
                String sql2 = "UPDATE account SET money = money + 1000 WHERE name = '李四'";
                try (Statement stmt = conn.createStatement()) {
                    stmt.executeUpdate(sql2);
                }
                
                // 提交事务
                conn.commit();
                System.out.println("转账成功!");
            } catch (SQLException e) {
                // 回滚事务
                conn.rollback();
                System.out.println("转账失败,已回滚!");
                e.printStackTrace();
            } finally {
                // 关闭连接
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
第二种方式:设置MySQL事务不默认提交的方式
import java.sql.*;

public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/yourdatabase";
        String user = "yourusername";
        String password = "yourpassword";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            // 设置不默认提交
            conn.setAutoCommit(false);
            
            try {
                // 从张三账户扣除1000元
                String sql1 = "UPDATE account SET money = money - 1000 WHERE name = '张三'";
                try (Statement stmt = conn.createStatement()) {
                    stmt.executeUpdate(sql1);
                }
                
                // 给李四账户增加1000元
                String sql2 = "UPDATE account SET money = money + 1000 WHERE name = '李四'";
                try (Statement stmt = conn.createStatement()) {
                    stmt.executeUpdate(sql2);
                }
                
                // 提交事务
                conn.commit();
                System.out.println("转账成功!");
            } catch (SQLException e) {
                // 回滚事务
                conn.rollback();
                System.out.println("转账失败,已回滚!");
                e.printStackTrace();
            } finally {
                // 恢复默认提交设置
                conn.setAutoCommit(true);
                // 关闭连接
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

【注:yourdatabaseyourusernameyourpassword对应实际数据库名称、用户名和密码,必要时请更改成自己对应的。】

相关文章:

  • notepad++右键菜单不见了
  • Docker 私有仓库 Harbor 详解
  • Rust Slice(切片)类型
  • uniapp邪门事件
  • 【技术洞察】2024科技绘卷:浪潮、突破、未来
  • 算法刷题-哈希表的总结
  • CTF-RE: 基础模块-循环移位
  • scroll、offset、client三大家族和getBoundingClientRect方法
  • python concurrent.futures
  • 基于YOLO11深度学习的果园苹果检测与计数系统设计与实现【python源码+Pyqt5界面+数据集+训练代码】
  • 【Spring生命周期】Bean元信息配置阶段
  • Python Selenium自动化操作详解:从入门到实战
  • JavaScript中的函数基础知识
  • win10本地部署deepseek-r1步骤
  • 用户的声音 | 文档结构化信息提取方案测评:LLM、开源模型部署与云端API,谁是合适选择?
  • 在 Vue 项目中,为什么要在列表组件中写 key,其作用是什么?
  • 什么是幂等性?
  • 【SpringMVC】Controller的多种方式接收请求参数
  • DeepSeek模型快速部署教程-搭建自己的DeepSeek
  • 在Unity中用简单工厂模式模拟原神中的元素反应
  • 首批证券公司科创债来了!拟发行规模超160亿元
  • 水利部:山西、陕西等地旱情将持续
  • 重庆动物园大熊猫被游客扔玻璃瓶,相同地方曾被扔可乐瓶
  • 陕南多地供水形势严峻:有的已呼吁启用自备水井
  • 碧桂园服务:拟向杨惠妍全资持有的公司提供10亿元贷款,借款将转借给碧桂园用作保交楼
  • 潘功胜:央行将设立5000亿元服务消费与养老再贷款