处理Oracle数据库的网络连接中断后的恢复操作

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class OracleConnectionRecovery {
    private static final String DB_URL = "jdbc:oracle:thin:@//localhost:1521/ORCL";
    private static final String USER = "username";
    private static final String PASSWORD = "password";

    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            // 建立连接
            conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);
            conn.setAutoCommit(false); // 关闭自动提交

            stmt = conn.createStatement();
            stmt.execute("INSERT INTO my_table VALUES (1, 'test')");

            // 模拟网络中断
            Thread.sleep(5000); // 假设这里网络中断了

            // 尝试重新连接
            if (conn.isClosed()) {
                System.out.println("Connection is closed. Attempting to reconnect...");
                conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);
                conn.setAutoCommit(false);
                stmt = conn.createStatement();
            }

            // 继续之前的操作
            stmt.execute("INSERT INTO my_table VALUES (2, 'test2')");
            conn.commit();
            System.out.println("Operations completed successfully.");
        } catch (SQLException | InterruptedException e) {
            e.printStackTrace();
            try {
                if (conn != null && !conn.isClosed()) {
                    conn.rollback(); // 回滚事务
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } finally {
            try {
                if (stmt != null) stmt.close();
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}