Oracle JDBC连接默认的自动提交行为

在本文中，我们将介绍Oracle JDBC连接的默认自动提交行为。首先，我们将解释什么是自动提交以及Oracle JDBC连接中的默认行为。然后，我们将通过实际的示例来说明默认自动提交行为对数据库操作的影响，并讨论如何改变默认行为。

自动提交行为和默认行为

自动提交是指每个单独的SQL语句在执行之后立即将更改提交到数据库中。这意味着在每次执行完一条SQL语句后，会立即将更改保存到数据库中，并且这些更改对其他会话可见。

在Oracle JDBC连接中，默认的自动提交行为是开启的。这意味着当我们执行完一条SQL语句后，会立即将更改提交给数据库。但是，如果我们在创建连接时明确地将自动提交设置为false，则在执行完一条SQL语句后，将需要手动调用commit()方法才能提交更改。

默认的自动提交行为存在的目的是为了简化开发和确保数据一致性。但在某些情况下，我们可能希望禁用自动提交，以便能够在多条SQL语句执行完后，通过调用commit()方法一次性提交更改。

示例说明

为了更好地理解默认自动提交行为对数据库操作的影响，我们将通过一个示例说明。

假设我们有一个名为”employees”的表，该表包含员工的姓名、员工号和薪水等信息。现在，我们想要通过JDBC连接到数据库，并将一些员工的薪水进行修改。

首先，我们需要创建一个数据库连接：

import java.sql.*;

public class Main {

    public static void main(String[] args) {
        String url = "jdbc:oracle:thin:@localhost:1521/xe";
        String user = "username";
        String password = "password";
        Connection conn = null;

        try {
            conn = DriverManager.getConnection(url, user, password);
            System.out.println("成功连接到数据库！");
        } catch (SQLException e) {
            e.printStackTrace();
        }

        // 执行SQL语句
        // ...

        // 关闭连接
        if (conn != null) {
            try {
                conn.close();
                System.out.println("成功关闭数据库连接！");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

接下来，我们可以执行一些SQL语句来修改员工的薪水，并观察默认自动提交行为带来的影响。

import java.sql.*;

public class Main {

    public static void main(String[] args) {
        String url = "jdbc:oracle:thin:@localhost:1521/xe";
        String user = "username";
        String password = "password";
        Connection conn = null;
        Statement stmt = null;

        try {
            conn = DriverManager.getConnection(url, user, password);
            stmt = conn.createStatement();

            // 默认自动提交行为
            String sql = "UPDATE employees SET salary = 5000 WHERE employee_id = 100";
            stmt.executeUpdate(sql);
            System.out.println("成功更新一条记录！");

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (stmt != null) {
                    stmt.close();
                }

                if (conn != null) {
                    conn.close();
                    System.out.println("成功关闭数据库连接！");
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

上述示例中的SQL语句将会修改员工ID为100的薪水为5000。由于默认开启了自动提交行为，我们不需要手动调用commit()方法，更改会立即提交到数据库中。

如果我们希望禁用自动提交，并在修改了多条记录后才一次性提交更改，我们可以通过设置连接的自动提交属性来实现。

import java.sql.*;

public class Main {

    public static void main(String[] args) {
        String url = "jdbc:oracle:thin:@localhost:1521/xe";
        String user = "username";
        String password = "password";
        Connection conn = null;
        Statement stmt = null;

        try {
            conn = DriverManager.getConnection(url, user, password);
            conn.setAutoCommit(false); // 禁用自动提交

            stmt = conn.createStatement();

            // 禁用自动提交行为
            String sql = "UPDATE employees SET salary = 5000 WHERE employee_id = 100";
            stmt.executeUpdate(sql);
            System.out.println("成功更新一条记录！");

            sql = "UPDATE employees SET salary = 6000 WHERE employee_id = 200";
            stmt.executeUpdate(sql);
            System.out.println("成功更新一条记录！");

            conn.commit(); // 手动提交更改
            System.out.println("成功提交更改！");

        } catch (SQLException e) {
            e.printStackTrace();
            if (conn != null) {
                try {
                    conn.rollback(); // 出现异常时回滚更改
                    System.out.println("发生异常，已回滚更改！");
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        } finally {
            try {
                if (stmt != null) {
                    stmt.close();
                }

                if (conn != null) {
                    conn.setAutoCommit(true); // 恢复默认自动提交行为
                    conn.close();
                    System.out.println("成功关闭数据库连接！");
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}