JAVA中的事务处理

原创

ithorizon 2个月前 (10-03) 阅读数 51 #Java

Java中的事务处理

事务在数据库操作中扮演着重要的角色，它可以确保一系列的操作要么全部胜利，要么全部失利，从而维护数据的一致性。Java通过JDBC（Java Database Connectivity）提供了对事务的赞成。本文将介绍Java中事务处理的基本概念和使用方法。

一、事务的基本概念

事务是由一系列操作组成的逻辑工作单元，这些操作要么全部胜利，要么全部失利。事务具有四个属性，通常称为ACID：

原子性（Atomicity）：事务中的所有操作要么全部完成，要么全部不做。

一致性（Consistency）：事务执行的导致必须使数据库从一个一致性状态转移到另一个一致性状态。

隔离性（Isolation）：一个事务的执行不能被其他事务干扰。

持久性（Durability）：一个事务一旦提交，它对数据库中数据的改变就是永久的。

二、JDBC中事务处理的方法

在Java中，通过以下步骤来控制事务：

获取数据库连接。

设置事务的隔离级别（可选）。

执行数据库操作。

提交或回滚事务。

关闭数据库连接。

三、示例代码

下面是一个易懂的示例，展示了怎样在Java中使用JDBC处理事务：


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "root";
        Connection conn = null;
        try {
            // 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 设置自动提交为false，开端事务
            conn.setAutoCommit(false);
            // 执行数据库操作
            String sql1 = "UPDATE account SET balance = balance - 100 WHERE id = ?";
            String sql2 = "UPDATE account SET balance = balance + 100 WHERE id = ?";
            PreparedStatement pstmt1 = conn.prepareStatement(sql1);
            PreparedStatement pstmt2 = conn.prepareStatement(sql2);
            pstmt1.setInt(1, 1);
            pstmt2.setInt(1, 2);
            pstmt1.executeUpdate();
            pstmt2.executeUpdate();
            // 提交事务
            conn.commit();
            System.out.println("事务提交胜利！");
        } catch (Exception e) {
            // 回滚事务
            if (conn != null) {
                try {
                    conn.rollback();
                    System.out.println("事务回滚！");
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
            e.printStackTrace();
        } finally {
            // 关闭数据库连接
            if (conn != null) {
                try {
                    conn.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}