JDBC MySql连接池实践可避免连接池耗尽

Z时代
2024-01-10
分类：问答

我在GlassFish上有一个Java-JSF

Web应用程序，我想在其中使用连接池。因此，我创建了一个有application范围的Bean，可与Connection其他Bean的实例一起使用：

public class DatabaseBean {
    private DataSource myDataSource;
    public DatabaseBean() {
        try {
            Context ctx = new InitialContext();
            ecwinsDataSource = (DataSource) ctx.lookup("jdbc/myDataSource");
        } catch (NamingException ex) {
            ex.printStackTrace();
        }
    }
    public Connection getConnection() throws ClassNotFoundException, SQLException, InstantiationException, IllegalAccessException {
        Connection connection = myDataSource.getConnection();
        System.out.println("Succesfully connected: " + connection);
        //Sample: Succesfully connected: com.sun.gjc.spi.jdbc40.ConnectionHolder40@7fb213a5
        return connection;
    }
}

这样，连接池很快就会被填满。在“ db-related”视图中进行几次导航后，应用程序将停止以下操作：

RAR5117：无法从连接池[mysql_testPool]获取/创建连接。原因：使用中的连接等于最大池大小和已过期的最大等待时间。无法分配更多连接。RAR5114：分配连接时出错：[分配连接时出错。原因：使用中的连接等于最大池大小和过期的最大等待时间。无法分配更多的连接。]
java.sql.SQLException：分配连接时出错。原因：使用中的连接等于最大池大小和过期的最大等待时间。无法分配更多连接。

我将关闭每种方法的连接和其他资源。该应用程序可以通过独立连接正常运行。

我究竟做错了什么？任何提示或建议，将不胜感激。

回答：

异常表明应用程序代码的典型情况是数据库连接泄漏。你需要确保你获得关闭所有的人（Connection，Statement

ResultSet）在try-with-

resources按照正常的JDBC成语在非常相同的方法块的块。

public void create(Entity entity) throws SQLException {
    try (
        Connection connection = dataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement(SQL_CREATE);
    ) { 
        statement.setSomeObject(1, entity.getSomeProperty());
        // ...
        statement.executeUpdate();
    }
}

或者，当您不使用Java 7时，请执行以下try-finally步骤。关闭它们finally将保证在有例外情况下也将它们关闭。

public void create(Entity entity) throws SQLException {
    Connection connection = null;
    PreparedStatement statement = null;
    try { 
        connection = dataSource.getConnection();
        statement = connection.prepareStatement(SQL_CREATE);
        statement.setSomeObject(1, entity.getSomeProperty());
        // ...
        statement.executeUpdate();
    } finally {
        if (statement != null) try { statement.close(); } catch (SQLException logOrIgnore) {}
        if (connection != null) try { connection.close(); } catch (SQLException logOrIgnore) {}
    }
}

是的，即使使用连接池，您仍然需要自己关闭连接。初学者常见的错误是，他们认为它将自动处理结局。这是

。连接池即返回包装的连接，该连接在close（）中执行以下操作：

public void close() throws SQLException {
    if (this.connection is still eligible for reuse) {
        do not close this.connection, but just return it to pool for reuse;
    } else {
        actually invoke this.connection.close();
    }
}

不关闭它们将导致连接不会释放回池以供重用，因此它将一次又一次获取新的连接，直到数据库用尽连接，这将导致应用程序崩溃。