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)
那么最后结果是血量增加了，而非期望的不变

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

package jdbc;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
 
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 s = c.createStatement();) {
 
            //没有事务的前提下
            //假设业务操作时，加血，减血各做一次
            //结束后，英雄的血量不变
             
            //加血的SQL
            String sql1 = "update hero set hp = hp +1 where id = 22";
            s.execute(sql1);
             
            //减血的SQL
            //不小心写错写成了 updata(而非update)
             
            String sql2 = "updata hero set hp = hp -1 where id = 22";
            s.execute(sql2);
 
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
 
    }
}

步骤 2 :

使用事务

edit 顶折

纠问

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

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

package jdbc;
 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
 
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 s = c.createStatement();) {
 
            // 有事务的前提下
            // 在事务中的多个操作，要么都成功，要么都失败
 
            c.setAutoCommit(false);
 
            // 加血的SQL
            String sql1 = "update hero set hp = hp +1 where id = 22";
            s.execute(sql1);
 
            // 减血的SQL
            // 不小心写错写成了 updata(而非update)
 
            String sql2 = "updata hero set hp = hp -1 where id = 22";
            s.execute(sql2);
 
            // 手动提交
            c.commit();
 
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
 
    }
}

步骤 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 删除成功！

public static void main(String[] args) {
		String url = "jdbc:mysql://127.0.0.1:3306/how2java?characterEncoding = UTF-8";
		try (Connection c = getConnetion(url, "root", "admin");
				Statement s = c.createStatement();) {
			c.setAutoCommit(false);
			int count = 10;
			s.execute("delete from hero limit "+count);
			ResultSet set = executeAllSQL("select * from hero limit 1");
			int id = 0;
			if(set.next())
			{
				id = set.getInt(1);
			}
			Scanner scanner = new Scanner(System.in);
			while(true)
			{
				System.out.printf("试图删除从 id = %d 开始的 %d 条数据%n",id,count);
				System.out.println("是否要删除数据（Y/N）？");
				String reply = scanner.next();
				if(reply.equals("Y"))
				{
					c.commit();
					System.out.println("删除成功！");
					break;
				}else if(reply.equals("N"))
				{
					System.out.println("已取消删除！");
					break;
				}
			}
			scanner.close();
			set.close();
		} catch (Exception e) {
			e.printStackTrace();
		} 
		
	}

2 个答案

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

getConnetion方法如下：

代码超过 5行，点击查看

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

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

代码超过 5行，点击查看

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

2022-12-07 答案：事务

logiczqr

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

如题

try {
            c.setAutoCommit(false);
            for(int i = 1 ; i < 11 ; i++) {
                String sql = "delete from hero where id = " + i ;
                s.execute(sql) ;
                System.out.printf("试图删除id= %d 的数据%n", i);
            }
            System.out.println("是否要删除数据(Y/N)");
            Scanner scanner = new Scanner(System.in) ;
            String isDel = scanner.nextLine() ;
            if ("Y".equals(isDel)) {
                c.commit();
                System.out.println("提交删除");
            }else {
                System.out.println("取消删除");
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }

2 个答案

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

代码超过 5行，点击查看

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-事务的提问

积分答案

String sqlQuery = "select * from hero limit 10";  // 查询前10条记录
            s.execute(sqlQuery);
            ResultSet rs = s.getResultSet();

            c.setAutoCommit(false); // 关闭自动提交
            while(rs.next()){
                int id=rs.getInt(1);
                System.out.println("试图删除id="+id+" 的数据");
                ps.setInt(1, id);
                ps.execute();
            }

            while(true){
                System.out.println("是否要删除以上数据(Y/N)");
                Scanner ss = new Scanner(System.in);
                String a = ss.nextLine();

                if (a.equalsIgnoreCase("Y")){
                    c.commit();
                    System.out.println("提交删除");
                    break;
                } else if (a.equalsIgnoreCase("N")) {
                    System.out.println("取消删除");
                    break;
                }
            }

        } catch (SQLException e){
            e.printStackTrace();
        }

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

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 条以前的提问，请点击查看

提问之前请登陆

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

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

尽量提供截图、代码和异常信息，有助于分析和解决问题。也可进本站QQ群交流: 578362961

提问尽量提供完整的代码，环境描述，越是有利于问题的重现，您的问题越能更快得到解答。
对教程中代码有疑问，请提供是哪个步骤，哪一行有疑问，这样便于快速定位问题，提高问题得到解答的速度
在已经存在的几千个提问里，有相当大的比例，是因为使用了和站长不同版本的开发环境导致的,比如 jdk, eclpise, idea, mysql,tomcat 等等软件的版本不一致。
请使用和站长一样的版本，可以节约自己大量的学习时间。站长把教学中用的软件版本整理了，都统一放在了这里，方便大家下载： https://how2j.cn/k/helloworld/helloworld-version/1718.html

上传截图