无法关闭来自 WebSphere 数据源的 Oracle 连接

Question

我尝试连接到 Oracle 数据库（检查连接状态）。我正在使用以下代码，效果很好。

public String getDatabaseStatus() {
    Connection conn;
    try {
        conn = DriverManager.getConnection( "jdbc:oracle:thin:@192.168.0.70:1521:XE", "foo","bar");
        conn.close();
    } catch (Exception e) {
        return "ERR - " + e.getMessage();
    }
    return "Connection succesful";
}

但是，当使用 Websphere 数据源时，在 10 次（连接限制）刷新后页面会挂起。代码：

public String getDatabaseStatus() {
    Connection conn;
    try {
        Context ctx = new InitialContext();
        DataSource ds = (DataSource) ctx.lookup("jdbc/xe");
        conn = WSCallHelper.getNativeConnection(ds.getConnection());
    } catch (Exception e) {
        return "ERR - " + e.getMessage();
    }
    return "Connection succesful";
}

我试图关闭提供的连接，但它给了我错误：

J2CA0206W - 发生连接错误。为了帮助确定问题，请在连接工厂或数据源上启用诊断连接使用选项。这是多线程访问检测选项。或者检查 Database 或 MessageProvider 是否可用。

任何帮助将不胜感激。

Answer 1

您必须关闭从数据源收到的连接：

public String getDatabaseStatus() {
    Connection conn;
    try {
        Context ctx = new InitialContext();
        DataSource ds = (DataSource) ctx.lookup("jdbc/xe");
        java.sql.Connection connection = ds.getConnection();
        try {
            conn = WSCallHelper.getNativeConnection(connection);
        } finally {
            safeClose(connection);
        }
    } catch (Exception e) {
        return "ERR - " + e.getMessage();
    }
    return "Connection succesful";
}

private void safeClose(java.sql.Connection connection) {
    try {
        connection.close();
    } catch (SQLException e) {
        log.warn("Failed to close database connection", e);
    }
}

如果您使用的是 Java 7 或更高版本，您可以将其简化为：

public String getDatabaseStatus() {
    Connection conn;
    try {
        Context ctx = new InitialContext();
        DataSource ds = (DataSource) ctx.lookup("jdbc/xe");
        try (java.sql.Connection connection = ds.getConnection()) {
            conn = WSCallHelper.getNativeConnection(connection);
        }
    } catch (Exception e) {
        return "ERR - " + e.getMessage();
    }
    return "Connection succesful";
}

如果您不这样做，您的连接将不会返回到池中，并且您将用完连接。