我是否正确使用Java PooledConnections？

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

我想在Java中使用池化连接（因为每个线程创建一个连接非常昂贵），所以我正在使用该MysqlConnectionPoolDataSource()对象。我正在跨线程保留我的数据源。因此，我在整个应用程序中仅使用一个数据源，如下所示：

  startRegistry();    // creates an RMI registry for MySQL
  MysqlConnectionPoolDataSource dataSource = new MysqlConnectionPoolDataSource();
  dataSource.setUser("username");
  dataSource.setPassword("password");
  dataSource.setServerName("serverIP");
  dataSource.setPort(3306);
  dataSource.setDatabaseName("dbname");
  InitialContext context = createContext();   // Creates a context
  context.rebind("MySQLDS", dataSource);

现在，我已经创建了数据源，然后在每个单独的线程中执行以下操作：

  PooledConnection connect = dataSource.getPooledConnection();
  Connection sqlConnection = connect.getConnection();
  Statement state = sqlConnection.createStatement();
  ResultSet result = state.executeQuery("select * from someTable");
  // Continue processing results

我猜我很困惑，dataSource.getPooledConnection();

是在

这个线程安全吗？我注意到PooledConnection具有诸如notify（）和wait（）之类的方法…这意味着我不认为它在做我认为在做的事情…

另外，何时以及如何释放连接？

我想知道如果自己动手滚动会更有益，因为那样的话我会更加熟悉，但是在这种情况下，我真的不想重新发明轮子。

非常感谢

回答：

这不是正确的方法。数据源需要由在其中运行应用程序的任何容器进行管理。MysqlConnectionPoolDataSource它

连接池。它只是javax.sql.DataSource接口的具体实现。您通常在JNDI上下文中定义它，然后从那里获取它。MySQL本身也在其文档中明确声明了所有内容。

现在，如何使用它取决于应用程序的目的。如果它是一个Web应用程序，那么您需要参考所涉及的servlet容器/应用服务器的JNDI资源文档。例如，如果是Tomcat，则可以在此处找到它。如果您正在运行客户端应用程序-我将高度质疑连接池的价值-

那么您需要寻找一个连接池框架，该框架可以利用MySQL提供的连接池数据源，例如C3P0。

您发布的代码的另一个问题是PooledConnection#getConnection()将会返回 基础 连接，因此它

池化连接。调用close不会将连接返回到池，而只是真正关闭它。池必须每次都创建一个新的连接。

然后是线程安全的故事，这取决于所讨论的 实际 连接池框架。C3P0已经证明了它的坚固性在几年，你不用担心，只要你写根据标准成语JDBC代码，即使用

在JDBC接口和采集 关闭所有资源（Connection，Statement并ResultSet在最短的范围内）。

以上是 我是否正确使用Java PooledConnections？ 的全部内容， 来源链接： utcz.com/qa/408312.html

回到顶部