当我的应用失去连接时，我应该如何恢复它？

Question

我有一个要连接到MySQL数据库的应用程序。它在半夜断开连接，然后喷出有关null连接的信息，并且JDBC在X秒内没有收到消息。

getConnection()在进行任何需要与SQL Server通信的操作之前，我先打电话给我。

这是我的getConnection()方法：

private Connection getConnection() {
    try {
        if (connection != null) {
            if (connection.isClosed() || !connection.isValid(10000)) {
                this.initializeRamsesConnection();
            }
        } else {
            this.initializeRamsesConnection();
        }
    } catch (Exception e) {
        debug("Connection failed: " + e);
    }
    return connection;
}

在该initializeRamsesConnection()方法中，我将密码等信息放入字符串中，然后以标准JDBC方式创建连接。

然后我调用此方法：

private Connection getConnectionFromConnectionString() {
    Connection con = null;
    String driver = "com.mysql.jdbc.Driver";
    try {
        Class.forName(driver);//jdbc sorcery
        //if there is no connection string
        if (getConnectionString() == null) {
            HMIDatabaseAdapter.debug("No connection string");
        }
        //makes a string out of the values of db/host
        String str = getConnectionString();
        //if there is no driver
        if (driver == null) {
            debug("" + ": " + "No driver");
        }
        //Tries to make a connection from the connection string, username, and the password.
        con = DriverManager.getConnection(str, username, password);
        //if for some reason the connection is null
        if (con == null) {
            HMIDatabaseAdapter.debug("CONNECTION IS NULL, WHAT?");
        }
    } catch (Exception ex) {
        HMIDatabaseAdapter.debug("getConnection() " + ex);
    }
    return con;
}

我可以对这两种方法进行哪些更改以适应丢失的连接？

Answer 1

这不是检索连接的正确方法。您正在检索连接并将其分配为该类的实例变量（或更糟糕的是，静态变量）。基本上，您将使连接永远保持打开状态，并对所有查询重新使用单个连接。如果查询由不同的线程执行，则可能会导致灾难。另外，当它保持打开状态太长时间时，DB会回收它，因为它假定它已死/泄漏。

您应该在 尽可能短的范围内 获取 并关闭 连接。即与执行查询的位置相同。像这样： __try

public Entity find(Long id) throws SQLException {
    Entity entity = null;

    try (
        Connection connection = dataSource.getConnection(); // This should return a NEW connection!
        PreparedStatement statement = connection.prepareStatement(SQL_FIND);
    ) {
        statement.setLong(1, id);

        try (ResultSet resultSet = preparedStatement.executeQuery()) {
            if (resultSet.next()) {
                entity = new Entity(
                    resultSet.getLong("id"),
                    resultSet.getString("name"),
                    resultSet.getInt("value")
                );
            }
        }
    }

    return entity;
}

如果您担心连接性能并想重用连接，则应该使用连接池。您可以自己种一个，但是我强烈不建议这样做，因为您似乎还很陌生。只需使用现有的连接池，例如BoneCP，C3P0或DBCP即可。请注意，您应该
不会 如在上面的例子改变JDBC成语。您仍然需要在尽可能短的范围内获取并关闭连接。连接池本身将担心实际重用，测试和/或关闭连接。