JDBC系列教材（八）- 如何在JDBC中使用事务

工具版本兼容问题

本视频是解读性视频，所以希望您已经看过了本知识点的内容，并且编写了相应的代码之后，带着疑问来观看，这样收获才多。不建议一开始就观看视频

6分4秒
本视频采用html5方式播放，如无法正常播放，请将浏览器升级至最新版本，推荐火狐，chrome，360浏览器。如果装有迅雷，播放视频呈现直接下载状态，请调整迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)。 chrome 的视频下载插件会影响播放，如 IDM 等，请关闭或者切换其他浏览器

1.0 原速 1.25 倍速 1.5 倍速 1.75 倍速

步骤 1 : 不使用事务的情况
步骤 2 : 使用事务
步骤 3 : MYSQL 表的类型必须是INNODB才支持事务
步骤 4 : 练习-事务
步骤 5 : 答案-事务

步骤 1 :

不使用事务的情况

edit 顶折

纠问

没有事务的前提下
假设业务操作是：加血，减血各做一次
结束后，英雄的血量不变
而减血的SQL
不小心写错写成了 updata(而非update)
那么最后结果是血量增加了，而非期望的不变

代码行数较多，请点击查看

步骤 2 :

使用事务

edit 顶折

纠问

在事务中的多个操作，要么都成功，要么都失败
通过 c.setAutoCommit(false);关闭自动提交
使用 c.commit();进行手动提交
在22行-35行之间的数据库操作，就处于同一个事务当中，要么都成功，要么都失败
所以，虽然第一条SQL语句是可以执行的，但是第二条SQL语句有错误，其结果就是两条SQL语句都没有被提交。除非两条SQL语句都是正确的。

代码行数较多，请点击查看

步骤 3 :

MYSQL 表的类型必须是INNODB才支持事务

edit 顶折

纠问

在Mysql中，只有当表的类型是INNODB的时候，才支持事务，所以需要把表的类型设置为INNODB,否则无法观察到事务.

修改表的类型为INNODB的SQL：

alter table hero ENGINE = innodb;

查看表的类型的SQL

show table status from how2java;

不过有个前提，就是当前的MYSQL服务器本身要支持INNODB,如果不支持，请看开启MYSQL INNODB的办法

步骤 4 :

练习-事务

edit 顶折

纠问

姿势不对,事倍功半! 点击查看做练习的正确姿势

当c.setAutoCommit(false);时，事务是不会提交的
只有执行使用 c.commit(); 才会提交进行

设计一个代码，删除表中前10条数据，但是删除前会在控制台弹出一个提示：
是否要删除数据(Y/N)
如果用户输入Y，则删除
如果输入N则不删除。
如果输入的既不是Y也不是N，则重复提示

步骤 5 :

答案-事务

edit 顶折

纠问

在查看答案前，尽量先自己完成，碰到问题再来查看答案，收获会更多

查看本答案会花费3个积分，您目前总共有点积分。查看相同答案不会花费额外积分。积分增加办法或者一次性购买JAVA 中级总计0个答案 (总共需要0积分)

账号未激活账号未激活，功能受限。请点击激活

本视频是解读性视频，所以希望您已经看过了本答案的内容，带着疑问来观看，这样收获才多。不建议一开始就观看视频

2分34秒本视频采用html5方式播放，如无法正常播放，请将浏览器升级至最新版本，推荐火狐，chrome，360浏览器。如果装有迅雷，播放视频呈现直接下载状态，请调整迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)。 chrome 的视频下载插件会影响播放，如 IDM 等，请关闭或者切换其他浏览器

1.0 原速 1.25 倍速 1.5 倍速 1.75 倍速

代码行数较多，请点击查看

package jdbc;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
 
public class TestJDBC {
 
    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
         
        try (Connection c = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding=UTF-8",
                "root", "admin");
                Statement st4Query = c.createStatement();
                Statement st4Delete = c.createStatement();
                Scanner s = new Scanner(System.in);) {
 
            //把自动提交关闭
            c.setAutoCommit(false);
            //查出前10条
            ResultSet rs =st4Query.executeQuery("select id from Hero order by id asc limit 0,10 ");
            while(rs.next()){
                int id = rs.getInt(1);
                System.out.println("试图删除id="+id+" 的数据");
                st4Delete.execute("delete from Hero where id = " +id);
            }
             
            //是否删除这10条
            while(true){
                System.out.println("是否要删除数据(Y/N)");
                 
                String str = s.next();
                if ("Y".equals(str)) {
                    //如果输入的是Y，则提交删除操作
                    c.commit();
                    System.out.println("提交删除");
                    break;
                } else if ("N".equals(str)) {
                    System.out.println("放弃删除");
                    break;
                }
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
    }
}

JDBC系列教材（七）- 获取自增长id以及表的元数据

JDBC系列教材（九）- 使用JDBC做一个ORM例子

HOW2J公众号，关注后实时获知最新的教程和优惠活动，谢谢。

问答区域

2024-07-15 利用事务和SQL语句实现删除前10条数据的功能

虚心求学

关于 JAVA 中级-JDBC-事务的提问

为实现删除前10条数据的功能，结合 commit 事务功能与 sql 语句： delete from hero limit 10; 运行结果：试图删除从 id = 1 开始的 10 条数据是否要删除数据（Y/N）？ no 试图删除从 id = 1 开始的 10 条数据是否要删除数据（Y/N）？ Y 删除成功！

2 个答案

虚心求学
答案时间：2024-07-15

getConnetion方法如下：

代码超过 5行，点击查看

虚心求学
答案时间：2024-07-15

上面的代码中用到，executeAllSQL方法，如下：

代码超过 5行，点击查看

回答已经提交成功，正在审核。请于我的回答处查看回答记录，谢谢

2022-12-07 答案：事务

logiczqr

关于 JAVA 中级-JDBC-事务 -练习-事务的提问

如题

2 个答案

HuiJie-Wang
答案时间：2023-09-15

代码超过 5行，点击查看

public static void deleteTenUser() {
        try (
            Scanner s = new Scanner(System.in);
        ) {
            // String sql = "delete from users where id = ?";
            try (
                Connection c = DriverManager.getConnection(
                    "jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding=UTF-8",
                    "root", "admin");
                Statement cs = c.createStatement();
            ) {
                c.setAutoCommit(false);
 
                // SELECT * FROM table_name ORDER BY id DESC LIMIT 10;
                ResultSet rs = cs.executeQuery("SELECT * FROM users ORDER BY id DESC LIMIT 10");
 
                while (rs.next()) {
                    int id = rs.getInt(1);
                    // String name = rs.getString(2);
                    PreparedStatement ps = c.prepareStatement("delete from users where id = ?");
                    ps.setInt(1, id);
 
                    ps.execute();
                }
 
                while (true) {
                    System.out.print("确定删除最后10条数据吗？请输入Y or N!");
                    String ui = s.nextLine();
 
                    if ("Y".equals(ui)) {
                        c.commit();
                        System.out.println("删除成功!");
                        break;
                    } else if ("N".equals(ui)) {
                        return;
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
                // TODO: handle exception
            }  
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }
 
    }

fwefsd
答案时间：2023-02-23

这个输入Y/N是可以的，但是输入其他的也会显示取消删除，而不是重复提示。

回答已经提交成功，正在审核。请于我的回答处查看回答记录，谢谢

2022-11-09 根据id删除数据库中存在的10条数据（判断一下id是否存在）

KSK_KIES

关于 JAVA 中级-JDBC-事务的提问

根据id来删除的，先获取第一个数据的id 在删除的时候要判断数据库中是否存在id，然后删除10个就行

public static void commit() {
        Scanner scanner= new Scanner(System.in); 
        String sql="delete from hero where id = ?";
        try (Connection c = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding=UTF-8","root", "admin");
             Statement s = c.createStatement();
              PreparedStatement ps = c.prepareStatement(sql);
        ) {
            String selectSql = "select id from hero limit 1";   
            ResultSet rs = ps.executeQuery(selectSql);
            int id=0;
            while(rs.next()) {   
                id=rs.getInt(1);
                System.out.println("数据库中第一条数据的id是："+id);
            }
            int count=0;
            c.setAutoCommit(false);
            while(count!=10) {
                System.out.println("是否要删除数据（Y/N）");
                String aString = scanner.nextLine();            
                if(aString.equals("Y")) {       
                    String sql1 = "select id from hero where id ="+ id;
                    ResultSet sl = s.executeQuery(sql1);
                    if(sl.next()) {
                        ps.setInt(1, id);
                        ps.execute();
                        System.out.println("试图删除id="+id+"的数据");
                        id++;
                        count++;
                    }else {
                        System.out.println("数据库中不存在id="+id+"的数据");
                        id++;
                    }
                }else if(aString.equals("N")){
                    String sql1 = "select id from hero where id ="+ id;
                    ResultSet sl = s.executeQuery(sql1);
                    if(sl.next()) {
                        System.out.println("不删除id="+id+"的数据");
                        id++;
                    }else {
                        System.out.println("数据库中不存在id="+id+"的数据");
                        id++;
                    }
                }else {
                    System.out.println("是否要删除数据（Y/N）");
                }               
            }
            System.out.println("提交删除");
            c.commit();                         
        } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }
    }

回答已经提交成功，正在审核。请于我的回答处查看回答记录，谢谢

2022-03-07 积分答案

dyf137

关于 JAVA 中级-JDBC-事务的提问

积分答案

回答已经提交成功，正在审核。请于我的回答处查看回答记录，谢谢

2021-11-14 删除前10条记录（完全符合题干要求）

AeIOUer

关于 JAVA 中级-JDBC-事务的提问

/** * 设计一个代码，删除表中前10条数据，但是删除前会在控制台弹出一个提示： * 是否要删除数据(Y/N) * 如果用户输入Y，则删除 * 如果输入N则不删除。 * 如果输入的既不是Y也不是N，则重复提示 */

package jdbc;
 
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
 
/**
 * 设计一个代码，删除表中前10条数据，但是删除前会在控制台弹出一个提示：
 * 是否要删除数据(Y/N)
 * 如果用户输入Y，则删除
 * 如果输入N则不删除。
 * 如果输入的既不是Y也不是N，则重复提示
 */
public class TestCommit {
    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
 
        String sql = "delete from hero where id = ?";
        try (Connection c = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding=UTF-8","root", "admin");
             Statement s = c.createStatement();
             PreparedStatement ps = c.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);){
 
            String sqlQuery = "select * from hero limit 10";  // 查询前10条记录
            s.execute(sqlQuery);
 
            ResultSet rs = s.getResultSet();
            List<Integer> idList = new ArrayList<>();
            while (rs.next()){
                idList.add(rs.getInt(1));
                System.out.printf("试图删除id=" + rs.getInt(1) + " 的数据%n");
            }
 
            c.setAutoCommit(false); // 关闭自动提交
            while(true){
                System.out.println("是否要删除以上数据(Y/N)");
                Scanner ss = new Scanner(System.in);
                String a = ss.nextLine();
 
                if (a.equalsIgnoreCase("Y")){
                    System.out.println("提交删除");
                    for (Integer id : idList){
                        ps.setInt(1, id);
                        ps.execute();
                        System.out.printf("正在删除id=" + id + " 的数据%n");
                    }
                    break;
                } else if (a.equalsIgnoreCase("N")){
                    System.out.println("取消删除");
                    break;
                } else {
                    System.out.println("输入的既不是Y也不是N,请重新输入");
                }
            }
 
            c.commit();  //手动提交
 
 
        }catch (SQLException e){
            e.printStackTrace();
        }
    }
}

2 个答案

hoolich
答案时间：2022-05-04

/*当c.setAutoCommit(false);时，事务是不会提交的只有执行使用 c.commit(); 才会提交进行设计一个代码，删除表中前10条数据，但是删除前会在控制台弹出一个提示：是否要删除数据(Y/N) 如果用户输入Y，则删除如果输入N则不删除。如果输入的既不是Y也不是N，则重复提示*/ package jdbc; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Scanner; public class TestJDBC { public static void main(String[] args) { try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } try (Connection c = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding=UTF-8","root", "12345678"); Statement st4Query = c.createStatement(); Statement st4Delete = c.createStatement(); Scanner s = new Scanner(System.in); ) { //把自动提交关闭 c.setAutoCommit(false); // 执行插入语句 //查出前10条 ResultSet rs= st4Query.executeQuery("select * from hero order by id asc limit 0,10"); while(rs.next()){ int id= rs.getInt(1); System.out.printf("试图删除id=%d的数据%n",id); st4Delete.execute("delete from hero where id="+id); } System.out.println("是否要删除数据(Y/N)"); String str=s.next(); //是否删除这10条 while(true) { if (str.equals("Y")) { // 手动提交 c.commit(); System.out.println("提交删除"); break; } else if(str.equals("N")){ System.out.println("放弃删除"); break; } } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

星空9975
答案时间：2021-12-19

删除前十个

代码超过 5行，点击查看

package jdbc;
 
import java.sql.*;
import java.util.Scanner;
 
public class affair {
    public static void main(String[] args) {
        connectioned();
        try(Connection c=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?" +
                "characterEncoding=UTF-8","root","admin");
                Statement s=c.createStatement();){
 
            c.setAutoCommit(false);
            String sql1="select * from hero";//查询数据库
 
            s.execute(sql1);
            ResultSet rs=s.getResultSet();
 
            int sum0=0;//用于计数，每次只计数前十个
            int[] content=new int[10];//数组用来存每条获取数据的id
            while (rs.next()){
                int id=rs.getInt("id");//获取每条数据的id
                String name=rs.getString("name");
                float hp=rs.getFloat("hp");
                int damage=rs.getInt("hp");
 
                sum0++;
                if (sum0==11){//当计数到11时，正好是是个数，跳出循环
                    break;
                }else {
                    content[sum0-1]=id;//把id放入数组
                    System.out.printf("试图删除第%d个英雄id：%d\t%s\t%f\t%d%n", sum0,id, name, hp, damage);
                }
            }
             
            boolean judge = true;//用来判断开关
            System.out.println("确认删除10个数据吗？");
            while (judge==true){
                System.out.println("请输入正确的选项！（y/n）");
                Scanner sc=new Scanner(System.in);//用于输入
                String input=sc.nextLine();
                if (input.equals("y")||input.equals("n")){//如果输入的是y或者n就不用循环输入判断了，
                    judge=false;
                }else {
                    judge=true;
                }
 
                if (input.equals("y")){//如果输入的是y，就遍历数组中的id，把它删除
                    for(int i:content){
                        connectioned();
                        try(Connection c1=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/how2java?" +
                                "characterEncoding=UTF-8","root","admin");
                            Statement s1=c1.createStatement();){
                            String sql="delete from hero where id="+i;
                            s1.execute(sql);
                        }catch (SQLException e){
                            e.printStackTrace();
                        }
                    }
                    System.out.println("删除成功！");
                }
            }
        }catch (SQLException e){
            e.printStackTrace();
        }
 
 
 
 
 
    }
 
    public static void connectioned(){//直接定义一个连接，方便调用
        try{
            Class.forName("com.mysql.jdbc.Driver");
        }catch (ClassNotFoundException e){
            e.printStackTrace();
        }
    }
}

回答已经提交成功，正在审核。请于我的回答处查看回答记录，谢谢

提问太多，页面渲染太慢，为了加快渲染速度，本页最多只显示几条提问。还有 41 条以前的提问，请点击查看

提问之前请登陆

提问已经提交成功，正在审核。请于我的提问处查看提问记录，谢谢