jdbc事务自动提交

什么是JDBC事务自动提交

JDBC事务自动提交是指在执行SQL语句时，如果没有显式地调用commit()方法来提交事务，那么在执行完SQL语句后，数据库会自动将事务进行提交，这种方式下，每个执行的SQL语句都会被视为一个独立的事务。

JDBC事务自动提交的特点

1、每个执行的SQL语句都会被视为一个独立的事务。

2、没有显式地调用commit()方法来提交事务，数据库会自动将事务进行提交。

3、如果执行过程中出现异常，事务不会回滚，可能会导致数据不一致。

4、适用于只执行单个SQL语句的场景。

JDBC事务自动提交与手动提交的区别

如何关闭JDBC事务自动提交

要关闭JDBC事务自动提交，需要在执行SQL语句之前，通过Connection对象的setAutoCommit(false)方法将自动提交模式设置为false，这样，在执行完SQL语句后，需要显式地调用commit()方法来提交事务，示例代码如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JdbcTransactionExample {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            // 加载驱动并获取连接
            Class.forName("com.mysql.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
            // 关闭自动提交模式
            connection.setAutoCommit(false);
            // 执行SQL语句
            preparedStatement = connection.prepareStatement("INSERT INTO users (username, password) VALUES (?, ?)");
            preparedStatement.setString(1, "user1");
            preparedStatement.setString(2, "password1");
            preparedStatement.executeUpdate();
            // 提交事务
            connection.commit();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            try {
                // 发生异常，回滚事务
                connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (resultSet != null) {
                    resultSet.close();
                }
                if (preparedStatement != null) {
                    preparedStatement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}