java手动声明事务

Java手动声明事务

事务是数据库操作中的一个重要概念，它是由一组数据库操作组成的逻辑单元，这些操作要么全部执行成功，要么全部回滚到初始状态。在Java中，我们可以通过手动声明事务来控制数据库的操作，保证数据的一致性和完整性。本文将介绍Java手动声明事务的概念、使用方法和示例代码，并使用Mermaid语法绘制序列图和饼状图来帮助读者更好地理解。

什么是事务

事务是一组数据库操作的集合，可以确保这些操作要么全部执行成功，要么全部回滚到初始状态。事务具有四个基本特性（ACID）：

• 原子性（Atomicity）：事务中的操作要么全部成功，要么全部失败回滚。
• 一致性（Consistency）：事务开始之前和结束之后，数据库的状态必须保持一致。
• 隔离性（Isolation）：事务之间的操作相互隔离，互不干扰。
• 持久性（Durability）：事务一旦提交，对数据库的改变是永久性的。

如何手动声明事务

在Java中，我们可以使用java.sql.Connection接口提供的方法来手动声明事务。下面是一个简单的示例代码：

Connection connection = null;
PreparedStatement statement = null;

try {
    // 获取数据库连接
    connection = getConnection();
    // 关闭自动提交
    connection.setAutoCommit(false);

    // 执行数据库操作
    statement = connection.prepareStatement("INSERT INTO users (name, age) VALUES (?, ?)");
    statement.setString(1, "Alice");
    statement.setInt(2, 25);
    statement.executeUpdate();

    // 提交事务
    connection.commit();

} catch (SQLException e) {
    // 出现异常，回滚事务
    if (connection != null) {
        try {
            connection.rollback();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
} finally {
    // 关闭数据库连接和语句
    if (statement != null) {
        try {
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    if (connection != null) {
        try {
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

在上面的示例代码中，我们首先获取数据库连接，并将自动提交关闭。然后，我们执行一系列的数据库操作，包括插入、更新、删除等。如果执行过程中出现异常，我们将回滚事务，将数据库恢复到初始状态；如果执行成功，我们则提交事务，将数据变更永久保存。

需要注意的是，事务必须在捕获异常的代码块中进行回滚，并在finally块中关闭数据库连接和语句。这样可以确保无论是否发生异常，数据库连接都能被正确关闭，避免资源泄露和数据不一致的情况。

示例：转账事务

下面我们通过一个转账的示例来演示Java手动声明事务的使用：

public void transferMoney(String fromAccount, String toAccount, double amount) {
    Connection connection = null;
    PreparedStatement withdrawStatement = null;
    PreparedStatement depositStatement = null;

    try {
        // 获取数据库连接
        connection = getConnection();
        // 关闭自动提交
        connection.setAutoCommit(false);

        // 执行转账操作
        withdrawStatement = connection.prepareStatement("UPDATE accounts SET balance = balance - ? WHERE account_number = ?");
        withdrawStatement.setDouble(1, amount);
        withdrawStatement.setString(2, fromAccount);
        withdrawStatement.executeUpdate();

        depositStatement = connection.prepareStatement("UPDATE accounts SET balance = balance + ? WHERE account_number = ?");
        depositStatement.setDouble(1, amount);
        depositStatement.setString(2, toAccount);
        depositStatement.executeUpdate();

        // 提交事务
        connection.commit();

    } catch (SQLException e) {
        // 出现异常，回滚事务
        if (connection != null) {
            try {
                connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }
    } finally {
        // 关闭数据库连接和语句
        if (withdrawStatement != null) {
            try {
                withdrawStatement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (depositStatement != null) {
            try {