在 JDBC 中，如何进行事务处理？

举报
Xxy_1008 发表于 2024/10/30 09:48:53 2024/10/30
【摘要】 事务的基本概念在数据库操作中，事务是一组要么全部成功执行，要么全部失败回滚的操作序列。例如，在银行转账系统中，从一个账户扣款并在另一个账户收款这两个操作应该作为一个事务来处理。如果扣款成功但收款失败，整个事务应该回滚，即撤销扣款操作，以保证数据的一致性。在 JDBC 中进行事务处理的步骤设置自动提交为 falseJDBC 默认是自动提交模式，即每条 SQL 语句执行后会自动提交事务。要进行事...
  1. 事务的基本概念
    • 在数据库操作中，事务是一组要么全部成功执行，要么全部失败回滚的操作序列。例如，在银行转账系统中，从一个账户扣款并在另一个账户收款这两个操作应该作为一个事务来处理。如果扣款成功但收款失败，整个事务应该回滚，即撤销扣款操作，以保证数据的一致性。
  2. 在 JDBC 中进行事务处理的步骤
    • 设置自动提交为 false
      • JDBC 默认是自动提交模式，即每条 SQL 语句执行后会自动提交事务。要进行事务处理，首先需要关闭自动提交。可以通过获取到的Connection对象来设置，例如：
       Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "username", "password");
       connection.setAutoCommit(false);

这里将自动提交设置为false，意味着后续的操作不会自动提交，而是需要手动控制事务的提交或回滚。

  • 执行事务操作
    • 接着，可以执行一系列数据库操作，这些操作构成了事务。例如，在一个简单的订单处理系统中，插入一个订单记录并更新商品库存：
       try {
         Statement statement = connection.createStatement();
         // 插入订单记录
         statement.executeUpdate("INSERT INTO orders (order_id, customer_id, order_date) VALUES (1, 101, '2024-10-30')");
         // 更新商品库存
         statement.executeUpdate("UPDATE products SET stock_quantity = stock_quantity - 1 WHERE product_id = 1");
       } catch (SQLException e) {
         e.printStackTrace();
       }

  • 提交或回滚事务
    • 提交事务：如果所有操作都成功执行，没有出现异常，那么可以提交事务。通过Connection对象的commit方法来实现，例如：
       try {
         //...执行事务操作
         connection.commit();
       } catch (SQLException e) {
         e.printStackTrace();
       }

  • 回滚事务：如果在事务执行过程中出现了异常，需要回滚事务以撤销已经执行的部分操作，保持数据的原始状态。使用Connection对象的rollback方法，例如：
       try {
         //...执行事务操作
         connection.commit();
       } catch (SQLException e) {
         try {
           connection.rollback();
         } catch (SQLException ex) {
           ex.printStackTrace();
         }
         e.printStackTrace();
       }

在这个例子中，如果提交事务时出现异常，会捕获该异常，然后尝试回滚事务。回滚操作本身也可能出现异常，所以也需要进行捕获和处理。

  1. 事务的隔离级别（可选但重要）
    • JDBC 还允许设置事务的隔离级别，以控制不同事务之间的并发访问。常见的隔离级别有：
      • READ_UNCOMMITTED（读未提交）：允许一个事务读取另一个未提交事务的数据，可能会导致脏读（读取到其他事务未提交的数据）。
      • READ_COMMITTED（读已提交）：一个事务只能读取另一个已提交事务的数据，避免了脏读，但可能会出现不可重复读（在一个事务中多次读取同一数据，结果不同，因为其他事务在期间修改并提交了该数据）。
      • REPEATABLE_READ（可重复读）：在一个事务中，多次读取同一数据的结果是一致的，即使其他事务修改并提交了该数据，这个事务也不会看到变化。不过，可能会出现幻读（在一个事务中，按照某个条件查询数据，多次查询结果不同，因为其他事务插入或删除了符合条件的数据）。
      • SERIALIZABLE（串行化）：最高的隔离级别，事务串行执行，像排队一样，完全避免了脏读、不可重复读和幻读，但性能开销较大。
    • 可以通过Connection对象来设置隔离级别，例如：
     connection.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

这里将事务隔离级别设置为READ_COMMITTED。不同的数据库对隔离级别的支持可能略有差异，在实际应用中需要根据具体情况选择合适的隔离级别。


【版权声明】本文为华为云社区用户原创内容，转载时必须标注文章的来源（华为云社区）、文章链接、文章作者等基本信息， 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱： cloudbbs@huaweicloud.com
Java JDBC
  • 点赞
  • 收藏
  • 关注作者

评论（0）

0/1000
抱歉，系统识别当前为高风险访问，暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称，即可参与社区互动！

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

确认 取消

加入云驻计划，成为创作者

  • 华为云周边好礼
  • 免费体验产品
  • 特殊身份标识
  • 线下官方门票
  • 内部专家零距离
  • 与10000+优质创作者共同成长
立即加入