我想在Java中使用池化连接(因为每个线程创建一个连接非常昂贵),所以我正在使用该MysqlConnectionPoolDataSource()对象。我正在跨线程保留我的数据源。因此,我在整个应用程序中仅使用一个数据源,如下所示:
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()之类的方法…这意味着我不认为它在做我认为在做的事情…
dataSource.getPooledConnection();
另外,何时以及如何释放连接?
我想知道如果自己动手滚动会更有益,因为那样的话我会更加熟悉,但是在这种情况下,我真的不想重新发明轮子。
非常感谢
这不是正确的方法。数据源需要由在其中运行应用程序的任何容器进行管理。MysqlConnectionPoolDataSource它 不是 连接池。它只是javax.sql.DataSource接口的具体实现。您通常在JNDI上下文中定义它,然后从那里获取它。MySQL本身也在其文档中明确声明了所有内容。
MysqlConnectionPoolDataSource
javax.sql.DataSource
现在,如何使用它取决于应用程序的目的。如果它是一个Web应用程序,那么您需要参考所涉及的servlet容器/应用服务器的JNDI资源文档。例如,如果是Tomcat,则可以在此处找到它。如果您正在运行客户端应用程序-我将高度质疑连接池的价值- 那么您需要寻找一个连接池框架,该框架可以利用MySQL提供的连接池数据源,例如C3P0。
您发布的代码的另一个问题是PooledConnection#getConnection()将会返回 基础 连接,因此它 不是 池化连接。调用close不会将连接返回到池,而只是真正关闭它。池必须每次都创建一个新的连接。
PooledConnection#getConnection()
然后是线程安全的故事,这取决于所讨论的 实际 连接池框架。C3P0已经证明了它的坚固性在几年,你不用担心,只要你写根据标准成语JDBC代码,即使用 只 在JDBC接口和采集 ,并 关闭所有资源(Connection,Statement并ResultSet在最短的范围内)。
Connection
Statement
ResultSet